coapconv

Documentation

Index

• func CoapCodeToStatus(code codes.Code, operation Operation) 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, resourceTypes []string, connectionID string, ...) *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
• func ToGrpcCode(code coapCodes.Code, def codes.Code) codes.Code
• func ToHTTPCode(code coapCodes.Code, def int) int
• type EncodeFunc
  • func GetEncoder(accept message.MediaType) (EncodeFunc, error)
• type Operation

Functions

func CoapCodeToStatus

func CoapCodeToStatus(code codes.Code, operation Operation) 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, resourceTypes []string, 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

func ToGrpcCode

func ToGrpcCode(code coapCodes.Code, def codes.Code) codes.Code

ToGrpcCode converts coap.Code to grpc.Code

func ToHTTPCode

func ToHTTPCode(code coapCodes.Code, def int) int

ToHTTPCode converts coap.Code to http.Status

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
	Retrieve Operation = 2
	Update   Operation = 3
	Delete   Operation = 4
)