supervisor

package

Go to main page

Versions in this module

v0

v0.18.0

May 25, 2024

v0.17.1

Mar 10, 2024

v0.17.0

Mar 8, 2024

Changes in this version

+ func CallActionV2Bind(manager Supervisor) func(params CallActionV2, value map[string]interface{})

type BaseActor

+ func (e *BaseActor) MatchTags(tags []string) bool

+ type CallActionV2 struct

+ ActionName string

+ AreaId *int64

+ EntityId *common.EntityId

+ Tags []string

type Plugin

+ func (p *Plugin) Check(msg events.EventCallEntityAction) (result []interface{}, ok bool)

type PluginActor

+ Area func() *m.Area

+ MatchTags func(tags []string) bool

type Supervisor

+ CallActionV2 func(CallActionV2, map[string]interface{})

v0.16.1

Feb 5, 2024

Changes in this version

type ActorInfo

+ RestoreState bool

type BaseActor

+ func (e *BaseActor) Spawn()

v0.16.0

Jan 29, 2024

v0.15.0

Jan 25, 2024

Changes in this version

type BaseActor

+ ScriptsEngine *scripts.EnginesWatcher

+ func (e *BaseActor) GetOldState() *events.EventEntityState

+ func (e *BaseActor) RestoreState(entity *m.Entity)

+ func (e *BaseActor) SetActorState(name *string)

+ func (e *BaseActor) SetActorStateImage(imageUrl, icon *string)

type PluginActor

+ GetOldState func() *events.EventEntityState

v0.14.2

Jan 12, 2024

v0.14.1

Jan 10, 2024

v0.14.0

Jan 8, 2024

Changes in this version

+ func PointInsideAreaBind(adaptors *adaptors.Adaptors) func(areaId int64, point m.Point) bool

+ func PushSystemEvent(manager Supervisor) func(command string, params map[string]interface{})

type Pluggable

+ Readme func(lang *string) ([]byte, error)

type Plugin

+ F embed.FS

+ func (p *Plugin) Readme(lang *string) (result []byte, err error)

type Supervisor

+ GetPluginReadme func(context.Context, string, *string) ([]byte, error)

+ PushSystemEvent func(strCommand string, params map[string]interface{})

v0.13.2

Jan 2, 2024

v0.13.1

Dec 23, 2023

v0.13.0

Dec 19, 2023

v0.12.0

Nov 2, 2023

Changes in this version

+ const PluginBuiltIn

+ const PluginInstallable

+ const StateAwait

+ const StateError

+ const StateInProcess

+ const StateOk

+ var ErrPluginIsLoaded = errors.New("plugin is loaded")

+ var ErrPluginIsUnloaded = errors.New("plugin is unloaded")

+ var ErrPluginNotLoaded = errors.New("plugin not loaded")

+ func CallActionBind(manager Supervisor) func(entityId, action string, value map[string]interface{})

+ func CallSceneBind(manager Supervisor) func(entityId string, value map[string]interface{})

+ func GetAttributesBind(manager Supervisor) func(entityId string) m.AttributeValue

+ func GetDistanceBetweenPointsBind(adaptors *adaptors.Adaptors) func(point1, point2 m.Point) float64

+ func GetDistanceToAreaBind(adaptors *adaptors.Adaptors) func(areaId int64, point m.Point) float64

+ func GetEntityBind(manager Supervisor) func(entityId string) *EntityBind

+ func GetSettingsBind(manager Supervisor) func(entityId string) m.AttributeValue

+ func GetStateBind(manager Supervisor) func(entityId string) *m.EntityStateShort

+ func NewEntity(a PluginActor) m.EntityShort

+ func PointInsideAriaBind(adaptors *adaptors.Adaptors) func(areaId int64, point m.Point) bool

+ func RegisterPlugin(name string, new func() Pluggable)

+ func SetAttributesBind(manager Supervisor) func(entityId string, params m.AttributeValue)

+ func SetMetricBind(manager Supervisor) func(entityId, name string, value map[string]interface{})

+ func SetStateBind(manager Supervisor) func(entityId string, params EntityStateParams)

+ func SetStateNameBind(manager Supervisor) func(entityId, stateName string)

+ func ToEntityActionShort(from map[string]ActorAction) (to map[string]m.EntityActionShort)

+ func ToEntityStateShort(from map[string]ActorState) (to map[string]m.EntityStateShort)

+ type ActorAction struct

+ Description string

+ Icon *string

+ ImageUrl *string

+ Name string

+ ScriptEngine *scripts.EngineWatcher

+ type ActorConstructor func(*m.Entity) (PluginActor, error)

+ type ActorInfo struct

+ Actions map[string]ActorAction

+ Area *m.Area

+ AutoLoad bool

+ DependsOn []string

+ Description string

+ Hidde bool

+ Icon *string

+ Id common.EntityId

+ ImageUrl *string

+ LastChanged *time.Time

+ LastUpdated *time.Time

+ Name string

+ ParentId *common.EntityId

+ PluginName string

+ State *ActorState

+ States map[string]ActorState

+ UnitOfMeasurement string

+ Value interface{}

+ type ActorState struct

+ Description string

+ Icon *string

+ ImageUrl *string

+ Name string

+ func (a *ActorState) Copy() (state *ActorState)

+ type BaseActor struct

+ Actions map[string]ActorAction

+ Area *m.Area

+ AttrMu *sync.RWMutex

+ Attrs m.Attributes

+ AutoLoad bool

+ Description string

+ EntityType string

+ Hidden bool

+ Icon *string

+ Id common.EntityId

+ ImageUrl *string

+ LastChanged *time.Time

+ LastUpdated *time.Time

+ Metric []*m.Metric

+ Name string

+ ParentId *common.EntityId

