messages

Documentation

Index

• Constants
• Variables
• type Event
  • func (e *Event) MarshallBinary() ([]byte, error)
  • func (e *Event) UnmarshallBinary(data []byte) error
• type Price
  • func (p *Price) Marshall() ([]byte, error)
  • func (p *Price) MarshallBinary() ([]byte, error)
  • func (p *Price) Unmarshall(b []byte) error
  • func (p *Price) UnmarshallBinary(data []byte) error

Constants

const EventMessageName = "event/v0"

const PriceMessageName = "price/v0"

Variables

var ErrPriceMalformedMessage = errors.New("malformed price message")

Types

type Event

type Event struct {
	// Type of the event.
	Type string
	// Unique ID of the event.
	ID []byte
	// Event index used to search for events.
	Index []byte
	// The date when the event message was created. It is *not* the date of
	// the event itself.
	Date time.Time
	// List of event data.
	Data map[string][]byte
	// List of event signatures.
	Signatures map[string][]byte
}

func (*Event) MarshallBinary

func (e *Event) MarshallBinary() ([]byte, error)

MarshallBinary implements the transport.Message interface.

func (*Event) UnmarshallBinary

func (e *Event) UnmarshallBinary(data []byte) error

UnmarshallBinary implements the transport.Message interface.

type Price

type Price struct {
	Price *oracle.Price   `json:"price"`
	Trace json.RawMessage `json:"trace"`
}

func (*Price) Marshall

func (p *Price) Marshall() ([]byte, error)

func (*Price) MarshallBinary

func (p *Price) MarshallBinary() ([]byte, error)

MarshallBinary implements the transport.Message interface.

func (*Price) Unmarshall

func (p *Price) Unmarshall(b []byte) error

func (*Price) UnmarshallBinary

func (p *Price) UnmarshallBinary(data []byte) error

UnmarshallBinary implements the transport.Message interface.