Documentation
¶
Index ¶
- func AllInvariants(k Keeper) sdk.Invariant
- func DemandOrderCountInvariant(k Keeper) sdk.Invariant
- func NewMsgServerImpl(keeper Keeper) types.MsgServer
- func RegisterInvariants(ir sdk.InvariantRegistry, k Keeper)
- func UnderlyingPacketExistInvariant(k Keeper) sdk.Invariant
- type Keeper
- func (k Keeper) EpochIdentifier(ctx sdk.Context) (res string)
- func (k Keeper) ErrAckFee(ctx sdk.Context) (res sdk.Dec)
- func (k Keeper) FulfillOrder(ctx sdk.Context, order *types.DemandOrder, fulfillerAddress sdk.AccAddress) error
- func (k Keeper) GetDelayedAckHooks() delayeacktypes.DelayedAckHooks
- func (k Keeper) GetDemandOrder(ctx sdk.Context, status commontypes.Status, id string) (*types.DemandOrder, error)
- func (k *Keeper) GetHooks() types.EIBCHooks
- func (k Keeper) GetParams(ctx sdk.Context) types.Params
- func (k Keeper) ListAllDemandOrders(ctx sdk.Context) (list []*types.DemandOrder, err error)
- func (k Keeper) ListDemandOrdersByStatus(ctx sdk.Context, status commontypes.Status) (list []*types.DemandOrder, err error)
- func (k Keeper) Logger(ctx sdk.Context) log.Logger
- func (k *Keeper) SetDelayedAckKeeper(delayedAckKeeper types.DelayedAckKeeper)
- func (k Keeper) SetDemandOrder(ctx sdk.Context, order *types.DemandOrder) error
- func (k *Keeper) SetHooks(hooks types.EIBCHooks)
- func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
- func (k Keeper) TimeoutFee(ctx sdk.Context) (res sdk.Dec)
- func (k *Keeper) UpdateDemandOrderWithStatus(ctx sdk.Context, demandOrder *types.DemandOrder, newStatus commontypes.Status) (*types.DemandOrder, error)
- type Querier
- func (q Querier) DemandOrderById(goCtx context.Context, req *types.QueryGetDemandOrderRequest) (*types.QueryGetDemandOrderResponse, error)
- func (q Querier) DemandOrdersByStatus(goCtx context.Context, req *types.QueryDemandOrdersByStatusRequest) (*types.QueryDemandOrdersByStatusResponse, error)
- func (q Querier) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AllInvariants ¶
AllInvariants runs all invariants of the x/streamer module.
func NewMsgServerImpl ¶
NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.
func RegisterInvariants ¶
func RegisterInvariants(ir sdk.InvariantRegistry, k Keeper)
RegisterInvariants registers the bank module invariants
Types ¶
type Keeper ¶
type Keeper struct {
types.AccountKeeper
types.BankKeeper
types.DelayedAckKeeper
// contains filtered or unexported fields
}
func NewKeeper ¶
func NewKeeper( cdc codec.BinaryCodec, storeKey, memKey storetypes.StoreKey, ps paramtypes.Subspace, accountKeeper types.AccountKeeper, bankKeeper types.BankKeeper, delayedAckKeeper types.DelayedAckKeeper, ) *Keeper
func (Keeper) FulfillOrder ¶
func (k Keeper) FulfillOrder(ctx sdk.Context, order *types.DemandOrder, fulfillerAddress sdk.AccAddress) error
FulfillOrder should be called only at most once per order.
func (Keeper) GetDelayedAckHooks ¶
func (k Keeper) GetDelayedAckHooks() delayeacktypes.DelayedAckHooks
func (Keeper) GetDemandOrder ¶
func (k Keeper) GetDemandOrder(ctx sdk.Context, status commontypes.Status, id string) (*types.DemandOrder, error)
GetDemandOrder returns the demand order with the given id and status.
func (Keeper) ListAllDemandOrders ¶
ListAllDemandOrders returns all demand orders.
func (Keeper) ListDemandOrdersByStatus ¶
func (k Keeper) ListDemandOrdersByStatus(ctx sdk.Context, status commontypes.Status) (list []*types.DemandOrder, err error)
func (*Keeper) SetDelayedAckKeeper ¶
func (k *Keeper) SetDelayedAckKeeper(delayedAckKeeper types.DelayedAckKeeper)
SetDelayedAckKeeper sets the delayedack keeper. must be called when initializing the keeper.
func (Keeper) SetDemandOrder ¶
func (*Keeper) UpdateDemandOrderWithStatus ¶
func (k *Keeper) UpdateDemandOrderWithStatus(ctx sdk.Context, demandOrder *types.DemandOrder, newStatus commontypes.Status) (*types.DemandOrder, error)
UpdateDemandOrderWithStatus deletes the current demand order and creates a new one with and updated packet status under a new key. Updating the status should be called only with this method as it effects the key of the packet. The assumption is that the passed demand order packet status field is not updated directly.
type Querier ¶
type Querier struct {
Keeper
}
func (Querier) DemandOrderById ¶
func (q Querier) DemandOrderById(goCtx context.Context, req *types.QueryGetDemandOrderRequest) (*types.QueryGetDemandOrderResponse, error)
func (Querier) DemandOrdersByStatus ¶
func (q Querier) DemandOrdersByStatus(goCtx context.Context, req *types.QueryDemandOrdersByStatusRequest) (*types.QueryDemandOrdersByStatusResponse, error)
func (Querier) Params ¶
func (q Querier) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.