pool

Documentation

Index

• type Message
  • func NewMessage() *Message
  • func (r *Message) Accept() (message.MediaType, error)
  • func (r *Message) AddETag(value []byte) error
  • func (r *Message) AddOptionBytes(opt message.OptionID, value []byte)
  • func (r *Message) AddOptionString(opt message.OptionID, value string)
  • func (r *Message) AddOptionUint32(opt message.OptionID, value uint32)
  • func (r *Message) AddQuery(query string)
  • func (r *Message) Body() io.ReadSeeker
  • func (r *Message) BodySize() (int64, error)
  • func (r *Message) Code() codes.Code
  • func (r *Message) ContentFormat() (message.MediaType, error)
  • func (r *Message) ETag() ([]byte, error)
  • func (r *Message) ETags(b [][]byte) (int, error)
  • func (r *Message) GetOptionAllBytes(id message.OptionID, b [][]byte) (int, error)
  • func (r *Message) GetOptionBytes(id message.OptionID) ([]byte, error)
  • func (r *Message) GetOptionUint32(id message.OptionID) (uint32, error)
  • func (r *Message) HasOption(id message.OptionID) bool
  • func (r *Message) Hijack()
  • func (r *Message) IsHijacked() bool
  • func (r *Message) IsModified() bool
  • func (r *Message) MustSetPath(p string)
  • func (r *Message) Observe() (uint32, error)
  • func (r *Message) Options() message.Options
  • func (r *Message) Path() (string, error)
  • func (r *Message) Queries() ([]string, error)
  • func (r *Message) ReadBody() ([]byte, error)
  • func (r *Message) Remove(opt message.OptionID)
  • func (r *Message) Reset()
  • func (r *Message) ResetOptionsTo(in message.Options)
  • func (r *Message) Sequence() uint64
  • func (r *Message) SetAccept(contentFormat message.MediaType)
  • func (r *Message) SetBody(s io.ReadSeeker)
  • func (r *Message) SetCode(code codes.Code)
  • func (r *Message) SetContentFormat(contentFormat message.MediaType)
  • func (r *Message) SetETag(value []byte) error
  • func (r *Message) SetModified(b bool)
  • func (r *Message) SetObserve(observe uint32)
  • func (r *Message) SetOptionBytes(opt message.OptionID, value []byte)
  • func (r *Message) SetOptionString(opt message.OptionID, value string)
  • func (r *Message) SetOptionUint32(opt message.OptionID, value uint32)
  • func (r *Message) SetPath(p string) error
  • func (r *Message) SetSequence(seq uint64)
  • func (r *Message) SetToken(token message.Token)
  • func (r *Message) String() string
  • func (r *Message) Token() message.Token

Types

type Message

type Message struct {
	// contains filtered or unexported fields
}

func NewMessage

func NewMessage() *Message

func (*Message) Accept

func (r *Message) Accept() (message.MediaType, error)

Accept get's accept option.

func (*Message) AddETag

func (r *Message) AddETag(value []byte) error

AddETag appends value to existing ETags.

Option definition:

• format: opaque, length: 1-8, repeatable

func (*Message) AddOptionBytes

func (r *Message) AddOptionBytes(opt message.OptionID, value []byte)

func (*Message) AddOptionString

func (r *Message) AddOptionString(opt message.OptionID, value string)

func (*Message) AddOptionUint32

func (r *Message) AddOptionUint32(opt message.OptionID, value uint32)

func (*Message) AddQuery

func (r *Message) AddQuery(query string)

func (*Message) Body

func (r *Message) Body() io.ReadSeeker

func (*Message) BodySize

func (r *Message) BodySize() (int64, error)

func (*Message) Code

func (r *Message) Code() codes.Code

func (*Message) ContentFormat

func (r *Message) ContentFormat() (message.MediaType, error)

func (*Message) ETag

func (r *Message) ETag() ([]byte, error)

ETag returns first ETag value

func (*Message) ETags

func (r *Message) ETags(b [][]byte) (int, error)

ETags returns all ETag values

Writes ETag values to output array, returns number of written values or error.

func (*Message) GetOptionAllBytes

func (r *Message) GetOptionAllBytes(id message.OptionID, b [][]byte) (int, error)

GetOptionAllBytes gets array of bytes of all options with given ID.

func (*Message) GetOptionBytes

func (r *Message) GetOptionBytes(id message.OptionID) ([]byte, error)

GetOptionBytes gets bytes of the first option with given ID.

func (*Message) GetOptionUint32

func (r *Message) GetOptionUint32(id message.OptionID) (uint32, error)

func (*Message) HasOption

func (r *Message) HasOption(id message.OptionID) bool

func (*Message) Hijack

func (r *Message) Hijack()

func (*Message) IsHijacked

func (r *Message) IsHijacked() bool

func (*Message) IsModified

func (r *Message) IsModified() bool

func (*Message) MustSetPath

func (r *Message) MustSetPath(p string)

MustSetPath calls SetPath and panics if it returns an error.

func (*Message) Observe

func (r *Message) Observe() (uint32, error)

func (*Message) Options

func (r *Message) Options() message.Options

func (*Message) Path

func (r *Message) Path() (string, error)

func (*Message) Queries

func (r *Message) Queries() ([]string, error)

func (*Message) ReadBody

func (r *Message) ReadBody() ([]byte, error)

func (*Message) Remove

func (r *Message) Remove(opt message.OptionID)

func (*Message) Reset

func (r *Message) Reset()

Reset clear message for next reuse

func (*Message) ResetOptionsTo

func (r *Message) ResetOptionsTo(in message.Options)

func (*Message) Sequence

func (r *Message) Sequence() uint64

func (*Message) SetAccept

func (r *Message) SetAccept(contentFormat message.MediaType)

SetAccept set's accept option.

func (*Message) SetBody

func (r *Message) SetBody(s io.ReadSeeker)

func (*Message) SetCode

func (r *Message) SetCode(code codes.Code)

func (*Message) SetContentFormat

func (r *Message) SetContentFormat(contentFormat message.MediaType)

func (*Message) SetETag

func (r *Message) SetETag(value []byte) error

SetETag inserts/replaces ETag option(s).

After a successful call only a single ETag value will remain.

func (*Message) SetModified

func (r *Message) SetModified(b bool)

func (*Message) SetObserve

func (r *Message) SetObserve(observe uint32)

func (*Message) SetOptionBytes

func (r *Message) SetOptionBytes(opt message.OptionID, value []byte)

func (*Message) SetOptionString

func (r *Message) SetOptionString(opt message.OptionID, value string)

func (*Message) SetOptionUint32

func (r *Message) SetOptionUint32(opt message.OptionID, value uint32)

func (*Message) SetPath

func (r *Message) SetPath(p string) error

SetPath stores the given path within URI-Path options.

The value is stored by the algorithm described in RFC7252 and using the internal buffer. If the path is too long, but valid (URI-Path segments must have maximal length of 255) the internal buffer is expanded. If the path is too long, but not valid then the function returns ErrInvalidValueLength error.

func (*Message) SetSequence

func (r *Message) SetSequence(seq uint64)

func (*Message) SetToken

func (r *Message) SetToken(token message.Token)

func (*Message) String

func (r *Message) String() string

func (*Message) Token

func (r *Message) Token() message.Token