Versions in this module Expand all Collapse all v1 v1.0.0 Jul 16, 2021 Changes in this version + var File_journal_proto protoreflect.FileDescriptor + func NewZKEventCancelContext(ctx context.Context, notify <-chan zk.Event) context.Context + type Checkpoint struct + LastEntryOffset int64 + NextEntryOffset int64 + func (*Checkpoint) Descriptor() ([]byte, []int) + func (*Checkpoint) ProtoMessage() + func (x *Checkpoint) GetLastEntryOffset() int64 + func (x *Checkpoint) GetNextEntryOffset() int64 + func (x *Checkpoint) ProtoReflect() protoreflect.Message + func (x *Checkpoint) Reset() + func (x *Checkpoint) String() string + type InvalidVersionError struct + func NewInvalidVersionError(version int64) *InvalidVersionError + func (i *InvalidVersionError) Error() string + type NoMoreMessageError struct + func (n *NoMoreMessageError) Error() string + type Receiver struct + func NewReceiver(server, topic string) (*Receiver, error) + func (r *Receiver) FetchEntry(ctx context.Context) ([]byte, *Checkpoint, error) + func (r *Receiver) SetOffset(offset int64) error + func (r *Receiver) TryFetchEntry(ctx context.Context) ([]byte, *Checkpoint, error) + type Writer struct + func NewWriter(server, topic string) (*Writer, error) + func (w *Writer) Checkpoint(ctx context.Context) (int64, error) + func (w *Writer) CommitEntry(ctx context.Context, entry []byte) error + func (w *Writer) ExitCheckpoint() + func (w *Writer) PrepareCheckpoint() int64
Go to main page