coap

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

type ClientCloseHandler struct {
	*Client
	// contains filtered or unexported fields
}

type ClientConn = interface {
	Post(ctx context.Context, path string, contentFormat message.MediaType, payload io.ReadSeeker, opts ...message.Option) (*pool.Message, error)
	Get(ctx context.Context, path string, opts ...message.Option) (*pool.Message, error)
	Delete(ctx context.Context, path string, opts ...message.Option) (*pool.Message, error)
	Observe(ctx context.Context, path string, observeFunc func(notification *pool.Message), opts ...message.Option) (Observation, error)
	RemoteAddr() net.Addr
	Close() error
	Context() context.Context
	Done() <-chan struct{}
}

type CloseHandlerFunc = func(err error)

type Codec interface {
	ContentFormat() message.MediaType
	Encode(v interface{}) ([]byte, error)
	Decode(m *pool.Message, v interface{}) error
}

type DecodeFunc = func(interface{}) error

type DetailedResponse[T any] struct {
	Code codes.Code // content format from the response options
	ETag []byte     // ETag from the response
	Body T          // parsed response body, pointer to the variable will be send to codec.Decode
}

type DetailedResponseSetter interface {
	SetCode(code codes.Code)
	SetETag(etag []byte)
	GetBody() interface{}
}

type Observation = interface {
	Cancel(context.Context, ...message.Option) error
	Canceled() bool
}

type ObservationHandler interface {
	Handle(client *Client, body DecodeFunc)
	Error(err error)
	Close()
}

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

type OptionFunc = func(message.Options) message.Options