data

Documentation

Index

• type Greet
  • func NewGreet(metadata *types.Device) *Greet
  • func NewGreetFromProto(m *types.GreetMessage) *Greet
  • func (m *Greet) Release()
• type LastMessage
  • func NewLastMessage() *LastMessage
  • func (m *LastMessage) Get() *Message
  • func (m *LastMessage) ListenUpdates()
• type Message
  • func MessageFrom(data []byte, metadata *types.Device) *Message
  • func MessageFromProto(m *types.Message) *Message
  • func (m *Message) Duplicate(new *Message) bool
  • func (m *Message) Release()

Types

type Greet

type Greet struct {
	*types.GreetMessage
}

func NewGreet

func NewGreet(metadata *types.Device) *Greet

func NewGreetFromProto

func NewGreetFromProto(m *types.GreetMessage) *Greet

func (*Greet) Release

func (m *Greet) Release()

type LastMessage

type LastMessage struct {
	*Message

	Update chan *Message
	// contains filtered or unexported fields
}

LastMessage which is stored in Node and serves to identify duplicate messages

func NewLastMessage

func NewLastMessage() *LastMessage

func (*LastMessage) Get

func (m *LastMessage) Get() *Message

func (*LastMessage) ListenUpdates

func (m *LastMessage) ListenUpdates()

ListenUpdates updates the lastMessage with the latest message received

type Message

type Message struct {
	*types.Message
}

func MessageFrom

func MessageFrom(data []byte, metadata *types.Device) *Message

MessageFrom creates a new Message with the provided data.

func MessageFromProto

func MessageFromProto(m *types.Message) *Message

func (*Message) Duplicate

func (m *Message) Duplicate(new *Message) bool

func (*Message) Release

func (m *Message) Release()