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 context.Context, id uint64) (types.Action, error)
  • func (k ActionKeeper) New(ctx context.Context, action *types.Action) (uint64, error)
  • func (k ActionKeeper) Set(ctx context.Context, action types.Action) error
• type ApproversEnv
  • func (approvers ApproversEnv) Get(name string) (object.Object, bool)
• type Keeper
  • func NewKeeper(cdc codec.Codec, 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 context.Context, creator string, msg sdk.Msg, timeoutHeight uint64) (*types.Action, error)
  • func (k Keeper) GetActionCreator(ctx context.Context) string
  • func (k Keeper) GetAuthority() string
  • func (k Keeper) GetModuleAddress() string
  • func (k Keeper) GetParams(ctx context.Context) (params types.Params)
  • func (k Keeper) GetRule(ctx context.Context, id uint64) (types.Rule, error)
  • func (k Keeper) Logger() log.Logger
  • func (k Keeper) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
  • func (k Keeper) RuleById(goCtx context.Context, req *types.QueryRuleByIdRequest) (*types.QueryRuleByIdResponse, error)
  • func (k Keeper) Rules(goCtx context.Context, req *types.QueryRulesRequest) (*types.QueryRulesResponse, error)
  • func (k Keeper) RulesRegistry() *types.RulesRegistry
  • func (k Keeper) SetParams(ctx context.Context, params types.Params) error
  • func (k Keeper) SimulateRule(goCtx context.Context, req *types.QuerySimulateRuleRequest) (*types.QuerySimulateRuleResponse, error)
  • func (k Keeper) TryExecuteAction(ctx context.Context, act *types.Action) error
• type Migrator
  • func NewMigrator(keeper Keeper) Migrator
  • func (m Migrator) Migrate2to3(ctx sdk.Context) error

Variables

var (
	ActionPrefix          = collections.NewPrefix(0)
	RulePrefix            = 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 context.Context, id uint64) (types.Action, error)

func (ActionKeeper) New

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

func (ActionKeeper) Set

func (k ActionKeeper) Set(ctx context.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.Codec,
	storeService store.KVStoreService,
	logger log.Logger,
	router baseapp.MessageRouter,
	authority string,
	actModuleAddress string,
	shieldExpanderFunc func() ast.Expander,
	rulesRegistry *types.RulesRegistry,
) 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 context.Context, creator string, msg sdk.Msg, timeoutHeight 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) GetActionCreator

func (k Keeper) GetActionCreator(ctx context.Context) string

GetActionCreator returns the original address of the creator of the Action. This function is intended to be used in the context of MsgHandlers being executed as part of an Action.

func (Keeper) GetAuthority

func (k Keeper) GetAuthority() string

GetAuthority returns the module's authority.

func (Keeper) GetModuleAddress

func (k Keeper) GetModuleAddress() string

func (Keeper) GetParams

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

GetParams get all parameters as types.Params

func (Keeper) GetRule

func (k Keeper) GetRule(ctx context.Context, id uint64) (types.Rule, 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) RuleById

func (k Keeper) RuleById(goCtx context.Context, req *types.QueryRuleByIdRequest) (*types.QueryRuleByIdResponse, error)

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

func (Keeper) Rules

func (k Keeper) Rules(goCtx context.Context, req *types.QueryRulesRequest) (*types.QueryRulesResponse, error)

func (Keeper) RulesRegistry

func (k Keeper) RulesRegistry() *types.RulesRegistry

func (Keeper) SetParams

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

SetParams set the params

func (Keeper) SimulateRule

func (k Keeper) SimulateRule(goCtx context.Context, req *types.QuerySimulateRuleRequest) (*types.QuerySimulateRuleResponse, error)

func (Keeper) TryExecuteAction

func (k Keeper) TryExecuteAction(ctx context.Context, act *types.Action) error

TryExecuteAction checks if the action's intent is satisfied and stores the result in the database.

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

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