send

Documentation

Index

• type Sender
  • func NewSender(queueSize int, endpoint string, logger *log.Logger) *Sender
  • func (s *Sender) EnqueueMessage(msg *protocol.SpaceMessage) int

Types

type Sender

type Sender struct {

	// This can be used to pass a custom logger to the sender. Left unset it defaults to the log default logger.
	Logger *log.Logger
	// contains filtered or unexported fields
}

Sender sends messages in a reliable way by queueing them and retrying any failed delivery. It is designed to be used only by a single caller and thus not concurrency safe!

func NewSender

func NewSender(queueSize int, endpoint string, logger *log.Logger) *Sender

func (*Sender) EnqueueMessage

func (s *Sender) EnqueueMessage(msg *protocol.SpaceMessage) int

EnqueueMessage adds a message to the delivery queue after assigning it a new ID.