keeper

package

v1.0.0-rc2 Latest Latest Go to latest Published: Oct 10, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/akash-network/node

Links

Open Source Insights

Documentation ¶

Index ¶

func DeploymentKey(id v1.DeploymentID) []byte
func GroupKey(id v1.GroupID) []byte
func GroupsKey(id v1.DeploymentID) []byte
type EscrowKeeper
type IKeeper
- func NewKeeper(cdc codec.BinaryCodec, skey storetypes.StoreKey, ekeeper EscrowKeeper, ...) IKeeper
type Keeper
type Querier

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DeploymentKey ¶

func DeploymentKey(id v1.DeploymentID) []byte

func GroupKey ¶

func GroupKey(id v1.GroupID) []byte

GroupKey provides prefixed key for a Group's marshalled data.

func GroupsKey ¶

func GroupsKey(id v1.DeploymentID) []byte

GroupsKey provides default store Key for Group data.

Types ¶

type EscrowKeeper ¶

type EscrowKeeper interface {
	GetAccount(ctx sdk.Context, id etypes.AccountID) (etypes.Account, error)
}

type IKeeper ¶

type IKeeper interface {
	StoreKey() storetypes.StoreKey
	Codec() codec.BinaryCodec
	GetDeployment(ctx sdk.Context, id v1.DeploymentID) (v1.Deployment, bool)
	GetGroup(ctx sdk.Context, id v1.GroupID) (types.Group, bool)
	GetGroups(ctx sdk.Context, id v1.DeploymentID) types.Groups
	Create(ctx sdk.Context, deployment v1.Deployment, groups []types.Group) error
	UpdateDeployment(ctx sdk.Context, deployment v1.Deployment) error
	CloseDeployment(ctx sdk.Context, deployment v1.Deployment) error
	OnCloseGroup(ctx sdk.Context, group types.Group, state types.Group_State) error
	OnPauseGroup(ctx sdk.Context, group types.Group) error
	OnStartGroup(ctx sdk.Context, group types.Group) error
	WithDeployments(ctx sdk.Context, fn func(v1.Deployment) bool)
	OnBidClosed(ctx sdk.Context, id v1.GroupID) error
	OnLeaseClosed(ctx sdk.Context, id v1.GroupID) (types.Group, error)
	GetParams(ctx sdk.Context) (params types.Params)
	SetParams(ctx sdk.Context, params types.Params) error
	GetAuthority() string

	NewQuerier() Querier
	// contains filtered or unexported methods
}

func NewKeeper ¶

func NewKeeper(cdc codec.BinaryCodec, skey storetypes.StoreKey, ekeeper EscrowKeeper, authority string) IKeeper

NewKeeper creates and returns an instance for deployment keeper

type Keeper ¶

type Keeper struct {
	// contains filtered or unexported fields
}

Keeper of the deployment store

func (Keeper) CloseDeployment ¶

func (k Keeper) CloseDeployment(ctx sdk.Context, deployment v1.Deployment) error

CloseDeployment close deployment

func (Keeper) Codec ¶

func (k Keeper) Codec() codec.BinaryCodec

Codec returns keeper codec

func (Keeper) Create ¶

func (k Keeper) Create(ctx sdk.Context, deployment v1.Deployment, groups []types.Group) error

Create creates a new deployment with given deployment and group specifications

func (Keeper) GetAuthority ¶

func (k Keeper) GetAuthority() string

GetAuthority returns the x/mint module's authority.

func (Keeper) GetDeployment ¶

func (k Keeper) GetDeployment(ctx sdk.Context, id v1.DeploymentID) (v1.Deployment, bool)

GetDeployment returns deployment details with provided DeploymentID

func (Keeper) GetGroup ¶

func (k Keeper) GetGroup(ctx sdk.Context, id v1.GroupID) (types.Group, bool)

GetGroup returns group details with given GroupID from deployment store

func (Keeper) GetGroups ¶

func (k Keeper) GetGroups(ctx sdk.Context, id v1.DeploymentID) types.Groups

GetGroups returns all groups of a deployment with given DeploymentID from deployment store

func (Keeper) GetParams ¶

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

GetParams returns the current x/deployment module parameters.

func (Keeper) NewQuerier ¶

func (k Keeper) NewQuerier() Querier

func (Keeper) OnBidClosed ¶

func (k Keeper) OnBidClosed(ctx sdk.Context, id v1.GroupID) error

OnBidClosed sets the group to state paused.

func (Keeper) OnCloseGroup ¶

func (k Keeper) OnCloseGroup(ctx sdk.Context, group types.Group, state types.Group_State) error

OnCloseGroup provides shutdown API for a Group

func (Keeper) OnLeaseClosed ¶

func (k Keeper) OnLeaseClosed(ctx sdk.Context, id v1.GroupID) (types.Group, error)

OnLeaseClosed keeps the group at state open

func (Keeper) OnPauseGroup ¶

func (k Keeper) OnPauseGroup(ctx sdk.Context, group types.Group) error

OnPauseGroup provides shutdown API for a Group

func (Keeper) OnStartGroup ¶

func (k Keeper) OnStartGroup(ctx sdk.Context, group types.Group) error

OnStartGroup provides shutdown API for a Group

func (Keeper) SetParams ¶

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

SetParams sets the x/deployment module parameters.

func (Keeper) StoreKey ¶

func (k Keeper) StoreKey() storetypes.StoreKey

func (Keeper) UpdateDeployment ¶

func (k Keeper) UpdateDeployment(ctx sdk.Context, deployment v1.Deployment) error

UpdateDeployment updates deployment details

func (Keeper) WithDeployments ¶

func (k Keeper) WithDeployments(ctx sdk.Context, fn func(v1.Deployment) bool)

WithDeployments iterates all deployments in deployment store

type Querier ¶

type Querier struct {
	Keeper
}

Querier is used as Keeper will have duplicate methods if used directly, and gRPC names take precedence over keeper

func (Querier) Deployment ¶

func (k Querier) Deployment(c context.Context, req *types.QueryDeploymentRequest) (*types.QueryDeploymentResponse, error)

Deployment returns deployment details based on DeploymentID

func (Querier) Deployments ¶

func (k Querier) Deployments(c context.Context, req *types.QueryDeploymentsRequest) (*types.QueryDeploymentsResponse, error)

Deployments returns deployments based on filters

func (Querier) Group ¶

func (k Querier) Group(c context.Context, req *types.QueryGroupRequest) (*types.QueryGroupResponse, error)

Group returns group details based on GroupID

func (Querier) Params ¶

func (k Querier) Params(ctx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL