wbgo

type ContentTracker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Control struct {
	Name        string
	Title       string
	Type        string
	Value       string
	Units       string
	Writability Writability
	HasMax      bool
	Max         float64
	Forget      bool
	Order       int
}

type DeferredList struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type DeviceBase struct {
	DevName  string
	DevTitle string
	Observer DeviceObserver
}

type DeviceModel interface {
	Name() string
	Title() string
	Observe(observer DeviceObserver)
	// AcceptValue accepts the specified control value sent via an MQTT value topic
	// (not .../on). For local devices, that can be a retained value, for external
	// devices, the current control value
	AcceptValue(name, value string)
}

type DeviceObserver interface {
	OnNewControl(dev LocalDeviceModel, control Control) string
	OnValue(dev DeviceModel, name, value string)
	OnError(dev DeviceModel, name, value string)
}

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

type DirWatcherClient interface {
	LoadFile(path string) error
	LiveLoadFile(path string) error
	LiveRemoveFile(path string) error
}

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

type ExtendedModel interface {
	Model
	AddExternalDevice(name string) (ExternalDeviceModel, error)
}

type ExternalDeviceModel interface {
	DeviceModel
	SetTitle(title string)
	AcceptControlType(name, controlType string)
	AcceptControlRange(name string, max float64)
}

type LocalDeviceModel interface {
	DeviceModel
	// AcceptOnValue accepts the specified control value sent via an MQTT .../on topic
	// for the target device and returns true if the value should be automatically
	// echoed back
	AcceptOnValue(name, value string) bool
	IsVirtual() bool
}

type MQTTClient interface {
	WaitForReady() <-chan struct{}
	Start()
	Stop()
	Publish(message MQTTMessage)
	Subscribe(callback MQTTMessageHandler, topics ...string)
	Unsubscribe(topics ...string)
}

type MQTTMessage struct {
	Topic    string
	Payload  string
	QoS      byte
	Retained bool
}

type MQTTMessageHandler func(message MQTTMessage)

type MQTTRPCServer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type MQTTSubscriptionMap map[string][]MQTTMessageHandler

type Model interface {
	Start() error
	Stop()
	Observe(observer ModelObserver)
	Poll()
}

type ModelBase struct {
	Observer ModelObserver
}

type ModelObserver interface {
	CallSync(thunk func())
	WhenReady(thunk func())
	RemoveDevice(dev DeviceModel)
	OnNewDevice(dev DeviceModel)
}

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

type RPCError interface {
	error
	ErrorCode() int32
}

type RTimer interface {
	// embed generic Timer here
	Timer

	// Reset changes the timer to expire after new duration d
	Reset(d time.Duration)
}

type RealRTimer struct {
	RealTimer
}

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

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

type Timer interface {
	// GetChannel retrieves a channel that signals timer expiration
	GetChannel() <-chan time.Time

	// Stop stops the timer
	Stop()
}

type Writability int