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

Index

• type AssocList
• type Processor
  • func NewAssociationProcessor(context context.T) *Processor
  • func (p *Processor) InitializeAssociationProcessor()
  • func (p *Processor) ModuleExecute()
  • func (p *Processor) ModuleStop() (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()

InitializeAssociationProcessor starts worker to process scheduled association

func (*Processor) ModuleExecute

func (p *Processor) ModuleExecute()

func (*Processor) ModuleStop

func (p *Processor) ModuleStop() (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