messages

Documentation

Index

• Constants
• Variables
• type Event
  • func (e *Event) Copy() *Event
  • func (e *Event) MarshallBinary() ([]byte, error)
  • func (e *Event) UnmarshallBinary(data []byte) error
• type EventSignature
• type Price
  • func (p *Price) AsV0() *Price
  • func (p *Price) AsV1() *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 EventV1MessageName = "event/v1"

const PriceV0MessageName = "price/v0"

const PriceV1MessageName = "price/v1"

Variables

var (
	ErrPriceMessageTooLarge       = errors.New("price message too large")
	ErrUnknownPriceMessageVersion = errors.New("unknown message version")
	ErrInvalidPriceMessage        = errors.New("invalid price message")
)

var ErrEventMessageTooLarge = errors.New("event message too large")

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 of the event.
	EventDate time.Time

	// The date when the event message was created.
	MessageDate time.Time

	// List of event data.
	Data map[string][]byte

	// List of event signatures.
	Signatures map[string]EventSignature
}

func (*Event) Copy

func (e *Event) Copy() *Event

Copy returns a copy of the event.

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 EventSignature

type EventSignature struct {
	Signer    []byte
	Signature []byte
}

type Price

type Price struct {
	Price   *median.Price   `json:"price"`
	Trace   json.RawMessage `json:"trace"`
	Version string          `json:"version,omitempty"` // TODO: this should move to some meta field e.g. `feedVersion`
	// contains filtered or unexported fields
}

func (*Price) AsV0

func (p *Price) AsV0() *Price

func (*Price) AsV1

func (p *Price) AsV1() *Price

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.