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 manage polling of associations, dispatching association to processor

Index

• type Processor
  • func NewAssociationProcessor(context context.T, instanceID string) *Processor
  • func (p *Processor) ExecuteInProgressDocument(docState *stateModel.DocumentState, cancelFlag task.CancelFlag)
  • func (p *Processor) ExecutePendingDocument(docState *stateModel.DocumentState)
  • func (p *Processor) InitializeAssociationProcessor()
  • func (p *Processor) ProcessAssociation()
  • func (p *Processor) SetPollJob(job *scheduler.Job)
  • func (p *Processor) ShutdownAndWait(timeout time.Duration)
  • func (p *Processor) Stop()
  • func (p *Processor) SubmitTask(log log.T, jobID string, job task.Job) error

Types

type Processor

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

Processor contains the logic for processing association

func NewAssociationProcessor

func NewAssociationProcessor(context context.T, instanceID string) *Processor

NewAssociationProcessor returns a new Processor with the given context.

func (*Processor) ExecuteInProgressDocument

func (p *Processor) ExecuteInProgressDocument(docState *stateModel.DocumentState, cancelFlag task.CancelFlag)

ExecuteInProgressDocument wraps ExecuteInProgressDocument from document executer

func (*Processor) ExecutePendingDocument

func (p *Processor) ExecutePendingDocument(docState *stateModel.DocumentState)

ExecutePendingDocument wraps ExecutePendingDocument from document executer

func (*Processor) InitializeAssociationProcessor

func (p *Processor) InitializeAssociationProcessor()

StartAssociationWorker starts worker to process scheduled association

func (*Processor) ProcessAssociation

func (p *Processor) ProcessAssociation()

ProcessAssociation poll and process all the associations

func (*Processor) SetPollJob

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

SetPollJob represents setter for PollJob

func (*Processor) ShutdownAndWait

func (p *Processor) ShutdownAndWait(timeout time.Duration)

ShutdownAndWait wraps the ShutdownAndWait for task pool

func (*Processor) Stop

func (p *Processor) Stop()

Stop stops the association processor and stops the poll job

func (*Processor) SubmitTask

func (p *Processor) SubmitTask(log log.T, jobID string, job task.Job) error

SubmitTask wraps SubmitTask for taskpool