receiver

Documentation

Index

• type ReceiveStrategy
• type ReceiveStrategyChain
  • func NewReceiveStrategyChain(strategies []ReceiveStrategy) *ReceiveStrategyChain
  • func (c *ReceiveStrategyChain) CanReceive(message []byte) bool
  • func (c *ReceiveStrategyChain) Receive(message []byte) message.MessageInterface
• type Receiver
• type ReceiverPool
  • func NewReceiverPool(receivers []Receiver) *ReceiverPool
  • func (p *ReceiverPool) AddReceiver(receiver Receiver)
  • func (p *ReceiverPool) Receive()
  • func (p *ReceiverPool) Size() int

Types

type ReceiveStrategy

type ReceiveStrategy interface {
	CanReceive(message []byte) bool
	Receive(message []byte) message.MessageInterface
}

type ReceiveStrategyChain

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

func NewReceiveStrategyChain

func NewReceiveStrategyChain(strategies []ReceiveStrategy) *ReceiveStrategyChain

func (*ReceiveStrategyChain) CanReceive

func (c *ReceiveStrategyChain) CanReceive(message []byte) bool

func (*ReceiveStrategyChain) Receive

func (c *ReceiveStrategyChain) Receive(message []byte) message.MessageInterface

type Receiver

type Receiver interface {
	Receive()
}

type ReceiverPool

type ReceiverPool struct {
	Receiver
	// contains filtered or unexported fields
}

func NewReceiverPool

func NewReceiverPool(receivers []Receiver) *ReceiverPool

func (*ReceiverPool) AddReceiver

func (p *ReceiverPool) AddReceiver(receiver Receiver)

func (*ReceiverPool) Receive

func (p *ReceiverPool) Receive()

func (*ReceiverPool) Size

func (p *ReceiverPool) Size() int