coapconv

Documentation

Index

• func CoapCodeToStatus(code codes.Code) commands.Status
• func GetAccept(opts message.Options) message.MediaType
• func GetContentData(opts message.Options, body io.Reader) (data []byte, contentFormat int32)
• func GrpcErr2CoapCode(err error, operation Operation) coapCodes.Code
• func MakeMediaType(coapContentFormat int32, contentType string) (message.MediaType, error)
• func NewCoapResourceCreateRequest(ctx context.Context, messagePool *pool.Pool, ...) (*pool.Message, error)
• func NewCoapResourceDeleteRequest(ctx context.Context, messagePool *pool.Pool, ...) (*pool.Message, error)
• func NewCoapResourceRetrieveRequest(ctx context.Context, messagePool *pool.Pool, ...) (*pool.Message, error)
• func NewCoapResourceUpdateRequest(ctx context.Context, messagePool *pool.Pool, ...) (*pool.Message, error)
• func NewCommandMetadata(sequenceNumber uint64, connectionID string) *commands.CommandMetadata
• func NewConfirmResourceCreateRequest(resourceID *commands.ResourceId, correlationID, connectionID string, ...) *commands.ConfirmResourceCreateRequest
• func NewConfirmResourceDeleteRequest(resourceID *commands.ResourceId, correlationID, connectionID string, ...) *commands.ConfirmResourceDeleteRequest
• func NewConfirmResourceRetrieveRequest(resourceID *commands.ResourceId, correlationID, connectionID string, ...) *commands.ConfirmResourceRetrieveRequest
• func NewConfirmResourceUpdateRequest(resourceID *commands.ResourceId, correlationID, connectionID string, ...) *commands.ConfirmResourceUpdateRequest
• func NewContent(opts message.Options, body io.Reader) *commands.Content
• func NewCreateResourceRequest(resourceID *commands.ResourceId, req *mux.Message, connectionID string) (*commands.CreateResourceRequest, error)
• func NewDeleteResourceRequest(resourceID *commands.ResourceId, req *mux.Message, connectionID string) (*commands.DeleteResourceRequest, error)
• func NewNotifyResourceChangedRequest(resourceID *commands.ResourceId, connectionID string, req *pool.Message) *commands.NotifyResourceChangedRequest
• func NewNotifyResourceChangedRequestsFromBatchResourceDiscovery(deviceID, connectionID string, req *pool.Message) ([]*commands.NotifyResourceChangedRequest, error)
• func NewRetrieveResourceRequest(resourceID *commands.ResourceId, req *mux.Message, connectionID string) (*commands.RetrieveResourceRequest, error)
• func NewUpdateResourceRequest(resourceID *commands.ResourceId, req *mux.Message, connectionID string) (*commands.UpdateResourceRequest, error)
• func StatusToCoapCode(status commands.Status, operation Operation) codes.Code
• type EncodeFunc
  • func GetEncoder(accept message.MediaType) (EncodeFunc, error)
• type Operation

Functions

func CoapCodeToStatus

func CoapCodeToStatus(code codes.Code) commands.Status

func GetAccept

func GetAccept(opts message.Options) message.MediaType

GetAccept returns expected content format by client

func GetContentData

func GetContentData(opts message.Options, body io.Reader) (data []byte, contentFormat int32)

func GrpcErr2CoapCode

func GrpcErr2CoapCode(err error, operation Operation) coapCodes.Code

func MakeMediaType

func MakeMediaType(coapContentFormat int32, contentType string) (message.MediaType, error)

func NewCoapResourceCreateRequest

func NewCoapResourceCreateRequest(ctx context.Context, messagePool *pool.Pool, event *events.ResourceCreatePending) (*pool.Message, error)

func NewCoapResourceDeleteRequest

func NewCoapResourceDeleteRequest(ctx context.Context, messagePool *pool.Pool, event *events.ResourceDeletePending) (*pool.Message, error)

func NewCoapResourceRetrieveRequest

func NewCoapResourceRetrieveRequest(ctx context.Context, messagePool *pool.Pool, event *events.ResourceRetrievePending) (*pool.Message, error)

func NewCoapResourceUpdateRequest

func NewCoapResourceUpdateRequest(ctx context.Context, messagePool *pool.Pool, event *events.ResourceUpdatePending) (*pool.Message, error)

func NewCommandMetadata

func NewCommandMetadata(sequenceNumber uint64, connectionID string) *commands.CommandMetadata

func NewConfirmResourceCreateRequest

func NewConfirmResourceCreateRequest(resourceID *commands.ResourceId, correlationID, connectionID string, req *pool.Message) *commands.ConfirmResourceCreateRequest

func NewConfirmResourceDeleteRequest

func NewConfirmResourceDeleteRequest(resourceID *commands.ResourceId, correlationID, connectionID string, req *pool.Message) *commands.ConfirmResourceDeleteRequest

func NewConfirmResourceRetrieveRequest

func NewConfirmResourceRetrieveRequest(resourceID *commands.ResourceId, correlationID, connectionID string, req *pool.Message) *commands.ConfirmResourceRetrieveRequest

func NewConfirmResourceUpdateRequest

func NewConfirmResourceUpdateRequest(resourceID *commands.ResourceId, correlationID, connectionID string, req *pool.Message) *commands.ConfirmResourceUpdateRequest

func NewContent

func NewContent(opts message.Options, body io.Reader) *commands.Content

func NewCreateResourceRequest

func NewCreateResourceRequest(resourceID *commands.ResourceId, req *mux.Message, connectionID string) (*commands.CreateResourceRequest, error)

func NewDeleteResourceRequest

func NewDeleteResourceRequest(resourceID *commands.ResourceId, req *mux.Message, connectionID string) (*commands.DeleteResourceRequest, error)

func NewNotifyResourceChangedRequest

func NewNotifyResourceChangedRequest(resourceID *commands.ResourceId, connectionID string, req *pool.Message) *commands.NotifyResourceChangedRequest

func NewNotifyResourceChangedRequestsFromBatchResourceDiscovery

func NewNotifyResourceChangedRequestsFromBatchResourceDiscovery(deviceID, connectionID string, req *pool.Message) ([]*commands.NotifyResourceChangedRequest, error)

func NewRetrieveResourceRequest

func NewRetrieveResourceRequest(resourceID *commands.ResourceId, req *mux.Message, connectionID string) (*commands.RetrieveResourceRequest, error)

func NewUpdateResourceRequest

func NewUpdateResourceRequest(resourceID *commands.ResourceId, req *mux.Message, connectionID string) (*commands.UpdateResourceRequest, error)

func StatusToCoapCode

func StatusToCoapCode(status commands.Status, operation Operation) codes.Code

Types

type EncodeFunc

type EncodeFunc = func(v interface{}) ([]byte, error)

func GetEncoder

func GetEncoder(accept message.MediaType) (EncodeFunc, error)

GetEncoder returns encoder by accept

type Operation

type Operation uint8

const Create Operation = 1

const Delete Operation = 4

const Retrieve Operation = 2

const Update Operation = 3