keeper

package
v0.10.0-rc0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 9, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMsgServiceServer added in v0.6.0

func NewMsgServiceServer(keeper Keeper) types.MsgServiceServer

func NewQueryServiceServer added in v0.6.0

func NewQueryServiceServer(keeper Keeper) types.QueryServiceServer

Types

type Keeper

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

func NewKeeper

func NewKeeper(cdc codec.BinaryCodec, key sdk.StoreKey, params paramstypes.Subspace, feeCollectorName string) Keeper

func (*Keeper) DeleteActiveSessionForAddress added in v0.5.0

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

func (*Keeper) DeleteInactiveSessionAt added in v0.7.0

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

func (*Keeper) DeleteInactiveSessionForAddress added in v0.6.1

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

func (*Keeper) DeleteSession added in v0.9.0

func (k *Keeper) DeleteSession(ctx sdk.Context, id uint64)

func (*Keeper) GetAccount added in v0.5.0

func (k *Keeper) GetAccount(ctx sdk.Context, address sdk.AccAddress) authtypes.AccountI

func (*Keeper) GetActiveSessionsForAddress added in v0.5.0

func (k *Keeper) GetActiveSessionsForAddress(ctx sdk.Context, address sdk.AccAddress, skip, limit int64) (items types.Sessions)

func (*Keeper) GetActiveSubscriptionsForAddress added in v0.8.0

func (k *Keeper) GetActiveSubscriptionsForAddress(ctx sdk.Context, address sdk.AccAddress, skip, limit int64) subscriptiontypes.Subscriptions

func (*Keeper) GetCount added in v0.4.0

func (k *Keeper) GetCount(ctx sdk.Context) uint64

func (*Keeper) GetInactiveSessionsForAddress added in v0.6.1

func (k *Keeper) GetInactiveSessionsForAddress(ctx sdk.Context, address sdk.AccAddress, skip, limit int64) (items types.Sessions)

func (*Keeper) GetNode added in v0.6.1

func (k *Keeper) GetNode(ctx sdk.Context, address hubtypes.NodeAddress) (nodetypes.Node, bool)

func (*Keeper) GetParams

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

func (*Keeper) GetQuota

func (k *Keeper) GetQuota(ctx sdk.Context, id uint64, address sdk.AccAddress) (subscriptiontypes.Quota, bool)

func (*Keeper) GetSession

func (k *Keeper) GetSession(ctx sdk.Context, id uint64) (session types.Session, found bool)

func (*Keeper) GetSessions

func (k *Keeper) GetSessions(ctx sdk.Context, skip, limit int64) (items types.Sessions)

func (*Keeper) GetSubscription

func (k *Keeper) GetSubscription(ctx sdk.Context, id uint64) (subscriptiontypes.Subscription, bool)

func (*Keeper) HasNodeForPlan

func (k *Keeper) HasNodeForPlan(ctx sdk.Context, id uint64, address hubtypes.NodeAddress) bool

func (*Keeper) HasQuota added in v0.3.2

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

func (*Keeper) InactiveDuration

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

func (*Keeper) IterateInactiveSessionsAt added in v0.7.0

func (k *Keeper) IterateInactiveSessionsAt(ctx sdk.Context, end time.Time, fn func(index int, item types.Session) (stop bool))

func (*Keeper) IterateSessions

func (k *Keeper) IterateSessions(ctx sdk.Context, fn func(index int, item types.Session) (stop bool))

func (*Keeper) Logger

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

func (*Keeper) ProcessPaymentAndUpdateQuota added in v0.6.1

func (k *Keeper) ProcessPaymentAndUpdateQuota(ctx sdk.Context, session types.Session) error

func (*Keeper) ProofVerificationEnabled added in v0.5.0

func (k *Keeper) ProofVerificationEnabled(ctx sdk.Context) (yes bool)

func (*Keeper) SendCoinFromDepositToAccount added in v0.8.0

func (k *Keeper) SendCoinFromDepositToAccount(ctx sdk.Context, from, to sdk.AccAddress, coin sdk.Coin) error

func (*Keeper) SendCoinFromDepositToModule added in v0.10.0

func (k *Keeper) SendCoinFromDepositToModule(ctx sdk.Context, from sdk.AccAddress, to string, coin sdk.Coin) error

func (*Keeper) SetActiveSessionForAddress added in v0.5.0

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

func (*Keeper) SetCount added in v0.4.0

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

func (*Keeper) SetInactiveSessionAt added in v0.7.0

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

func (*Keeper) SetInactiveSessionForAddress added in v0.6.1

func (k *Keeper) SetInactiveSessionForAddress(ctx sdk.Context, address sdk.AccAddress, 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 subscriptiontypes.Quota)

func (*Keeper) SetSession

func (k *Keeper) SetSession(ctx sdk.Context, session types.Session)

func (*Keeper) Store

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

func (*Keeper) VerifyProof added in v0.5.0

func (k *Keeper) VerifyProof(ctx sdk.Context, address sdk.AccAddress, proof types.Proof, signature []byte) error

func (*Keeper) WithAccountKeeper added in v0.5.0

func (k *Keeper) WithAccountKeeper(keeper expected.AccountKeeper)

func (*Keeper) WithBankKeeper added in v0.10.0

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

func (*Keeper) WithDepositKeeper added in v0.3.1

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

func (*Keeper) WithNodeKeeper added in v0.6.1

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

func (*Keeper) WithPlanKeeper

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

func (*Keeper) WithSubscriptionKeeper

func (k *Keeper) WithSubscriptionKeeper(keeper expected.SubscriptionKeeper)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL