processor

Documentation

Overview

Package processor manage polling of associations, dispatching association to processor

Package processor manage polling of associations, dispatching association to processor

Package processor refreshes association immediately

Package processor manage polling of associations, dispatching association to processor

Index

• type AssocList
• type Processor
  • func NewAssociationProcessor(context context.T) *Processor
  • func (p *Processor) InitializeAssociationProcessor()
  • func (p *Processor) ModuleExecute(context context.T)
  • func (p *Processor) ModuleRequestStop(stopType contracts.StopType) (err error)
  • func (p *Processor) ProcessAssociation()
  • func (p *Processor) ProcessRefreshAssociation(log log.T, pluginRes *contracts.PluginResult, orchestrationDir string, ...)
  • func (p *Processor) SetPollJob(job *scheduler.Job)

Types

type AssocList

type AssocList []string

type Processor

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

Processor contains the logic for processing association

func NewAssociationProcessor

func NewAssociationProcessor(context context.T) *Processor

NewAssociationProcessor returns a new Processor with the given context.

func (*Processor) InitializeAssociationProcessor

func (p *Processor) InitializeAssociationProcessor()

StartAssociationWorker starts worker to process scheduled association

func (*Processor) ModuleExecute

func (p *Processor) ModuleExecute(context context.T)

func (*Processor) ModuleRequestStop

func (p *Processor) ModuleRequestStop(stopType contracts.StopType) (err error)

func (*Processor) ProcessAssociation

func (p *Processor) ProcessAssociation()

ProcessAssociation poll and process all the associations

func (*Processor) ProcessRefreshAssociation

func (p *Processor) ProcessRefreshAssociation(log log.T, pluginRes *contracts.PluginResult, orchestrationDir string, apply bool)

ProcessRefreshAssociation executes one set of commands and returns their output.

func (*Processor) SetPollJob

func (p *Processor) SetPollJob(job *scheduler.Job)

SetPollJob represents setter for PollJob