sequencer

Documentation

Index

• func BuildLogMapPartitionToOffsetsRange(changeItems [][]abstract.ChangeItem) string
• func BuildMapPartitionToOffsetsRange(messages []QueueMessage) string
• func BuildPartitionOffsetLogLine(messages []QueueMessage) string
• type QueueMessage
• type Sequencer
  • func NewSequencer() *Sequencer
  • func (s *Sequencer) Pushed(messages []QueueMessage) ([]QueueMessage, error)
  • func (s *Sequencer) StartProcessing(messages []QueueMessage) error
  • func (s *Sequencer) ToStringRanges() string
  • func (s *Sequencer) ToStringRangesWithTopic() string

Functions

func BuildLogMapPartitionToOffsetsRange

func BuildLogMapPartitionToOffsetsRange(changeItems [][]abstract.ChangeItem) string

BuildLogMapPartitionToOffsetsRange - is used only in logging

func BuildMapPartitionToOffsetsRange

func BuildMapPartitionToOffsetsRange(messages []QueueMessage) string

BuildMapPartitionToOffsetsRange - is used only in logging

func BuildPartitionOffsetLogLine

func BuildPartitionOffsetLogLine(messages []QueueMessage) string

BuildPartitionOffsetLogLine - is used only in logging

Types

type QueueMessage

type QueueMessage struct {
	Topic     string
	Partition int
	Offset    int64
}

type Sequencer

type Sequencer struct {
	// contains filtered or unexported fields
}

func NewSequencer

func NewSequencer() *Sequencer

func (*Sequencer) Pushed

func (s *Sequencer) Pushed(messages []QueueMessage) ([]QueueMessage, error)

func (*Sequencer) StartProcessing

func (s *Sequencer) StartProcessing(messages []QueueMessage) error

func (*Sequencer) ToStringRanges

func (s *Sequencer) ToStringRanges() string

func (*Sequencer) ToStringRangesWithTopic

func (s *Sequencer) ToStringRangesWithTopic() string