autoevent

Documentation

Index

• func NewManager(ctx context.Context, wg *sync.WaitGroup, bufferSize int, dic *di.Container)
• type Executor
  • func NewExecutor(deviceName string, ae contract.AutoEvent) (*Executor, error)
  • func (e *Executor) Run(ctx context.Context, wg *sync.WaitGroup, dic *di.Container)
  • func (e *Executor) Stop()
• type Manager
  • func GetManager() Manager

Functions

func NewManager

func NewManager(ctx context.Context, wg *sync.WaitGroup, bufferSize int, dic *di.Container)

NewManager initiates the AutoEvent manager once

Types

type Executor

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

func NewExecutor

func NewExecutor(deviceName string, ae contract.AutoEvent) (*Executor, error)

NewExecutor creates an Executor for an AutoEvent

func (*Executor) Run

func (e *Executor) Run(ctx context.Context, wg *sync.WaitGroup, dic *di.Container)

Run triggers this Executor executes the handler for the resource periodically

func (*Executor) Stop

func (e *Executor) Stop()

Stop marks this Executor stopped

type Manager

type Manager interface {
	StartAutoEvents(dic *di.Container) bool
	StopAutoEvents()
	RestartForDevice(deviceName string, dic *di.Container)
	StopForDevice(deviceName string)
}

func GetManager

func GetManager() Manager

GetManager returns Manager instance