keeper

package
v0.6.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2021 License: Apache-2.0 Imports: 17 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.BinaryMarshaler, key sdk.StoreKey, params params.Subspace) Keeper

func (*Keeper) DeleteActiveSessionAt 

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

func (*Keeper) DeleteActiveSessionForAddress added in v0.5.0 

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

func (*Keeper) GetAccount added in v0.5.0 

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

func (*Keeper) GetActiveSessionForAddress added in v0.5.0 

func (k *Keeper) GetActiveSessionForAddress(ctx sdk.Context, address sdk.AccAddress, subscription uint64, node hubtypes.NodeAddress) (session types.Session, found bool)

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) GetChannel added in v0.5.0 

func (k *Keeper) GetChannel(ctx sdk.Context, address sdk.AccAddress, subscription uint64, node hubtypes.NodeAddress) uint64

func (*Keeper) GetCount added in v0.4.0 

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

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) (subscription.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) GetSessionsForAddress 

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

func (*Keeper) GetSessionsForNode 

func (k *Keeper) GetSessionsForNode(ctx sdk.Context, address hubtypes.NodeAddress, skip, limit int64) (items types.Sessions)

func (*Keeper) GetSessionsForSubscription 

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

func (*Keeper) GetSubscription 

func (k *Keeper) GetSubscription(ctx sdk.Context, id uint64) (subscription.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) HasSubscriptionForNode 

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

func (*Keeper) InactiveDuration 

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

func (*Keeper) IterateActiveSessionsAt added in v0.5.0 

func (k *Keeper) IterateActiveSessionsAt(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) ProofVerificationEnabled added in v0.5.0 

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

func (*Keeper) SendCoinsFromDepositToAccount added in v0.3.1 

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

func (*Keeper) SetActiveSessionAt 

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

func (*Keeper) SetActiveSessionForAddress added in v0.5.0 

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

func (*Keeper) SetChannel added in v0.5.0 

func (k *Keeper) SetChannel(ctx sdk.Context, address sdk.AccAddress, subscription uint64, node hubtypes.NodeAddress, channel uint64)

func (*Keeper) SetCount added in v0.4.0 

func (k *Keeper) SetCount(ctx sdk.Context, count 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 subscription.Quota)

func (*Keeper) SetSession 

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

func (*Keeper) SetSessionForAddress 

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

func (*Keeper) SetSessionForNode 

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

func (*Keeper) SetSessionForSubscription 

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

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) WithDepositKeeper added in v0.3.1 

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

func (*Keeper) WithPlanKeeper 

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

func (*Keeper) WithSubscriptionKeeper 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.