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) (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 WaitGroupTimeout(wg *sync.WaitGroup, timeOut time.Duration) bool
• func WaitSupervisor(eventBus bus.Bus, timeOut time.Duration)
• func WaitT[T events.EventStateChanged | alexa.EventAlexaAction | []byte | struct{}](timeOut time.Duration, ch chan T) (v T, ok 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) (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 WaitGroupTimeout

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

func WaitSupervisor

func WaitSupervisor(eventBus bus.Bus, timeOut time.Duration)

func WaitT

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

WaitT ...