+ ScriptEngines []*scripts.EngineWatcher

+ Scripts []*m.Script

+ Service Service

+ SettingsMu *sync.RWMutex

+ Setts m.Attributes

+ State *ActorState

+ States map[string]ActorState

+ UnitOfMeasurement string

+ Value *atomic.String

+ func NewBaseActor(entity *m.Entity, service Service) BaseActor

+ func (e *BaseActor) AddMetric(name string, value map[string]interface{})

+ func (e *BaseActor) Attributes() m.Attributes

+ func (e *BaseActor) DeserializeAttr(data m.AttributeValue)

+ func (e *BaseActor) DeserializeSettings(settings m.AttributeValue)

+ func (e *BaseActor) GetCurrentState() *bus.EventEntityState

+ func (e *BaseActor) GetEventState() (eventState bus.EventEntityState)

+ func (e *BaseActor) Info() (info ActorInfo)

+ func (e *BaseActor) Metrics() []*m.Metric

+ func (e *BaseActor) Now(oldState bus.EventEntityState) time.Time

+ func (e *BaseActor) SaveState(msg events.EventStateChanged)

+ func (e *BaseActor) SetCurrentState(state bus.EventEntityState)

+ func (e *BaseActor) SetState(EntityStateParams) error

+ func (e *BaseActor) Settings() m.Attributes

+ func (e *BaseActor) StopWatchers()

+ type EntityBind struct

+ func NewEntityBind(id common.EntityId, manager Supervisor) *EntityBind

+ type EntityStateParams struct

+ AttributeValues m.AttributeValue

+ NewState *string

+ SettingsValue m.AttributeValue

+ StorageSave bool

+ type Installable interface

+ Install func() error

+ Uninstall func() error

+ type MessageStateChanged struct

+ NewState bus.EventEntityState

+ OldState bus.EventEntityState

+ StorageSave bool

+ type Pluggable interface

+ AddOrUpdateActor func(*m.Entity) error

+ Depends func() []string

+ EntityIsLoaded func(id common.EntityId) bool

+ GetActor func(id common.EntityId) (pla PluginActor, err error)

+ Load func(context.Context, Service) error

+ Name func() string

+ Options func() m.PluginOptions

+ RemoveActor func(common.EntityId) error

+ Type func() PluginType

+ Unload func(context.Context) error

+ Version func() string

+ type Plugin struct

+ Actors *sync.Map

+ IsStarted *atomic.Bool

+ Service Service

+ func NewPlugin() *Plugin

+ func (p *Plugin) AddActor(pla PluginActor, entity *m.Entity) (err error)

+ func (p *Plugin) AddOrUpdateActor(entity *m.Entity) (err error)

+ func (p *Plugin) Depends() []string

+ func (p *Plugin) EntityIsLoaded(id common.EntityId) bool

+ func (p *Plugin) GetActor(id common.EntityId) (pla PluginActor, err error)

+ func (p *Plugin) Load(ctx context.Context, service Service, actorConstructor ActorConstructor) error

+ func (p *Plugin) LoadSettings(pl Pluggable) (settings m.Attributes, err error)

+ func (p *Plugin) Name() string

+ func (p *Plugin) Options() m.PluginOptions

+ func (p *Plugin) RemoveActor(entityId common.EntityId) (err error)

+ func (p *Plugin) Type() PluginType

+ func (p *Plugin) Unload(ctx context.Context) error

+ func (p *Plugin) Version() string

+ type PluginActor interface

+ AddMetric func(name string, value map[string]interface{})

+ Attributes func() m.Attributes

+ Destroy func()

+ GetCurrentState func() *bus.EventEntityState

+ GetEventState func() (eventState bus.EventEntityState)

+ Info func() ActorInfo

+ Metrics func() []*m.Metric

+ SetCurrentState func(bus.EventEntityState)

+ SetState func(EntityStateParams) error

+ Settings func() m.Attributes

+ Spawn func()

+ StopWatchers func()

+ type PluginInfo struct

+ Enabled bool

+ Name string

+ System bool

+ Version string

+ type PluginType string

+ type Service interface

+ Adaptors func() *adaptors.Adaptors

+ AppConfig func() *m.AppConfig

+ Crawler func() web.Crawler

+ EventBus func() bus.Bus

+ GateClient func() *gate_client.GateClient

+ MqttServ func() mqtt.MqttServ

+ Plugins func() map[string]Pluggable

+ Scheduler func() *scheduler.Scheduler

+ ScriptService func() scripts.ScriptService

+ Supervisor func() Supervisor

+ type Supervisor interface

+ AddEntity func(*m.Entity) error

+ CallAction func(common.EntityId, string, map[string]interface{})

+ CallScene func(common.EntityId, map[string]interface{})

+ DisablePlugin func(context.Context, string) error

+ EnablePlugin func(context.Context, string) error

+ EntityIsLoaded func(id common.EntityId) (loaded bool)

+ GetActorById func(common.EntityId) (PluginActor, error)

+ GetEntityById func(common.EntityId) (m.EntityShort, error)

+ GetPlugin func(name string) (plugin interface{}, err error)

+ GetService func() Service

+ PluginIsLoaded func(name string) (loaded bool)

+ PluginList func() (list []PluginInfo, total int64, err error)

+ Restart func(context.Context) error

+ SetMetric func(common.EntityId, string, map[string]interface{})

+ SetState func(common.EntityId, EntityStateParams) error

+ Shutdown func(context.Context) error

+ Start func(context.Context) error

+ UnloadEntity func(common.EntityId)

+ UpdateEntity func(*m.Entity) error

+ func NewSupervisor(lc fx.Lifecycle, adaptors *adaptors.Adaptors, bus bus.Bus, ...) Supervisor

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL