okenvelope

Documentation

Index

• Constants
• func Message(reason Reason, prefix string) string
• type Reason
  • func (r Reason) S() string
• type T
  • func NewOKEnvelope(eventID eventid.T, ok bool, reason string) (o *T, err error)
  • func (env *T) Bytes() (s []byte)
  • func (env *T) Label() (l string)
  • func (env *T) MarshalJSON() ([]byte, error)
  • func (env *T) String() (s string)
  • func (env *T) ToArray() (a array.T)
  • func (env *T) Unmarshal(buf *text.Buffer) (err error)
  • func (env *T) UnmarshalJSON(bytes []byte) error

Constants

const (
	Btrue     = "true"
	BtrueLen  = len(Btrue)
	Bfalse    = "false"
	BfalseLen = len(Bfalse)
)

Functions

func Message

func Message(reason Reason, prefix string) string

Message takes a string message that is to be sent in an `OK` or `CLOSED` command and prefixes it with "<prefix>: " if it doesn't already have an acceptable prefix.

Types

type Reason

type Reason string

const (
	PoW         Reason = "pow"
	Duplicate   Reason = "duplicate"
	Blocked     Reason = "blocked"
	RateLimited Reason = "rate-limited"
	Invalid     Reason = "invalid"
	Error       Reason = "error"
)

func (Reason) S

func (r Reason) S() string

type T

type T struct {
	ID     eventid.T
	OK     bool
	Reason string
}

T is a relay message sent in response to an EventEnvelope to indicate acceptance (OK is true), rejection and provide a human readable Reason for clients to display to users, with the first word being a machine readable reason type, as listed in the RejectReason* constants above, followed by ": " and a human readable message.

func NewOKEnvelope

func NewOKEnvelope(eventID eventid.T, ok bool, reason string) (o *T,
	err error)

func (*T) Bytes

func (env *T) Bytes() (s []byte)

func (*T) Label

func (env *T) Label() (l string)

func (*T) MarshalJSON

func (env *T) MarshalJSON() ([]byte, error)

func (*T) String

func (env *T) String() (s string)

func (*T) ToArray

func (env *T) ToArray() (a array.T)

func (*T) Unmarshal

func (env *T) Unmarshal(buf *text.Buffer) (err error)

Unmarshal the envelope.

func (*T) UnmarshalJSON

func (env *T) UnmarshalJSON(bytes []byte) error