countenvelope

Documentation

Index

• Constants
• type Request
  • func New() *Request
  • func NewRequest(id *subscription.Id, filters *filters.T) *Request
  • func ParseRequest(b by) (t *Request, rem by, err er)
  • func (en *Request) Label() string
  • func (en *Request) Marshal(dst by) (b by)
  • func (en *Request) Unmarshal(b by) (r by, err er)
  • func (en *Request) Write(w io.Writer) (err er)
• type Response
  • func NewResponse() *Response
  • func NewResponseFrom[V st | by](s V, cnt no, approx ...bo) (res *Response, err er)
  • func Parse(b by) (t *Response, rem by, err er)
  • func (en *Response) Label() string
  • func (en *Response) Marshal(dst by) (b by)
  • func (en *Response) Unmarshal(b by) (r by, err er)
  • func (en *Response) Write(w io.Writer) (err er)

Constants

const L = "COUNT"

Types

type Request

type Request struct {
	Subscription *subscription.Id
	Filters      *filters.T
}

func New

func New() *Request

func NewRequest

func NewRequest(id *subscription.Id, filters *filters.T) *Request

func ParseRequest

func ParseRequest(b by) (t *Request, rem by, err er)

func (*Request) Label

func (en *Request) Label() string

func (*Request) Marshal

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

func (*Request) Unmarshal

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

func (*Request) Write

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

type Response

type Response struct {
	ID          *subscription.Id
	Count       no
	Approximate bo
}

func NewResponse

func NewResponse() *Response

func NewResponseFrom

func NewResponseFrom[V st | by](s V, cnt no, approx ...bo) (res *Response, err er)

func Parse

func Parse(b by) (t *Response, rem by, err er)

func (*Response) Label

func (en *Response) Label() string

func (*Response) Marshal

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

func (*Response) Unmarshal

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

func (*Response) Write

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