fifo

Documentation

Index

• type MessageFifo
  • func NewMessageFifo() *MessageFifo
  • func (f *MessageFifo) Close()
  • func (f *MessageFifo) Get(msg *model.Message) error
  • func (f *MessageFifo) Put(msg *model.Message)

Types

type MessageFifo

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

func NewMessageFifo

func NewMessageFifo() *MessageFifo

set the fifo capacity to MessageFiFoSizeMax

func (*MessageFifo) Close

func (f *MessageFifo) Close()

func (*MessageFifo) Get

func (f *MessageFifo) Get(msg *model.Message) error

Get get message from fifo this api is blocked when the fifo is empty

func (*MessageFifo) Put

func (f *MessageFifo) Put(msg *model.Message)

Put put the message into fifo