messagebuffer

Documentation

Index

• type MessageBuffer
  • func NewMessageBuffer() *MessageBuffer
  • func (messageBuffer *MessageBuffer) AddMessage(clientID []byte, msg *pb.Relay)
  • func (messageBuffer *MessageBuffer) PopMessages(clientID []byte) []*pb.Relay

Types

type MessageBuffer

type MessageBuffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

MessageBuffer is the buffer to hold message for clients not online

func NewMessageBuffer

func NewMessageBuffer() *MessageBuffer

NewMessageBuffer creates a MessageBuffer

func (*MessageBuffer) AddMessage

func (messageBuffer *MessageBuffer) AddMessage(clientID []byte, msg *pb.Relay)

AddMessage adds a message to message buffer

func (*MessageBuffer) PopMessages

func (messageBuffer *MessageBuffer) PopMessages(clientID []byte) []*pb.Relay

PopMessages reads and clears all messages of a client