Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue struct { *beam.PipeSender // contains filtered or unexported fields }
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) String ¶
func (s *StackSender) String() string
Click to show internal directories.
Click to hide internal directories.