processor

Documentation

Index

• Constants
• func CheckDuplication(opr *OperationProcessor, op base.Operation) error
• func DuplicationKey(key string, duplType types.DuplicationType) string
• func GetNewProcessor(opr *OperationProcessor, op base.Operation) (base.OperationProcessor, bool, error)
• type BaseOperationProcessor
• type GetLastBlockFunc
• type OperationProcessor
  • func NewOperationProcessor() *OperationProcessor
  • func (opr *OperationProcessor) Cancel() error
  • func (opr *OperationProcessor) CheckNewAddressDuplication(as []base.Address) error
  • func (opr *OperationProcessor) Close() error
  • func (opr *OperationProcessor) GetNewProcessorFromHintset(op base.Operation) (base.OperationProcessor, error)
  • func (opr *OperationProcessor) New(height base.Height, getStateFunc base.GetStateFunc, ...) (*OperationProcessor, error)
  • func (opr *OperationProcessor) PreProcess(ctx context.Context, op base.Operation, getStateFunc base.GetStateFunc) (context.Context, base.OperationProcessReasonError, error)
  • func (opr *OperationProcessor) Process(ctx context.Context, op base.Operation, getStateFunc base.GetStateFunc) ([]base.StateMergeValue, base.OperationProcessReasonError, error)
  • func (opr *OperationProcessor) SetCheckDuplicationFunc(f func(*OperationProcessor, base.Operation) error) error
  • func (opr *OperationProcessor) SetGetNewProcessorFunc(...) error
  • func (opr *OperationProcessor) SetProcessor(hint hint.Hint, newProcessor types.GetNewProcessor) error

Constants

const (
	DuplicationTypeSender   types.DuplicationType = "sender"
	DuplicationTypeCurrency types.DuplicationType = "currency"
	DuplicationTypeContract types.DuplicationType = "contract"
)

Functions

func CheckDuplication

func CheckDuplication(opr *OperationProcessor, op base.Operation) error

func DuplicationKey

func DuplicationKey(key string, duplType types.DuplicationType) string

func GetNewProcessor

func GetNewProcessor(opr *OperationProcessor, op base.Operation) (base.OperationProcessor, bool, error)

Types

type BaseOperationProcessor

type BaseOperationProcessor interface {
	PreProcess(base.Operation, base.GetStateFunc) (base.OperationProcessReasonError, error)
	Process(base.Operation, base.GetStateFunc) ([]base.StateMergeValue, base.OperationProcessReasonError, error)
	Close() error
}

type GetLastBlockFunc

type GetLastBlockFunc func() (base.BlockMap, bool, error)

type OperationProcessor

type OperationProcessor struct {
	// id string
	sync.RWMutex
	*logging.Logging
	*base.BaseOperationProcessor

	Duplicated map[string]struct{}

	GetStateFunc         base.GetStateFunc
	CollectFee           func(*OperationProcessor, types.AddFee) error
	CheckDuplicationFunc func(*OperationProcessor, base.Operation) error
	GetNewProcessorFunc  func(*OperationProcessor, base.Operation) (base.OperationProcessor, bool, error)
	// contains filtered or unexported fields
}

func NewOperationProcessor

func NewOperationProcessor() *OperationProcessor

func (*OperationProcessor) Cancel

func (opr *OperationProcessor) Cancel() error

func (*OperationProcessor) CheckNewAddressDuplication

func (opr *OperationProcessor) CheckNewAddressDuplication(as []base.Address) error

func (*OperationProcessor) Close

func (opr *OperationProcessor) Close() error

func (*OperationProcessor) GetNewProcessorFromHintset

func (opr *OperationProcessor) GetNewProcessorFromHintset(op base.Operation) (base.OperationProcessor, error)

func (*OperationProcessor) New

func (opr *OperationProcessor) New(
	height base.Height,
	getStateFunc base.GetStateFunc,
	newPreProcessConstraintFunc base.NewOperationProcessorProcessFunc,
	newProcessConstraintFunc base.NewOperationProcessorProcessFunc) (*OperationProcessor, error)

func (*OperationProcessor) PreProcess

func (opr *OperationProcessor) PreProcess(ctx context.Context, op base.Operation, getStateFunc base.GetStateFunc) (context.Context, base.OperationProcessReasonError, error)

func (*OperationProcessor) Process

func (opr *OperationProcessor) Process(ctx context.Context, op base.Operation, getStateFunc base.GetStateFunc) ([]base.StateMergeValue, base.OperationProcessReasonError, error)

func (*OperationProcessor) SetCheckDuplicationFunc

func (opr *OperationProcessor) SetCheckDuplicationFunc(
	f func(*OperationProcessor, base.Operation) error,
) error

func (*OperationProcessor) SetGetNewProcessorFunc

func (opr *OperationProcessor) SetGetNewProcessorFunc(
	f func(*OperationProcessor, base.Operation) (base.OperationProcessor, bool, error),
) error

func (*OperationProcessor) SetProcessor

func (opr *OperationProcessor) SetProcessor(
	hint hint.Hint,
	newProcessor types.GetNewProcessor,
) error