eventenvelope

Documentation

Index

• Constants
• func ParseResult(b B) (t *Result, rem B, err E)
• func ParseSubmission(b B) (t *Submission, rem B, err E)
• type Result
  • func NewResult() *Result
  • func NewResultWith(s *sid.T, ev *event.T) *Result
  • func (en *Result) Label() S
  • func (en *Result) MarshalJSON(dst B) (b B, err error)
  • func (en *Result) UnmarshalJSON(b B) (r B, err error)
  • func (en *Result) Write(w io.Writer) (err E)
• type Submission
  • func NewSubmission() *Submission
  • func NewSubmissionWith(ev *event.T) *Submission
  • func (en *Submission) Label() string
  • func (en *Submission) MarshalJSON(dst B) (b B, err error)
  • func (en *Submission) UnmarshalJSON(b B) (r B, err error)
  • func (en *Submission) Write(w io.Writer) (err E)

Constants

const L = "EVENT"

Functions

func ParseResult

func ParseResult(b B) (t *Result, rem B, err E)

func ParseSubmission

func ParseSubmission(b B) (t *Submission, rem B, err E)

Types

type Result

type Result struct {
	Subscription *sid.T
	Event        *event.T
}

Result is an event matching a filter associated with a subscription.

func NewResult

func NewResult() *Result

func NewResultWith

func NewResultWith(s *sid.T, ev *event.T) *Result

func (*Result) Label

func (en *Result) Label() S

func (*Result) MarshalJSON

func (en *Result) MarshalJSON(dst B) (b B, err error)

func (*Result) UnmarshalJSON

func (en *Result) UnmarshalJSON(b B) (r B, err error)

func (*Result) Write

func (en *Result) Write(w io.Writer) (err E)

type Submission

type Submission struct {
	*event.T
}

Submission is a request from a client for a relay to store an event.

func NewSubmission

func NewSubmission() *Submission

func NewSubmissionWith

func NewSubmissionWith(ev *event.T) *Submission

func (*Submission) Label

func (en *Submission) Label() string

func (*Submission) MarshalJSON

func (en *Submission) MarshalJSON(dst B) (b B, err error)

func (*Submission) UnmarshalJSON

func (en *Submission) UnmarshalJSON(b B) (r B, err error)

func (*Submission) Write

func (en *Submission) Write(w io.Writer) (err E)