eose

Documentation

Index

• type Envelope
  • func (E *Envelope) Bytes() (s []byte)
  • func (E *Envelope) Label() string
  • func (E *Envelope) MarshalJSON() ([]byte, error)
  • func (E *Envelope) String() (s string)
  • func (E *Envelope) ToArray() array.T
  • func (E *Envelope) Unmarshal(buf *text.Buffer) (e error)

Types

type Envelope

type Envelope struct {
	subscriptionid.T
}

Envelope is a message that indicates that all cached events have been delivered and thereafter events will be new and delivered in pubsub subscribe fashion while the socket remains open.

func (*Envelope) Bytes

func (E *Envelope) Bytes() (s []byte)

func (*Envelope) Label

func (E *Envelope) Label() string

func (*Envelope) MarshalJSON

func (E *Envelope) MarshalJSON() ([]byte, error)

func (*Envelope) String

func (E *Envelope) String() (s string)

func (*Envelope) ToArray

func (E *Envelope) ToArray() array.T

func (*Envelope) Unmarshal

func (E *Envelope) Unmarshal(buf *text.Buffer) (e error)

Unmarshal the envelope.