volumediscount

Documentation

Index

• Constants
• type Broker
• type Engine
  • func New(broker Broker, marketActivityTracker MarketActivityTracker) *Engine
  • func (e *Engine) HasProgramEnded() bool
  • func (e *Engine) OnEpoch(ctx context.Context, ep types.Epoch)
  • func (e *Engine) OnEpochRestore(_ context.Context, ep types.Epoch)
  • func (e *Engine) TakerNotionalForParty(party types.PartyID) num.Decimal
  • func (e *Engine) UpdateProgram(newProgram *types.VolumeDiscountProgram)
  • func (e *Engine) VolumeDiscountFactorForParty(party types.PartyID) num.Decimal
• type MarketActivityTracker
• type SnapshottedEngine
  • func NewSnapshottedEngine(broker Broker, mat MarketActivityTracker) *SnapshottedEngine
  • func (e *SnapshottedEngine) GetState(k string) ([]byte, []types.StateProvider, error)
  • func (e *SnapshottedEngine) Keys() []string
  • func (e *SnapshottedEngine) LoadState(_ context.Context, p *types.Payload) ([]types.StateProvider, error)
  • func (e *SnapshottedEngine) Namespace() types.SnapshotNamespace
  • func (e *SnapshottedEngine) Stopped() bool

Constants

const MaximumWindowLength uint64 = 100

Types

type Broker

type Broker interface {
	Send(events.Event)
}

type Engine

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

func New

func New(broker Broker, marketActivityTracker MarketActivityTracker) *Engine

func (*Engine) HasProgramEnded

func (e *Engine) HasProgramEnded() bool

func (*Engine) OnEpoch

func (e *Engine) OnEpoch(ctx context.Context, ep types.Epoch)

func (*Engine) OnEpochRestore

func (e *Engine) OnEpochRestore(_ context.Context, ep types.Epoch)

func (*Engine) TakerNotionalForParty

func (e *Engine) TakerNotionalForParty(party types.PartyID) num.Decimal

func (*Engine) UpdateProgram

func (e *Engine) UpdateProgram(newProgram *types.VolumeDiscountProgram)

func (*Engine) VolumeDiscountFactorForParty

func (e *Engine) VolumeDiscountFactorForParty(party types.PartyID) num.Decimal

type MarketActivityTracker

type MarketActivityTracker interface {
	NotionalTakerVolumeForAllParties() map[types.PartyID]*num.Uint
}

type SnapshottedEngine

type SnapshottedEngine struct {
	*Engine
	// contains filtered or unexported fields
}

func NewSnapshottedEngine

func NewSnapshottedEngine(broker Broker, mat MarketActivityTracker) *SnapshottedEngine

func (*SnapshottedEngine) GetState

func (e *SnapshottedEngine) GetState(k string) ([]byte, []types.StateProvider, error)

func (*SnapshottedEngine) Keys

func (e *SnapshottedEngine) Keys() []string

func (*SnapshottedEngine) LoadState

func (e *SnapshottedEngine) LoadState(_ context.Context, p *types.Payload) ([]types.StateProvider, error)

func (*SnapshottedEngine) Namespace

func (e *SnapshottedEngine) Namespace() types.SnapshotNamespace

func (*SnapshottedEngine) Stopped

func (e *SnapshottedEngine) Stopped() bool