Documentation ¶
Index ¶
- func NewMsgServiceServer(k Keeper) types.MsgServiceServer
- func NewQueryServiceServer(k Keeper) types.QueryServiceServer
- type Keeper
- func (k *Keeper) ActiveDuration(ctx sdk.Context) (v time.Duration)
- func (k *Keeper) CreateSubscriptionForNode(ctx sdk.Context, accAddr sdk.AccAddress, nodeAddr hubtypes.NodeAddress, ...) (*subscriptiontypes.NodeSubscription, error)
- func (k *Keeper) DeleteActiveNode(ctx sdk.Context, addr hubtypes.NodeAddress)
- func (k *Keeper) DeleteInactiveNode(ctx sdk.Context, addr hubtypes.NodeAddress)
- func (k *Keeper) DeleteNodeForInactiveAt(ctx sdk.Context, at time.Time, addr hubtypes.NodeAddress)
- func (k *Keeper) DeleteNodeForPlan(ctx sdk.Context, id uint64, addr hubtypes.NodeAddress)
- func (k *Keeper) Deposit(ctx sdk.Context) (v sdk.Coin)
- func (k *Keeper) EndBlock(ctx sdk.Context) []abcitypes.ValidatorUpdate
- func (k *Keeper) FundCommunityPool(ctx sdk.Context, fromAddr sdk.AccAddress, coin sdk.Coin) error
- func (k *Keeper) GetActiveNode(ctx sdk.Context, addr hubtypes.NodeAddress) (v types.Node, found bool)
- func (k *Keeper) GetInactiveNode(ctx sdk.Context, addr hubtypes.NodeAddress) (v types.Node, found bool)
- func (k *Keeper) GetNode(ctx sdk.Context, addr hubtypes.NodeAddress) (node types.Node, found bool)
- func (k *Keeper) GetNodes(ctx sdk.Context) (items types.Nodes)
- func (k *Keeper) GetNodesForPlan(ctx sdk.Context, id uint64) (items types.Nodes)
- func (k *Keeper) GetParams(ctx sdk.Context) types.Params
- func (k *Keeper) HasActiveNode(ctx sdk.Context, addr hubtypes.NodeAddress) bool
- func (k *Keeper) HasInactiveNode(ctx sdk.Context, addr hubtypes.NodeAddress) bool
- func (k *Keeper) HasNode(ctx sdk.Context, addr hubtypes.NodeAddress) bool
- func (k *Keeper) HasNodeForPlan(ctx sdk.Context, id uint64, addr hubtypes.NodeAddress) bool
- func (k *Keeper) HasProvider(ctx sdk.Context, addr hubtypes.ProvAddress) bool
- func (k *Keeper) IsMaxGigabytePricesModified(ctx sdk.Context) bool
- func (k *Keeper) IsMaxHourlyPricesModified(ctx sdk.Context) bool
- func (k *Keeper) IsMinGigabytePricesModified(ctx sdk.Context) bool
- func (k *Keeper) IsMinHourlyPricesModified(ctx sdk.Context) bool
- func (k *Keeper) IsValidGigabytePrices(ctx sdk.Context, prices sdk.Coins) bool
- func (k *Keeper) IsValidHourlyPrices(ctx sdk.Context, prices sdk.Coins) bool
- func (k *Keeper) IsValidSubscriptionGigabytes(ctx sdk.Context, gigabytes int64) bool
- func (k *Keeper) IsValidSubscriptionHours(ctx sdk.Context, hours int64) bool
- func (k *Keeper) IterateNodes(ctx sdk.Context, fn func(index int, item types.Node) (stop bool))
- func (k *Keeper) IterateNodesForInactiveAt(ctx sdk.Context, at time.Time, fn func(index int, item types.Node) (stop bool))
- func (k *Keeper) Logger(ctx sdk.Context) log.Logger
- func (k *Keeper) MaxGigabytePrices(ctx sdk.Context) (v sdk.Coins)
- func (k *Keeper) MaxHourlyPrices(ctx sdk.Context) (v sdk.Coins)
- func (k *Keeper) MaxSubscriptionGigabytes(ctx sdk.Context) (v int64)
- func (k *Keeper) MaxSubscriptionHours(ctx sdk.Context) (v int64)
- func (k *Keeper) MinGigabytePrices(ctx sdk.Context) (v sdk.Coins)
- func (k *Keeper) MinHourlyPrices(ctx sdk.Context) (v sdk.Coins)
- func (k *Keeper) MinSubscriptionGigabytes(ctx sdk.Context) (v int64)
- func (k *Keeper) MinSubscriptionHours(ctx sdk.Context) (v int64)
- func (k *Keeper) SetActiveNode(ctx sdk.Context, node types.Node)
- func (k *Keeper) SetInactiveNode(ctx sdk.Context, node types.Node)
- func (k *Keeper) SetNode(ctx sdk.Context, node types.Node)
- func (k *Keeper) SetNodeForInactiveAt(ctx sdk.Context, at time.Time, addr hubtypes.NodeAddress)
- func (k *Keeper) SetNodeForPlan(ctx sdk.Context, id uint64, addr hubtypes.NodeAddress)
- func (k *Keeper) SetParams(ctx sdk.Context, params types.Params)
- func (k *Keeper) StakingShare(ctx sdk.Context) (v sdk.Dec)
- func (k *Keeper) Store(ctx sdk.Context) sdk.KVStore
- func (k *Keeper) WithDistributionKeeper(keeper expected.DistributionKeeper)
- func (k *Keeper) WithProviderKeeper(keeper expected.ProviderKeeper)
- func (k *Keeper) WithSubscriptionKeeper(keeper expected.SubscriptionKeeper)
- type Migrator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMsgServiceServer ¶ added in v0.6.0
func NewMsgServiceServer(k Keeper) types.MsgServiceServer
NewMsgServiceServer creates a new instance of `types.MsgServiceServer` using the provided Keeper.
func NewQueryServiceServer ¶ added in v0.6.0
func NewQueryServiceServer(k 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) Keeper
func (*Keeper) ActiveDuration ¶ added in v0.11.0
func (*Keeper) CreateSubscriptionForNode ¶ added in v0.11.0
func (k *Keeper) CreateSubscriptionForNode(ctx sdk.Context, accAddr sdk.AccAddress, nodeAddr hubtypes.NodeAddress, gigabytes, hours int64, denom string) (*subscriptiontypes.NodeSubscription, error)
func (*Keeper) DeleteActiveNode ¶ added in v0.4.0
func (k *Keeper) DeleteActiveNode(ctx sdk.Context, addr hubtypes.NodeAddress)
func (*Keeper) DeleteInactiveNode ¶ added in v0.4.0
func (k *Keeper) DeleteInactiveNode(ctx sdk.Context, addr hubtypes.NodeAddress)
func (*Keeper) DeleteNodeForInactiveAt ¶ added in v0.11.0
func (*Keeper) DeleteNodeForPlan ¶
func (*Keeper) EndBlock ¶ added in v0.11.0
func (k *Keeper) EndBlock(ctx sdk.Context) []abcitypes.ValidatorUpdate
func (*Keeper) FundCommunityPool ¶ added in v0.4.0
func (*Keeper) GetActiveNode ¶ added in v0.11.0
func (*Keeper) GetInactiveNode ¶ added in v0.11.0
func (*Keeper) GetNodesForPlan ¶ added in v0.11.0
func (*Keeper) HasActiveNode ¶ added in v0.11.0
func (*Keeper) HasInactiveNode ¶ added in v0.11.0
func (*Keeper) HasNodeForPlan ¶ added in v0.11.0
func (*Keeper) HasProvider ¶
func (*Keeper) IsMaxGigabytePricesModified ¶ added in v0.11.0
func (*Keeper) IsMaxHourlyPricesModified ¶ added in v0.11.0
func (*Keeper) IsMinGigabytePricesModified ¶ added in v0.11.0
func (*Keeper) IsMinHourlyPricesModified ¶ added in v0.11.0
func (*Keeper) IsValidGigabytePrices ¶ added in v0.11.0
func (*Keeper) IsValidHourlyPrices ¶ added in v0.11.0
func (*Keeper) IsValidSubscriptionGigabytes ¶ added in v0.11.0
func (*Keeper) IsValidSubscriptionHours ¶ added in v0.11.0
func (*Keeper) IterateNodes ¶
func (*Keeper) IterateNodesForInactiveAt ¶ added in v0.11.0
func (*Keeper) MaxGigabytePrices ¶ added in v0.11.0
func (*Keeper) MaxHourlyPrices ¶ added in v0.11.0
func (*Keeper) MaxSubscriptionGigabytes ¶ added in v0.11.0
func (*Keeper) MaxSubscriptionHours ¶ added in v0.11.0
func (*Keeper) MinGigabytePrices ¶ added in v0.11.0
func (*Keeper) MinHourlyPrices ¶ added in v0.11.0
func (*Keeper) MinSubscriptionGigabytes ¶ added in v0.11.0
func (*Keeper) MinSubscriptionHours ¶ added in v0.11.0
func (*Keeper) SetActiveNode ¶ added in v0.4.0
func (*Keeper) SetInactiveNode ¶ added in v0.4.0
func (*Keeper) SetNodeForInactiveAt ¶ added in v0.11.0
func (*Keeper) SetNodeForPlan ¶ added in v0.11.0
func (*Keeper) StakingShare ¶ added in v0.10.0
func (*Keeper) WithDistributionKeeper ¶ added in v0.4.0
func (k *Keeper) WithDistributionKeeper(keeper expected.DistributionKeeper)
func (*Keeper) WithProviderKeeper ¶
func (k *Keeper) WithProviderKeeper(keeper expected.ProviderKeeper)
func (*Keeper) WithSubscriptionKeeper ¶ added in v0.11.0
func (k *Keeper) WithSubscriptionKeeper(keeper expected.SubscriptionKeeper)
Click to show internal directories.
Click to hide internal directories.