keeper

package
v0.0.10 Latest Latest
Warning

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

 Go to latest Published: Mar 24, 2023 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMsgServerImpl 

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

Types

type Keeper 

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

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey,
	memKey storetypes.StoreKey,
	ps paramtypes.Subspace,
	bankKeeper types.BankKeeper,
	accountKeeper types.AccountKeeper,
	spKeeper types.SpKeeper,
) *Keeper

func (Keeper) ApplyStreamRecordChanges 

func (k Keeper) ApplyStreamRecordChanges(ctx sdk.Context, streamRecordChanges []types.StreamRecordChange) error

ApplyStreamRecordChanges assume StreamRecordChange is unique by Addr

func (Keeper) ApplyUserFlowsList added in v0.0.7 

func (k Keeper) ApplyUserFlowsList(ctx sdk.Context, userFlowsList []types.UserFlows) (err error)

ApplyUserFlowsList

func (Keeper) AutoSettle 

func (k Keeper) AutoSettle(ctx sdk.Context)

func (Keeper) AutoSettleRecord 

func (k Keeper) AutoSettleRecord(c context.Context, req *types.QueryGetAutoSettleRecordRequest) (*types.QueryGetAutoSettleRecordResponse, error)

func (Keeper) AutoSettleRecordAll 

func (k Keeper) AutoSettleRecordAll(c context.Context, req *types.QueryAllAutoSettleRecordRequest) (*types.QueryAllAutoSettleRecordResponse, error)

func (Keeper) CheckStreamRecord added in v0.0.7 

func (k Keeper) CheckStreamRecord(streamRecord *types.StreamRecord)

func (Keeper) DerivePaymentAccountAddress added in v0.0.10 

func (k Keeper) DerivePaymentAccountAddress(owner sdk.AccAddress, index uint64) sdk.AccAddress

func (Keeper) DynamicBalance 

func (k Keeper) DynamicBalance(goCtx context.Context, req *types.QueryDynamicBalanceRequest) (*types.QueryDynamicBalanceResponse, error)

func (Keeper) ForceSettle 

func (k Keeper) ForceSettle(ctx sdk.Context, streamRecord *types.StreamRecord) error

func (Keeper) GetAllAutoSettleRecord 

func (k Keeper) GetAllAutoSettleRecord(ctx sdk.Context) (list []types.AutoSettleRecord)

GetAllAutoSettleRecord returns all autoSettleRecord

func (Keeper) GetAllPaymentAccount 

func (k Keeper) GetAllPaymentAccount(ctx sdk.Context) (list []types.PaymentAccount)

GetAllPaymentAccount returns all paymentAccount

func (Keeper) GetAllPaymentAccountCount 

func (k Keeper) GetAllPaymentAccountCount(ctx sdk.Context) (list []types.PaymentAccountCount)

GetAllPaymentAccountCount returns all paymentAccountCount

func (Keeper) GetAllStreamRecord 

func (k Keeper) GetAllStreamRecord(ctx sdk.Context) (list []types.StreamRecord)

GetAllStreamRecord returns all streamRecord

func (Keeper) GetAutoSettleRecord 

func (k Keeper) GetAutoSettleRecord(
	ctx sdk.Context,
	timestamp int64,
	addr sdk.AccAddress,
) (val *types.AutoSettleRecord, found bool)

GetAutoSettleRecord returns a autoSettleRecord from its index

func (Keeper) GetParams 

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

GetParams get all parameters as types.Params

func (Keeper) GetPaymentAccount 

func (k Keeper) GetPaymentAccount(
	ctx sdk.Context,
	addr sdk.AccAddress,
) (val *types.PaymentAccount, found bool)

GetPaymentAccount returns a paymentAccount from its index

func (Keeper) GetPaymentAccountCount 

func (k Keeper) GetPaymentAccountCount(
	ctx sdk.Context,
	owner sdk.AccAddress,
) (val *types.PaymentAccountCount, found bool)

GetPaymentAccountCount returns a paymentAccountCount from its index

func (Keeper) GetPaymentAccountsByOwner 

func (k Keeper) GetPaymentAccountsByOwner(goCtx context.Context, req *types.QueryGetPaymentAccountsByOwnerRequest) (*types.QueryGetPaymentAccountsByOwnerResponse, error)

func (Keeper) GetStoragePrice added in v0.0.7 

func (k Keeper) GetStoragePrice(ctx sdk.Context, params types.StoragePriceParams) (price types.StoragePrice, err error)

func (Keeper) GetStreamRecord 

func (k Keeper) GetStreamRecord(
	ctx sdk.Context,
	account sdk.AccAddress,
) (val *types.StreamRecord, found bool)

GetStreamRecord returns a streamRecord from its index

func (Keeper) IsPaymentAccountOwner 

func (k Keeper) IsPaymentAccountOwner(ctx sdk.Context, addr, owner sdk.AccAddress) bool

