keeper

Documentation

Index

• type Keeper
  • func NewKeeper(cdc *codec.Codec, key sdk.StoreKey, params params.Subspace) Keeper
  • func (k Keeper) AddDeposit(ctx sdk.Context, address sdk.AccAddress, coin sdk.Coin) sdk.Error
  • func (k Keeper) CancelDuration(ctx sdk.Context) (duration time.Duration)
  • func (k Keeper) DeleteCancelSubscriptionAt(ctx sdk.Context, at time.Time, id uint64)
  • func (k Keeper) DeleteQuota(ctx sdk.Context, id uint64, address sdk.AccAddress)
  • func (k Keeper) DeleteSubscriptionForAddress(ctx sdk.Context, address sdk.AccAddress, id uint64)
  • func (k Keeper) GetNode(ctx sdk.Context, address hub.NodeAddress) (node.Node, bool)
  • func (k Keeper) GetParams(ctx sdk.Context) types.Params
  • func (k Keeper) GetPlan(ctx sdk.Context, id uint64) (plan.Plan, bool)
  • func (k Keeper) GetQuota(ctx sdk.Context, id uint64, address sdk.AccAddress) (quota types.Quota, found bool)
  • func (k Keeper) GetQuotas(ctx sdk.Context, id uint64) (items types.Quotas)
  • func (k Keeper) GetSubscription(ctx sdk.Context, id uint64) (subscription types.Subscription, found bool)
  • func (k Keeper) GetSubscriptions(ctx sdk.Context) (items types.Subscriptions)
  • func (k Keeper) GetSubscriptionsCount(ctx sdk.Context) (count uint64)
  • func (k Keeper) GetSubscriptionsForAddress(ctx sdk.Context, address sdk.AccAddress) (items types.Subscriptions)
  • func (k Keeper) GetSubscriptionsForNode(ctx sdk.Context, address hub.NodeAddress) (items types.Subscriptions)
  • func (k Keeper) GetSubscriptionsForPlan(ctx sdk.Context, plan uint64) (items types.Subscriptions)
  • func (k Keeper) HasQuota(ctx sdk.Context, id uint64, address sdk.AccAddress) bool
  • func (k Keeper) HasSubscriptionForAddress(ctx sdk.Context, address sdk.AccAddress, id uint64) bool
  • func (k Keeper) HasSubscriptionForNode(ctx sdk.Context, address hub.NodeAddress, id uint64) bool
  • func (k Keeper) HasSubscriptionForPlan(ctx sdk.Context, plan, id uint64) bool
  • func (k Keeper) IterateCancelSubscriptions(ctx sdk.Context, end time.Time, ...)
  • func (k Keeper) IterateQuotas(ctx sdk.Context, id uint64, f func(index int, item types.Quota) (stop bool))
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) SendCoin(ctx sdk.Context, from sdk.AccAddress, to sdk.AccAddress, coin sdk.Coin) sdk.Error
  • func (k Keeper) SetCancelSubscriptionAt(ctx sdk.Context, at time.Time, id uint64)
  • func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
  • func (k Keeper) SetQuota(ctx sdk.Context, id uint64, quota types.Quota)
  • func (k Keeper) SetSubscription(ctx sdk.Context, subscription types.Subscription)
  • func (k Keeper) SetSubscriptionForAddress(ctx sdk.Context, address sdk.AccAddress, id uint64)
  • func (k Keeper) SetSubscriptionForNode(ctx sdk.Context, address hub.NodeAddress, id uint64)
  • func (k Keeper) SetSubscriptionForPlan(ctx sdk.Context, plan, id uint64)
  • func (k Keeper) SetSubscriptionsCount(ctx sdk.Context, count uint64)
  • func (k Keeper) Store(ctx sdk.Context) sdk.KVStore
  • func (k Keeper) SubtractDeposit(ctx sdk.Context, address sdk.AccAddress, coin sdk.Coin) sdk.Error
  • func (k *Keeper) WithBankKeeper(keeper expected.BankKeeper)
  • func (k *Keeper) WithDepositKeeper(keeper expected.DepositKeeper)
  • func (k *Keeper) WithNodeKeeper(keeper expected.NodeKeeper)
  • func (k *Keeper) WithPlanKeeper(keeper expected.PlanKeeper)

Types

type Keeper

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

func NewKeeper

func NewKeeper(cdc *codec.Codec, key sdk.StoreKey, params params.Subspace) Keeper

func (Keeper) AddDeposit

func (k Keeper) AddDeposit(ctx sdk.Context, address sdk.AccAddress, coin sdk.Coin) sdk.Error

func (Keeper) CancelDuration

func (k Keeper) CancelDuration(ctx sdk.Context) (duration time.Duration)

func (Keeper) DeleteCancelSubscriptionAt

func (k Keeper) DeleteCancelSubscriptionAt(ctx sdk.Context, at time.Time, id uint64)

func (Keeper) DeleteQuota

