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) AutoResume ¶ added in v0.2.3

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

func (Keeper) AutoSettle ¶

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

func (Keeper) AutoSettleRecords ¶ added in v0.2.4

func (k Keeper) AutoSettleRecords(c context.Context, req *types.QueryAutoSettleRecordsRequest) (*types.QueryAutoSettleRecordsResponse, error)

func (Keeper) CheckStreamRecord ¶ added in v0.0.7

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

func (Keeper) DelayedWithdrawal ¶ added in v0.2.5

func (k Keeper) DelayedWithdrawal(goCtx context.Context, req *types.QueryDelayedWithdrawalRequest) (*types.QueryDelayedWithdrawalResponse, error)

func (Keeper) DeleteOutFlow ¶ added in v0.2.3

func (k Keeper) DeleteOutFlow(ctx sdk.Context, key []byte)

DeleteOutFlow set a specific OutFlow from the store

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) ExistsAutoResumeRecord ¶ added in v0.2.3

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

ExistsAutoResumeRecord checks whether there exists a autoResumeRecord

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) GetAuthority ¶ added in v0.2.0

func (k Keeper) GetAuthority() string

func (Keeper) GetAutoResumeRecord ¶ added in v0.2.3

func (k Keeper) GetAutoResumeRecord(
	ctx sdk.Context,
	timestamp int64,
	addr sdk.AccAddress,
) (*types.AutoResumeRecord, bool)

GetAutoResumeRecord returns a autoResumeRecord from its index

func (Keeper) GetDelayedWithdrawalRecord ¶ added in v0.2.5

func (k Keeper) GetDelayedWithdrawalRecord(
	ctx sdk.Context,
	addr sdk.AccAddress,
) (*types.DelayedWithdrawalRecord, bool)

GetDelayedWithdrawalRecord returns a delayedWithdrawal from its index

func (Keeper) GetOutFlow ¶ added in v0.2.3

func (k Keeper) GetOutFlow(ctx sdk.Context, addr sdk.AccAddress, status types.OutFlowStatus, toAddr sdk.AccAddress) *types.OutFlow

GetOutFlow get a specific OutFlow in the store from its index

func (Keeper) GetOutFlows ¶ added in v0.2.3

func (k Keeper) GetOutFlows(ctx sdk.Context, addr sdk.AccAddress) []types.OutFlow

GetOutFlows get OutFlows for a specific from address

func (Keeper) GetParams ¶

func (k Keeper) GetParams(ctx sdk.Context) (p 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) 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) GetVersionedParamsWithTs ¶ added in v0.2.3

func (k Keeper) GetVersionedParamsWithTs(ctx sdk.Context, ts int64) (verParams types.VersionedParams, err error)

GetVersionedParamsWithTs find the latest params before and equal than the specific timestamp

func (Keeper) IsEmptyNetFlow ¶ added in v0.2.3

func (k Keeper) IsEmptyNetFlow(ctx sdk.Context, account sdk.AccAddress) bool

func (Keeper) IsPaymentAccount ¶ added in v0.2.5

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

IsPaymentAccount returns is the account address a payment account

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) MergeActiveOutFlows ¶ added in v0.2.3

func (k Keeper) MergeActiveOutFlows(ctx sdk.Context, addr sdk.AccAddress, outFlows []types.OutFlow) int

MergeActiveOutFlows merge active OutFlows and save them in the store

func (Keeper) MergeFrozenOutFlows ¶ added in v0.2.3

func (k Keeper) MergeFrozenOutFlows(ctx sdk.Context, addr sdk.AccAddress, outFlows []types.OutFlow) int

MergeFrozenOutFlows merge frozen OutFlows and save them in the store

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) OutFlows ¶ added in v0.2.3

func (k Keeper) OutFlows(c context.Context, req *types.QueryOutFlowsRequest) (*types.QueryOutFlowsResponse, error)

func (Keeper) Params ¶

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

