keeper

Documentation

Index

• type Keeper
  • func NewKeeper(cdc *codec.Codec, key sdk.StoreKey, params params.Subspace) Keeper
  • func (k Keeper) DeleteActiveSessionAt(ctx sdk.Context, at time.Time, id uint64)
  • func (k Keeper) DeleteOngoingSession(ctx sdk.Context, id uint64, address sdk.AccAddress)
  • func (k Keeper) GetCount(ctx sdk.Context) (count uint64)
  • func (k Keeper) GetOngoingSession(ctx sdk.Context, id uint64, address sdk.AccAddress) (session types.Session, found bool)
  • func (k Keeper) GetParams(ctx sdk.Context) types.Params
  • func (k Keeper) GetQuota(ctx sdk.Context, id uint64, address sdk.AccAddress) (subscription.Quota, bool)
  • func (k Keeper) GetSession(ctx sdk.Context, id uint64) (session types.Session, found bool)
  • func (k Keeper) GetSessions(ctx sdk.Context, skip, limit int) (items types.Sessions)
  • func (k Keeper) GetSessionsForAddress(ctx sdk.Context, address sdk.AccAddress, skip, limit int) (items types.Sessions)
  • func (k Keeper) GetSessionsForNode(ctx sdk.Context, address hub.NodeAddress, skip, limit int) (items types.Sessions)
  • func (k Keeper) GetSessionsForSubscription(ctx sdk.Context, id uint64, skip, limit int) (items types.Sessions)
  • func (k Keeper) GetSubscription(ctx sdk.Context, id uint64) (subscription.Subscription, bool)
  • func (k Keeper) HasNodeForPlan(ctx sdk.Context, id uint64, address hub.NodeAddress) bool
  • func (k Keeper) HasQuota(ctx sdk.Context, id uint64, address sdk.AccAddress) bool
  • func (k Keeper) HasSubscriptionForNode(ctx sdk.Context, address hub.NodeAddress, id uint64) bool
  • func (k Keeper) InactiveDuration(ctx sdk.Context) (duration time.Duration)
  • func (k Keeper) IterateActiveSessions(ctx sdk.Context, end time.Time, ...)
  • func (k Keeper) IterateSessions(ctx sdk.Context, fn func(index int, item types.Session) (stop bool))
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) SendCoinsFromDepositToAccount(ctx sdk.Context, from, to sdk.AccAddress, coin sdk.Coin) error
  • func (k Keeper) SetActiveSessionAt(ctx sdk.Context, at time.Time, id uint64)
  • func (k Keeper) SetCount(ctx sdk.Context, count uint64)
  • func (k Keeper) SetOngoingSession(ctx sdk.Context, subscription uint64, address sdk.AccAddress, id uint64)
  • func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
  • func (k Keeper) SetQuota(ctx sdk.Context, id uint64, quota subscription.Quota)
  • func (k Keeper) SetSession(ctx sdk.Context, session types.Session)
  • func (k Keeper) SetSessionForAddress(ctx sdk.Context, address sdk.AccAddress, id uint64)
  • func (k Keeper) SetSessionForNode(ctx sdk.Context, address hub.NodeAddress, id uint64)
  • func (k Keeper) SetSessionForSubscription(ctx sdk.Context, subscription, id uint64)
  • func (k Keeper) Store(ctx sdk.Context) sdk.KVStore
  • func (k *Keeper) WithDepositKeeper(keeper expected.DepositKeeper)
  • func (k *Keeper) WithPlanKeeper(keeper expected.PlanKeeper)
  • func (k *Keeper) WithSubscriptionKeeper(keeper expected.SubscriptionKeeper)

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) DeleteActiveSessionAt

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

func (Keeper) DeleteOngoingSession

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

func (Keeper) GetCount

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

func (Keeper) GetOngoingSession

func (k Keeper) GetOngoingSession(ctx sdk.Context, id uint64, address sdk.AccAddress) (session types.Session, found 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) (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 int) (items types.Sessions)

func (Keeper) GetSessionsForAddress

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

func (Keeper) GetSessionsForNode

func (k Keeper) GetSessionsForNode(ctx sdk.Context, address hub.NodeAddress, skip, limit int) (items types.Sessions)

func (Keeper) GetSessionsForSubscription

func (k Keeper) GetSessionsForSubscription(ctx sdk.Context, id uint64, skip, limit int) (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 hub.NodeAddress) bool

func (Keeper) HasQuota

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

func (Keeper) HasSubscriptionForNode

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

func (Keeper) InactiveDuration

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

func (Keeper) IterateActiveSessions

func (k Keeper) IterateActiveSessions(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) SendCoinsFromDepositToAccount

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) SetCount

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

func (Keeper) SetOngoingSession

func (k Keeper) SetOngoingSession(ctx sdk.Context, subscription uint64, 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 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 hub.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) WithDepositKeeper

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)