func (Keeper) Logger 

func (k Keeper) Logger(ctx sdk.Context) log.Logger

func (Keeper) MergeOutFlows added in v0.0.7 

func (k Keeper) MergeOutFlows(flows []types.OutFlow) []types.OutFlow

MergeOutFlows merge flows with same address

func (Keeper) MergeStreamRecordChanges 

func (k Keeper) MergeStreamRecordChanges(changes []types.StreamRecordChange) []types.StreamRecordChange

MergeStreamRecordChanges merge changes with same address

func (Keeper) MergeUserFlows added in v0.0.7 

func (k Keeper) MergeUserFlows(userFlowsList []types.UserFlows) []types.UserFlows

MergeUserFlows merge flows with same From address

func (Keeper) Params 

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

func (Keeper) PaymentAccount 

func (k Keeper) PaymentAccount(c context.Context, req *types.QueryGetPaymentAccountRequest) (*types.QueryGetPaymentAccountResponse, error)

func (Keeper) PaymentAccountAll 

func (k Keeper) PaymentAccountAll(c context.Context, req *types.QueryAllPaymentAccountRequest) (*types.QueryAllPaymentAccountResponse, error)

func (Keeper) PaymentAccountCount 

func (k Keeper) PaymentAccountCount(c context.Context, req *types.QueryGetPaymentAccountCountRequest) (*types.QueryGetPaymentAccountCountResponse, error)

func (Keeper) PaymentAccountCountAll 

func (k Keeper) PaymentAccountCountAll(c context.Context, req *types.QueryAllPaymentAccountCountRequest) (*types.QueryAllPaymentAccountCountResponse, error)

func (Keeper) QueryDynamicBalance added in v0.0.10 

func (k Keeper) QueryDynamicBalance(ctx sdk.Context, addr sdk.AccAddress) (amount sdkmath.Int, err error)

func (Keeper) RemoveAutoSettleRecord 

func (k Keeper) RemoveAutoSettleRecord(
	ctx sdk.Context,
	timestamp int64,
	addr sdk.AccAddress,
)

RemoveAutoSettleRecord removes a autoSettleRecord from the store

func (Keeper) RemovePaymentAccountCount 

func (k Keeper) RemovePaymentAccountCount(
	ctx sdk.Context,
	owner sdk.AccAddress,
)

RemovePaymentAccountCount removes a paymentAccountCount from the store

func (Keeper) SetAutoSettleRecord 

func (k Keeper) SetAutoSettleRecord(ctx sdk.Context, autoSettleRecord *types.AutoSettleRecord)

SetAutoSettleRecord set a specific autoSettleRecord in the store from its index

func (Keeper) SetParams 

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

SetParams set the params

func (Keeper) SetPaymentAccount 

func (k Keeper) SetPaymentAccount(ctx sdk.Context, paymentAccount *types.PaymentAccount)

SetPaymentAccount set a specific paymentAccount in the store from its index

func (Keeper) SetPaymentAccountCount 

func (k Keeper) SetPaymentAccountCount(ctx sdk.Context, paymentAccountCount *types.PaymentAccountCount)

SetPaymentAccountCount set a specific paymentAccountCount in the store from its index

func (Keeper) SetStreamRecord 

func (k Keeper) SetStreamRecord(ctx sdk.Context, streamRecord *types.StreamRecord)

SetStreamRecord set a specific streamRecord in the store from its index

func (Keeper) StreamRecord 

func (k Keeper) StreamRecord(c context.Context, req *types.QueryGetStreamRecordRequest) (*types.QueryGetStreamRecordResponse, error)

func (Keeper) StreamRecordAll 

func (k Keeper) StreamRecordAll(c context.Context, req *types.QueryAllStreamRecordRequest) (*types.QueryAllStreamRecordResponse, error)

func (Keeper) TryResumeStreamRecord added in v0.0.7 

func (k Keeper) TryResumeStreamRecord(ctx sdk.Context, streamRecord *types.StreamRecord, depositBalance sdkmath.Int) error

func (Keeper) UpdateAutoSettleRecord 

func (k Keeper) UpdateAutoSettleRecord(ctx sdk.Context, addr sdk.AccAddress, oldTime, newTime int64)

func (Keeper) UpdateStreamRecord 

func (k Keeper) UpdateStreamRecord(ctx sdk.Context, streamRecord *types.StreamRecord, change *types.StreamRecordChange, autoSettle bool) error

func (Keeper) UpdateStreamRecordByAddr 

func (k Keeper) UpdateStreamRecordByAddr(ctx sdk.Context, change *types.StreamRecordChange) (ret *types.StreamRecord, err error)

func (Keeper) Withdraw added in v0.0.10 

func (k Keeper) Withdraw(ctx sdk.Context, fromAddr, toAddr sdk.AccAddress, amount sdkmath.Int) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.