kafka

Documentation

Overview

Package kafka implements a Kafka client as a blog.AkutanLog.

Index

• type Log
  • func NewLog(ctx context.Context, cfg *config.Akutan, brokers discovery.Locator) (*Log, error)
  • func (aLog *Log) Append(ctx context.Context, msgs [][]byte) ([]blog.Index, error)
  • func (aLog *Log) AppendSingle(ctx context.Context, data []byte) (blog.Index, error)
  • func (aLog *Log) Discard(ctx context.Context, startIndex blog.Index) error
  • func (aLog *Log) Info(ctx context.Context) (*blog.Info, error)
  • func (aLog *Log) InfoStream(ctx context.Context, infoCh chan<- *blog.Info) error
  • func (aLog *Log) Read(ctx context.Context, startIndex blog.Index, entriesCh chan<- []blog.Entry) error

Types

type Log

type Log struct {
	// contains filtered or unexported fields
}

Log is a client to Kafka. It implements blog.AkutanLog. TODO: many of these methods are misbehaved in that they handle errors differently than described in blog.AkutanLog.

func NewLog

func NewLog(ctx context.Context, cfg *config.Akutan, brokers discovery.Locator) (*Log, error)

NewLog constructs a new Log.

func (*Log) Append

func (aLog *Log) Append(ctx context.Context, msgs [][]byte) ([]blog.Index, error)

Append implements the method from blog.AkutanLog.

func (*Log) AppendSingle

func (aLog *Log) AppendSingle(ctx context.Context, data []byte) (blog.Index, error)

AppendSingle implements the method from blog.AkutanLog.

func (*Log) Discard

func (aLog *Log) Discard(ctx context.Context, startIndex blog.Index) error

Discard implements the method from blog.AkutanLog.

func (*Log) Info

func (aLog *Log) Info(ctx context.Context) (*blog.Info, error)

Info implements the method from blog.AkutanLog.

func (*Log) InfoStream

func (aLog *Log) InfoStream(ctx context.Context, infoCh chan<- *blog.Info) error

InfoStream implements the method from blog.AkutanLog.

func (*Log) Read

func (aLog *Log) Read(ctx context.Context, startIndex blog.Index, entriesCh chan<- []blog.Entry) error

Read implements the method from blog.AkutanLog.