keeper

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 9, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StateOpenPrefixID      = byte(0x01)
	StateClosedPrefixID    = byte(0x02)
	StateOverdrawnPrefixID = byte(0x03)
)

Variables

View Source
var (
	AccountPrefix        = []byte{0x11, 0x00}
	PaymentPrefix        = []byte{0x12, 0x00}
	StateOpenPrefix      = []byte{StateOpenPrefixID}
	StateClosedPrefix    = []byte{StateClosedPrefixID}
	StateOverdrawnPrefix = []byte{StateOverdrawnPrefixID}
)

Functions

func BuildAccountsKey

func BuildAccountsKey(state etypes.State, id escrowid.ID) []byte

func BuildPaymentsKey

func BuildPaymentsKey(state etypes.State, id escrowid.ID) []byte

func LegacyAccountKey

func LegacyAccountKey(id v1beta3.AccountID) []byte

func LegacyPaymentKey

func LegacyPaymentKey(id v1beta3.AccountID, pid string) []byte

func NewQuerier

func NewQuerier(_ Keeper) types.QueryServer

func ParseAccountKey

func ParseAccountKey(key []byte) (escrowid.Account, etypes.State)

func ParsePaymentKey

func ParsePaymentKey(key []byte) (escrowid.Payment, etypes.State)

Types

type AccountHook

type AccountHook func(sdk.Context, etypes.Account)

type AuthzKeeper

type AuthzKeeper interface {
	DeleteGrant(ctx context.Context, grantee sdk.AccAddress, granter sdk.AccAddress, msgType string) error
	GetAuthorization(ctx context.Context, grantee sdk.AccAddress, granter sdk.AccAddress, msgType string) (authz.Authorization, *time.Time)
	SaveGrant(ctx context.Context, grantee sdk.AccAddress, granter sdk.AccAddress, authorization authz.Authorization, expiration *time.Time) error
	IterateGrants(ctx context.Context, handler func(granterAddr sdk.AccAddress, granteeAddr sdk.AccAddress, grant authz.Grant) bool)
	GetGranteeGrantsByMsgType(ctx context.Context, grantee sdk.AccAddress, msgType string, onGrant authzkeeper.OnGrantFn)
}

type BankKeeper

type BankKeeper interface {
	SpendableCoins(ctx context.Context, addr sdk.AccAddress) sdk.Coins
	SpendableCoin(ctx context.Context, addr sdk.AccAddress, denom string) sdk.Coin
	SendCoinsFromModuleToAccount(ctx context.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx context.Context, senderModule, recipientModule string, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx context.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
}

type Keeper

type Keeper interface {
	Codec() codec.BinaryCodec
	StoreKey() storetypes.StoreKey
	AuthorizeDeposits(sctx sdk.Context, msg sdk.Msg) ([]etypes.Depositor, error)
	AccountCreate(ctx sdk.Context, id escrowid.Account, owner sdk.AccAddress, deposits []etypes.Depositor) error
	AccountDeposit(ctx sdk.Context, id escrowid.Account, deposits []etypes.Depositor) error
	AccountSettle(ctx sdk.Context, id escrowid.Account) (bool, error)
	AccountClose(ctx sdk.Context, id escrowid.Account) error
	PaymentCreate(ctx sdk.Context, id escrowid.Payment, owner sdk.AccAddress, rate sdk.DecCoin) error
	PaymentWithdraw(ctx sdk.Context, id escrowid.Payment) error
	PaymentClose(ctx sdk.Context, id escrowid.Payment) error
	GetAccount(ctx sdk.Context, id escrowid.Account) (etypes.Account, error)
	GetPayment(ctx sdk.Context, id escrowid.Payment) (etypes.Payment, error)
	AddOnAccountClosedHook(AccountHook) Keeper
	AddOnPaymentClosedHook(PaymentHook) Keeper
	WithAccounts(sdk.Context, func(etypes.Account) bool)
	WithPayments(sdk.Context, func(etypes.Payment) bool)
	SaveAccount(sdk.Context, etypes.Account) error
	SavePayment(sdk.Context, etypes.Payment)
	NewQuerier() Querier
}

func NewKeeper

func NewKeeper(
	cdc codec.BinaryCodec,
	skey storetypes.StoreKey,
	bkeeper BankKeeper,
	tkeeper TakeKeeper,
	akeeper AuthzKeeper,
	feepool collections.Item[distrtypes.FeePool],
) Keeper

type PaymentHook

type PaymentHook func(sdk.Context, etypes.Payment)

type Querier

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

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

func (Querier) AccountClose

func (k Querier) AccountClose(ctx sdk.Context, id escrowid.Account) error

func (Querier) AccountCreate

func (k Querier) AccountCreate(ctx sdk.Context, id escrowid.Account, owner sdk.AccAddress, deposits []etypes.Depositor) error

func (Querier) AccountDeposit

func (k Querier) AccountDeposit(ctx sdk.Context, id escrowid.Account, deposits []etypes.Depositor) error

func (Querier) AccountSettle

func (k Querier) AccountSettle(ctx sdk.Context, id escrowid.Account) (bool, error)

func (Querier) Accounts

func (k Querier) Accounts(c context.Context, req *v1.QueryAccountsRequest) (*v1.QueryAccountsResponse, error)

func (Querier) AddOnAccountClosedHook

func (k Querier) AddOnAccountClosedHook(hook AccountHook) Keeper

func (Querier) AddOnPaymentClosedHook

func (k Querier) AddOnPaymentClosedHook(hook PaymentHook) Keeper

func (Querier) AuthorizeDeposits

func (k Querier) AuthorizeDeposits(sctx sdk.Context, msg sdk.Msg) ([]etypes.Depositor, error)

func (Querier) Codec

func (k Querier) Codec() codec.BinaryCodec

func (Querier) GetAccount

func (k Querier) GetAccount(ctx sdk.Context, id escrowid.Account) (etypes.Account, error)

func (Querier) GetPayment

func (k Querier) GetPayment(ctx sdk.Context, id escrowid.Payment) (etypes.Payment, error)

func (Querier) NewQuerier

func (k Querier) NewQuerier() Querier

func (Querier) PaymentClose

func (k Querier) PaymentClose(ctx sdk.Context, id escrowid.Payment) error

func (Querier) PaymentCreate

func (k Querier) PaymentCreate(ctx sdk.Context, id escrowid.Payment, owner sdk.AccAddress, rate sdk.DecCoin) error

func (Querier) PaymentWithdraw

func (k Querier) PaymentWithdraw(ctx sdk.Context, id escrowid.Payment) error

func (Querier) Payments

func (k Querier) Payments(c context.Context, req *v1.QueryPaymentsRequest) (*v1.QueryPaymentsResponse, error)

func (Querier) SaveAccount

func (k Querier) SaveAccount(ctx sdk.Context, obj etypes.Account) error

func (Querier) SavePayment

func (k Querier) SavePayment(ctx sdk.Context, obj etypes.Payment)

func (Querier) StoreKey

func (k Querier) StoreKey() storetypes.StoreKey

StoreKey returns store key

func (Querier) WithAccounts

func (k Querier) WithAccounts(ctx sdk.Context, fn func(etypes.Account) bool)

func (Querier) WithPayments

func (k Querier) WithPayments(ctx sdk.Context, fn func(etypes.Payment) bool)

type TakeKeeper

type TakeKeeper interface {
	SubtractFees(ctx sdk.Context, amt sdk.Coin) (sdk.Coin, sdk.Coin, error)
}

Jump to

Keyboard shortcuts

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