eventenvelope

Documentation

Index

• Constants
• type Result
  • func NewResult() *Result
  • func NewResultWith[V string | []byte](s V, ev *event.T) (res *Result, err error)
  • func ParseResult(b []byte) (t *Result, rem []byte, err error)
  • func (en *Result) Label() string
  • func (en *Result) Marshal(dst []byte) (b []byte)
  • func (en *Result) Unmarshal(b []byte) (r []byte, err error)
  • func (en *Result) Write(w io.Writer) (err error)
• type Submission
  • func NewSubmission() *Submission
  • func NewSubmissionWith(ev *event.T) *Submission
  • func ParseSubmission(b []byte) (t *Submission, rem []byte, err error)
  • func (en *Submission) Label() string
  • func (en *Submission) Marshal(dst []byte) (b []byte)
  • func (en *Submission) Unmarshal(b []byte) (r []byte, err error)
  • func (en *Submission) Write(w io.Writer) (err error)

Constants

const L = "EVENT"

Types

type Result

type Result struct {
	Subscription *subscription.Id
	Event        *event.T
}

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

func NewResult

func NewResult() *Result

func NewResultWith

func NewResultWith[V string | []byte](s V, ev *event.T) (res *Result, err error)

func ParseResult

func ParseResult(b []byte) (t *Result, rem []byte, err error)

func (*Result) Label

func (en *Result) Label() string

func (*Result) Marshal

func (en *Result) Marshal(dst []byte) (b []byte)

func (*Result) Unmarshal

func (en *Result) Unmarshal(b []byte) (r []byte, err error)

func (*Result) Write

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

type Submission

type Submission struct {
	*event.T
}

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

func NewSubmission

func NewSubmission() *Submission

func NewSubmissionWith

func NewSubmissionWith(ev *event.T) *Submission

func ParseSubmission

func ParseSubmission(b []byte) (t *Submission, rem []byte, err error)

func (*Submission) Label

func (en *Submission) Label() string

func (*Submission) Marshal

func (en *Submission) Marshal(dst []byte) (b []byte)

func (*Submission) Unmarshal

func (en *Submission) Unmarshal(b []byte) (r []byte, err error)

func (*Submission) Write

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