client

Oct 28, 2024

Changes in this version

+ const DisableObserveAction

+ const EnableObserveAction

+ const ObjectPathDelimiter

+ const ObjectRoot

+ type Client struct

+ func NewClient(ctx context.Context, config Config) (*Client, error)

+ func (c *Client) AddObject(object Object)

+ func (c *Client) AutoUpdate() error

+ func (c *Client) CleanUp()

+ func (c *Client) Delete() error

+ func (c *Client) Object() Object

+ func (c *Client) Ping() error

+ func (c *Client) Register() error

+ func (c *Client) Start() error

+ func (c *Client) Update() error

+ type Config struct

+ DeviceShifuHost string

+ EndpointName string

+ EndpointUrl string

+ Settings v1alpha1.LwM2MSetting

+ type Link struct

+ Attributes map[string]string

+ ResourcePath string

+ func NewLink(resourcePath string, attributes map[string]string) *Link

+ func (l *Link) String() string

+ type Object struct

+ Child map[string]Object

+ Id string

+ func NewObject(Id string, data ObjectAPI) *Object

+ func (o *Object) AddGroup(group Object)

+ func (o *Object) AddObject(path string, childObject ObjectAPI)

+ func (o *Object) GetAllChildPaths() []string

+ func (o *Object) GetCoRELinkString() string

+ func (o Object) GetChildObject(path string) *Object

+ func (o Object) ReadAll(baseName string) (Resource, error)

+ type ObjectAPI interface

+ Execute func() error

+ Read func() (interface{}, error)

+ Write func(interface{}) error

+ type ObjectData struct

+ BoolValue *bool

+ FloatValue float64

+ ParameterName string

+ StringValue string

+ type QueryParams string

+ const QueryParamsBindingMode

+ const QueryParamsEndpointName

+ const QueryParamsLwM2MVersion

+ const QueryParamslifeTime

+ type Resource struct

+ BaseName string

+ ResourceArray []ObjectData

+ func (r *Resource) ReadAsJSON() string

+ type Task struct

+ CancelFunc context.CancelFunc

+ Ticker *time.Ticker

+ type TaskManager struct

+ Lock sync.Mutex

+ Tasks map[string]*Task

+ func NewTaskManager(ctx context.Context) *TaskManager

+ func (m *TaskManager) AddTask(id string, interval time.Duration, fn func())

+ func (m *TaskManager) CancelAllTasks()

+ func (m *TaskManager) CancelTask(id string)

+ func (m *TaskManager) ResetTask(id string)