logspecclient

Documentation

Overview

Package logspecclient implements a client for the akutan/logspec API.

Index

• type Log
  • func New(ctx context.Context, cfg *config.Akutan, servers discovery.Locator) (*Log, error)
  • func (aLog *Log) Append(ctx context.Context, data [][]byte) ([]blog.Index, error)
  • func (aLog *Log) AppendSingle(ctx context.Context, data []byte) (blog.Index, error)
  • func (aLog *Log) Discard(ctx context.Context, firstIndex blog.Index) error
  • func (aLog *Log) Disconnect()
  • 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, nextIndex blog.Index, entriesCh chan<- []blog.Entry) error

Types

type Log

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

Log is a client to the logspec API.

func New

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

New constructs a Log.

func (*Log) Append

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

Append implements the method defined by blog.AkutanLog.

func (*Log) AppendSingle

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

AppendSingle implements the method defined by blog.AkutanLog.

func (*Log) Discard

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

Discard implements the method declared in blog.AkutanLog.

func (*Log) Disconnect

func (aLog *Log) Disconnect()

Disconnect implements the method declared in blog.Disconnector.

func (*Log) Info

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

Info implements the method declared in blog.AkutanLog.

func (*Log) InfoStream

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

InfoStream implements the method declared in blog.AkutanLog.

func (*Log) Read

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

Read implements the method declared in blog.AkutanLog.