triggers

Documentation

Index

• Constants
• func New() supervisor.Pluggable
• type IGetTrigger
• type IRegistrar
• type ITrigger
  • func NewStateChangedTrigger(eventBus bus.Bus) ITrigger
  • func NewSystemTrigger(eventBus bus.Bus) ITrigger
  • func NewTimeTrigger(eventBus bus.Bus, scheduler *scheduler.Scheduler) ITrigger
• type StateChangeTrigger
  • func (t *StateChangeTrigger) AsyncAttach(wg *sync.WaitGroup)
  • 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 (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 (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"
)

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/event/start" //todo move
	// TopicSystemStop ...
	TopicSystemStop = "system/event/stop" //todo move

	Version = "0.0.1"
)

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

Functions

func New

func New() supervisor.Pluggable

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
}

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,
	scheduler *scheduler.Scheduler) 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) 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) 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) 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 ...