shuffle

Documentation

Index

• type Shuffle
  • func NewShuffle(bufferIdentifiers []string) *Shuffle
  • func (s *Shuffle) Shuffle(key string) string
  • func (s *Shuffle) ShuffleMessages(messages []*isb.Message) map[string][]*isb.Message

Types

type Shuffle

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

Shuffle shuffles messages among ISB

func NewShuffle

func NewShuffle(bufferIdentifiers []string) *Shuffle

NewShuffle accepts list of buffer identifiers(unique identifier of isb) and returns new shuffle instance

func (*Shuffle) Shuffle

func (s *Shuffle) Shuffle(key string) string

Shuffle functions returns a shuffled identifier.

func (*Shuffle) ShuffleMessages

func (s *Shuffle) ShuffleMessages(messages []*isb.Message) map[string][]*isb.Message

ShuffleMessages accepts list of isb messages and returns the mapping of isb to messages