Documentation
¶
Overview ¶
Package kafka implements a Kafka client as a blog.AkutanLog.
Index ¶
- type Log
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*Log) AppendSingle ¶
AppendSingle implements the method from blog.AkutanLog.
func (*Log) InfoStream ¶
InfoStream implements the method from blog.AkutanLog.