func (Keeper) ParamsByTimestamp ¶ added in v0.2.3

func (k Keeper) ParamsByTimestamp(c context.Context, req *types.QueryParamsByTimestampRequest) (*types.QueryParamsByTimestampResponse, error)

func (Keeper) PaymentAccount ¶

func (k Keeper) PaymentAccount(c context.Context, req *types.QueryPaymentAccountRequest) (*types.QueryPaymentAccountResponse, error)

func (Keeper) PaymentAccountCount ¶

func (k Keeper) PaymentAccountCount(c context.Context, req *types.QueryPaymentAccountCountRequest) (*types.QueryPaymentAccountCountResponse, error)

func (Keeper) PaymentAccountCounts ¶ added in v0.2.4

func (k Keeper) PaymentAccountCounts(c context.Context, req *types.QueryPaymentAccountCountsRequest) (*types.QueryPaymentAccountCountsResponse, error)

func (Keeper) PaymentAccounts ¶ added in v0.2.4

func (k Keeper) PaymentAccounts(c context.Context, req *types.QueryPaymentAccountsRequest) (*types.QueryPaymentAccountsResponse, error)

func (Keeper) PaymentAccountsByOwner ¶ added in v0.2.4

func (k Keeper) PaymentAccountsByOwner(goCtx context.Context, req *types.QueryPaymentAccountsByOwnerRequest) (*types.QueryPaymentAccountsByOwnerResponse, 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) RemoveAutoResumeRecord ¶ added in v0.2.3

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

RemoveAutoResumeRecord removes a autoResumeRecord from the store

func (Keeper) RemoveAutoSettleRecord ¶

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

RemoveAutoSettleRecord removes a autoSettleRecord from the store

func (Keeper) RemoveDelayedWithdrawalRecord ¶ added in v0.2.5

func (k Keeper) RemoveDelayedWithdrawalRecord(
	ctx sdk.Context,
	addr sdk.AccAddress,
)

RemoveDelayedWithdrawalRecord removes a delayedWithdrawal from the store

func (Keeper) SetAutoResumeRecord ¶ added in v0.2.3

func (k Keeper) SetAutoResumeRecord(ctx sdk.Context, autoResumeRecord *types.AutoResumeRecord)

SetAutoResumeRecord set a specific autoResumeRecord in the store from its index

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) SetDelayedWithdrawalRecord ¶ added in v0.2.5

func (k Keeper) SetDelayedWithdrawalRecord(ctx sdk.Context, delayedWithdrawalRecord *types.DelayedWithdrawalRecord)

SetDelayedWithdrawalRecord set a specific delayedWithdrawal in the store from its index

func (Keeper) SetOutFlow ¶ added in v0.2.3

func (k Keeper) SetOutFlow(ctx sdk.Context, addr sdk.AccAddress, outFlow *types.OutFlow)

SetOutFlow set a specific OutFlow in the store from its index

func (Keeper) SetParams ¶

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

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) SetVersionedParamsWithTs ¶ added in v0.2.3

func (k Keeper) SetVersionedParamsWithTs(ctx sdk.Context, verParams types.VersionedParams) error

func (Keeper) StreamRecord ¶

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

func (Keeper) StreamRecords ¶ added in v0.2.4

func (k Keeper) StreamRecords(c context.Context, req *types.QueryStreamRecordsRequest) (*types.QueryStreamRecordsResponse, 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) UpdateFrozenStreamRecord ¶ added in v0.2.2

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

UpdateFrozenStreamRecord updates frozen streamRecord in `force delete` scenarios it only handles the lock balance change and ignore the other changes(since the streams are already changed and the accumulated OutFlows are changed outside this function)

func (Keeper) UpdateStreamRecord ¶

func (k Keeper) UpdateStreamRecord(ctx sdk.Context, streamRecord *types.StreamRecord, change *types.StreamRecordChange) 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

func (Migrator) MigrateV1toV2 ¶ added in v0.2.5

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