Versions in this module Expand all Collapse all v0 v0.1.0 Feb 28, 2019 Changes in this version + var ErrInvalidPrevHash = errors.New("processor: invalid transfer prev hash") + var ErrInvalidSettingsID = errors.New("processor: invalid settings id") + var ErrInvalidSettingsPrevHash = errors.New("settings processor: invalid prev hash") + var ErrInvalidSign = errors.New("processor: invalid sign") + var ErrNegativeAmount = errors.New("processor: invalid receiver amount") + var ErrNoBalance = errors.New("processor: no balance") + var ErrNoReceivers = errors.New("processor: empty batch. no receivers") + type Multiprocessor struct + func NewMultiprocessor(chain pt.Chain, n int) *Multiprocessor + func (p *Multiprocessor) GetBalance(ctx context.Context, acc pt.AccID) (int64, error) + func (p *Multiprocessor) GetPrevHash(ctx context.Context, acc pt.AccID) (pt.Hash, error) + func (p *Multiprocessor) ProcessTransfer(ctx context.Context, t pt.Transfer) (pt.TransferResult, error) + func (p *Multiprocessor) SetPreloader(preloader pt.Preloader) + func (p *Multiprocessor) SetPusher(pusher pt.Pusher) + func (p *Multiprocessor) SetSettingsChain(sc pt.SettingsChain) + type Processor struct + func NewProcessor(chain pt.Chain) *Processor + func (p *Processor) GetBalance(ctx context.Context, acc pt.AccID) (int64, error) + func (p *Processor) GetPrevHash(ctx context.Context, acc pt.AccID) (pt.Hash, error) + func (p *Processor) ProcessTransfer(ctx context.Context, t pt.Transfer) (pt.TransferResult, error) + func (p *Processor) SetPreloader(pl pt.Preloader) + func (p *Processor) SetPusher(pusher pt.Pusher) + func (p *Processor) SetSettingsChain(c pt.SettingsChain) + type SettingsMultiprocessor struct + func NewSettingsMultiprocessor(chain pt.SettingsChain, n int) *SettingsMultiprocessor + func (p *SettingsMultiprocessor) GetLastSettings(ctx context.Context, acc pt.AccID) (*pt.Settings, error) + func (p *SettingsMultiprocessor) ProcessSettings(ctx context.Context, s *pt.Settings) (pt.SettingsResult, error) + type SettingsProcessor struct + func NewSettingsProcessor(chain pt.SettingsChain) *SettingsProcessor + func (p *SettingsProcessor) GetLastSettings(ctx context.Context, acc pt.AccID) (*pt.Settings, error) + func (p *SettingsProcessor) ProcessSettings(ctx context.Context, s *pt.Settings) (pt.SettingsResult, error) + func (p *SettingsProcessor) SetPreloader(pl pt.Preloader) + func (p *SettingsProcessor) SetPusher(pusher pt.SettingsPusher)