message

Documentation

Index

• type Message
  • func (m *Message) Add(msg *fsm.Message, num *uint64)
  • func (m *Message) From(a, b uint64) []*fsm.Message
  • func (m *Message) MarshalJSON() ([]byte, error)
  • func (m *Message) UnmarshalJSON(b []byte) error

Types

type Message

type Message struct {
	Messages   []*fsm.Message
	LastSeqNum uint64
}

Message stores the messages sent by an agent per channel.

func (*Message) Add

func (m *Message) Add(msg *fsm.Message, num *uint64)

Add appends the latest sent message to the Message object, updating the latest sequence number

func (*Message) From

func (m *Message) From(a, b uint64) []*fsm.Message

From returns all message sent from sequence number a, inclusive up until sequence number b, exclusive.

func (*Message) MarshalJSON

func (m *Message) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler. Required for genbolt.

func (*Message) UnmarshalJSON

func (m *Message) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler. Required for genbolt.