coapconv

Documentation

Index

• func CoapCodeToStatus(code codes.Code) pbRA.Status
• func GrpcCode2CoapCode(statusCode codes.Code, method coapCodes.Code) coapCodes.Code
• func HttpCode2CoapCode(statusCode int, method coapCodes.Code) coapCodes.Code
• func MakeCommandMetadata(sequenceNumber uint64, connectionID string) pbCQRS.CommandMetadata
• func MakeConfirmResourceRetrieveRequest(resourceId, correlationId string, authCtx pbCQRS.AuthorizationContext, ...) pbRA.ConfirmResourceRetrieveRequest
• func MakeConfirmResourceUpdateRequest(resourceId, correlationId string, authCtx pbCQRS.AuthorizationContext, ...) pbRA.ConfirmResourceUpdateRequest
• func MakeContent(opts message.Options, body io.Reader) pbRA.Content
• func MakeMediaType(coapContentFormat int32, contentType string) (message.MediaType, error)
• func MakeNotifyResourceChangedRequest(resourceId string, authCtx pbCQRS.AuthorizationContext, connectionID string, ...) pbRA.NotifyResourceChangedRequest
• func MakeRetrieveResourceRequest(resourceId, resourceInterface, correlationId string, ...) pbRA.RetrieveResourceRequest
• func MakeUpdateResourceRequest(deviceID, href string, req *mux.Message) *pbGRPC.UpdateResourceValuesRequest
• func NewCoapResourceRetrieveRequest(ctx context.Context, event *pb.Event_ResourceRetrievePending) (*pool.Message, error)
• func NewCoapResourceUpdateRequest(ctx context.Context, event *pb.Event_ResourceUpdatePending) (*pool.Message, error)
• func StatusToCoapCode(status pbGRPC.Status, cmdCode codes.Code) codes.Code

Functions

func CoapCodeToStatus

func CoapCodeToStatus(code codes.Code) pbRA.Status

func GrpcCode2CoapCode

func GrpcCode2CoapCode(statusCode codes.Code, method coapCodes.Code) coapCodes.Code

func HttpCode2CoapCode

func HttpCode2CoapCode(statusCode int, method coapCodes.Code) coapCodes.Code

func MakeCommandMetadata

func MakeCommandMetadata(sequenceNumber uint64, connectionID string) pbCQRS.CommandMetadata

func MakeConfirmResourceRetrieveRequest

func MakeConfirmResourceRetrieveRequest(resourceId, correlationId string, authCtx pbCQRS.AuthorizationContext, connectionID string, req *pool.Message) pbRA.ConfirmResourceRetrieveRequest

func MakeConfirmResourceUpdateRequest

func MakeConfirmResourceUpdateRequest(resourceId, correlationId string, authCtx pbCQRS.AuthorizationContext, connectionID string, req *pool.Message) pbRA.ConfirmResourceUpdateRequest

func MakeContent

func MakeContent(opts message.Options, body io.Reader) pbRA.Content

func MakeMediaType

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

func MakeNotifyResourceChangedRequest

func MakeNotifyResourceChangedRequest(resourceId string, authCtx pbCQRS.AuthorizationContext, connectionID string, req *pool.Message) pbRA.NotifyResourceChangedRequest

func MakeRetrieveResourceRequest

func MakeRetrieveResourceRequest(resourceId, resourceInterface, correlationId string, authCtx pbCQRS.AuthorizationContext, connectionID string, req *mux.Message) pbRA.RetrieveResourceRequest

func MakeUpdateResourceRequest

func MakeUpdateResourceRequest(deviceID, href string, req *mux.Message) *pbGRPC.UpdateResourceValuesRequest

func NewCoapResourceRetrieveRequest

func NewCoapResourceRetrieveRequest(ctx context.Context, event *pb.Event_ResourceRetrievePending) (*pool.Message, error)

func NewCoapResourceUpdateRequest

func NewCoapResourceUpdateRequest(ctx context.Context, event *pb.Event_ResourceUpdatePending) (*pool.Message, error)

func StatusToCoapCode

func StatusToCoapCode(status pbGRPC.Status, cmdCode codes.Code) codes.Code