bundler

Documentation

Index

• func JSONLEncode(message proto.Message) ([]byte, error)
• type Bundler
  • func New(size uint64, boundaryWriter writer.Writer, stateStore state.Store, ...) (*Bundler, error)
  • func (b *Bundler) Close()
  • func (b *Bundler) GetCursor() (*sink.Cursor, error)
  • func (b *Bundler) Launch(ctx context.Context)
  • func (b *Bundler) Roll(ctx context.Context, blockNum uint64) error
  • func (b *Bundler) SetCursor(cursor *sink.Cursor)
  • func (b *Bundler) Start(blockNum uint64) error
  • func (b *Bundler) TrackBlockProcessDuration(elapsed time.Duration)
  • func (b *Bundler) Writer() writer.Writer
• type Encoder

Functions

func JSONLEncode

func JSONLEncode(message proto.Message) ([]byte, error)

Types

type Bundler

type Bundler struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

func New

func New(
	size uint64,
	boundaryWriter writer.Writer,
	stateStore state.Store,
	outputStore dstore.Store,
	zlogger *zap.Logger,
) (*Bundler, error)

func (*Bundler) Close

func (b *Bundler) Close()

func (*Bundler) GetCursor

func (b *Bundler) GetCursor() (*sink.Cursor, error)

func (*Bundler) Launch

func (b *Bundler) Launch(ctx context.Context)

func (*Bundler) Roll

func (b *Bundler) Roll(ctx context.Context, blockNum uint64) error

func (*Bundler) SetCursor

func (b *Bundler) SetCursor(cursor *sink.Cursor)

func (*Bundler) Start

func (b *Bundler) Start(blockNum uint64) error

func (*Bundler) TrackBlockProcessDuration

func (b *Bundler) TrackBlockProcessDuration(elapsed time.Duration)

func (*Bundler) Writer

func (b *Bundler) Writer() writer.Writer

type Encoder

type Encoder func(proto.Message) ([]byte, error)