operation

Documentation

Index

• type DuplicationType
• type OperationProcessor
  • func NewOperationProcessor(cp *extensioncurrency.CurrencyPool) *OperationProcessor
  • func (opr *OperationProcessor) Cancel() error
  • func (opr *OperationProcessor) Close() error
  • func (opr *OperationProcessor) New(pool *storage.Statepool) prprocessor.OperationProcessor
  • func (opr *OperationProcessor) PreProcess(op state.Processor) (state.Processor, error)
  • func (opr *OperationProcessor) Process(op state.Processor) error
  • func (opr *OperationProcessor) SetProcessor(hinter hint.Hinter, newProcessor currency.GetNewProcessor) (prprocessor.OperationProcessor, error)

Types

type DuplicationType

type DuplicationType string

const (
	DuplicationTypeSender   DuplicationType = "sender"
	DuplicationTypeCurrency DuplicationType = "currency"
)

type OperationProcessor

type OperationProcessor struct {
	sync.RWMutex
	*logging.Logging
	// contains filtered or unexported fields
}

func NewOperationProcessor

func NewOperationProcessor(cp *extensioncurrency.CurrencyPool) *OperationProcessor

func (*OperationProcessor) Cancel

func (opr *OperationProcessor) Cancel() error

func (*OperationProcessor) Close

func (opr *OperationProcessor) Close() error

func (*OperationProcessor) New

func (opr *OperationProcessor) New(pool *storage.Statepool) prprocessor.OperationProcessor

func (*OperationProcessor) PreProcess

func (opr *OperationProcessor) PreProcess(op state.Processor) (state.Processor, error)

func (*OperationProcessor) Process

func (opr *OperationProcessor) Process(op state.Processor) error

func (*OperationProcessor) SetProcessor

func (opr *OperationProcessor) SetProcessor(
	hinter hint.Hinter,
	newProcessor currency.GetNewProcessor,
) (prprocessor.OperationProcessor, error)