processor

Documentation

Index

• type Processor
• type ProcessorFunc
• type SimpleProcessor
  • func NewSimpleProcessor(ctx context.Context) SimpleProcessor
  • func (p *SimpleProcessor) AddTask(processorFunc ProcessorFunc)
  • func (p *SimpleProcessor) ProcessAll() error

Types

type Processor

type Processor interface {
	AddTask(ProcessorFunc)
	ProcessAll() error
}

type ProcessorFunc

type ProcessorFunc func() error

type SimpleProcessor

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

func NewSimpleProcessor

func NewSimpleProcessor(ctx context.Context) SimpleProcessor

func (*SimpleProcessor) AddTask

func (p *SimpleProcessor) AddTask(processorFunc ProcessorFunc)

func (*SimpleProcessor) ProcessAll

func (p *SimpleProcessor) ProcessAll() error