queue

Documentation

Index

• func NewPublisher() (message.Publisher, error)
• func NewSubscriber() (message.Subscriber, error)
• type ChessMoveMessage
  • func FromQueueMessage(msg *message.Message) (ChessMoveMessage, error)
  • func (m ChessMoveMessage) ToQueueMessage() (*message.Message, error)

Functions

func NewPublisher

func NewPublisher() (message.Publisher, error)

func NewSubscriber

func NewSubscriber() (message.Subscriber, error)

Types

type ChessMoveMessage

type ChessMoveMessage struct {
	model.ChessMove
	PublishedAt time.Time `json:"published_at" bson:"published_at"`
}

func FromQueueMessage

func FromQueueMessage(msg *message.Message) (ChessMoveMessage, error)

func (ChessMoveMessage) ToQueueMessage

func (m ChessMoveMessage) ToQueueMessage() (*message.Message, error)