volumerebate

Aug 29, 2024

Changes in this version

type Engine

+ func (e *Engine) OnMarketFeeFactorsBuyBackFeeUpdate(ctx context.Context, d num.Decimal) error

+ func (e *Engine) OnMarketFeeFactorsTreasuryFeeUpdate(ctx context.Context, d num.Decimal) error

Aug 14, 2024

Changes in this version

+ const MaximumWindowLength

+ type Broker interface

+ Send func(events.Event)

+ type Engine struct

+ func New(broker Broker, marketActivityTracker MarketActivityTracker) *Engine

+ func (e *Engine) HasProgramEnded() bool

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

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

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

+ func (e *Engine) UpdateProgram(newProgram *types.VolumeRebateProgram)

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

+ type MarketActivityTracker interface

+ CalculateTotalMakerContributionInQuantum func(windowSize int) (map[string]*num.Uint, map[string]num.Decimal)

+ type SnapshottedEngine struct

+ 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