keeper

Documentation

Index

• Variables
• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• func NewQueryServerImpl(keeper Keeper) types.QueryServer
• type ActionApprovedVotesEnv
  • func (votes ActionApprovedVotesEnv) Get(name string) (object.Object, bool)
• 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) ExpiredActions(ctx context.Context, blockTime time.Time, ...) ([]types.Action, error)
  • func (k ActionKeeper) Get(ctx context.Context, id uint64) (types.Action, error)
  • func (k ActionKeeper) GetLatestPruneHeight(ctx context.Context) (int64, error)
  • func (k ActionKeeper) Import(ctx sdk.Context, actions []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 ActionRejectedVotesEnv
  • func (votes ActionRejectedVotesEnv) 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) EndBlocker(ctx context.Context) error
  • func (k *Keeper) ExportState(ctx sdk.Context, genState *types.GenesisState) 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) GetTemplate(ctx context.Context, id uint64) (types.Template, error)
  • func (k *Keeper) ImportState(ctx sdk.Context, genState types.GenesisState) error
  • func (k Keeper) IsValidTemplate(ctx context.Context, id uint64) error
  • func (k Keeper) Logger() log.Logger
  • func (k Keeper) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
  • func (k Keeper) SetParams(ctx context.Context, params types.Params) error
  • func (k Keeper) SimulateTemplate(goCtx context.Context, req *types.QuerySimulateTemplateRequest) (*types.QuerySimulateTemplateResponse, error)
  • func (k Keeper) TemplateById(goCtx context.Context, req *types.QueryTemplateByIdRequest) (*types.QueryTemplateByIdResponse, error)
  • func (k Keeper) Templates(goCtx context.Context, req *types.QueryTemplatesRequest) (*types.QueryTemplatesResponse, error)
  • func (k Keeper) TemplatesRegistry() *types.TemplatesRegistry
  • func (k Keeper) TryExecuteVotedAction(ctx context.Context, act *types.Action) error
  • func (k Keeper) TryRejectVotedAction(ctx context.Context, act *types.Action) error

Variables

var (
	ActionPrefix                   = collections.NewPrefix(0)
	TemplatePrefix                 = collections.NewPrefix(1)
	ActionByAddressPrefix          = collections.NewPrefix(2)
	PreviousPruneBlockHeightPrefix = collections.NewPrefix(3)
)

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

func NewQueryServerImpl

func NewQueryServerImpl(keeper Keeper) types.QueryServer

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

Types

type ActionApprovedVotesEnv

type ActionApprovedVotesEnv []*types.ActionVote

ActionApprovedVotesEnv is an environment that resolves action positive votes addresses to true.

func (ActionApprovedVotesEnv) Get

func (votes ActionApprovedVotesEnv) Get(name string) (object.Object, bool)

Get implements positive action vote evaluator.Environment.

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

func (k ActionKeeper) ExpiredActions(ctx context.Context, blockTime time.Time, pendingTimeout, completedTimeout time.Duration) ([]types.Action, error)

func (ActionKeeper) Get

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

func (ActionKeeper) GetLatestPruneHeight

func (k ActionKeeper) GetLatestPruneHeight(ctx context.Context) (int64, error)

func (ActionKeeper) Import

func (k ActionKeeper) Import(ctx sdk.Context, actions []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 ActionRejectedVotesEnv

type ActionRejectedVotesEnv []*types.ActionVote

ActionRejectedVotesEnv is an environment that resolves action negative votes addresses to true.

func (ActionRejectedVotesEnv) Get

func (votes ActionRejectedVotesEnv) Get(name string) (object.Object, bool)

Get implements negative action vote 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,
	templatesRegistry *types.TemplatesRegistry,
) 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, expectedApproveExpression *ast.Expression, expectedRejectExpression *ast.Expression) (*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) EndBlocker

func (k Keeper) EndBlocker(ctx context.Context) error

func (*Keeper) ExportState

func (k *Keeper) ExportState(ctx sdk.Context, genState *types.GenesisState) error

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

func (k Keeper) GetTemplate(ctx context.Context, id uint64) (types.Template, error)

func (*Keeper) ImportState

func (k *Keeper) ImportState(ctx sdk.Context, genState types.GenesisState) error

func (Keeper) IsValidTemplate

func (k Keeper) IsValidTemplate(ctx context.Context, id uint64) 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) SetParams

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

SetParams set the params

func (Keeper) SimulateTemplate

func (k Keeper) SimulateTemplate(goCtx context.Context, req *types.QuerySimulateTemplateRequest) (*types.QuerySimulateTemplateResponse, error)

func (Keeper) TemplateById

func (k Keeper) TemplateById(goCtx context.Context, req *types.QueryTemplateByIdRequest) (*types.QueryTemplateByIdResponse, error)

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

func (Keeper) Templates

func (k Keeper) Templates(goCtx context.Context, req *types.QueryTemplatesRequest) (*types.QueryTemplatesResponse, error)

func (Keeper) TemplatesRegistry

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

func (Keeper) TryExecuteVotedAction

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

TryExecuteVotedAction checks if the action's expression is satisfied and stores the result in the database.

func (Keeper) TryRejectVotedAction

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

TryRejectVotedAction checks if the action's reject expression is satisfied and updates its status revoked.