pbq

Nov 29, 2022

Changes in this version

type Manager

+ func (m *Manager) GetExistingPartitions(ctx context.Context) ([]partition.ID, error)

Oct 27, 2022

Changes in this version

+ var ErrCOB = errors.New("error while writing to pbq, pbq is closed")

type PBQ

+ PartitionID partition.ID

Sep 20, 2022

Changes in this version

+ var COBErr error = errors.New("error while writing to pbq, pbq is closed")

+ func DefaultOptions() *options

+ type Manager struct

+ func NewManager(ctx context.Context, opts ...PBQOption) (*Manager, error)

+ func (m *Manager) CreateNewPBQ(ctx context.Context, partitionID string) (ReadWriteCloser, error)

+ func (m *Manager) GetPBQ(partitionID string) ReadWriteCloser

+ func (m *Manager) ListPartitions() []*PBQ

+ func (m *Manager) Replay(ctx context.Context)

+ func (m *Manager) ShutDown(ctx context.Context)

+ func (m *Manager) StartUp(_ context.Context) error

+ type PBQ struct

+ func (p *PBQ) Close() error

+ func (p *PBQ) CloseOfBook()

+ func (p *PBQ) GC() error

+ func (p *PBQ) ReadCh() <-chan *isb.Message

+ func (p *PBQ) Write(ctx context.Context, message *isb.Message) error

+ type PBQOption func(options *options) error

+ func WithChannelBufferSize(size int64) PBQOption

+ func WithPBQStoreOptions(opts ...store.StoreOption) PBQOption

+ func WithReadBatchSize(size int64) PBQOption

+ func WithReadTimeout(seconds time.Duration) PBQOption

+ type ReadWriteCloser interface

+ type Reader interface

+ GC func() error

+ ReadCh func() <-chan *isb.Message

+ type WriteCloser interface

+ Close func() error

+ CloseOfBook func()

+ Write func(ctx context.Context, msg *isb.Message) error