utils

Documentation

Index

• type Buffer
  • func (buf *Buffer) Close() error
  • func (buf *Buffer) Send(msg *beam.Message) (beam.Receiver, error)
• type Queue
  • func NewQueue(dst beam.Sender, size int) *Queue
• type StackSender
  • func NewStackSender() *StackSender
  • func (s *StackSender) Add(dst beam.Sender) *StackSender
  • func (s *StackSender) Close() error
  • func (s *StackSender) Len() int
  • func (s *StackSender) Send(msg *beam.Message) (ret beam.Receiver, err error)
  • func (s *StackSender) String() string

Types

type Buffer

type Buffer []*beam.Message

func (*Buffer) Close

func (buf *Buffer) Close() error

func (*Buffer) Send

func (buf *Buffer) Send(msg *beam.Message) (beam.Receiver, error)

type Queue

type Queue struct {
	*beam.PipeSender
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(dst beam.Sender, size int) *Queue

type StackSender

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

StackSender forwards beam messages to a dynamic list of backend receivers. New backends are stacked on top. When a message is sent, each backend is tried until one succeeds. Any failing backends encountered along the way are removed from the queue.

func NewStackSender

func NewStackSender() *StackSender

func (*StackSender) Add

func (s *StackSender) Add(dst beam.Sender) *StackSender

func (*StackSender) Close

func (s *StackSender) Close() error

func (*StackSender) Len

func (s *StackSender) Len() int

func (*StackSender) Send

func (s *StackSender) Send(msg *beam.Message) (ret beam.Receiver, err error)

func (*StackSender) String

func (s *StackSender) String() string