processor

Documentation

Index

• Constants
• func GetProcesses() map[string]IProcessor
• func StartAllProcessors(stopCh <-chan struct{})
• type IProcessor
• type Processor
  • func NewProcessor(name string, processorObj interface{}, handlerType handler.Type, ...) *Processor
  • func (p *Processor) List() ([]interface{}, error)
  • func (p *Processor) Process(opType string, obj interface{})
  • func (p *Processor) ProcessObject() interface{}
  • func (p *Processor) ProcessType() string
  • func (p *Processor) Run(stopCh <-chan struct{})

Constants

const (

	// LongestDurationForProcess defines the timeout interval for asynchronous event processing
	LongestDurationForProcess = 20 * time.Minute
)

const (
	// WorkersPerProcessor indicates the number of asynchronous threads for each type of event processing
	WorkersPerProcessor = 5
)

Functions

func GetProcesses

func GetProcesses() map[string]IProcessor

GetProcesses returns the type of process

func StartAllProcessors

func StartAllProcessors(stopCh <-chan struct{})

StartAllProcessors start all register process

Types

type IProcessor

type IProcessor interface {
	List() ([]interface{}, error)
	Process(opType string, obj interface{})
	Run(stopCh <-chan struct{})
	ProcessType() string
	ProcessObject() interface{}
}

IProcessor is asynchronous thread interface

type Processor

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

Processor the struct of process attribute

func NewProcessor

func NewProcessor(name string, processorObj interface{}, handlerType handler.Type, resourceType resource.Type,
	workerCounts int, actionSets sets.String) *Processor

NewProcessor return the entity object of process

func (*Processor) List

func (p *Processor) List() ([]interface{}, error)

List implements watcher.Processor interface

func (*Processor) Process

func (p *Processor) Process(opType string, obj interface{})

Process implements watcher.Processor interface

func (*Processor) ProcessObject

func (p *Processor) ProcessObject() interface{}

ProcessObject return the object of process

func (*Processor) ProcessType

func (p *Processor) ProcessType() string

ProcessType return the process name

func (*Processor) Run

func (p *Processor) Run(stopCh <-chan struct{})

Run start to run process