dispatcher

Documentation

Index

• Constants
• type Dispatcher
• type MessageDispatcher
  • func NewDispatcher(ctx context.Context, outboundPool *goconcurrentqueue.FIFO, ...) *MessageDispatcher
  • func (d *MessageDispatcher) Dispatch() error
  • func (d *MessageDispatcher) Push(msg message.Message, channelID string) error
  • func (d *MessageDispatcher) SetPublisher(channelID string, p publisher.Publisher)
• type MessageForDelivery
  • func (m MessageForDelivery) GetMessage() message.Message

Constants

const DispatcherThreads = 5

Types

type Dispatcher

type Dispatcher interface {
	Push(msg message.Message, channelID string) error
	Dispatch() error
}

type MessageDispatcher

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

func NewDispatcher

func NewDispatcher(ctx context.Context, outboundPool *goconcurrentqueue.FIFO, dataStorage *storage.PqStorage) *MessageDispatcher

func (*MessageDispatcher) Dispatch

func (d *MessageDispatcher) Dispatch() error

func (*MessageDispatcher) Push

func (d *MessageDispatcher) Push(msg message.Message, channelID string) error

func (*MessageDispatcher) SetPublisher

func (d *MessageDispatcher) SetPublisher(channelID string, p publisher.Publisher)

type MessageForDelivery

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

func (MessageForDelivery) GetMessage

func (m MessageForDelivery) GetMessage() message.Message