common

Documentation

Index

• type GenericProcessor
  • func NewGenericProcessor(name string, accountContext *model2.AccountContext, ...) *GenericProcessor
  • func (h *GenericProcessor) RequestStop()
  • func (h *GenericProcessor) Start() error
  • func (h *GenericProcessor) WaitStop()

Types

type GenericProcessor

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

func NewGenericProcessor

func NewGenericProcessor(name string, accountContext *model2.AccountContext, processingContext *processor.ProcessingContext, period time.Duration, accountIndex int, numberOfContexts int, run func(accountContext *model2.AccountContext, processingContext *processor.ProcessingContext, close *bool)) *GenericProcessor

func (*GenericProcessor) RequestStop

func (h *GenericProcessor) RequestStop()

func (*GenericProcessor) Start

func (h *GenericProcessor) Start() error

func (*GenericProcessor) WaitStop

func (h *GenericProcessor) WaitStop()