keeper

func (Keeper) ExpireOldStats ¶

func (k Keeper) ExpireOldStats(ctx sdk.Context)

ExpireOldStats expiration of stats when they fall out of the window. TrailingEpoch is next epoch that can potentially fall out of the window. Attempt to expire the next epoch. TrailingEpoch will be advanced at most once.

func (Keeper) GetBlockStats ¶

func (k Keeper) GetBlockStats(ctx sdk.Context) *types.BlockStats

func (Keeper) GetEpochStatsOrNil ¶

func (k Keeper) GetEpochStatsOrNil(ctx sdk.Context, epoch uint32) *types.EpochStats

GetEpochStatsOrNil returns the EpochStats for an epoch. This function returns nil if epoch stats aren't found.

func (Keeper) GetGlobalStats ¶

func (k Keeper) GetGlobalStats(ctx sdk.Context) *types.GlobalStats

func (Keeper) GetParams ¶

func (k Keeper) GetParams(
	ctx sdk.Context,
) (
	params types.Params,
)

GetParams returns the Params in state.

func (Keeper) GetStatsMetadata ¶

func (k Keeper) GetStatsMetadata(ctx sdk.Context) *types.StatsMetadata

func (Keeper) GetUserStats ¶

func (k Keeper) GetUserStats(ctx sdk.Context, address string) *types.UserStats

func (Keeper) GetWindowDuration ¶

func (k Keeper) GetWindowDuration(ctx sdk.Context) time.Duration

func (Keeper) GlobalStats ¶

func (k Keeper) GlobalStats(
	c context.Context,
	req *types.QueryGlobalStatsRequest,
) (
	*types.QueryGlobalStatsResponse,
	error,
)

func (Keeper) HasAuthority ¶

func (k Keeper) HasAuthority(authority string) bool

func (Keeper) InitializeForGenesis ¶

func (k Keeper) InitializeForGenesis(ctx sdk.Context)

func (Keeper) Logger ¶

func (k Keeper) Logger(ctx sdk.Context) log.Logger

func (Keeper) Params ¶

func (k Keeper) Params(
	c context.Context,
	req *types.QueryParamsRequest,
) (
	*types.QueryParamsResponse,
	error,
)

Params processes a query request/response for the Params from state.

func (Keeper) ProcessBlockStats ¶

func (k Keeper) ProcessBlockStats(ctx sdk.Context)

ProcessBlockStats persists the info from this block's BlockStats this epoch's stats. It also appropriately increments the overall stats globally and for each user

func (Keeper) RecordFill ¶

func (k Keeper) RecordFill(ctx sdk.Context, takerAddress string, makerAddress string, notional *big.Int)

Record a match in BlockStats, which is stored in the transient store

func (Keeper) SetBlockStats ¶

func (k Keeper) SetBlockStats(ctx sdk.Context, blockStats *types.BlockStats)

func (Keeper) SetEpochStats ¶

func (k Keeper) SetEpochStats(ctx sdk.Context, epoch uint32, epochStats *types.EpochStats)

func (Keeper) SetGlobalStats ¶

func (k Keeper) SetGlobalStats(ctx sdk.Context, globalStats *types.GlobalStats)

func (Keeper) SetParams ¶

func (k Keeper) SetParams(
	ctx sdk.Context,
	params types.Params,
) error

SetParams updates the Params in state. Returns an error iff validation fails.

func (Keeper) SetStatsMetadata ¶

func (k Keeper) SetStatsMetadata(ctx sdk.Context, metadata *types.StatsMetadata)

func (Keeper) SetUserStats ¶

func (k Keeper) SetUserStats(ctx sdk.Context, address string, userStats *types.UserStats)

func (Keeper) StatsMetadata ¶

func (k Keeper) StatsMetadata(
	c context.Context,
	req *types.QueryStatsMetadataRequest,
) (
	*types.QueryStatsMetadataResponse,
	error,
)

func (Keeper) UserStats ¶

func (k Keeper) UserStats(
	c context.Context,
	req *types.QueryUserStatsRequest,
) (
	*types.QueryUserStatsResponse,
	error,
)