message

Documentation

Index

• Variables
• func ReleaseMessage(m *Message)
• type Message
  • func AcquireMessage() *Message
  • func (m *Message) Reset()
• type Messages
  • func NewMessages() *Messages
  • func (m *Messages) Decode(buf []byte) error
  • func (m *Messages) GetByIndex(idx int) (*Message, error)
  • func (m *Messages) GetByName(name string) (*Message, error)
  • func (m *Messages) Len() int
  • func (m *Messages) Reset()

Variables

var (
	ErrMessageNotFound = errors.New("message not found")
)

Functions

func ReleaseMessage

func ReleaseMessage(m *Message)

Types

type Message

type Message struct {
	Name string
	KV   *kv.KV
}

func AcquireMessage

func AcquireMessage() *Message

func (*Message) Reset

func (m *Message) Reset()

type Messages

type Messages []*Message

func NewMessages

func NewMessages() *Messages

func (*Messages) Decode

func (m *Messages) Decode(buf []byte) error

func (*Messages) GetByIndex

func (m *Messages) GetByIndex(idx int) (*Message, error)

func (*Messages) GetByName

func (m *Messages) GetByName(name string) (*Message, error)

func (*Messages) Len

func (m *Messages) Len() int

func (*Messages) Reset

func (m *Messages) Reset()