Versions in this module Expand all Collapse all v1 v1.10.1 Aug 1, 2024 v1.10.0 Jul 30, 2024 Changes in this version + func AllInvariants(keeper Keeper) sdk.Invariant + func ModuleAccountInvariant(k Keeper) sdk.Invariant + func NewMsgServerImpl(keeper Keeper) types.MsgServer + func RegisterInvariants(ir sdk.InvariantRegistry, keeper Keeper) + type Keeper struct + func NewKeeper(storeKey storetypes.StoreKey, bankKeeper types.BankKeeper, ...) Keeper + func (k Keeper) AddDeposit(ctx sdk.Context, receiverAddr, senderAddr sdk.AccAddress, ...) (bool, error) + func (k Keeper) CalculateFlowRate(ctx context.Context, request *types.QueryCalculateFlowRateRequest) (*types.QueryCalculateFlowRateResponse, error) + func (k Keeper) CancelStreamBySenderReceiver(ctx sdk.Context, receiverAddr, senderAddr sdk.AccAddress) error + func (k Keeper) Cdc() codec.BinaryCodec + func (k Keeper) ClaimFromStream(ctx sdk.Context, receiverAddr, senderAddr sdk.AccAddress) (sdk.Coin, sdk.Coin, sdk.Coin, sdk.Coin, error) + func (k Keeper) CreateNewStream(ctx sdk.Context, receiverAddr, senderAddr sdk.AccAddress, deposit sdk.Coin, ...) (types.Stream, error) + func (k Keeper) DeleteStream(ctx sdk.Context, receiverAddr, senderAddr sdk.AccAddress) + func (k Keeper) ExportGenesis(ctx sdk.Context) *types.GenesisState + func (k Keeper) GetAuthority() string + func (k Keeper) GetParams(ctx sdk.Context) (params types.Params) + func (k Keeper) GetStream(ctx sdk.Context, receiverAddr, senderAddr sdk.AccAddress) (types.Stream, bool) + func (k Keeper) GetStreamModuleAccount(ctx sdk.Context) authtypes.ModuleAccountI + func (k Keeper) GetStreamModuleAccountBalances(ctx sdk.Context) sdk.Coins + func (k Keeper) GetTotalDeposits(ctx sdk.Context) sdk.Coins + func (k Keeper) InitGenesis(ctx sdk.Context, genState *types.GenesisState) + func (k Keeper) IsStream(ctx sdk.Context, receiverAddr, senderAddr sdk.AccAddress) bool + func (k Keeper) IterateAllStreams(ctx sdk.Context, cb func(sdk.AccAddress, sdk.AccAddress, types.Stream) bool) + func (k Keeper) Logger(ctx sdk.Context) log.Logger + func (k Keeper) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error) + func (k Keeper) SetNewFlowRate(ctx sdk.Context, receiverAddr, senderAddr sdk.AccAddress, newFlowRate int64) error + func (k Keeper) SetParams(ctx sdk.Context, params types.Params) error + func (k Keeper) SetStream(ctx sdk.Context, receiverAddr, senderAddr sdk.AccAddress, stream types.Stream) error + func (q Keeper) AllStreamsForReceiver(c context.Context, req *types.QueryAllStreamsForReceiverRequest) (*types.QueryAllStreamsForReceiverResponse, error) + func (q Keeper) AllStreamsForSender(c context.Context, req *types.QueryAllStreamsForSenderRequest) (*types.QueryAllStreamsForSenderResponse, error) + func (q Keeper) StreamByReceiverSender(c context.Context, req *types.QueryStreamByReceiverSenderRequest) (*types.QueryStreamByReceiverSenderResponse, error) + func (q Keeper) StreamReceiverSenderCurrentFlow(c context.Context, req *types.QueryStreamReceiverSenderCurrentFlowRequest) (*types.QueryStreamReceiverSenderCurrentFlowResponse, error) + func (q Keeper) Streams(c context.Context, req *types.QueryStreamsRequest) (*types.QueryStreamsResponse, error)
Go to main page