runner

Documentation

Index

• type BaseOperation
  • func NewBaseOperation(name string, freq time.Duration) *BaseOperation
  • func (e *BaseOperation) GetFrequency() time.Duration
  • func (e *BaseOperation) GetId() uuid.UUID
  • func (e *BaseOperation) GetName() string
  • func (e *BaseOperation) SetFrequency(f time.Duration) error
• type ErrorHandler
• type LimitedRunner
  • func (r *LimitedRunner) AddOperation(e Operation) error
  • func (r *LimitedRunner) IsRunning() bool
  • func (r *LimitedRunner) RemoveOperation(e Operation) error
  • func (r *LimitedRunner) RemovePolicyById(id uuid.UUID) (Operation, error)
  • func (r *LimitedRunner) Start(closeNotify <-chan struct{}) error
  • func (r *LimitedRunner) Stop() error
• type Operation
• type Runner
  • func NewRunner(minF, maxF time.Duration, eh ErrorHandler) (Runner, error)

Types

type BaseOperation

type BaseOperation struct {
	Frequency time.Duration
	Id        uuid.UUID
	Name      string
}

func NewBaseOperation

func NewBaseOperation(name string, freq time.Duration) *BaseOperation

func (*BaseOperation) GetFrequency

func (e *BaseOperation) GetFrequency() time.Duration

func (*BaseOperation) GetId

func (e *BaseOperation) GetId() uuid.UUID

func (*BaseOperation) GetName

func (e *BaseOperation) GetName() string

func (*BaseOperation) SetFrequency

func (e *BaseOperation) SetFrequency(f time.Duration) error

type ErrorHandler

type ErrorHandler func(error, Operation)

type LimitedRunner

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

func (*LimitedRunner) AddOperation

func (r *LimitedRunner) AddOperation(e Operation) error

func (*LimitedRunner) IsRunning

func (r *LimitedRunner) IsRunning() bool

func (*LimitedRunner) RemoveOperation

func (r *LimitedRunner) RemoveOperation(e Operation) error

func (*LimitedRunner) RemovePolicyById

func (r *LimitedRunner) RemovePolicyById(id uuid.UUID) (Operation, error)

func (*LimitedRunner) Start

func (r *LimitedRunner) Start(closeNotify <-chan struct{}) error

func (*LimitedRunner) Stop

func (r *LimitedRunner) Stop() error

type Operation

type Operation interface {
	GetName() string
	GetId() uuid.UUID
	Run() error
	GetFrequency() time.Duration
	SetFrequency(duration time.Duration) error
}

type Runner

type Runner interface {
	AddOperation(Operation) error
	RemoveOperation(Operation) error
	RemovePolicyById(uuid.UUID) (Operation, error)
	Start(closeNotify <-chan struct{}) error
	Stop() error
	IsRunning() bool
}

func NewRunner

func NewRunner(minF, maxF time.Duration, eh ErrorHandler) (Runner, error)