demoProvider

func DiscoveredNetworks ¶

func DiscoveredNetworks() []string

* NeworkDiscovery() * Discovers available Homie networks

func Initialize ¶

func Initialize(dfg cc.Config) (sch.OTAInteractor, dss.StreamProvider, []string, error)

func NewMockClient ¶

func NewMockClient() mqtt.Client

func NewOTAStream ¶

func NewOTAStream(plog log.Logger) sch.OTAInteractor

func NewStreamProvider ¶

func NewStreamProvider(plog log.Logger) dss.StreamProvider

func Start ¶

func Start() error

func Stop ¶

func Stop()

func UnWatchOTAProgress ¶

func UnWatchOTAProgress(network, device string) error

UnWatchOTAProgress for Scheduler

func WatchOTAProgress ¶

func WatchOTAProgress(network, device string) error

WatchOTAProgress for Scheduler