Versions in this module Expand all Collapse all v0 v0.2.0 Apr 2, 2024 Changes in this version + type BootstrapOption = func(b *Bootstrapper) + func WithBootstrapInfo(i *core.BootstrapServerBootstrapInfo) BootstrapOption + func WithServerInfo(s *ServerInfo) BootstrapOption type DeviceController + func (d *DeviceController) OnPack(newValue []byte) error + type ServerInfo struct v0.1.0 Mar 7, 2024 Changes in this version + func NewAbnormalEvent(args ...string) Event + func NewBootstrappedEvent(args ...string) Event + func NewDeviceChangedEvent(args ...string) Event + func NewInfoObservedEvent(args ...string) Event + func NewInfoReportedEvent(args ...string) Event + func NewRegUpdatedEvent(args ...string) Event + func NewRegisteredEvent(args ...string) Event + func NewUnregisteredEvent(args ...string) Event + type AbnormalEvent struct + type BootstrappedEvent struct + type Bootstrapper struct + func NewBootstrapper(client *LwM2MClient) *Bootstrapper + func (r *Bootstrapper) BootstrapServerBootstrapInfo() *core.BootstrapServerBootstrapInfo + func (r *Bootstrapper) Bootstrapped() bool + func (r *Bootstrapper) OnDelete() error + func (r *Bootstrapper) OnDiscover() (*core.ResourceField, error) + func (r *Bootstrapper) OnFinish() error + func (r *Bootstrapper) OnRead() (*core.ResourceField, error) + func (r *Bootstrapper) OnWrite() error + func (r *Bootstrapper) PackRequest() error + func (r *Bootstrapper) Request() error + func (r *Bootstrapper) SetBootstrapServerBootstrapInfo(info *core.BootstrapServerBootstrapInfo) + func (r *Bootstrapper) Start() bool + func (r *Bootstrapper) Stop() + func (r *Bootstrapper) Timeout() bool + type Client interface + Notify func(somebody string, something []byte) error + OnEvent func(et core.EventType, h core.EventHandler) + Send func(data []byte) ([]byte, error) + type DeviceChangedEvent struct + type DeviceController struct + func NewDeviceController(c *LwM2MClient) *DeviceController + func (d *DeviceController) OnCreate(oid core.ObjectID, newValue []byte) error + func (d *DeviceController) OnDelete(oid core.ObjectID, instId core.InstanceID, resId core.ResourceID, ...) error + func (d *DeviceController) OnDiscover(oid core.ObjectID, instId core.InstanceID, resId core.ResourceID, depth int) error + func (d *DeviceController) OnExecute(oid core.ObjectID, instId core.InstanceID, resId core.ResourceID, args string) error + func (d *DeviceController) OnRead(oid core.ObjectID, instId core.InstanceID, resId core.ResourceID, ...) ([]byte, error) + func (d *DeviceController) OnWrite(oid core.ObjectID, instId core.InstanceID, resId core.ResourceID, ...) error + type InfoObservedEvent struct + type InfoReportedEvent struct + type LwM2MClient struct + func New(name string, store ObjectInstanceStore, opts ...Option) *LwM2MClient + func (c *LwM2MClient) EnableInstance(oid ObjectID, ids ...InstanceID) + func (c *LwM2MClient) EnableInstances(m InstanceIdsMap) + func (c *LwM2MClient) Notify(somebody string, something []byte) error + func (c *LwM2MClient) OnEvent(et EventType, h EventHandler) + func (c *LwM2MClient) Send(data []byte) ([]byte, error) + func (c *LwM2MClient) Servicing() bool + func (c *LwM2MClient) SetOperator(oid ObjectID, operator Operator) + func (c *LwM2MClient) SetOperators(operators OperatorMap) + func (c *LwM2MClient) Start() bool + func (c *LwM2MClient) Stop() + type MessagerClient struct + func NewMessager(c *LwM2MClient) *MessagerClient + func (m *MessagerClient) Close() error + func (m *MessagerClient) Connected() bool + func (m *MessagerClient) Deregister(info *regInfo) error + func (m *MessagerClient) Dial(addr string, opts ...coap.PeerOption) error + func (m *MessagerClient) PauseUserPlane() + func (m *MessagerClient) Redial(addr string, opts ...coap.PeerOption) error + func (m *MessagerClient) Register(info *regInfo) error + func (m *MessagerClient) ResumeUserPlane() + func (m *MessagerClient) Start() + func (m *MessagerClient) Update(info *regInfo, params ...string) error + type Observation struct + type Observer struct + type Option func(*Options) + func WithDTLSConfig(conf *piondtls.Config) Option + func WithLocalAddress(local string) Option + func WithObjectClassRegistry(registry core.ObjectRegistry) Option + func WithServerAddresses(addrString string) Option + func WithServerRecvTimeout(timeout time.Duration) Option + func WithServerSendTimeout(timeout time.Duration) Option + type Options struct + type RegUpdatedEvent struct + type RegisteredEvent struct + type Registrar struct + func NewRegistrar(client *LwM2MClient) *Registrar + func (r *Registrar) Deregister() error + func (r *Registrar) Register() error + func (r *Registrar) Registered() bool + func (r *Registrar) Start() bool + func (r *Registrar) Stop() + func (r *Registrar) Timeout() bool + func (r *Registrar) Update(params ...string) error + type Reporter struct + func NewReporter(c *LwM2MClient) *Reporter + func (r *Reporter) FailureCounter() int32 + func (r *Reporter) Notify(observationId string, value []byte) error + func (r *Reporter) OnCancelObservation(observationId string) error + func (r *Reporter) OnCancelObservationComposite() error + func (r *Reporter) OnObserve(observationId string, attrs core.NotificationAttrs) error + func (r *Reporter) OnObserveComposite() error + func (r *Reporter) Send(value []byte) ([]byte, error) + type UnregisteredEvent struct
Go to main page