keeper

Documentation

Index

• type Keeper
  • func NewKeeper(cdc *codec.Codec, key sdk.StoreKey, params params.Subspace) Keeper
  • func (k Keeper) GetActiveSession(ctx sdk.Context, s uint64, n hub.NodeAddress, a sdk.AccAddress) (session types.Session, found bool)
  • func (k Keeper) GetParams(ctx sdk.Context) types.Params
  • func (k Keeper) GetSession(ctx sdk.Context, id uint64) (session types.Session, found bool)
  • func (k Keeper) GetSessions(ctx sdk.Context) (items types.Sessions)
  • func (k Keeper) GetSessionsCount(ctx sdk.Context) (count uint64)
  • 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) HasSubscriptionForAddress(ctx sdk.Context, address sdk.AccAddress, id uint64) 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) IterateSessions(ctx sdk.Context, f func(index int, item types.Session) (stop bool))
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) SetActiveSession(ctx sdk.Context, s uint64, n hub.NodeAddress, a sdk.AccAddress, id uint64)
  • func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
  • func (k Keeper) SetSession(ctx sdk.Context, session types.Session)
  • func (k Keeper) SetSessionsCount(ctx sdk.Context, count uint64)
  • func (k Keeper) SetSubscription(ctx sdk.Context, subscription subscription.Subscription)
  • func (k Keeper) Store(ctx sdk.Context) sdk.KVStore
  • 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) GetActiveSession

func (k Keeper) GetActiveSession(ctx sdk.Context, s uint64, n hub.NodeAddress, a sdk.AccAddress) (session types.Session, found bool)

func (Keeper) GetParams

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

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) (items types.Sessions)

func (Keeper) GetSessionsCount

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

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

func (k Keeper) HasSubscriptionForAddress(ctx sdk.Context, address sdk.AccAddress, id uint64) 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) IterateSessions

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

func (Keeper) Logger

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

func (Keeper) SetActiveSession

func (k Keeper) SetActiveSession(ctx sdk.Context, s uint64, n hub.NodeAddress, a sdk.AccAddress, id uint64)

func (Keeper) SetParams

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

func (Keeper) SetSession

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

func (Keeper) SetSessionsCount

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

func (Keeper) SetSubscription

func (k Keeper) SetSubscription(ctx sdk.Context, subscription subscription.Subscription)

func (Keeper) Store

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

func (*Keeper) WithPlanKeeper

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

func (*Keeper) WithSubscriptionKeeper

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