Versions in this module Expand all Collapse all v1 v1.7.4 Apr 15, 2023 v1.7.3 Apr 15, 2023 Changes in this version + func CheckResult(jsonStr string) (code types.ResultCode, msg string) + func GetExchangeRateFromJSON(jsonStr string) (sdk.Dec, error) + func NewMsgServerImpl(keeper Keeper) types.MsgServer + func NewQuerier(k Keeper, legacyQuerierCdc *codec.LegacyAmino) sdk.Querier + func ParamKeyTable() paramstypes.KeyTable + func TxHash(ctx sdk.Context) []byte + type Keeper struct + func NewKeeper(cdc codec.Codec, key storetypes.StoreKey, accountKeeper types.AccountKeeper, ...) Keeper + func (k Keeper) ActiveRequestsIterator(ctx sdk.Context, serviceName string, provider sdk.AccAddress) sdk.Iterator + func (k Keeper) ActiveRequestsIteratorByReqCtx(ctx sdk.Context, requestContextID tmbytes.HexBytes, batchCounter uint64) sdk.Iterator + func (k Keeper) AddActiveRequest(ctx sdk.Context, serviceName string, provider sdk.AccAddress, ...) + func (k Keeper) AddActiveRequestByBinding(ctx sdk.Context, serviceName string, provider sdk.AccAddress, ...) + func (k Keeper) AddActiveRequestByID(ctx sdk.Context, requestID tmbytes.HexBytes) + func (k Keeper) AddEarnedFee(ctx sdk.Context, provider sdk.AccAddress, fee sdk.Coins) error + func (k Keeper) AddNewRequestBatch(ctx sdk.Context, requestContextID tmbytes.HexBytes, requestBatchHeight int64) + func (k Keeper) AddRequestBatchExpiration(ctx sdk.Context, requestContextID tmbytes.HexBytes, expirationHeight int64) + func (k Keeper) AddResponse(ctx sdk.Context, requestID tmbytes.HexBytes, provider sdk.AccAddress, ...) (request types.Request, response types.Response, err error) + func (k Keeper) AddServiceBinding(ctx sdk.Context, serviceName string, provider sdk.AccAddress, ...) error + func (k Keeper) AddServiceDefinition(ctx sdk.Context, name, description string, tags []string, ...) error + func (k Keeper) AllActiveRequestsIterator(store sdk.KVStore) sdk.Iterator + func (k Keeper) AllEarnedFeesIterator(ctx sdk.Context) sdk.Iterator + func (k Keeper) AllServiceBindingsIterator(ctx sdk.Context) sdk.Iterator + func (k Keeper) ArbitrationTimeLimit(ctx sdk.Context) (res time.Duration) + func (k Keeper) BaseDenom(ctx sdk.Context) (res string) + func (k Keeper) Binding(c context.Context, req *types.QueryBindingRequest) (*types.QueryBindingResponse, error) + func (k Keeper) Bindings(c context.Context, req *types.QueryBindingsRequest) (*types.QueryBindingsResponse, error) + func (k Keeper) Callback(ctx sdk.Context, requestContextID tmbytes.HexBytes) + func (k Keeper) CheckAuthority(ctx sdk.Context, consumer sdk.AccAddress, requestContextID tmbytes.HexBytes, ...) error + func (k Keeper) CleanBatch(ctx sdk.Context, requestContext types.RequestContext, ...) + func (k Keeper) ComplaintRetrospect(ctx sdk.Context) (res time.Duration) + func (k Keeper) CompleteBatch(ctx sdk.Context, requestContext types.RequestContext, ...) types.RequestContext + func (k Keeper) CompleteServiceContext(ctx sdk.Context, context types.RequestContext, ...) + func (k Keeper) CreateRequestContext(ctx sdk.Context, serviceName string, providers []sdk.AccAddress, ...) (tmbytes.HexBytes, error) + func (k Keeper) DeductServiceFees(ctx sdk.Context, consumer sdk.AccAddress, serviceFees sdk.Coins) error + func (k Keeper) Definition(c context.Context, req *types.QueryDefinitionRequest) (*types.QueryDefinitionResponse, error) + func (k Keeper) DeleteActiveRequest(ctx sdk.Context, serviceName string, provider sdk.AccAddress, ...) + func (k Keeper) DeleteActiveRequestByBinding(ctx sdk.Context, serviceName string, provider sdk.AccAddress, ...) + func (k Keeper) DeleteActiveRequestByID(ctx sdk.Context, requestID tmbytes.HexBytes) + func (k Keeper) DeleteCompactRequest(ctx sdk.Context, requestID tmbytes.HexBytes) + func (k Keeper) DeleteEarnedFees(ctx sdk.Context, provider sdk.AccAddress) + func (k Keeper) DeleteNewRequestBatch(ctx sdk.Context, requestContextID tmbytes.HexBytes, requestBatchHeight int64) + func (k Keeper) DeleteNewRequestBatchHeight(ctx sdk.Context, requestContextID tmbytes.HexBytes) + func (k Keeper) DeleteOwnerEarnedFees(ctx sdk.Context, owner sdk.AccAddress) + func (k Keeper) DeleteRequestBatchExpiration(ctx sdk.Context, requestContextID tmbytes.HexBytes, expirationHeight int64) + func (k Keeper) DeleteRequestBatchExpirationHeight(ctx sdk.Context, requestContextID tmbytes.HexBytes) + func (k Keeper) DeleteRequestContext(ctx sdk.Context, requestContextID tmbytes.HexBytes) + func (k Keeper) DeleteResponse(ctx sdk.Context, requestID tmbytes.HexBytes) + func (k Keeper) DisableServiceBinding(ctx sdk.Context, serviceName string, provider, owner sdk.AccAddress) error + func (k Keeper) EarnedFees(c context.Context, req *types.QueryEarnedFeesRequest) (*types.QueryEarnedFeesResponse, error) + func (k Keeper) EnableServiceBinding(ctx sdk.Context, serviceName string, provider sdk.AccAddress, ...) error + func (k Keeper) FilterServiceProviders(ctx sdk.Context, serviceName string, providers []sdk.AccAddress, timeout int64, ...) ([]sdk.AccAddress, sdk.Coins, string, error) + func (k Keeper) GetCompactRequest(ctx sdk.Context, requestID tmbytes.HexBytes) (request types.CompactRequest, found bool) + func (k Keeper) GetEarnedFees(ctx sdk.Context, provider sdk.AccAddress) (fees sdk.Coins, found bool) + func (k Keeper) GetExchangeRate(ctx sdk.Context, quoteDenom, baseDenom string) (sdk.Dec, error) + func (k Keeper) GetExchangedPrice(ctx sdk.Context, consumer sdk.AccAddress, binding types.ServiceBinding) (sdk.Coins, string, error) + func (k Keeper) GetInternalIndex(ctx sdk.Context) int64 + func (k Keeper) GetMinDeposit(ctx sdk.Context, pricing types.Pricing) (sdk.Coins, error) + func (k Keeper) GetModuleServiceByModuleName(moduleName string) (*types.ModuleService, bool) + func (k Keeper) GetModuleServiceByServiceName(serviceName string) (string, *types.ModuleService, bool) + func (k Keeper) GetOwner(ctx sdk.Context, provider sdk.AccAddress) (sdk.AccAddress, bool) + func (k Keeper) GetOwnerEarnedFees(ctx sdk.Context, owner sdk.AccAddress) (fees sdk.Coins, found bool) + func (k Keeper) GetOwnerServiceBindings(ctx sdk.Context, owner sdk.AccAddress, serviceName string) []*types.ServiceBinding + func (k Keeper) GetParams(ctx sdk.Context) types.Params + func (k Keeper) GetPrice(ctx sdk.Context, consumer sdk.AccAddress, binding types.ServiceBinding) sdk.Coins + func (k Keeper) GetPricing(ctx sdk.Context, serviceName string, provider sdk.AccAddress) (pricing types.Pricing) + func (k Keeper) GetRequest(ctx sdk.Context, requestID tmbytes.HexBytes) (request types.Request, found bool) + func (k Keeper) GetRequestContext(ctx sdk.Context, requestContextID tmbytes.HexBytes) (requestContext types.RequestContext, found bool) + func (k Keeper) GetRequestVolume(ctx sdk.Context, consumer sdk.AccAddress, serviceName string, ...) uint64 + func (k Keeper) GetResponse(ctx sdk.Context, requestID tmbytes.HexBytes) (response types.Response, found bool) + func (k Keeper) GetResponseCallback(moduleName string) (types.ResponseCallback, error) + func (k Keeper) GetResponseOutputs(ctx sdk.Context, requestContextID tmbytes.HexBytes, batchCounter uint64) []string + func (k Keeper) GetServiceBinding(ctx sdk.Context, serviceName string, provider sdk.AccAddress) (svcBinding types.ServiceBinding, found bool) + func (k Keeper) GetServiceDefinition(ctx sdk.Context, serviceName string) (svcDef types.ServiceDefinition, found bool) + func (k Keeper) GetServiceDepositAccount(ctx sdk.Context) authtypes.ModuleAccountI + func (k Keeper) GetServiceRequestAccount(ctx sdk.Context) authtypes.ModuleAccountI + func (k Keeper) GetStateCallback(moduleName string) (types.StateCallback, error) + func (k Keeper) GetWithdrawAddress(ctx sdk.Context, owner sdk.AccAddress) sdk.AccAddress + func (k Keeper) HasNewRequestBatch(ctx sdk.Context, requestContextID tmbytes.HexBytes) bool + func (k Keeper) HasRequestBatchExpiration(ctx sdk.Context, requestContextID tmbytes.HexBytes) bool + func (k Keeper) IncreaseRequestVolume(ctx sdk.Context, consumer sdk.AccAddress, serviceName string, ...) + func (k Keeper) InitiateRequests(ctx sdk.Context, requestContextID tmbytes.HexBytes, providers []sdk.AccAddress, ...) []tmbytes.HexBytes + func (k Keeper) IsRequestActive(ctx sdk.Context, requestID tmbytes.HexBytes) bool + func (k Keeper) IterateActiveRequests(ctx sdk.Context, requestContextID tmbytes.HexBytes, batchCounter uint64, ...) + func (k Keeper) IterateExpiredRequestBatch(ctx sdk.Context, expirationHeight int64, ...) + func (k Keeper) IterateNewRequestBatch(ctx sdk.Context, requestBatchHeight int64, ...) + func (k Keeper) IterateRequestContexts(ctx sdk.Context, ...) + func (k Keeper) IterateRequests(ctx sdk.Context, ...) + func (k Keeper) IterateResponses(ctx sdk.Context, ...) + func (k Keeper) IterateServiceBindings(ctx sdk.Context, op func(binding types.ServiceBinding) (stop bool)) + func (k Keeper) IterateServiceDefinitions(ctx sdk.Context, op func(definition types.ServiceDefinition) (stop bool)) + func (k Keeper) IterateWithdrawAddresses(ctx sdk.Context, ...) + func (k Keeper) KillRequestContext(ctx sdk.Context, requestContextID tmbytes.HexBytes, consumer sdk.AccAddress) error + func (k Keeper) Logger(ctx sdk.Context) log.Logger + func (k Keeper) MaxRequestTimeout(ctx sdk.Context) (res int64) + func (k Keeper) MinDeposit(ctx sdk.Context) (res sdk.Coins) + func (k Keeper) MinDepositMultiple(ctx sdk.Context) (res int64) + func (k Keeper) OnRequestContextPaused(ctx sdk.Context, requestContext *types.RequestContext, ...) + func (k Keeper) OwnerProvidersIterator(ctx sdk.Context, owner sdk.AccAddress) sdk.Iterator + func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error) + func (k Keeper) ParsePricing(ctx sdk.Context, pricing string) (p types.Pricing, err error) + func (k Keeper) PauseRequestContext(ctx sdk.Context, requestContextID tmbytes.HexBytes, consumer sdk.AccAddress) error + func (k Keeper) RefundDeposit(ctx sdk.Context, serviceName string, provider, owner sdk.AccAddress) error + func (k Keeper) RefundDeposits(ctx sdk.Context) error + func (k Keeper) RefundEarnedFees(ctx sdk.Context) error + func (k Keeper) RefundServiceFee(ctx sdk.Context, consumer sdk.AccAddress, serviceFee sdk.Coins) error + func (k Keeper) RefundServiceFees(ctx sdk.Context) error + func (k Keeper) RegisterModuleService(moduleName string, moduleService *types.ModuleService) error + func (k Keeper) RegisterResponseCallback(moduleName string, respCallback types.ResponseCallback) error + func (k Keeper) RegisterStateCallback(moduleName string, stateCallback types.StateCallback) error + func (k Keeper) Request(c context.Context, req *types.QueryRequestRequest) (*types.QueryRequestResponse, error) + func (k Keeper) RequestContext(c context.Context, req *types.QueryRequestContextRequest) (*types.QueryRequestContextResponse, error) + func (k Keeper) RequestModuleService(ctx sdk.Context, moduleService *types.ModuleService, ...) error + func (k Keeper) Requests(c context.Context, req *types.QueryRequestsRequest) (*types.QueryRequestsResponse, error) + func (k Keeper) RequestsByReqCtx(c context.Context, req *types.QueryRequestsByReqCtxRequest) (*types.QueryRequestsByReqCtxResponse, error) + func (k Keeper) RequestsIteratorByReqCtx(ctx sdk.Context, requestContextID tmbytes.HexBytes, batchCounter uint64) sdk.Iterator + func (k Keeper) ResetRequestContextsStateAndBatch(ctx sdk.Context) error + func (k Keeper) Response(c context.Context, req *types.QueryResponseRequest) (*types.QueryResponseResponse, error) + func (k Keeper) Responses(c context.Context, req *types.QueryResponsesRequest) (*types.QueryResponsesResponse, error) + func (k Keeper) ResponsesIteratorByReqCtx(ctx sdk.Context, requestContextID tmbytes.HexBytes, batchCounter uint64) sdk.Iterator + func (k Keeper) RestrictedServiceFeeDenom(ctx sdk.Context) (res bool) + func (k Keeper) Schema(c context.Context, req *types.QuerySchemaRequest) (*types.QuerySchemaResponse, error) + func (k Keeper) ServiceBindingsIterator(ctx sdk.Context, serviceName string) sdk.Iterator + func (k Keeper) ServiceFeeTax(ctx sdk.Context) (res sdk.Dec) + func (k Keeper) SetCompactRequest(ctx sdk.Context, requestID tmbytes.HexBytes, request types.CompactRequest) + func (k Keeper) SetEarnedFees(ctx sdk.Context, provider sdk.AccAddress, fees sdk.Coins) + func (k Keeper) SetInternalIndex(ctx sdk.Context, index int64) + func (k Keeper) SetModuleService(moduleName string, moduleService *types.ModuleService) + func (k Keeper) SetNewRequestBatchHeight(ctx sdk.Context, requestContextID tmbytes.HexBytes, requestBatchHeight int64) + func (k Keeper) SetOwner(ctx sdk.Context, provider, owner sdk.AccAddress) + func (k Keeper) SetOwnerEarnedFees(ctx sdk.Context, owner sdk.AccAddress, fees sdk.Coins) + func (k Keeper) SetOwnerProvider(ctx sdk.Context, owner, provider sdk.AccAddress) + func (k Keeper) SetOwnerServiceBinding(ctx sdk.Context, svcBinding types.ServiceBinding) + func (k Keeper) SetParams(ctx sdk.Context, params types.Params) + func (k Keeper) SetPricing(ctx sdk.Context, serviceName string, provider sdk.AccAddress, ...) + func (k Keeper) SetRequestBatchExpirationHeight(ctx sdk.Context, requestContextID tmbytes.HexBytes, expirationHeight int64) + func (k Keeper) SetRequestContext(ctx sdk.Context, requestContextID tmbytes.HexBytes, ...) + func (k Keeper) SetRequestVolume(ctx sdk.Context, consumer sdk.AccAddress, serviceName string, ...) + func (k Keeper) SetResponse(ctx sdk.Context, requestID tmbytes.HexBytes, response types.Response) + func (k Keeper) SetServiceBinding(ctx sdk.Context, svcBinding types.ServiceBinding) + func (k Keeper) SetServiceBindingForGenesis(ctx sdk.Context, svcBinding types.ServiceBinding) error + func (k Keeper) SetServiceDefinition(ctx sdk.Context, svcDef types.ServiceDefinition) + func (k Keeper) SetWithdrawAddress(ctx sdk.Context, owner, withdrawAddr sdk.AccAddress) + func (k Keeper) SkipCurrentRequestBatch(ctx sdk.Context, requestContextID tmbytes.HexBytes, ...) + func (k Keeper) Slash(ctx sdk.Context, requestID tmbytes.HexBytes) error + func (k Keeper) SlashFraction(ctx sdk.Context) (res sdk.Dec) + func (k Keeper) StartRequestContext(ctx sdk.Context, requestContextID tmbytes.HexBytes, consumer sdk.AccAddress) error + func (k Keeper) TxSizeLimit(ctx sdk.Context) (res uint64) + func (k Keeper) UpdateRequestContext(ctx sdk.Context, requestContextID tmbytes.HexBytes, providers []sdk.AccAddress, ...) error + func (k Keeper) UpdateServiceBinding(ctx sdk.Context, serviceName string, provider sdk.AccAddress, ...) error + func (k Keeper) WithdrawAddress(c context.Context, req *types.QueryWithdrawAddressRequest) (*types.QueryWithdrawAddressResponse, error) + func (k Keeper) WithdrawEarnedFees(ctx sdk.Context, owner, provider sdk.AccAddress) error
Go to main page