keeper

Documentation

Index

• Variables
• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• type ActionKeeper
  • func (k ActionKeeper) ActionsByAddress() collections.Map[collections.Pair[sdk.AccAddress, uint64], uint64]
  • func (k ActionKeeper) Coll() repo.SeqCollection[types.Action]
  • func (k ActionKeeper) Get(ctx sdk.Context, id uint64) (types.Action, error)
  • func (k ActionKeeper) New(ctx sdk.Context, action *types.Action) (uint64, error)
  • func (k ActionKeeper) Set(ctx sdk.Context, action types.Action) error
• type ApproversEnv
  • func (approvers ApproversEnv) Get(name string) (object.Object, bool)
• type Keeper
  • func NewKeeper(cdc codec.BinaryCodec, storeService store.KVStoreService, logger log.Logger, ...) Keeper
  • func (k Keeper) ActionById(goCtx context.Context, req *types.QueryActionByIdRequest) (*types.QueryActionByIdResponse, error)
  • func (k Keeper) Actions(goCtx context.Context, req *types.QueryActionsRequest) (*types.QueryActionsResponse, error)
  • func (k Keeper) ActionsByAddress(goCtx context.Context, req *types.QueryActionsByAddressRequest) (*types.QueryActionsByAddressResponse, error)
  • func (k Keeper) AddAction(ctx sdk.Context, creator string, msg sdk.Msg, intent types.Intent, btl uint64) (*types.Action, error)
  • func (k Keeper) CheckActionReady(ctx sdk.Context, act types.Action) (bool, error)
  • func (k Keeper) ExecuteAction(ctx sdk.Context, act *types.Action) error
  • func (k Keeper) GetAuthority() string
  • func (k Keeper) GetIntent(ctx sdk.Context, id uint64) (types.Intent, error)
  • func (k Keeper) GetParams(ctx context.Context) (params types.Params)
  • func (k Keeper) IntentById(goCtx context.Context, req *types.QueryIntentByIdRequest) (*types.QueryIntentByIdResponse, error)
  • func (k Keeper) Intents(goCtx context.Context, req *types.QueryIntentsRequest) (*types.QueryIntentsResponse, error)
  • func (k Keeper) Logger() log.Logger
  • func (k Keeper) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
  • func (k Keeper) RegisterActionHandler(actionType string, handlerFn types.ActionHandler)
  • func (k Keeper) SetParams(ctx context.Context, params types.Params) error
• type Migrator
  • func NewMigrator(keeper Keeper) Migrator
  • func (m Migrator) Migrate1to2(ctx sdk.Context) error

Variables

var (
	ActionPrefix          = collections.NewPrefix(0)
	IntentPrefix          = collections.NewPrefix(1)
	ActionByAddressPrefix = collections.NewPrefix(2)
)

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.

Types

type ActionKeeper

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

func (ActionKeeper) ActionsByAddress

func (k ActionKeeper) ActionsByAddress() collections.Map[collections.Pair[sdk.AccAddress, uint64], uint64]

func (ActionKeeper) Coll

func (k ActionKeeper) Coll() repo.SeqCollection[types.Action]

func (ActionKeeper) Get

func (k ActionKeeper) Get(ctx sdk.Context, id uint64) (types.Action, error)

func (ActionKeeper) New

func (k ActionKeeper) New(ctx sdk.Context, action *types.Action) (uint64, error)

func (ActionKeeper) Set

func (k ActionKeeper) Set(ctx sdk.Context, action types.Action) error

type ApproversEnv

type ApproversEnv []*types.Approver

ApproversEnv is an environment that resolves approvers' addresses to true.

func (ApproversEnv) Get

func (approvers ApproversEnv) Get(name string) (object.Object, bool)

Get implements evaluator.Environment.

type Keeper

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

func NewKeeper

func NewKeeper(
	cdc codec.BinaryCodec,
	storeService store.KVStoreService,
	logger log.Logger,
	authority string,
	shieldExpanderFunc func() ast.Expander,
) Keeper

func (Keeper) ActionById

func (k Keeper) ActionById(goCtx context.Context, req *types.QueryActionByIdRequest) (*types.QueryActionByIdResponse, error)

func (Keeper) Actions

func (k Keeper) Actions(goCtx context.Context, req *types.QueryActionsRequest) (*types.QueryActionsResponse, error)

func (Keeper) ActionsByAddress

func (k Keeper) ActionsByAddress(goCtx context.Context, req *types.QueryActionsByAddressRequest) (*types.QueryActionsByAddressResponse, error)

func (Keeper) AddAction

func (k Keeper) AddAction(ctx sdk.Context, creator string, msg sdk.Msg, intent types.Intent, btl uint64) (*types.Action, error)

AddAction creates a new action. The action is created with the provided creator as the first approver. This function also tries to execute the action immediately if it's ready.

func (Keeper) CheckActionReady

func (k Keeper) CheckActionReady(ctx sdk.Context, act types.Action) (bool, error)

CheckActionReady checks if the intent attached to the action is satisfied. If the intent is satisfied, the action is marked as completed and true is returned, the actual execution of the action is left for the caller.

func (Keeper) ExecuteAction

func (k Keeper) ExecuteAction(ctx sdk.Context, act *types.Action) error

ExecuteAction executes the action and stores the result in the database. The action will be modified in place, setting the Result field. The updated action will also be persisted in the database.

func (Keeper) GetAuthority

func (k Keeper) GetAuthority() string

GetAuthority returns the module's authority.

func (Keeper) GetIntent

func (k Keeper) GetIntent(ctx sdk.Context, id uint64) (types.Intent, error)

func (Keeper) GetParams

func (k Keeper) GetParams(ctx context.Context) (params types.Params)

GetParams get all parameters as types.Params

func (Keeper) IntentById

func (k Keeper) IntentById(goCtx context.Context, req *types.QueryIntentByIdRequest) (*types.QueryIntentByIdResponse, error)

nolint:stylecheck,st1003 revive:disable-next-line var-naming

func (Keeper) Intents

func (k Keeper) Intents(goCtx context.Context, req *types.QueryIntentsRequest) (*types.QueryIntentsResponse, error)

func (Keeper) Logger

func (k Keeper) Logger() log.Logger

Logger returns a module-specific logger.

func (Keeper) Params

func (k Keeper) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

func (Keeper) RegisterActionHandler

func (k Keeper) RegisterActionHandler(actionType string, handlerFn types.ActionHandler)

RegisterActionHandler registers a handler for a specific action type.

func (Keeper) SetParams

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

SetParams set the params

type Migrator

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

Migrator is a struct for handling in-place store migrations.

func NewMigrator

func NewMigrator(keeper Keeper) Migrator

NewMigrator returns a new Migrator.

func (Migrator) Migrate1to2

func (m Migrator) Migrate1to2(ctx sdk.Context) error