triggers

Documentation

Index

• Constants
• func New() plugins.Plugable
• type IGetTrigger
• type IRegistrar
• type ITrigger
  • func NewStateChangedTrigger(eventBus bus.Bus) ITrigger
  • func NewSystemTrigger(eventBus bus.Bus) ITrigger
  • func NewTimeTrigger(eventBus bus.Bus) ITrigger
• type StateChangeTrigger
  • func (t *StateChangeTrigger) AsyncAttach(wg *sync.WaitGroup)
  • func (t *StateChangeTrigger) CallManual()
  • func (b *StateChangeTrigger) FunctionName() string
  • func (b *StateChangeTrigger) Name() string
  • func (t *StateChangeTrigger) Subscribe(options Subscriber) error
  • func (t *StateChangeTrigger) Unsubscribe(options Subscriber) error
• type Subscriber
• type SystemTrigger
  • func (t *SystemTrigger) AsyncAttach(wg *sync.WaitGroup)
  • func (t *SystemTrigger) CallManual()
  • func (b *SystemTrigger) FunctionName() string
  • func (b *SystemTrigger) Name() string
  • func (t *SystemTrigger) Subscribe(options Subscriber) error
  • func (t *SystemTrigger) Unsubscribe(options Subscriber) error
• type TimeTrigger
  • func (t *TimeTrigger) AsyncAttach(wg *sync.WaitGroup)
  • func (t *TimeTrigger) CallManual()
  • func (b *TimeTrigger) FunctionName() string
  • func (b *TimeTrigger) Name() string
  • func (t *TimeTrigger) Subscribe(options Subscriber) error
  • func (t *TimeTrigger) Unsubscribe(options Subscriber) error

Constants

const (
	// StateChangeName ...
	StateChangeName = "state_change"
	// StateChangeFunctionName ...
	StateChangeFunctionName = "automationTriggerStateChanged"
	// StateChangeQueueSize ...
	StateChangeQueueSize = 10
)

const (
	// TopicSystem ...
	TopicSystem = "system"
	// EventStart ...
	EventStart = "START"
	// EventStop ...
	EventStop = "STOP"
	// SystemName ...
	SystemName = "system"
	// SystemFunctionName ...
	SystemFunctionName = "automationTriggerSystem"
	// SystemQueueSize ...
	SystemQueueSize = 10
)

const (
	// TimeName ...
	TimeName = "time"
	// TimeFunctionName ...
	TimeFunctionName = "automationTriggerTime"
	// TimeQueueSize ...
	TimeQueueSize = 10
)

const (
	// Name ...
	Name = "triggers"
	// TopicSystemStart ...
	TopicSystemStart = "system_start"
	// TopicSystemStop ...
	TopicSystemStop = "system_stop"
)

const (
	// CronOptionTrigger ...
	CronOptionTrigger = "cron"
)

Functions

func New

func New() plugins.Plugable

New ...

Types

type IGetTrigger

type IGetTrigger interface {
	GetTrigger(string) (ITrigger, error)
}

IGetTrigger ...

type IRegistrar

type IRegistrar interface {
	RegisterTrigger(ITrigger) error
	UnregisterTrigger(string) error
	TriggerList() []string
}

IRegistrar ...

type ITrigger

type ITrigger interface {
	Name() string
	AsyncAttach(wg *sync.WaitGroup)
	Subscribe(Subscriber) error
	Unsubscribe(Subscriber) error
	FunctionName() string
	CallManual()
}

todo deAttach

func NewStateChangedTrigger

func NewStateChangedTrigger(eventBus bus.Bus) ITrigger

NewStateChangedTrigger ...

func NewSystemTrigger

func NewSystemTrigger(eventBus bus.Bus) ITrigger

NewSystemTrigger ...

func NewTimeTrigger

func NewTimeTrigger(eventBus bus.Bus) ITrigger

NewTimeTrigger ...

type StateChangeTrigger

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

StateChangeTrigger ...

func (*StateChangeTrigger) AsyncAttach

func (t *StateChangeTrigger) AsyncAttach(wg *sync.WaitGroup)

AsyncAttach ...

func (*StateChangeTrigger) CallManual

func (t *StateChangeTrigger) CallManual()

CallManual ...

func (*StateChangeTrigger) FunctionName

func (b *StateChangeTrigger) FunctionName() string

FunctionName ...

func (*StateChangeTrigger) Name

func (b *StateChangeTrigger) Name() string

Name ...

func (*StateChangeTrigger) Subscribe

func (t *StateChangeTrigger) Subscribe(options Subscriber) error

Subscribe ...

func (*StateChangeTrigger) Unsubscribe

func (t *StateChangeTrigger) Unsubscribe(options Subscriber) error

Unsubscribe ...

type Subscriber

type Subscriber struct {
	EntityId *common.EntityId
	Handler  interface{}
	Payload  m.Attributes
}

Subscriber ...

type SystemTrigger

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

SystemTrigger ...

func (*SystemTrigger) AsyncAttach

func (t *SystemTrigger) AsyncAttach(wg *sync.WaitGroup)

AsyncAttach ...

func (*SystemTrigger) CallManual

func (t *SystemTrigger) CallManual()

CallManual ...

func (*SystemTrigger) FunctionName

func (b *SystemTrigger) FunctionName() string

FunctionName ...

func (*SystemTrigger) Name

func (b *SystemTrigger) Name() string

Name ...

func (*SystemTrigger) Subscribe

func (t *SystemTrigger) Subscribe(options Subscriber) error

Subscribe ...

func (*SystemTrigger) Unsubscribe

func (t *SystemTrigger) Unsubscribe(options Subscriber) error

Unsubscribe ...

type TimeTrigger

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

TimeTrigger ...

func (*TimeTrigger) AsyncAttach

func (t *TimeTrigger) AsyncAttach(wg *sync.WaitGroup)

AsyncAttach ...

func (*TimeTrigger) CallManual

func (t *TimeTrigger) CallManual()

CallManual ...

func (*TimeTrigger) FunctionName

func (b *TimeTrigger) FunctionName() string

FunctionName ...

func (*TimeTrigger) Name

func (b *TimeTrigger) Name() string

Name ...

func (*TimeTrigger) Subscribe

func (t *TimeTrigger) Subscribe(options Subscriber) error

Subscribe ...

func (*TimeTrigger) Unsubscribe

func (t *TimeTrigger) Unsubscribe(options Subscriber) error

Unsubscribe ...