reliabletopic

Documentation

Index

• Constants
• type Message
  • func NewMessage(payload serialization.Data, publisherAddr core.Address) *Message
  • func (r *Message) ClassID() (classID int32)
  • func (r *Message) FactoryID() (factoryID int32)
  • func (r *Message) Payload() serialization.Data
  • func (r *Message) PublishTime() int64
  • func (r *Message) PublisherAddress() core.Address
  • func (r *Message) ReadData(input serialization.DataInput) (err error)
  • func (r *Message) WriteData(output serialization.DataOutput) (err error)
• type MessageFactory
  • func NewMessageFactory() *MessageFactory
  • func (r *MessageFactory) Create(id int32) (instance serialization.IdentifiedDataSerializable)

Constants

const (
	// FactoryID is the factory id of reliable topic message.
	FactoryID = -18

	// MessageClassID is the class id of reliable topic message.
	MessageClassID = 2
)

Types

type Message

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

func NewMessage

func NewMessage(payload serialization.Data, publisherAddr core.Address) *Message

func (*Message) ClassID

func (r *Message) ClassID() (classID int32)

func (*Message) FactoryID

func (r *Message) FactoryID() (factoryID int32)

func (*Message) Payload

func (r *Message) Payload() serialization.Data

func (*Message) PublishTime

func (r *Message) PublishTime() int64

func (*Message) PublisherAddress

func (r *Message) PublisherAddress() core.Address

func (*Message) ReadData

func (r *Message) ReadData(input serialization.DataInput) (err error)

func (*Message) WriteData

func (r *Message) WriteData(output serialization.DataOutput) (err error)

type MessageFactory

type MessageFactory struct {
}

func NewMessageFactory

func NewMessageFactory() *MessageFactory

func (*MessageFactory) Create

func (r *MessageFactory) Create(id int32) (instance serialization.IdentifiedDataSerializable)