processor

Documentation

Index

• Variables
• type Multiprocessor
  • 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
  • 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
  • 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
  • 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)

Variables

var (
	ErrInvalidPrevHash   = errors.New("processor: invalid transfer prev hash")
	ErrNoReceivers       = errors.New("processor: empty batch. no receivers")
	ErrNegativeAmount    = errors.New("processor: invalid receiver amount")
	ErrNoBalance         = errors.New("processor: no balance")
	ErrInvalidSettingsID = errors.New("processor: invalid settings id")
	ErrInvalidSign       = errors.New("processor: invalid sign")

	ErrInvalidSettingsPrevHash = errors.New("settings processor: invalid prev hash")
)

Types

type Multiprocessor

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

Multiprocessor allows to use many processors in parallel safe.

func NewMultiprocessor

func NewMultiprocessor(chain pt.Chain, n int) *Multiprocessor

NewMultiprocessor creates n parallel Processors on top of chain

func (*Multiprocessor) GetBalance

func (p *Multiprocessor) GetBalance(ctx context.Context, acc pt.AccID) (int64, error)

func (*Multiprocessor) GetPrevHash

func (p *Multiprocessor) GetPrevHash(ctx context.Context, acc pt.AccID) (pt.Hash, error)

func (*Multiprocessor) ProcessTransfer

func (p *Multiprocessor) ProcessTransfer(ctx context.Context, t pt.Transfer) (pt.TransferResult, error)

func (*Multiprocessor) SetPreloader

func (p *Multiprocessor) SetPreloader(preloader pt.Preloader)

func (*Multiprocessor) SetPusher

func (p *Multiprocessor) SetPusher(pusher pt.Pusher)

func (*Multiprocessor) SetSettingsChain

func (p *Multiprocessor) SetSettingsChain(sc pt.SettingsChain)

type Processor

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

Processor is an transaction processor. It checks if request is correct, creates new transactions, pushes them to Pusher.

func NewProcessor

func NewProcessor(chain pt.Chain) *Processor

func (*Processor) GetBalance

func (p *Processor) GetBalance(ctx context.Context, acc pt.AccID) (int64, error)

func (*Processor) GetPrevHash

func (p *Processor) GetPrevHash(ctx context.Context, acc pt.AccID) (pt.Hash, error)

func (*Processor) ProcessTransfer

func (p *Processor) ProcessTransfer(ctx context.Context, t pt.Transfer) (pt.TransferResult, error)

func (*Processor) SetPreloader

func (p *Processor) SetPreloader(pl pt.Preloader)

func (*Processor) SetPusher

func (p *Processor) SetPusher(pusher pt.Pusher)

func (*Processor) SetSettingsChain

func (p *Processor) SetSettingsChain(c pt.SettingsChain)

type SettingsMultiprocessor

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

SettingsMultiprocessor allows to use many settings processors in parallel safe.

func NewSettingsMultiprocessor

func NewSettingsMultiprocessor(chain pt.SettingsChain, n int) *SettingsMultiprocessor

NewSettingsMultiprocessor creates n parallel SettingsProcessors on top of chain

func (*SettingsMultiprocessor) GetLastSettings

func (p *SettingsMultiprocessor) GetLastSettings(ctx context.Context, acc pt.AccID) (*pt.Settings, error)

func (*SettingsMultiprocessor) ProcessSettings

func (p *SettingsMultiprocessor) ProcessSettings(ctx context.Context, s *pt.Settings) (pt.SettingsResult, error)

type SettingsProcessor

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

SettingsProcessor is an accounts settings processor.

func NewSettingsProcessor

func NewSettingsProcessor(chain pt.SettingsChain) *SettingsProcessor

func (*SettingsProcessor) GetLastSettings

func (p *SettingsProcessor) GetLastSettings(ctx context.Context, acc pt.AccID) (*pt.Settings, error)

func (*SettingsProcessor) ProcessSettings

func (p *SettingsProcessor) ProcessSettings(ctx context.Context, s *pt.Settings) (pt.SettingsResult, error)

func (*SettingsProcessor) SetPreloader

func (p *SettingsProcessor) SetPreloader(pl pt.Preloader)

func (*SettingsProcessor) SetPusher

func (p *SettingsProcessor) SetPusher(pusher pt.SettingsPusher)