func (k Keeper) DeleteQuota(ctx sdk.Context, id uint64, address sdk.AccAddress)

func (Keeper) DeleteSubscriptionForAddress

func (k Keeper) DeleteSubscriptionForAddress(ctx sdk.Context, address sdk.AccAddress, id uint64)

func (Keeper) GetNode

func (k Keeper) GetNode(ctx sdk.Context, address hub.NodeAddress) (node.Node, bool)

func (Keeper) GetParams

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

func (Keeper) GetPlan

func (k Keeper) GetPlan(ctx sdk.Context, id uint64) (plan.Plan, bool)

func (Keeper) GetQuota

func (k Keeper) GetQuota(ctx sdk.Context, id uint64, address sdk.AccAddress) (quota types.Quota, found bool)

func (Keeper) GetQuotas

func (k Keeper) GetQuotas(ctx sdk.Context, id uint64) (items types.Quotas)

func (Keeper) GetSubscription

func (k Keeper) GetSubscription(ctx sdk.Context, id uint64) (subscription types.Subscription, found bool)

func (Keeper) GetSubscriptions

func (k Keeper) GetSubscriptions(ctx sdk.Context) (items types.Subscriptions)

func (Keeper) GetSubscriptionsCount

func (k Keeper) GetSubscriptionsCount(ctx sdk.Context) (count uint64)

func (Keeper) GetSubscriptionsForAddress

func (k Keeper) GetSubscriptionsForAddress(ctx sdk.Context, address sdk.AccAddress) (items types.Subscriptions)

func (Keeper) GetSubscriptionsForNode

func (k Keeper) GetSubscriptionsForNode(ctx sdk.Context, address hub.NodeAddress) (items types.Subscriptions)

func (Keeper) GetSubscriptionsForPlan

func (k Keeper) GetSubscriptionsForPlan(ctx sdk.Context, plan uint64) (items types.Subscriptions)

func (Keeper) HasQuota

func (k Keeper) HasQuota(ctx sdk.Context, id uint64, address sdk.AccAddress) bool

func (Keeper) HasSubscriptionForAddress

func (k Keeper) HasSubscriptionForAddress(ctx sdk.Context, address sdk.AccAddress, id uint64) bool

func (Keeper) HasSubscriptionForNode

func (k Keeper) HasSubscriptionForNode(ctx sdk.Context, address hub.NodeAddress, id uint64) bool

func (Keeper) HasSubscriptionForPlan

func (k Keeper) HasSubscriptionForPlan(ctx sdk.Context, plan, id uint64) bool

func (Keeper) IterateCancelSubscriptions

func (k Keeper) IterateCancelSubscriptions(ctx sdk.Context, end time.Time, f func(index int, item types.Subscription) (stop bool))

func (Keeper) IterateQuotas

func (k Keeper) IterateQuotas(ctx sdk.Context, id uint64, f func(index int, item types.Quota) (stop bool))

func (Keeper) Logger

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

func (Keeper) SendCoin

func (k Keeper) SendCoin(ctx sdk.Context, from sdk.AccAddress, to sdk.AccAddress, coin sdk.Coin) sdk.Error

func (Keeper) SetCancelSubscriptionAt

func (k Keeper) SetCancelSubscriptionAt(ctx sdk.Context, at time.Time, id uint64)

func (Keeper) SetParams

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

func (Keeper) SetQuota

func (k Keeper) SetQuota(ctx sdk.Context, id uint64, quota types.Quota)

func (Keeper) SetSubscription

func (k Keeper) SetSubscription(ctx sdk.Context, subscription types.Subscription)

func (Keeper) SetSubscriptionForAddress

func (k Keeper) SetSubscriptionForAddress(ctx sdk.Context, address sdk.AccAddress, id uint64)

func (Keeper) SetSubscriptionForNode

func (k Keeper) SetSubscriptionForNode(ctx sdk.Context, address hub.NodeAddress, id uint64)

func (Keeper) SetSubscriptionForPlan

func (k Keeper) SetSubscriptionForPlan(ctx sdk.Context, plan, id uint64)

func (Keeper) SetSubscriptionsCount

func (k Keeper) SetSubscriptionsCount(ctx sdk.Context, count uint64)

func (Keeper) Store

func (k Keeper) Store(ctx sdk.Context) sdk.KVStore

func (Keeper) SubtractDeposit

func (k Keeper) SubtractDeposit(ctx sdk.Context, address sdk.AccAddress, coin sdk.Coin) sdk.Error

func (*Keeper) WithBankKeeper

func (k *Keeper) WithBankKeeper(keeper expected.BankKeeper)

func (*Keeper) WithDepositKeeper

func (k *Keeper) WithDepositKeeper(keeper expected.DepositKeeper)

func (*Keeper) WithNodeKeeper

func (k *Keeper) WithNodeKeeper(keeper expected.NodeKeeper)

func (*Keeper) WithPlanKeeper

func (k *Keeper) WithPlanKeeper(keeper expected.PlanKeeper)