core

type Binding string

type Device struct {
	Id          string
	Endpoint    string
	Version     string
	BindingMode Binding

	Lifetime int
	Sms      *string
	Manager  Manager
	// contains filtered or unexported fields
}

type DeviceEvent struct {
	EventType DeviceEventType
	Device    *Device
}

type DeviceEventType int

type DeviceManager interface {
	Read(ctx context.Context, p node.Path) ([]node.Node, error)
	ReadObject(ctx context.Context, p node.Path) (*node.Object, error)
	ReadResource(ctx context.Context, p node.Path) (*node.Resource, error)
	Write(ctx context.Context, p node.Path, val ...node.Node) error
	WriteResource(ctx context.Context, p node.Path, val *node.Resource) error
	WriteObjectInstance(ctx context.Context, p node.Path, val *node.ObjectInstance) error
	Discover(ctx context.Context, p node.Path) ([]*encoding.CoreLink, error)
}

type InactivityMonitor[C inactivity.Conn] struct {
	// contains filtered or unexported fields
}

type InactivityMonitorOpt[C options.OnInactiveFunc] struct {
	// contains filtered or unexported fields
}

type Manager interface {
	Register(req *RegisterRequest, links []*encoding.CoreLink, conn mux.Conn) (*Device, error)
	// PostRegister call by transport when register response send
	PostRegister(id string)
	Update(id string, req *UpdateRequest, links []*encoding.CoreLink, conn mux.Conn) error
	PostUpdate(id string)
	Deregister(id string) error
	GetDevice(id string) (*Device, error)
	GetDeviceByEP(ep string) (*Device, error)
	OnDeviceStateChange(f OnDeviceStateChangeFunc)
}

type ManagerConfig struct {
	// contains filtered or unexported fields
}

type ManagerOption func(cfg *ManagerConfig)

type Observation struct {
	// contains filtered or unexported fields
}

type ObserveFunc func(d *Device, p node.Path, notify []node.Node)

type ObserveObjectFunc func(d *Device, p node.Path, notify *node.Object)

type ObserveResourceFunc func(d *Device, p node.Path, notify *node.Resource)

type Observer interface {
	ObserveSync(p node.Path, onMsg ObserveFunc) error
	Observe(p node.Path, onMsg ObserveFunc) error
	ObserveObject(p node.Path, onMsg ObserveObjectFunc) error
	ObserveResource(p node.Path, onMsg ObserveResourceFunc) error
	CancelObserve(p node.Path) error
}

type OnDeviceStateChangeFunc func(e DeviceEvent, m Manager)

type RegisterRequest struct {
	Ep          string
	Lifetime    int
	Version     string
	BindingMode Binding
	Queue       bool
	SmsNumber   *string
}

type UpdateRequest struct {
	Lifetime    *int
	BindingMode *Binding
	SmsNumber   *string
}