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 sdkmath.LegacyDec)
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMsgServiceServer ¶
func NewMsgServiceServer(k Keeper) types.MsgServiceServer
NewMsgServiceServer creates a new instance of `types.MsgServiceServer` using the provided Keeper.
func NewQueryServiceServer ¶
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 storetypes.StoreKey, params paramstypes.Subspace) Keeper
func (*Keeper) CreateSubscriptionForNode ¶
func (k *Keeper) CreateSubscriptionForNode(ctx sdk.Context, accAddr sdk.AccAddress, nodeAddr hubtypes.NodeAddress, gigabytes, hours int64, denom string) (*subscriptiontypes.NodeSubscription, error)
func (*Keeper) DeleteActiveNode ¶
func (k *Keeper) DeleteActiveNode(ctx sdk.Context, addr hubtypes.NodeAddress)
func (*Keeper) DeleteInactiveNode ¶
func (k *Keeper) DeleteInactiveNode(ctx sdk.Context, addr hubtypes.NodeAddress)
func (*Keeper) DeleteNodeForInactiveAt ¶
func (*Keeper) DeleteNodeForPlan ¶
func (*Keeper) FundCommunityPool ¶
func (*Keeper) GetActiveNode ¶
func (*Keeper) GetInactiveNode ¶
func (*Keeper) GetNodesForPlan ¶
func (*Keeper) HasActiveNode ¶
func (*Keeper) HasInactiveNode ¶
func (*Keeper) HasNodeForPlan ¶
func (*Keeper) HasProvider ¶
func (*Keeper) IsMaxGigabytePricesModified ¶
func (*Keeper) IsMaxHourlyPricesModified ¶
func (*Keeper) IsMinGigabytePricesModified ¶
func (*Keeper) IsMinHourlyPricesModified ¶
func (*Keeper) IsValidGigabytePrices ¶
func (*Keeper) IsValidHourlyPrices ¶
func (*Keeper) IsValidSubscriptionGigabytes ¶
func (*Keeper) IsValidSubscriptionHours ¶
func (*Keeper) IterateNodes ¶
func (*Keeper) IterateNodesForInactiveAt ¶
func (*Keeper) MaxGigabytePrices ¶
func (*Keeper) MaxSubscriptionGigabytes ¶
func (*Keeper) MaxSubscriptionHours ¶
func (*Keeper) MinGigabytePrices ¶
func (*Keeper) MinSubscriptionGigabytes ¶
func (*Keeper) MinSubscriptionHours ¶
func (*Keeper) SetNodeForInactiveAt ¶
func (*Keeper) SetNodeForPlan ¶
func (*Keeper) WithDistributionKeeper ¶
func (k *Keeper) WithDistributionKeeper(keeper expected.DistributionKeeper)
func (*Keeper) WithProviderKeeper ¶
func (k *Keeper) WithProviderKeeper(keeper expected.ProviderKeeper)
func (*Keeper) WithSubscriptionKeeper ¶
func (k *Keeper) WithSubscriptionKeeper(keeper expected.SubscriptionKeeper)
Click to show internal directories.
Click to hide internal directories.