queue

Documentation

Index

• type MemoryQueue
  • func (mq *MemoryQueue) Send(messageType string, message []byte) error
  • func (mq *MemoryQueue) Subscribe(messageType string) (string, chan gosignal.QueueMessage, error)
  • func (mq *MemoryQueue) Unsubscribe(messageType, sid string) error
• type MemoryQueueMessage
  • func (MemoryQueueMessage) Ack() error
  • func (MemoryQueueMessage) Attempts() int
  • func (mqm MemoryQueueMessage) Message() []byte
  • func (MemoryQueueMessage) Nack() error
  • func (MemoryQueueMessage) Retry(gosignal.RetryParams) error
  • func (mqm MemoryQueueMessage) Type() string

Types

type MemoryQueue

type MemoryQueue struct {
	Queue map[string]map[uint]chan gosignal.QueueMessage
}

func (*MemoryQueue) Send

func (mq *MemoryQueue) Send(messageType string, message []byte) error

func (*MemoryQueue) Subscribe

func (mq *MemoryQueue) Subscribe(messageType string) (string, chan gosignal.QueueMessage, error)

func (*MemoryQueue) Unsubscribe

func (mq *MemoryQueue) Unsubscribe(messageType, sid string) error

type MemoryQueueMessage

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

func (MemoryQueueMessage) Ack

func (MemoryQueueMessage) Ack() error

func (MemoryQueueMessage) Attempts

func (MemoryQueueMessage) Attempts() int

func (MemoryQueueMessage) Message

func (mqm MemoryQueueMessage) Message() []byte

func (MemoryQueueMessage) Nack

func (MemoryQueueMessage) Nack() error

func (MemoryQueueMessage) Retry

func (MemoryQueueMessage) Retry(gosignal.RetryParams) error

func (MemoryQueueMessage) Type

func (mqm MemoryQueueMessage) Type() string