eventenvelope

Documentation

Index

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

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 st | by](s V, ev *event.T) (res *Result, err er)

func ParseResult

func ParseResult(b by) (t *Result, rem by, err er)

func (*Result) Label

func (en *Result) Label() st

func (*Result) Marshal

func (en *Result) Marshal(dst by) (b by)

func (*Result) Unmarshal

func (en *Result) Unmarshal(b by) (r by, err er)

func (*Result) Write

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

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 by) (t *Submission, rem by, err er)

func (*Submission) Label

func (en *Submission) Label() string

func (*Submission) Marshal

func (en *Submission) Marshal(dst by) (b by)

func (*Submission) Unmarshal

func (en *Submission) Unmarshal(b by) (r by, err er)

func (*Submission) Write

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