package autoevent

import "github.com/edgexfoundry/device-sdk-go/internal/autoevent"

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

Source Files ¶

executor.go manager.go