Versions in this module Expand all Collapse all v0 v0.2.0 Jan 10, 2023 v0.1.0 Jan 6, 2023 Changes in this version + func JSONLEncode(message proto.Message) ([]byte, error) + type Bundler struct + 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 func(proto.Message) ([]byte, error)
Go to main page