resources

Documentation

Index

• Constants
• func CreateErrorResponse(ctx context.Context, code codes.Code, err error) (*pool.Message, error)
• func CreateResponseBadRequest(ctx context.Context, err error) (*pool.Message, error)
• func CreateResponseContent(ctx context.Context, data interface{}, code codes.Code) (*pool.Message, error)
• func CreateResponseContentWithCodec(ctx context.Context, codec coap.Codec, data interface{}, code codes.Code) (*pool.Message, error)
• func CreateResponseMethodNotAllowed(ctx context.Context, token message.Token) *pool.Message
• func GetETag() uint64
• func MergeCBORStructs(a ...interface{}) interface{}
• func ToUUID(id string) uuid.UUID
• func Unique(strSlice []string) []string
• type CreateSubscriptionFunc
• type GetHandlerFunc
• type PostHandlerFunc
• type Resource
  • func NewResource(href string, getHandler GetHandlerFunc, postHandler PostHandlerFunc, ...) *Resource
  • func (r *Resource) Close()
  • func (r *Resource) ETag() []byte
  • func (r *Resource) GetHref() string
  • func (r *Resource) GetPolicyBitMask() schema.BitMask
  • func (r *Resource) GetResourceInterfaces() []string
  • func (r *Resource) GetResourceTypes() []string
  • func (r *Resource) HandleRequest(req *net.Request) (*pool.Message, error)
  • func (r *Resource) SetObserveHandler(loop *eventloop.Loop, createSubscription CreateSubscriptionFunc)
  • func (r *Resource) SetResourceTypes(resourceTypes []string)
  • func (r *Resource) SupportsOperations() SupportedOperation
  • func (r *Resource) UpdateETag()
• type SupportedOperation
  • func (o SupportedOperation) HasOperation(operation SupportedOperation) bool

Constants

const PublishToCloud schema.BitMask = 1 << 7

Functions

func CreateErrorResponse

func CreateErrorResponse(ctx context.Context, code codes.Code, err error) (*pool.Message, error)

func CreateResponseBadRequest

func CreateResponseBadRequest(ctx context.Context, err error) (*pool.Message, error)

func CreateResponseContent

func CreateResponseContent(ctx context.Context, data interface{}, code codes.Code) (*pool.Message, error)

func CreateResponseContentWithCodec

func CreateResponseContentWithCodec(ctx context.Context, codec coap.Codec, data interface{}, code codes.Code) (*pool.Message, error)

func CreateResponseMethodNotAllowed

func CreateResponseMethodNotAllowed(ctx context.Context, token message.Token) *pool.Message

func GetETag

func GetETag() uint64

func MergeCBORStructs

func MergeCBORStructs(a ...interface{}) interface{}

func ToUUID

func ToUUID(id string) uuid.UUID

func Unique

func Unique(strSlice []string) []string

Types

type CreateSubscriptionFunc

type CreateSubscriptionFunc func(*net.Request, func(*pool.Message, error)) (func(), error)

type GetHandlerFunc

type GetHandlerFunc func(*net.Request) (*pool.Message, error)

type PostHandlerFunc

type PostHandlerFunc func(*net.Request) (*pool.Message, error)

type Resource

type Resource struct {
	Href               string
	ResourceInterfaces []string
	PolicyBitMask      schema.BitMask
	// contains filtered or unexported fields
}

func NewResource

func NewResource(href string, getHandler GetHandlerFunc, postHandler PostHandlerFunc, resourceTypes, resourceInterfaces []string) *Resource

func (*Resource) Close

func (r *Resource) Close()

Close closes resource and cancel all subscriptions

func (*Resource) ETag

func (r *Resource) ETag() []byte

func (*Resource) GetHref

func (r *Resource) GetHref() string

func (*Resource) GetPolicyBitMask

func (r *Resource) GetPolicyBitMask() schema.BitMask

func (*Resource) GetResourceInterfaces

func (r *Resource) GetResourceInterfaces() []string

func (*Resource) GetResourceTypes

func (r *Resource) GetResourceTypes() []string

func (*Resource) HandleRequest

func (r *Resource) HandleRequest(req *net.Request) (*pool.Message, error)

func (*Resource) SetObserveHandler

func (r *Resource) SetObserveHandler(loop *eventloop.Loop, createSubscription CreateSubscriptionFunc)

func (*Resource) SetResourceTypes

func (r *Resource) SetResourceTypes(resourceTypes []string)

func (*Resource) SupportsOperations

func (r *Resource) SupportsOperations() SupportedOperation

func (*Resource) UpdateETag

func (r *Resource) UpdateETag()

type SupportedOperation

type SupportedOperation int

const (
	SupportedOperationRead SupportedOperation = 0x1 << iota
	SupportedOperationWrite
	SupportedOperationObserve
)

func (SupportedOperation) HasOperation

func (o SupportedOperation) HasOperation(operation SupportedOperation) bool