message

Documentation

Index

• type Bolt
  • func NewBolt(partitionPath string) *Bolt
  • func (b *Bolt) AckMessage(_ context.Context, commandID uint64, message *model.Message, ...) error
  • func (b *Bolt) AppendMessage(_ context.Context, commandID uint64, message *model.Message) error
  • func (b *Bolt) Close(context.Context) error
  • func (b *Bolt) LastAppliedCommandID(_ context.Context, partitions []string) (uint64, error)
  • func (b *Bolt) LastMessageID(_ context.Context, partitionKey string) ([]byte, error)
  • func (b *Bolt) MessageAtIndex(_ context.Context, partition *model.Partition, messageID []byte) (*model.Message, error)
  • func (b *Bolt) NextUnAckedMessageID(_ context.Context, partition *model.Partition, group *model.ConsumerGroup) ([]byte, error)
  • func (b *Bolt) RecoverFromSnapshot(ctx context.Context, r io.Reader) error
  • func (b *Bolt) Snapshot(ctx context.Context, w io.Writer) error

Types

type Bolt

type Bolt struct {
	PartitionsPath string
	// contains filtered or unexported fields
}

func NewBolt

func NewBolt(partitionPath string) *Bolt

func (*Bolt) AckMessage

func (b *Bolt) AckMessage(
	_ context.Context,
	commandID uint64,
	message *model.Message,
	group *model.ConsumerGroup,
) error

func (*Bolt) AppendMessage

func (b *Bolt) AppendMessage(
	_ context.Context,
	commandID uint64,
	message *model.Message,
) error

func (*Bolt) Close

func (b *Bolt) Close(context.Context) error

func (*Bolt) LastAppliedCommandID

func (b *Bolt) LastAppliedCommandID(
	_ context.Context,
	partitions []string,
) (uint64, error)

func (*Bolt) LastMessageID

func (b *Bolt) LastMessageID(_ context.Context, partitionKey string) ([]byte, error)

func (*Bolt) MessageAtIndex

func (b *Bolt) MessageAtIndex(_ context.Context, partition *model.Partition, messageID []byte) (*model.Message, error)

func (*Bolt) NextUnAckedMessageID

func (b *Bolt) NextUnAckedMessageID(_ context.Context, partition *model.Partition, group *model.ConsumerGroup) ([]byte, error)

func (*Bolt) RecoverFromSnapshot

func (b *Bolt) RecoverFromSnapshot(ctx context.Context, r io.Reader) error

func (*Bolt) Snapshot

func (b *Bolt) Snapshot(ctx context.Context, w io.Writer) error