plugins

Documentation

Index

• func AddPlugin(adaptors *adaptors.Adaptors, name string, opts ...m.AttributeValue) (err error)
• func AddScript(name, src string, adaptors *adaptors.Adaptors, ...) (script *m.Script, err error)
• func AddTask(newTask *m.NewTask, adaptors *adaptors.Adaptors, eventBus bus.Bus) (task1Id int64, err error)
• func AddTrigger(trigger *m.NewTrigger, adaptors *adaptors.Adaptors, eventBus bus.Bus) (id int64, err error)
• func GetNewBitmineL3(name string) *m.Entity
• func GetNewButton(id string, scripts []*m.Script) *m.Entity
• func GetNewModbusRtu(name string) *m.Entity
• func GetNewModbusTcp(name string) *m.Entity
• func GetNewMoon(name string) *m.Entity
• func GetNewNode(name string) *m.Entity
• func GetNewPlug(id string, scrits []*m.Script) *m.Entity
• func GetNewScene(id string, scripts []*m.Script) *m.Entity
• func GetNewSensor(name string) *m.Entity
• func GetNewSun(name string) *m.Entity
• func GetNewTelegram(name string) *m.Entity
• func GetNewWeatherMet(name string) *m.Entity
• func GetPort() int64
• func MockHttpServer(ctx context.Context, ip string, port int64, payload []byte) (err error)
• func MockTCPServer(ctx context.Context, ip string, port int64, payloads ...[]byte) (err error)
• func RegisterConvey(scriptService scripts.ScriptService, ctx convey.C)
• func Wait(timeOut time.Duration, ch chan interface{}) (ok bool)
• func WaitEntity(eventBus bus.Bus, timeOut time.Duration, entities ...string) (result chan bool)
• func WaitGroupTimeout(wg *sync.WaitGroup, timeOut time.Duration) bool
• func WaitMessage[...](eventBus bus.Bus, timeOut time.Duration, topic string, options ...interface{}) (msg T, ok bool)
• func WaitPlugins(eventBus bus.Bus, timeOut time.Duration, plugins ...string) (result chan bool)
• func WaitService(eventBus bus.Bus, timeOut time.Duration, services ...string) (result chan bool)
• func WaitT[...](timeOut time.Duration, ch chan T) (v T, ok bool)
• func WaitTask(eventBus bus.Bus, timeOut time.Duration, tasks ...int64) (result chan bool)

Functions

func AddPlugin

func AddPlugin(adaptors *adaptors.Adaptors, name string, opts ...m.AttributeValue) (err error)

AddPlugin ...

func AddScript

func AddScript(name, src string, adaptors *adaptors.Adaptors, scriptService scripts.ScriptService) (script *m.Script, err error)

AddScript ...

func AddTask

func AddTask(newTask *m.NewTask, adaptors *adaptors.Adaptors, eventBus bus.Bus) (task1Id int64, err error)

func AddTrigger

func AddTrigger(trigger *m.NewTrigger, adaptors *adaptors.Adaptors, eventBus bus.Bus) (id int64, err error)

func GetNewBitmineL3

func GetNewBitmineL3(name string) *m.Entity

GetNewBitmineL3 ...

func GetNewButton

func GetNewButton(id string, scripts []*m.Script) *m.Entity

GetNewButton ...

func GetNewModbusRtu

func GetNewModbusRtu(name string) *m.Entity

GetNewModbusRtu ...

func GetNewModbusTcp

func GetNewModbusTcp(name string) *m.Entity

GetNewModbusTcp ...

func GetNewMoon

func GetNewMoon(name string) *m.Entity

GetNewMoon ...

func GetNewNode

func GetNewNode(name string) *m.Entity

GetNewNode ...

func GetNewPlug

func GetNewPlug(id string, scrits []*m.Script) *m.Entity

GetNewPlug ...

func GetNewScene

func GetNewScene(id string, scripts []*m.Script) *m.Entity

GetNewScene ...

func GetNewSensor

func GetNewSensor(name string) *m.Entity

GetNewSensor ...

func GetNewSun

func GetNewSun(name string) *m.Entity

GetNewSun ...

func GetNewTelegram

func GetNewTelegram(name string) *m.Entity

GetNewTelegram ...

func GetNewWeatherMet

func GetNewWeatherMet(name string) *m.Entity

GetNewWeatherMet ...

func GetPort

func GetPort() int64

GetPort ...

func MockHttpServer

func MockHttpServer(ctx context.Context, ip string, port int64, payload []byte) (err error)

MockHttpServer ...

func MockTCPServer

func MockTCPServer(ctx context.Context, ip string, port int64, payloads ...[]byte) (err error)

MockTCPServer ...

func RegisterConvey

func RegisterConvey(scriptService scripts.ScriptService, ctx convey.C)

RegisterConvey ...

func Wait

func Wait(timeOut time.Duration, ch chan interface{}) (ok bool)

Wait ...

func WaitEntity

func WaitEntity(eventBus bus.Bus, timeOut time.Duration, entities ...string) (result chan bool)

func WaitGroupTimeout

func WaitGroupTimeout(wg *sync.WaitGroup, timeOut time.Duration) bool

func WaitMessage

func WaitMessage[T events.EventStateChanged | events.EventTriggerCompleted | events.EventTriggerLoaded](
	eventBus bus.Bus, timeOut time.Duration, topic string, options ...interface{},
) (msg T, ok bool)

func WaitPlugins

func WaitPlugins(eventBus bus.Bus, timeOut time.Duration, plugins ...string) (result chan bool)

func WaitService

func WaitService(eventBus bus.Bus, timeOut time.Duration, services ...string) (result chan bool)

func WaitT

func WaitT[T events.EventTriggerLoaded | events.EventTriggerCompleted | events.EventStateChanged | alexa.EventAlexaAction | []byte | struct{}](timeOut time.Duration, ch chan T) (v T, ok bool)

WaitT ...

func WaitTask

func WaitTask(eventBus bus.Bus, timeOut time.Duration, tasks ...int64) (result chan bool)