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 + const AttributeKeyAuthor + const AttributeKeyConsumer + const AttributeKeyExpirationHeight + const AttributeKeyModuleService + const AttributeKeyOwner + const AttributeKeyPriceDenom + const AttributeKeyProvider + const AttributeKeyRequestContextID + const AttributeKeyRequestContextState + const AttributeKeyRequestHeight + const AttributeKeyRequestID + const AttributeKeyRequests + const AttributeKeyServiceFee + const AttributeKeyServiceName + const AttributeKeySlashedCoins + const AttributeKeyWithdrawAddress + const AttributeValueCategory + const ContextIDLen + const DefaultParamspace + const DepositAccName + const EventTypeCompleteBatch + const EventTypeCompleteContext + const EventTypeCreateBinding + const EventTypeCreateContext + const EventTypeCreateDefinition + const EventTypeDisableBinding + const EventTypeEnableBinding + const EventTypeKillContext + const EventTypeNewBatch + const EventTypeNewBatchRequest + const EventTypeNewBatchRequestProvider + const EventTypeNoExchangeRate + const EventTypePauseContext + const EventTypeRefundDeposit + const EventTypeRespondService + const EventTypeServiceSlash + const EventTypeSetWithdrawAddress + const EventTypeStartContext + const EventTypeUpdateBinding + const EventTypeUpdateContext + const EventTypeWithdrawEarnedFees + const FeeCollectorName + const InputSchema + const MaxDescriptionLength + const MaxNameLength + const MaxProvidersNum + const MaxTagLength + const MaxTagsNum + const ModuleName + const OraclePriceAuthorDescription + const OraclePriceSchemas + const OraclePriceServiceDesc + const OraclePriceServiceName + const OraclePriceValueJSONPath + const OutputSchema + const PATH_BODY + const PricingSchema + const QuerierRoute + const QueryBinding + const QueryBindings + const QueryDefinition + const QueryEarnedFees + const QueryParameters + const QueryRequest + const QueryRequestContext + const QueryRequests + const QueryRequestsByReqCtx + const QueryResponse + const QueryResponses + const QuerySchema + const QueryWithdrawAddress + const RegisterModuleName + const RequestAccName + const RequestIDLen + const ResultSchema + const RouterKey + const StoreKey + const TypeMsgBindService + const TypeMsgCallService + const TypeMsgDefineService + const TypeMsgDisableServiceBinding + const TypeMsgEnableServiceBinding + const TypeMsgKillRequestContext + const TypeMsgPauseRequestContext + const TypeMsgRefundServiceDeposit + const TypeMsgRespondService + const TypeMsgSetWithdrawAddress + const TypeMsgStartRequestContext + const TypeMsgUpdateRequestContext + const TypeMsgUpdateServiceBinding + const TypeMsgWithdrawEarnedFees + var ActiveRequestByIDKey = []byte + var ActiveRequestKey = []byte + var DefaultArbitrationTimeLimit = 5 * 24 * time.Hour + var DefaultBaseDenom = sdk.DefaultBondDenom + var DefaultComplaintRetrospect = 15 * 24 * time.Hour + var DefaultMaxRequestTimeout = int64(100) + var DefaultMinDeposit = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdk.NewInt(5000))) + var DefaultMinDepositMultiple = int64(1000) + var DefaultRestrictedServiceFeeDenom = false + var DefaultServiceFeeTax = sdk.NewDecWithPrec(5, 2) + var DefaultSlashFraction = sdk.NewDecWithPrec(1, 3) + var DefaultTxSizeLimit = uint64(4000) + var Delimiter = []byte + var EarnedFeesKey = []byte + var ErrBindModuleService = sdkerrors.Register(ModuleName, 44, "can not bind module service") + var ErrCallbackNotRegistered = sdkerrors.Register(ModuleName, 35, "callback not registered") + var ErrCallbackRegistered = sdkerrors.Register(ModuleName, 34, "callback registered") + var ErrIncorrectRefundTime = sdkerrors.Register(ModuleName, 17, "incorrect refund time") + var ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowService = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") + var ErrInvalidDeposit = sdkerrors.Register(ModuleName, 8, "invalid deposit") + var ErrInvalidDescription = sdkerrors.Register(ModuleName, 3, "invalid description") + var ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthService = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidMinDeposit = sdkerrors.Register(ModuleName, 9, "invalid minimum deposit") + var ErrInvalidModuleService = sdkerrors.Register(ModuleName, 43, "invalid module service") + var ErrInvalidOptions = sdkerrors.Register(ModuleName, 12, "invalid options") + var ErrInvalidPricing = sdkerrors.Register(ModuleName, 10, "invalid pricing") + var ErrInvalidProviders = sdkerrors.Register(ModuleName, 19, "invalid providers") + var ErrInvalidQoS = sdkerrors.Register(ModuleName, 11, "invalid QoS") + var ErrInvalidRepeatedFreq = sdkerrors.Register(ModuleName, 21, "invalid repeated frequency") + var ErrInvalidRepeatedTotal = sdkerrors.Register(ModuleName, 22, "invalid repeated total count") + var ErrInvalidRequestContextID = sdkerrors.Register(ModuleName, 29, "invalid request context ID") + var ErrInvalidRequestID = sdkerrors.Register(ModuleName, 25, "invalid request ID") + var ErrInvalidRequestInput = sdkerrors.Register(ModuleName, 37, "invalid request input") + var ErrInvalidRequestInputBody = sdkerrors.Register(ModuleName, 45, "invalid request input body") + var ErrInvalidResponse = sdkerrors.Register(ModuleName, 24, "invalid response") + var ErrInvalidResponseOutput = sdkerrors.Register(ModuleName, 38, "invalid response output") + var ErrInvalidResponseOutputBody = sdkerrors.Register(ModuleName, 46, "invalid response output body") + var ErrInvalidResponseResult = sdkerrors.Register(ModuleName, 39, "invalid response result") + var ErrInvalidResponseThreshold = sdkerrors.Register(ModuleName, 23, "invalid response threshold") + var ErrInvalidSchemaName = sdkerrors.Register(ModuleName, 40, "invalid service schema name") + var ErrInvalidSchemas = sdkerrors.Register(ModuleName, 5, "invalid schemas") + var ErrInvalidServiceFeeCap = sdkerrors.Register(ModuleName, 18, "invalid service fee cap") + var ErrInvalidServiceName = sdkerrors.Register(ModuleName, 2, ...) + var ErrInvalidTags = sdkerrors.Register(ModuleName, 4, "invalid tags") + var ErrInvalidTimeout = sdkerrors.Register(ModuleName, 20, "invalid timeout") + var ErrModuleServiceRegistered = sdkerrors.Register(ModuleName, 42, "module service registered") + var ErrNoEarnedFees = sdkerrors.Register(ModuleName, 36, "no earned fees") + var ErrNotAuthorized = sdkerrors.Register(ModuleName, 41, "not authorized") + var ErrRequestContextCompleted = sdkerrors.Register(ModuleName, 33, "request context completed") + var ErrRequestContextNonRepeated = sdkerrors.Register(ModuleName, 30, "request context non repeated") + var ErrRequestContextNotPaused = sdkerrors.Register(ModuleName, 32, "request context not paused") + var ErrRequestContextNotRunning = sdkerrors.Register(ModuleName, 31, "request context not running") + var ErrServiceBindingAvailable = sdkerrors.Register(ModuleName, 16, "service binding available") + var ErrServiceBindingExists = sdkerrors.Register(ModuleName, 13, "service binding already exists") + var ErrServiceBindingUnavailable = sdkerrors.Register(ModuleName, 15, "service binding unavailable") + var ErrServiceDefinitionExists = sdkerrors.Register(ModuleName, 7, "service definition already exists") + var ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") + var ErrUnknownRequest = sdkerrors.Register(ModuleName, 26, "unknown request") + var ErrUnknownRequestContext = sdkerrors.Register(ModuleName, 28, "unknown request context") + var ErrUnknownResponse = sdkerrors.Register(ModuleName, 27, "unknown response") + var ErrUnknownServiceBinding = sdkerrors.Register(ModuleName, 14, "unknown service binding") + var ErrUnknownServiceDefinition = sdkerrors.Register(ModuleName, 6, "unknown service definition") + var ExpiredRequestBatchHeightKey = []byte + var ExpiredRequestBatchKey = []byte + var InternalCounterKey = []byte + var KeyArbitrationTimeLimit = []byte("ArbitrationTimeLimit") + var KeyBaseDenom = []byte("BaseDenom") + var KeyComplaintRetrospect = []byte("ComplaintRetrospect") + var KeyMaxRequestTimeout = []byte("MaxRequestTimeout") + var KeyMinDeposit = []byte("MinDeposit") + var KeyMinDepositMultiple = []byte("MinDepositMultiple") + var KeyRestrictedServiceFeeDenom = []byte("RestrictedServiceFeeDenom") + var KeyServiceFeeTax = []byte("ServiceFeeTax") + var KeySlashFraction = []byte("SlashFraction") + var KeyTxSizeLimit = []byte("TxSizeLimit") + var ModuleCdc = codec.NewAminoCodec(amino) + var NewRequestBatchHeightKey = []byte + var NewRequestBatchKey = []byte + var OraclePriceServiceAuthor = sdk.AccAddress(crypto.AddressHash([]byte(RegisterModuleName))) + var OraclePriceServiceProvider = sdk.AccAddress(crypto.AddressHash([]byte(RegisterModuleName))) + var OraclePriceServiceTags = []string + var OwnerEarnedFeesKey = []byte + var OwnerKey = []byte + var OwnerProviderKey = []byte + var OwnerServiceBindingKey = []byte + var PricingKey = []byte + var RequestContextBatchState_name = map[int32]string + var RequestContextBatchState_value = map[string]int32 + var RequestContextKey = []byte + var RequestContextState_name = map[int32]string + var RequestContextState_value = map[string]int32 + var RequestKey = []byte + var RequestVolumeKey = []byte + var ResponseKey = []byte + var ServiceBindingKey = []byte + var ServiceDefinitionKey = []byte + var WithdrawAddrKey = []byte + func ActionTag(action string, tagKeys ...string) string + func CheckPricing(pricing Pricing) error + func ConvertRequestID(requestIDStr string) (tmbytes.HexBytes, error) + func GenerateRequestContextID(txHash []byte, msgIndex int64) tmbytes.HexBytes + func GenerateRequestID(requestContextID tmbytes.HexBytes, requestContextBatchCounter uint64, ...) tmbytes.HexBytes + func GetActiveRequestKey(serviceName string, provider sdk.AccAddress, expirationHeight int64, ...) []byte + func GetActiveRequestKeyByID(requestID []byte) []byte + func GetActiveRequestSubspace(serviceName string, provider sdk.AccAddress) []byte + func GetActiveRequestSubspaceByReqCtx(requestContextID []byte, batchCounter uint64) []byte + func GetBindingsSubspace(serviceName string) []byte + func GetDiscountByTime(pricing Pricing, time time.Time) sdk.Dec + func GetDiscountByVolume(pricing Pricing, volume uint64) sdk.Dec + func GetEarnedFeesKey(provider sdk.AccAddress, denom string) []byte + func GetEarnedFeesSubspace(provider sdk.AccAddress) []byte + func GetExpiredRequestBatchHeightKey(requestContextID []byte) []byte + func GetExpiredRequestBatchKey(requestContextID []byte, batchExpirationHeight int64) []byte + func GetExpiredRequestBatchSubspace(batchExpirationHeight int64) []byte + func GetNewRequestBatchHeightKey(requestContextID []byte) []byte + func GetNewRequestBatchKey(requestContextID []byte, requestBatchHeight int64) []byte + func GetNewRequestBatchSubspace(requestBatchHeight int64) []byte + func GetOwnerBindingsSubspace(owner sdk.AccAddress, serviceName string) []byte + func GetOwnerEarnedFeesKey(owner sdk.AccAddress, denom string) []byte + func GetOwnerEarnedFeesSubspace(owner sdk.AccAddress) []byte + func GetOwnerKey(provider sdk.AccAddress) []byte + func GetOwnerProviderKey(owner, provider sdk.AccAddress) []byte + func GetOwnerProvidersSubspace(owner sdk.AccAddress) []byte + func GetOwnerServiceBindingKey(owner sdk.AccAddress, serviceName string, provider sdk.AccAddress) []byte + func GetPricingKey(serviceName string, provider sdk.AccAddress) []byte + func GetRequestContextKey(requestContextID []byte) []byte + func GetRequestKey(requestID []byte) []byte + func GetRequestSubspaceByReqCtx(requestContextID []byte, batchCounter uint64) []byte + func GetRequestVolumeKey(consumer sdk.AccAddress, serviceName string, provider sdk.AccAddress) []byte + func GetResponseKey(requestID []byte) []byte + func GetResponseSubspaceByReqCtx(requestContextID []byte, batchCounter uint64) []byte + func GetServiceBindingKey(serviceName string, provider sdk.AccAddress) []byte + func GetServiceDefinitionKey(serviceName string) []byte + func GetWithdrawAddrKey(provider sdk.AccAddress) []byte + func HasDuplicate(arr []string) bool + func RegisterInterfaces(registry types.InterfaceRegistry) + func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino) + func RegisterMsgServer(s grpc1.Server, srv MsgServer) + func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error + func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error + func RegisterQueryServer(s grpc1.Server, srv QueryServer) + func SplitRequestContextID(contextID tmbytes.HexBytes) (tmbytes.HexBytes, int64, error) + func SplitRequestID(requestID tmbytes.HexBytes) (tmbytes.HexBytes, uint64, int64, int16, error) + func ValidateAuthor(author string) error + func ValidateAuthorDescription(authorDescription string) error + func ValidateBindingPricing(pricing string) error + func ValidateConsumer(consumer string) error + func ValidateContextID(contextID string) error + func ValidateGenesis(data GenesisState) error + func ValidateInput(input string) error + func ValidateOptions(options string) error + func ValidateOutput(code ResultCode, output string) error + func ValidateOwner(owner string) error + func ValidatePricing(pricing string) error + func ValidateProvider(provider string) error + func ValidateProviders(providers []sdk.AccAddress) error + func ValidateProvidersCanEmpty(providers []sdk.AccAddress) error + func ValidateQoS(qos uint64) error + func ValidateRequest(serviceName string, serviceFeeCap sdk.Coins, providers []sdk.AccAddress, ...) error + func ValidateRequestContextUpdating(providers []sdk.AccAddress, serviceFeeCap sdk.Coins, timeout int64, ...) error + func ValidateRequestID(reqID string) error + func ValidateRequestInput(input string) error + func ValidateRequestInputBody(schemas string, inputBody string) error + func ValidateResponseOutput(output string) error + func ValidateResponseOutputBody(schemas string, outputBody string) error + func ValidateResponseResult(result string) error + func ValidateServiceDeposit(deposit sdk.Coins) error + func ValidateServiceDescription(svcDescription string) error + func ValidateServiceFeeCap(serviceFeeCap sdk.Coins) error + func ValidateServiceName(name string) error + func ValidateServiceSchemas(schemas string) error + func ValidateTags(tags []string) error + func ValidateWithdrawAddress(withdrawAddress string) error + type AccountKeeper interface + GetAccount func(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI + GetModuleAccount func(ctx sdk.Context, name string) authtypes.ModuleAccountI + GetModuleAddress func(name string) sdk.AccAddress + type BankKeeper interface + BurnCoins func(ctx sdk.Context, moduleName string, amt sdk.Coins) error + GetBalance func(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin + GetSupply func(ctx sdk.Context, denom string) sdk.Coin + MintCoins func(ctx sdk.Context, moduleName string, amt sdk.Coins) error + SendCoinsFromAccountToModule func(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, ...) error + SendCoinsFromModuleToAccount func(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, ...) error + SendCoinsFromModuleToModule func(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error + SpendableCoins func(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins + type BatchState struct + BatchCounter uint64 + BatchRequestCount uint32 + BatchResponseCount uint32 + BatchResponseThreshold uint32 + State RequestContextBatchState + type CompactRequest struct + ExpirationHeight int64 + Provider string + RequestContextBatchCounter uint64 + RequestContextId string + RequestHeight int64 + ServiceFee github_com_cosmos_cosmos_sdk_types.Coins + func NewCompactRequest(requestContextID tmbytes.HexBytes, batchCounter uint64, ...) CompactRequest + func (*CompactRequest) Descriptor() ([]byte, []int) + func (*CompactRequest) ProtoMessage() + func (m *CompactRequest) Marshal() (dAtA []byte, err error) + func (m *CompactRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CompactRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CompactRequest) Reset() + func (m *CompactRequest) Size() (n int) + func (m *CompactRequest) String() string + func (m *CompactRequest) Unmarshal(dAtA []byte) error + func (m *CompactRequest) XXX_DiscardUnknown() + func (m *CompactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactRequest) XXX_Merge(src proto.Message) + func (m *CompactRequest) XXX_Size() int + func (m *CompactRequest) XXX_Unmarshal(b []byte) error + type GenesisState struct + Bindings []ServiceBinding + Definitions []ServiceDefinition + Params Params + RequestContexts map[string]*RequestContext + WithdrawAddresses map[string]string + func DefaultGenesisState() *GenesisState + func NewGenesisState(params Params, definitions []ServiceDefinition, bindings []ServiceBinding, ...) *GenesisState + func (*GenesisState) Descriptor() ([]byte, []int) + func (*GenesisState) ProtoMessage() + func (m *GenesisState) GetBindings() []ServiceBinding + func (m *GenesisState) GetDefinitions() []ServiceDefinition + func (m *GenesisState) GetParams() Params + func (m *GenesisState) GetRequestContexts() map[string]*RequestContext + func (m *GenesisState) GetWithdrawAddresses() map[string]string + func (m *GenesisState) Marshal() (dAtA []byte, err error) + func (m *GenesisState) MarshalTo(dAtA []byte) (int, error) + func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GenesisState) Reset() + func (m *GenesisState) Size() (n int) + func (m *GenesisState) String() string + func (m *GenesisState) Unmarshal(dAtA []byte) error + func (m *GenesisState) XXX_DiscardUnknown() + func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GenesisState) XXX_Merge(src proto.Message) + func (m *GenesisState) XXX_Size() int + func (m *GenesisState) XXX_Unmarshal(b []byte) error + type ModuleService struct + Provider sdk.AccAddress + ReuquestService func(ctx sdk.Context, input string) (result string, output string) + ServiceName string + type MsgBindService struct + Deposit github_com_cosmos_cosmos_sdk_types.Coins + Options string + Owner string + Pricing string + Provider string + QoS uint64 + ServiceName string + func NewMsgBindService(serviceName string, provider string, deposit sdk.Coins, pricing string, ...) *MsgBindService + func (*MsgBindService) Descriptor() ([]byte, []int) + func (*MsgBindService) ProtoMessage() + func (m *MsgBindService) Marshal() (dAtA []byte, err error) + func (m *MsgBindService) MarshalTo(dAtA []byte) (int, error) + func (m *MsgBindService) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgBindService) Reset() + func (m *MsgBindService) Size() (n int) + func (m *MsgBindService) String() string + func (m *MsgBindService) Unmarshal(dAtA []byte) error + func (m *MsgBindService) XXX_DiscardUnknown() + func (m *MsgBindService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgBindService) XXX_Merge(src proto.Message) + func (m *MsgBindService) XXX_Size() int + func (m *MsgBindService) XXX_Unmarshal(b []byte) error + func (msg MsgBindService) GetSignBytes() []byte + func (msg MsgBindService) GetSigners() []sdk.AccAddress + func (msg MsgBindService) Route() string + func (msg MsgBindService) Type() string + func (msg MsgBindService) ValidateBasic() error + type MsgBindServiceResponse struct + func (*MsgBindServiceResponse) Descriptor() ([]byte, []int) + func (*MsgBindServiceResponse) ProtoMessage() + func (m *MsgBindServiceResponse) Marshal() (dAtA []byte, err error) + func (m *MsgBindServiceResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgBindServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgBindServiceResponse) Reset() + func (m *MsgBindServiceResponse) Size() (n int) + func (m *MsgBindServiceResponse) String() string + func (m *MsgBindServiceResponse) Unmarshal(dAtA []byte) error + func (m *MsgBindServiceResponse) XXX_DiscardUnknown() + func (m *MsgBindServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgBindServiceResponse) XXX_Merge(src proto.Message) + func (m *MsgBindServiceResponse) XXX_Size() int + func (m *MsgBindServiceResponse) XXX_Unmarshal(b []byte) error + type MsgCallService struct + Consumer string + Input string + Providers []string + Repeated bool + RepeatedFrequency uint64 + RepeatedTotal int64 + ServiceFeeCap github_com_cosmos_cosmos_sdk_types.Coins + ServiceName string + Timeout int64 + func NewMsgCallService(serviceName string, providers []string, consumer string, input string, ...) *MsgCallService + func (*MsgCallService) Descriptor() ([]byte, []int) + func (*MsgCallService) ProtoMessage() + func (m *MsgCallService) Marshal() (dAtA []byte, err error) + func (m *MsgCallService) MarshalTo(dAtA []byte) (int, error) + func (m *MsgCallService) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgCallService) Reset() + func (m *MsgCallService) Size() (n int) + func (m *MsgCallService) String() string + func (m *MsgCallService) Unmarshal(dAtA []byte) error + func (m *MsgCallService) XXX_DiscardUnknown() + func (m *MsgCallService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgCallService) XXX_Merge(src proto.Message) + func (m *MsgCallService) XXX_Size() int + func (m *MsgCallService) XXX_Unmarshal(b []byte) error + func (msg MsgCallService) GetSignBytes() []byte + func (msg MsgCallService) GetSigners() []sdk.AccAddress + func (msg MsgCallService) Route() string + func (msg MsgCallService) Type() string + func (msg MsgCallService) ValidateBasic() error + type MsgCallServiceResponse struct + RequestContextId string + func (*MsgCallServiceResponse) Descriptor() ([]byte, []int) + func (*MsgCallServiceResponse) ProtoMessage() + func (m *MsgCallServiceResponse) Marshal() (dAtA []byte, err error) + func (m *MsgCallServiceResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgCallServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgCallServiceResponse) Reset() + func (m *MsgCallServiceResponse) Size() (n int) + func (m *MsgCallServiceResponse) String() string + func (m *MsgCallServiceResponse) Unmarshal(dAtA []byte) error + func (m *MsgCallServiceResponse) XXX_DiscardUnknown() + func (m *MsgCallServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgCallServiceResponse) XXX_Merge(src proto.Message) + func (m *MsgCallServiceResponse) XXX_Size() int + func (m *MsgCallServiceResponse) XXX_Unmarshal(b []byte) error + type MsgClient interface + BindService func(ctx context.Context, in *MsgBindService, opts ...grpc.CallOption) (*MsgBindServiceResponse, error) + CallService func(ctx context.Context, in *MsgCallService, opts ...grpc.CallOption) (*MsgCallServiceResponse, error) + DefineService func(ctx context.Context, in *MsgDefineService, opts ...grpc.CallOption) (*MsgDefineServiceResponse, error) + DisableServiceBinding func(ctx context.Context, in *MsgDisableServiceBinding, opts ...grpc.CallOption) (*MsgDisableServiceBindingResponse, error) + EnableServiceBinding func(ctx context.Context, in *MsgEnableServiceBinding, opts ...grpc.CallOption) (*MsgEnableServiceBindingResponse, error) + KillRequestContext func(ctx context.Context, in *MsgKillRequestContext, opts ...grpc.CallOption) (*MsgKillRequestContextResponse, error) + PauseRequestContext func(ctx context.Context, in *MsgPauseRequestContext, opts ...grpc.CallOption) (*MsgPauseRequestContextResponse, error) + RefundServiceDeposit func(ctx context.Context, in *MsgRefundServiceDeposit, opts ...grpc.CallOption) (*MsgRefundServiceDepositResponse, error) + RespondService func(ctx context.Context, in *MsgRespondService, opts ...grpc.CallOption) (*MsgRespondServiceResponse, error) + SetWithdrawAddress func(ctx context.Context, in *MsgSetWithdrawAddress, opts ...grpc.CallOption) (*MsgSetWithdrawAddressResponse, error) + StartRequestContext func(ctx context.Context, in *MsgStartRequestContext, opts ...grpc.CallOption) (*MsgStartRequestContextResponse, error) + UpdateRequestContext func(ctx context.Context, in *MsgUpdateRequestContext, opts ...grpc.CallOption) (*MsgUpdateRequestContextResponse, error) + UpdateServiceBinding func(ctx context.Context, in *MsgUpdateServiceBinding, opts ...grpc.CallOption) (*MsgUpdateServiceBindingResponse, error) + WithdrawEarnedFees func(ctx context.Context, in *MsgWithdrawEarnedFees, opts ...grpc.CallOption) (*MsgWithdrawEarnedFeesResponse, error) + func NewMsgClient(cc grpc1.ClientConn) MsgClient + type MsgDefineService struct + Author string + AuthorDescription string + Description string + Name string + Schemas string + Tags []string + func NewMsgDefineService(name string, description string, tags []string, author string, ...) *MsgDefineService + func (*MsgDefineService) Descriptor() ([]byte, []int) + func (*MsgDefineService) ProtoMessage() + func (m *MsgDefineService) Marshal() (dAtA []byte, err error) + func (m *MsgDefineService) MarshalTo(dAtA []byte) (int, error) + func (m *MsgDefineService) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgDefineService) Reset() + func (m *MsgDefineService) Size() (n int) + func (m *MsgDefineService) String() string + func (m *MsgDefineService) Unmarshal(dAtA []byte) error + func (m *MsgDefineService) XXX_DiscardUnknown() + func (m *MsgDefineService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgDefineService) XXX_Merge(src proto.Message) + func (m *MsgDefineService) XXX_Size() int + func (m *MsgDefineService) XXX_Unmarshal(b []byte) error + func (msg MsgDefineService) GetSignBytes() []byte + func (msg MsgDefineService) GetSigners() []sdk.AccAddress + func (msg MsgDefineService) Route() string + func (msg MsgDefineService) Type() string + func (msg MsgDefineService) ValidateBasic() error + type MsgDefineServiceResponse struct + func (*MsgDefineServiceResponse) Descriptor() ([]byte, []int) + func (*MsgDefineServiceResponse) ProtoMessage() + func (m *MsgDefineServiceResponse) Marshal() (dAtA []byte, err error) + func (m *MsgDefineServiceResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgDefineServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgDefineServiceResponse) Reset() + func (m *MsgDefineServiceResponse) Size() (n int) + func (m *MsgDefineServiceResponse) String() string + func (m *MsgDefineServiceResponse) Unmarshal(dAtA []byte) error + func (m *MsgDefineServiceResponse) XXX_DiscardUnknown() + func (m *MsgDefineServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgDefineServiceResponse) XXX_Merge(src proto.Message) + func (m *MsgDefineServiceResponse) XXX_Size() int + func (m *MsgDefineServiceResponse) XXX_Unmarshal(b []byte) error + type MsgDisableServiceBinding struct + Owner string + Provider string + ServiceName string + func NewMsgDisableServiceBinding(serviceName, provider, owner string) *MsgDisableServiceBinding + func (*MsgDisableServiceBinding) Descriptor() ([]byte, []int) + func (*MsgDisableServiceBinding) ProtoMessage() + func (m *MsgDisableServiceBinding) Marshal() (dAtA []byte, err error) + func (m *MsgDisableServiceBinding) MarshalTo(dAtA []byte) (int, error) + func (m *MsgDisableServiceBinding) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgDisableServiceBinding) Reset() + func (m *MsgDisableServiceBinding) Size() (n int) + func (m *MsgDisableServiceBinding) String() string + func (m *MsgDisableServiceBinding) Unmarshal(dAtA []byte) error + func (m *MsgDisableServiceBinding) XXX_DiscardUnknown() + func (m *MsgDisableServiceBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgDisableServiceBinding) XXX_Merge(src proto.Message) + func (m *MsgDisableServiceBinding) XXX_Size() int + func (m *MsgDisableServiceBinding) XXX_Unmarshal(b []byte) error + func (msg MsgDisableServiceBinding) GetSignBytes() []byte + func (msg MsgDisableServiceBinding) GetSigners() []sdk.AccAddress + func (msg MsgDisableServiceBinding) Route() string + func (msg MsgDisableServiceBinding) Type() string + func (msg MsgDisableServiceBinding) ValidateBasic() error + type MsgDisableServiceBindingResponse struct + func (*MsgDisableServiceBindingResponse) Descriptor() ([]byte, []int) + func (*MsgDisableServiceBindingResponse) ProtoMessage() + func (m *MsgDisableServiceBindingResponse) Marshal() (dAtA []byte, err error) + func (m *MsgDisableServiceBindingResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgDisableServiceBindingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgDisableServiceBindingResponse) Reset() + func (m *MsgDisableServiceBindingResponse) Size() (n int) + func (m *MsgDisableServiceBindingResponse) String() string + func (m *MsgDisableServiceBindingResponse) Unmarshal(dAtA []byte) error + func (m *MsgDisableServiceBindingResponse) XXX_DiscardUnknown() + func (m *MsgDisableServiceBindingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgDisableServiceBindingResponse) XXX_Merge(src proto.Message) + func (m *MsgDisableServiceBindingResponse) XXX_Size() int + func (m *MsgDisableServiceBindingResponse) XXX_Unmarshal(b []byte) error + type MsgEnableServiceBinding struct + Deposit github_com_cosmos_cosmos_sdk_types.Coins + Owner string + Provider string + ServiceName string + func NewMsgEnableServiceBinding(serviceName string, provider string, deposit sdk.Coins, owner string) *MsgEnableServiceBinding + func (*MsgEnableServiceBinding) Descriptor() ([]byte, []int) + func (*MsgEnableServiceBinding) ProtoMessage() + func (m *MsgEnableServiceBinding) Marshal() (dAtA []byte, err error) + func (m *MsgEnableServiceBinding) MarshalTo(dAtA []byte) (int, error) + func (m *MsgEnableServiceBinding) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgEnableServiceBinding) Reset() + func (m *MsgEnableServiceBinding) Size() (n int) + func (m *MsgEnableServiceBinding) String() string + func (m *MsgEnableServiceBinding) Unmarshal(dAtA []byte) error + func (m *MsgEnableServiceBinding) XXX_DiscardUnknown() + func (m *MsgEnableServiceBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgEnableServiceBinding) XXX_Merge(src proto.Message) + func (m *MsgEnableServiceBinding) XXX_Size() int + func (m *MsgEnableServiceBinding) XXX_Unmarshal(b []byte) error + func (msg MsgEnableServiceBinding) GetSignBytes() []byte + func (msg MsgEnableServiceBinding) GetSigners() []sdk.AccAddress + func (msg MsgEnableServiceBinding) Route() string + func (msg MsgEnableServiceBinding) Type() string + func (msg MsgEnableServiceBinding) ValidateBasic() error + type MsgEnableServiceBindingResponse struct + func (*MsgEnableServiceBindingResponse) Descriptor() ([]byte, []int) + func (*MsgEnableServiceBindingResponse) ProtoMessage() + func (m *MsgEnableServiceBindingResponse) Marshal() (dAtA []byte, err error) + func (m *MsgEnableServiceBindingResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgEnableServiceBindingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgEnableServiceBindingResponse) Reset() + func (m *MsgEnableServiceBindingResponse) Size() (n int) + func (m *MsgEnableServiceBindingResponse) String() string + func (m *MsgEnableServiceBindingResponse) Unmarshal(dAtA []byte) error + func (m *MsgEnableServiceBindingResponse) XXX_DiscardUnknown() + func (m *MsgEnableServiceBindingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgEnableServiceBindingResponse) XXX_Merge(src proto.Message) + func (m *MsgEnableServiceBindingResponse) XXX_Size() int + func (m *MsgEnableServiceBindingResponse) XXX_Unmarshal(b []byte) error + type MsgKillRequestContext struct + Consumer string + RequestContextId string + func NewMsgKillRequestContext(requestContextID, consumer string) *MsgKillRequestContext + func (*MsgKillRequestContext) Descriptor() ([]byte, []int) + func (*MsgKillRequestContext) ProtoMessage() + func (m *MsgKillRequestContext) Marshal() (dAtA []byte, err error) + func (m *MsgKillRequestContext) MarshalTo(dAtA []byte) (int, error) + func (m *MsgKillRequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgKillRequestContext) Reset() + func (m *MsgKillRequestContext) Size() (n int) + func (m *MsgKillRequestContext) String() string + func (m *MsgKillRequestContext) Unmarshal(dAtA []byte) error + func (m *MsgKillRequestContext) XXX_DiscardUnknown() + func (m *MsgKillRequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgKillRequestContext) XXX_Merge(src proto.Message) + func (m *MsgKillRequestContext) XXX_Size() int + func (m *MsgKillRequestContext) XXX_Unmarshal(b []byte) error + func (msg MsgKillRequestContext) GetSignBytes() []byte + func (msg MsgKillRequestContext) GetSigners() []sdk.AccAddress + func (msg MsgKillRequestContext) Route() string + func (msg MsgKillRequestContext) Type() string + func (msg MsgKillRequestContext) ValidateBasic() error + type MsgKillRequestContextResponse struct + func (*MsgKillRequestContextResponse) Descriptor() ([]byte, []int) + func (*MsgKillRequestContextResponse) ProtoMessage() + func (m *MsgKillRequestContextResponse) Marshal() (dAtA []byte, err error) + func (m *MsgKillRequestContextResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgKillRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgKillRequestContextResponse) Reset() + func (m *MsgKillRequestContextResponse) Size() (n int) + func (m *MsgKillRequestContextResponse) String() string + func (m *MsgKillRequestContextResponse) Unmarshal(dAtA []byte) error + func (m *MsgKillRequestContextResponse) XXX_DiscardUnknown() + func (m *MsgKillRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgKillRequestContextResponse) XXX_Merge(src proto.Message) + func (m *MsgKillRequestContextResponse) XXX_Size() int + func (m *MsgKillRequestContextResponse) XXX_Unmarshal(b []byte) error + type MsgPauseRequestContext struct + Consumer string + RequestContextId string + func NewMsgPauseRequestContext(requestContextID, consumer string) *MsgPauseRequestContext + func (*MsgPauseRequestContext) Descriptor() ([]byte, []int) + func (*MsgPauseRequestContext) ProtoMessage() + func (m *MsgPauseRequestContext) Marshal() (dAtA []byte, err error) + func (m *MsgPauseRequestContext) MarshalTo(dAtA []byte) (int, error) + func (m *MsgPauseRequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgPauseRequestContext) Reset() + func (m *MsgPauseRequestContext) Size() (n int) + func (m *MsgPauseRequestContext) String() string + func (m *MsgPauseRequestContext) Unmarshal(dAtA []byte) error + func (m *MsgPauseRequestContext) XXX_DiscardUnknown() + func (m *MsgPauseRequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgPauseRequestContext) XXX_Merge(src proto.Message) + func (m *MsgPauseRequestContext) XXX_Size() int + func (m *MsgPauseRequestContext) XXX_Unmarshal(b []byte) error + func (msg MsgPauseRequestContext) GetSignBytes() []byte + func (msg MsgPauseRequestContext) GetSigners() []sdk.AccAddress + func (msg MsgPauseRequestContext) Route() string + func (msg MsgPauseRequestContext) Type() string + func (msg MsgPauseRequestContext) ValidateBasic() error + type MsgPauseRequestContextResponse struct + func (*MsgPauseRequestContextResponse) Descriptor() ([]byte, []int) + func (*MsgPauseRequestContextResponse) ProtoMessage() + func (m *MsgPauseRequestContextResponse) Marshal() (dAtA []byte, err error) + func (m *MsgPauseRequestContextResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgPauseRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgPauseRequestContextResponse) Reset() + func (m *MsgPauseRequestContextResponse) Size() (n int) + func (m *MsgPauseRequestContextResponse) String() string + func (m *MsgPauseRequestContextResponse) Unmarshal(dAtA []byte) error + func (m *MsgPauseRequestContextResponse) XXX_DiscardUnknown() + func (m *MsgPauseRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgPauseRequestContextResponse) XXX_Merge(src proto.Message) + func (m *MsgPauseRequestContextResponse) XXX_Size() int + func (m *MsgPauseRequestContextResponse) XXX_Unmarshal(b []byte) error + type MsgRefundServiceDeposit struct + Owner string + Provider string + ServiceName string + func NewMsgRefundServiceDeposit(serviceName, provider, owner string) *MsgRefundServiceDeposit + func (*MsgRefundServiceDeposit) Descriptor() ([]byte, []int) + func (*MsgRefundServiceDeposit) ProtoMessage() + func (m *MsgRefundServiceDeposit) Marshal() (dAtA []byte, err error) + func (m *MsgRefundServiceDeposit) MarshalTo(dAtA []byte) (int, error) + func (m *MsgRefundServiceDeposit) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgRefundServiceDeposit) Reset() + func (m *MsgRefundServiceDeposit) Size() (n int) + func (m *MsgRefundServiceDeposit) String() string + func (m *MsgRefundServiceDeposit) Unmarshal(dAtA []byte) error + func (m *MsgRefundServiceDeposit) XXX_DiscardUnknown() + func (m *MsgRefundServiceDeposit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgRefundServiceDeposit) XXX_Merge(src proto.Message) + func (m *MsgRefundServiceDeposit) XXX_Size() int + func (m *MsgRefundServiceDeposit) XXX_Unmarshal(b []byte) error + func (msg MsgRefundServiceDeposit) GetSignBytes() []byte + func (msg MsgRefundServiceDeposit) GetSigners() []sdk.AccAddress + func (msg MsgRefundServiceDeposit) Route() string + func (msg MsgRefundServiceDeposit) Type() string + func (msg MsgRefundServiceDeposit) ValidateBasic() error + type MsgRefundServiceDepositResponse struct + func (*MsgRefundServiceDepositResponse) Descriptor() ([]byte, []int) + func (*MsgRefundServiceDepositResponse) ProtoMessage() + func (m *MsgRefundServiceDepositResponse) Marshal() (dAtA []byte, err error) + func (m *MsgRefundServiceDepositResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgRefundServiceDepositResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgRefundServiceDepositResponse) Reset() + func (m *MsgRefundServiceDepositResponse) Size() (n int) + func (m *MsgRefundServiceDepositResponse) String() string + func (m *MsgRefundServiceDepositResponse) Unmarshal(dAtA []byte) error + func (m *MsgRefundServiceDepositResponse) XXX_DiscardUnknown() + func (m *MsgRefundServiceDepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgRefundServiceDepositResponse) XXX_Merge(src proto.Message) + func (m *MsgRefundServiceDepositResponse) XXX_Size() int + func (m *MsgRefundServiceDepositResponse) XXX_Unmarshal(b []byte) error + type MsgRespondService struct + Output string + Provider string + RequestId string + Result string + func NewMsgRespondService(requestID, provider, result, output string) *MsgRespondService + func (*MsgRespondService) Descriptor() ([]byte, []int) + func (*MsgRespondService) ProtoMessage() + func (m *MsgRespondService) Marshal() (dAtA []byte, err error) + func (m *MsgRespondService) MarshalTo(dAtA []byte) (int, error) + func (m *MsgRespondService) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgRespondService) Reset() + func (m *MsgRespondService) Size() (n int) + func (m *MsgRespondService) String() string + func (m *MsgRespondService) Unmarshal(dAtA []byte) error + func (m *MsgRespondService) XXX_DiscardUnknown() + func (m *MsgRespondService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgRespondService) XXX_Merge(src proto.Message) + func (m *MsgRespondService) XXX_Size() int + func (m *MsgRespondService) XXX_Unmarshal(b []byte) error + func (msg MsgRespondService) GetSignBytes() []byte + func (msg MsgRespondService) GetSigners() []sdk.AccAddress + func (msg MsgRespondService) Route() string + func (msg MsgRespondService) Type() string + func (msg MsgRespondService) ValidateBasic() error + type MsgRespondServiceResponse struct + func (*MsgRespondServiceResponse) Descriptor() ([]byte, []int) + func (*MsgRespondServiceResponse) ProtoMessage() + func (m *MsgRespondServiceResponse) Marshal() (dAtA []byte, err error) + func (m *MsgRespondServiceResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgRespondServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgRespondServiceResponse) Reset() + func (m *MsgRespondServiceResponse) Size() (n int) + func (m *MsgRespondServiceResponse) String() string + func (m *MsgRespondServiceResponse) Unmarshal(dAtA []byte) error + func (m *MsgRespondServiceResponse) XXX_DiscardUnknown() + func (m *MsgRespondServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgRespondServiceResponse) XXX_Merge(src proto.Message) + func (m *MsgRespondServiceResponse) XXX_Size() int + func (m *MsgRespondServiceResponse) XXX_Unmarshal(b []byte) error + type MsgServer interface + BindService func(context.Context, *MsgBindService) (*MsgBindServiceResponse, error) + CallService func(context.Context, *MsgCallService) (*MsgCallServiceResponse, error) + DefineService func(context.Context, *MsgDefineService) (*MsgDefineServiceResponse, error) + DisableServiceBinding func(context.Context, *MsgDisableServiceBinding) (*MsgDisableServiceBindingResponse, error) + EnableServiceBinding func(context.Context, *MsgEnableServiceBinding) (*MsgEnableServiceBindingResponse, error) + KillRequestContext func(context.Context, *MsgKillRequestContext) (*MsgKillRequestContextResponse, error) + PauseRequestContext func(context.Context, *MsgPauseRequestContext) (*MsgPauseRequestContextResponse, error) + RefundServiceDeposit func(context.Context, *MsgRefundServiceDeposit) (*MsgRefundServiceDepositResponse, error) + RespondService func(context.Context, *MsgRespondService) (*MsgRespondServiceResponse, error) + SetWithdrawAddress func(context.Context, *MsgSetWithdrawAddress) (*MsgSetWithdrawAddressResponse, error) + StartRequestContext func(context.Context, *MsgStartRequestContext) (*MsgStartRequestContextResponse, error) + UpdateRequestContext func(context.Context, *MsgUpdateRequestContext) (*MsgUpdateRequestContextResponse, error) + UpdateServiceBinding func(context.Context, *MsgUpdateServiceBinding) (*MsgUpdateServiceBindingResponse, error) + WithdrawEarnedFees func(context.Context, *MsgWithdrawEarnedFees) (*MsgWithdrawEarnedFeesResponse, error) + type MsgSetWithdrawAddress struct + Owner string + WithdrawAddress string + func NewMsgSetWithdrawAddress(owner, withdrawAddr string) *MsgSetWithdrawAddress + func (*MsgSetWithdrawAddress) Descriptor() ([]byte, []int) + func (*MsgSetWithdrawAddress) ProtoMessage() + func (m *MsgSetWithdrawAddress) Marshal() (dAtA []byte, err error) + func (m *MsgSetWithdrawAddress) MarshalTo(dAtA []byte) (int, error) + func (m *MsgSetWithdrawAddress) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgSetWithdrawAddress) Reset() + func (m *MsgSetWithdrawAddress) Size() (n int) + func (m *MsgSetWithdrawAddress) String() string + func (m *MsgSetWithdrawAddress) Unmarshal(dAtA []byte) error + func (m *MsgSetWithdrawAddress) XXX_DiscardUnknown() + func (m *MsgSetWithdrawAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgSetWithdrawAddress) XXX_Merge(src proto.Message) + func (m *MsgSetWithdrawAddress) XXX_Size() int + func (m *MsgSetWithdrawAddress) XXX_Unmarshal(b []byte) error + func (msg MsgSetWithdrawAddress) GetSignBytes() []byte + func (msg MsgSetWithdrawAddress) GetSigners() []sdk.AccAddress + func (msg MsgSetWithdrawAddress) Normalize() MsgSetWithdrawAddress + func (msg MsgSetWithdrawAddress) Route() string + func (msg MsgSetWithdrawAddress) Type() string + func (msg MsgSetWithdrawAddress) ValidateBasic() error + type MsgSetWithdrawAddressResponse struct + func (*MsgSetWithdrawAddressResponse) Descriptor() ([]byte, []int) + func (*MsgSetWithdrawAddressResponse) ProtoMessage() + func (m *MsgSetWithdrawAddressResponse) Marshal() (dAtA []byte, err error) + func (m *MsgSetWithdrawAddressResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgSetWithdrawAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgSetWithdrawAddressResponse) Reset() + func (m *MsgSetWithdrawAddressResponse) Size() (n int) + func (m *MsgSetWithdrawAddressResponse) String() string + func (m *MsgSetWithdrawAddressResponse) Unmarshal(dAtA []byte) error + func (m *MsgSetWithdrawAddressResponse) XXX_DiscardUnknown() + func (m *MsgSetWithdrawAddressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgSetWithdrawAddressResponse) XXX_Merge(src proto.Message) + func (m *MsgSetWithdrawAddressResponse) XXX_Size() int + func (m *MsgSetWithdrawAddressResponse) XXX_Unmarshal(b []byte) error + type MsgStartRequestContext struct + Consumer string + RequestContextId string + func NewMsgStartRequestContext(requestContextID, consumer string) *MsgStartRequestContext + func (*MsgStartRequestContext) Descriptor() ([]byte, []int) + func (*MsgStartRequestContext) ProtoMessage() + func (m *MsgStartRequestContext) Marshal() (dAtA []byte, err error) + func (m *MsgStartRequestContext) MarshalTo(dAtA []byte) (int, error) + func (m *MsgStartRequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgStartRequestContext) Reset() + func (m *MsgStartRequestContext) Size() (n int) + func (m *MsgStartRequestContext) String() string + func (m *MsgStartRequestContext) Unmarshal(dAtA []byte) error + func (m *MsgStartRequestContext) XXX_DiscardUnknown() + func (m *MsgStartRequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgStartRequestContext) XXX_Merge(src proto.Message) + func (m *MsgStartRequestContext) XXX_Size() int + func (m *MsgStartRequestContext) XXX_Unmarshal(b []byte) error + func (msg MsgStartRequestContext) GetSignBytes() []byte + func (msg MsgStartRequestContext) GetSigners() []sdk.AccAddress + func (msg MsgStartRequestContext) Route() string + func (msg MsgStartRequestContext) Type() string + func (msg MsgStartRequestContext) ValidateBasic() error + type MsgStartRequestContextResponse struct + func (*MsgStartRequestContextResponse) Descriptor() ([]byte, []int) + func (*MsgStartRequestContextResponse) ProtoMessage() + func (m *MsgStartRequestContextResponse) Marshal() (dAtA []byte, err error) + func (m *MsgStartRequestContextResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgStartRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgStartRequestContextResponse) Reset() + func (m *MsgStartRequestContextResponse) Size() (n int) + func (m *MsgStartRequestContextResponse) String() string + func (m *MsgStartRequestContextResponse) Unmarshal(dAtA []byte) error + func (m *MsgStartRequestContextResponse) XXX_DiscardUnknown() + func (m *MsgStartRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgStartRequestContextResponse) XXX_Merge(src proto.Message) + func (m *MsgStartRequestContextResponse) XXX_Size() int + func (m *MsgStartRequestContextResponse) XXX_Unmarshal(b []byte) error + type MsgUpdateRequestContext struct + Consumer string + Providers []string + RepeatedFrequency uint64 + RepeatedTotal int64 + RequestContextId string + ServiceFeeCap github_com_cosmos_cosmos_sdk_types.Coins + Timeout int64 + func NewMsgUpdateRequestContext(requestContextID string, providers []string, serviceFeeCap sdk.Coins, ...) *MsgUpdateRequestContext + func (*MsgUpdateRequestContext) Descriptor() ([]byte, []int) + func (*MsgUpdateRequestContext) ProtoMessage() + func (m *MsgUpdateRequestContext) Marshal() (dAtA []byte, err error) + func (m *MsgUpdateRequestContext) MarshalTo(dAtA []byte) (int, error) + func (m *MsgUpdateRequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgUpdateRequestContext) Reset() + func (m *MsgUpdateRequestContext) Size() (n int) + func (m *MsgUpdateRequestContext) String() string + func (m *MsgUpdateRequestContext) Unmarshal(dAtA []byte) error + func (m *MsgUpdateRequestContext) XXX_DiscardUnknown() + func (m *MsgUpdateRequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgUpdateRequestContext) XXX_Merge(src proto.Message) + func (m *MsgUpdateRequestContext) XXX_Size() int + func (m *MsgUpdateRequestContext) XXX_Unmarshal(b []byte) error + func (msg MsgUpdateRequestContext) GetSignBytes() []byte + func (msg MsgUpdateRequestContext) GetSigners() []sdk.AccAddress + func (msg MsgUpdateRequestContext) Route() string + func (msg MsgUpdateRequestContext) Type() string + func (msg MsgUpdateRequestContext) ValidateBasic() error + type MsgUpdateRequestContextResponse struct + func (*MsgUpdateRequestContextResponse) Descriptor() ([]byte, []int) + func (*MsgUpdateRequestContextResponse) ProtoMessage() + func (m *MsgUpdateRequestContextResponse) Marshal() (dAtA []byte, err error) + func (m *MsgUpdateRequestContextResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgUpdateRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgUpdateRequestContextResponse) Reset() + func (m *MsgUpdateRequestContextResponse) Size() (n int) + func (m *MsgUpdateRequestContextResponse) String() string + func (m *MsgUpdateRequestContextResponse) Unmarshal(dAtA []byte) error + func (m *MsgUpdateRequestContextResponse) XXX_DiscardUnknown() + func (m *MsgUpdateRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgUpdateRequestContextResponse) XXX_Merge(src proto.Message) + func (m *MsgUpdateRequestContextResponse) XXX_Size() int + func (m *MsgUpdateRequestContextResponse) XXX_Unmarshal(b []byte) error + type MsgUpdateServiceBinding struct + Deposit github_com_cosmos_cosmos_sdk_types.Coins + Options string + Owner string + Pricing string + Provider string + QoS uint64 + ServiceName string + func NewMsgUpdateServiceBinding(serviceName string, provider string, deposit sdk.Coins, pricing string, ...) *MsgUpdateServiceBinding + func (*MsgUpdateServiceBinding) Descriptor() ([]byte, []int) + func (*MsgUpdateServiceBinding) ProtoMessage() + func (m *MsgUpdateServiceBinding) Marshal() (dAtA []byte, err error) + func (m *MsgUpdateServiceBinding) MarshalTo(dAtA []byte) (int, error) + func (m *MsgUpdateServiceBinding) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgUpdateServiceBinding) Reset() + func (m *MsgUpdateServiceBinding) Size() (n int) + func (m *MsgUpdateServiceBinding) String() string + func (m *MsgUpdateServiceBinding) Unmarshal(dAtA []byte) error + func (m *MsgUpdateServiceBinding) XXX_DiscardUnknown() + func (m *MsgUpdateServiceBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgUpdateServiceBinding) XXX_Merge(src proto.Message) + func (m *MsgUpdateServiceBinding) XXX_Size() int + func (m *MsgUpdateServiceBinding) XXX_Unmarshal(b []byte) error + func (msg MsgUpdateServiceBinding) GetSignBytes() []byte + func (msg MsgUpdateServiceBinding) GetSigners() []sdk.AccAddress + func (msg MsgUpdateServiceBinding) Route() string + func (msg MsgUpdateServiceBinding) Type() string + func (msg MsgUpdateServiceBinding) ValidateBasic() error + type MsgUpdateServiceBindingResponse struct + func (*MsgUpdateServiceBindingResponse) Descriptor() ([]byte, []int) + func (*MsgUpdateServiceBindingResponse) ProtoMessage() + func (m *MsgUpdateServiceBindingResponse) Marshal() (dAtA []byte, err error) + func (m *MsgUpdateServiceBindingResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgUpdateServiceBindingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgUpdateServiceBindingResponse) Reset() + func (m *MsgUpdateServiceBindingResponse) Size() (n int) + func (m *MsgUpdateServiceBindingResponse) String() string + func (m *MsgUpdateServiceBindingResponse) Unmarshal(dAtA []byte) error + func (m *MsgUpdateServiceBindingResponse) XXX_DiscardUnknown() + func (m *MsgUpdateServiceBindingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgUpdateServiceBindingResponse) XXX_Merge(src proto.Message) + func (m *MsgUpdateServiceBindingResponse) XXX_Size() int + func (m *MsgUpdateServiceBindingResponse) XXX_Unmarshal(b []byte) error + type MsgWithdrawEarnedFees struct + Owner string + Provider string + func NewMsgWithdrawEarnedFees(owner, provider string) *MsgWithdrawEarnedFees + func (*MsgWithdrawEarnedFees) Descriptor() ([]byte, []int) + func (*MsgWithdrawEarnedFees) ProtoMessage() + func (m *MsgWithdrawEarnedFees) Marshal() (dAtA []byte, err error) + func (m *MsgWithdrawEarnedFees) MarshalTo(dAtA []byte) (int, error) + func (m *MsgWithdrawEarnedFees) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgWithdrawEarnedFees) Reset() + func (m *MsgWithdrawEarnedFees) Size() (n int) + func (m *MsgWithdrawEarnedFees) String() string + func (m *MsgWithdrawEarnedFees) Unmarshal(dAtA []byte) error + func (m *MsgWithdrawEarnedFees) XXX_DiscardUnknown() + func (m *MsgWithdrawEarnedFees) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgWithdrawEarnedFees) XXX_Merge(src proto.Message) + func (m *MsgWithdrawEarnedFees) XXX_Size() int + func (m *MsgWithdrawEarnedFees) XXX_Unmarshal(b []byte) error + func (msg MsgWithdrawEarnedFees) GetSignBytes() []byte + func (msg MsgWithdrawEarnedFees) GetSigners() []sdk.AccAddress + func (msg MsgWithdrawEarnedFees) Route() string + func (msg MsgWithdrawEarnedFees) Type() string + func (msg MsgWithdrawEarnedFees) ValidateBasic() error + type MsgWithdrawEarnedFeesResponse struct + func (*MsgWithdrawEarnedFeesResponse) Descriptor() ([]byte, []int) + func (*MsgWithdrawEarnedFeesResponse) ProtoMessage() + func (m *MsgWithdrawEarnedFeesResponse) Marshal() (dAtA []byte, err error) + func (m *MsgWithdrawEarnedFeesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgWithdrawEarnedFeesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgWithdrawEarnedFeesResponse) Reset() + func (m *MsgWithdrawEarnedFeesResponse) Size() (n int) + func (m *MsgWithdrawEarnedFeesResponse) String() string + func (m *MsgWithdrawEarnedFeesResponse) Unmarshal(dAtA []byte) error + func (m *MsgWithdrawEarnedFeesResponse) XXX_DiscardUnknown() + func (m *MsgWithdrawEarnedFeesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgWithdrawEarnedFeesResponse) XXX_Merge(src proto.Message) + func (m *MsgWithdrawEarnedFeesResponse) XXX_Size() int + func (m *MsgWithdrawEarnedFeesResponse) XXX_Unmarshal(b []byte) error + type Params struct + ArbitrationTimeLimit time.Duration + BaseDenom string + ComplaintRetrospect time.Duration + MaxRequestTimeout int64 + MinDeposit github_com_cosmos_cosmos_sdk_types.Coins + MinDepositMultiple int64 + RestrictedServiceFeeDenom bool + ServiceFeeTax github_com_cosmos_cosmos_sdk_types.Dec + SlashFraction github_com_cosmos_cosmos_sdk_types.Dec + TxSizeLimit uint64 + func DefaultParams() Params + func NewParams(maxRequestTimeout, minDepositMultiple int64, minDeposit sdk.Coins, ...) Params + func (*Params) Descriptor() ([]byte, []int) + func (*Params) ProtoMessage() + func (m *Params) Marshal() (dAtA []byte, err error) + func (m *Params) MarshalTo(dAtA []byte) (int, error) + func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Params) Reset() + func (m *Params) Size() (n int) + func (m *Params) Unmarshal(dAtA []byte) error + func (m *Params) XXX_DiscardUnknown() + func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Params) XXX_Merge(src proto.Message) + func (m *Params) XXX_Size() int + func (m *Params) XXX_Unmarshal(b []byte) error + func (p *Params) ParamSetPairs() paramstypes.ParamSetPairs + func (p Params) String() string + func (p Params) Validate() error + func (this *Params) Equal(that interface{}) bool + type Pricing struct + Price github_com_cosmos_cosmos_sdk_types.Coins + PromotionsByTime []PromotionByTime + PromotionsByVolume []PromotionByVolume + func ParsePricing(pricing string) (p Pricing, err error) + func (*Pricing) Descriptor() ([]byte, []int) + func (*Pricing) ProtoMessage() + func (m *Pricing) Marshal() (dAtA []byte, err error) + func (m *Pricing) MarshalTo(dAtA []byte) (int, error) + func (m *Pricing) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Pricing) Reset() + func (m *Pricing) Size() (n int) + func (m *Pricing) String() string + func (m *Pricing) Unmarshal(dAtA []byte) error + func (m *Pricing) XXX_DiscardUnknown() + func (m *Pricing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Pricing) XXX_Merge(src proto.Message) + func (m *Pricing) XXX_Size() int + func (m *Pricing) XXX_Unmarshal(b []byte) error + type PromotionByTime struct + Discount github_com_cosmos_cosmos_sdk_types.Dec + EndTime time.Time + StartTime time.Time + func (*PromotionByTime) Descriptor() ([]byte, []int) + func (*PromotionByTime) ProtoMessage() + func (m *PromotionByTime) Marshal() (dAtA []byte, err error) + func (m *PromotionByTime) MarshalTo(dAtA []byte) (int, error) + func (m *PromotionByTime) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PromotionByTime) Reset() + func (m *PromotionByTime) Size() (n int) + func (m *PromotionByTime) String() string + func (m *PromotionByTime) Unmarshal(dAtA []byte) error + func (m *PromotionByTime) XXX_DiscardUnknown() + func (m *PromotionByTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PromotionByTime) XXX_Merge(src proto.Message) + func (m *PromotionByTime) XXX_Size() int + func (m *PromotionByTime) XXX_Unmarshal(b []byte) error + type PromotionByVolume struct + Discount github_com_cosmos_cosmos_sdk_types.Dec + Volume uint64 + func (*PromotionByVolume) Descriptor() ([]byte, []int) + func (*PromotionByVolume) ProtoMessage() + func (m *PromotionByVolume) Marshal() (dAtA []byte, err error) + func (m *PromotionByVolume) MarshalTo(dAtA []byte) (int, error) + func (m *PromotionByVolume) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PromotionByVolume) Reset() + func (m *PromotionByVolume) Size() (n int) + func (m *PromotionByVolume) String() string + func (m *PromotionByVolume) Unmarshal(dAtA []byte) error + func (m *PromotionByVolume) XXX_DiscardUnknown() + func (m *PromotionByVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PromotionByVolume) XXX_Merge(src proto.Message) + func (m *PromotionByVolume) XXX_Size() int + func (m *PromotionByVolume) XXX_Unmarshal(b []byte) error + type QueryBindingParams struct + Provider sdk.AccAddress + ServiceName string + type QueryBindingRequest struct + Provider string + ServiceName string + func (*QueryBindingRequest) Descriptor() ([]byte, []int) + func (*QueryBindingRequest) ProtoMessage() + func (m *QueryBindingRequest) GetProvider() string + func (m *QueryBindingRequest) GetServiceName() string + func (m *QueryBindingRequest) Marshal() (dAtA []byte, err error) + func (m *QueryBindingRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryBindingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryBindingRequest) Reset() + func (m *QueryBindingRequest) Size() (n int) + func (m *QueryBindingRequest) String() string + func (m *QueryBindingRequest) Unmarshal(dAtA []byte) error + func (m *QueryBindingRequest) XXX_DiscardUnknown() + func (m *QueryBindingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryBindingRequest) XXX_Merge(src proto.Message) + func (m *QueryBindingRequest) XXX_Size() int + func (m *QueryBindingRequest) XXX_Unmarshal(b []byte) error + type QueryBindingResponse struct + ServiceBinding *ServiceBinding + func (*QueryBindingResponse) Descriptor() ([]byte, []int) + func (*QueryBindingResponse) ProtoMessage() + func (m *QueryBindingResponse) GetServiceBinding() *ServiceBinding + func (m *QueryBindingResponse) Marshal() (dAtA []byte, err error) + func (m *QueryBindingResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryBindingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryBindingResponse) Reset() + func (m *QueryBindingResponse) Size() (n int) + func (m *QueryBindingResponse) String() string + func (m *QueryBindingResponse) Unmarshal(dAtA []byte) error + func (m *QueryBindingResponse) XXX_DiscardUnknown() + func (m *QueryBindingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryBindingResponse) XXX_Merge(src proto.Message) + func (m *QueryBindingResponse) XXX_Size() int + func (m *QueryBindingResponse) XXX_Unmarshal(b []byte) error + type QueryBindingsParams struct + Owner sdk.AccAddress + ServiceName string + type QueryBindingsRequest struct + Owner string + Pagination *query.PageRequest + ServiceName string + func (*QueryBindingsRequest) Descriptor() ([]byte, []int) + func (*QueryBindingsRequest) ProtoMessage() + func (m *QueryBindingsRequest) GetOwner() string + func (m *QueryBindingsRequest) GetPagination() *query.PageRequest + func (m *QueryBindingsRequest) GetServiceName() string + func (m *QueryBindingsRequest) Marshal() (dAtA []byte, err error) + func (m *QueryBindingsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryBindingsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryBindingsRequest) Reset() + func (m *QueryBindingsRequest) Size() (n int) + func (m *QueryBindingsRequest) String() string + func (m *QueryBindingsRequest) Unmarshal(dAtA []byte) error + func (m *QueryBindingsRequest) XXX_DiscardUnknown() + func (m *QueryBindingsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryBindingsRequest) XXX_Merge(src proto.Message) + func (m *QueryBindingsRequest) XXX_Size() int + func (m *QueryBindingsRequest) XXX_Unmarshal(b []byte) error + type QueryBindingsResponse struct + Pagination *query.PageResponse + ServiceBindings []*ServiceBinding + func (*QueryBindingsResponse) Descriptor() ([]byte, []int) + func (*QueryBindingsResponse) ProtoMessage() + func (m *QueryBindingsResponse) GetPagination() *query.PageResponse + func (m *QueryBindingsResponse) GetServiceBindings() []*ServiceBinding + func (m *QueryBindingsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryBindingsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryBindingsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryBindingsResponse) Reset() + func (m *QueryBindingsResponse) Size() (n int) + func (m *QueryBindingsResponse) String() string + func (m *QueryBindingsResponse) Unmarshal(dAtA []byte) error + func (m *QueryBindingsResponse) XXX_DiscardUnknown() + func (m *QueryBindingsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryBindingsResponse) XXX_Merge(src proto.Message) + func (m *QueryBindingsResponse) XXX_Size() int + func (m *QueryBindingsResponse) XXX_Unmarshal(b []byte) error + type QueryClient interface + Binding func(ctx context.Context, in *QueryBindingRequest, opts ...grpc.CallOption) (*QueryBindingResponse, error) + Bindings func(ctx context.Context, in *QueryBindingsRequest, opts ...grpc.CallOption) (*QueryBindingsResponse, error) + Definition func(ctx context.Context, in *QueryDefinitionRequest, opts ...grpc.CallOption) (*QueryDefinitionResponse, error) + EarnedFees func(ctx context.Context, in *QueryEarnedFeesRequest, opts ...grpc.CallOption) (*QueryEarnedFeesResponse, error) + Params func(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error) + Request func(ctx context.Context, in *QueryRequestRequest, opts ...grpc.CallOption) (*QueryRequestResponse, error) + RequestContext func(ctx context.Context, in *QueryRequestContextRequest, opts ...grpc.CallOption) (*QueryRequestContextResponse, error) + Requests func(ctx context.Context, in *QueryRequestsRequest, opts ...grpc.CallOption) (*QueryRequestsResponse, error) + RequestsByReqCtx func(ctx context.Context, in *QueryRequestsByReqCtxRequest, opts ...grpc.CallOption) (*QueryRequestsByReqCtxResponse, error) + Response func(ctx context.Context, in *QueryResponseRequest, opts ...grpc.CallOption) (*QueryResponseResponse, error) + Responses func(ctx context.Context, in *QueryResponsesRequest, opts ...grpc.CallOption) (*QueryResponsesResponse, error) + Schema func(ctx context.Context, in *QuerySchemaRequest, opts ...grpc.CallOption) (*QuerySchemaResponse, error) + WithdrawAddress func(ctx context.Context, in *QueryWithdrawAddressRequest, opts ...grpc.CallOption) (*QueryWithdrawAddressResponse, error) + func NewQueryClient(cc grpc1.ClientConn) QueryClient + type QueryDefinitionParams struct + ServiceName string + type QueryDefinitionRequest struct + ServiceName string + func (*QueryDefinitionRequest) Descriptor() ([]byte, []int) + func (*QueryDefinitionRequest) ProtoMessage() + func (m *QueryDefinitionRequest) GetServiceName() string + func (m *QueryDefinitionRequest) Marshal() (dAtA []byte, err error) + func (m *QueryDefinitionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryDefinitionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryDefinitionRequest) Reset() + func (m *QueryDefinitionRequest) Size() (n int) + func (m *QueryDefinitionRequest) String() string + func (m *QueryDefinitionRequest) Unmarshal(dAtA []byte) error + func (m *QueryDefinitionRequest) XXX_DiscardUnknown() + func (m *QueryDefinitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryDefinitionRequest) XXX_Merge(src proto.Message) + func (m *QueryDefinitionRequest) XXX_Size() int + func (m *QueryDefinitionRequest) XXX_Unmarshal(b []byte) error + type QueryDefinitionResponse struct + ServiceDefinition *ServiceDefinition + func (*QueryDefinitionResponse) Descriptor() ([]byte, []int) + func (*QueryDefinitionResponse) ProtoMessage() + func (m *QueryDefinitionResponse) GetServiceDefinition() *ServiceDefinition + func (m *QueryDefinitionResponse) Marshal() (dAtA []byte, err error) + func (m *QueryDefinitionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryDefinitionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryDefinitionResponse) Reset() + func (m *QueryDefinitionResponse) Size() (n int) + func (m *QueryDefinitionResponse) String() string + func (m *QueryDefinitionResponse) Unmarshal(dAtA []byte) error + func (m *QueryDefinitionResponse) XXX_DiscardUnknown() + func (m *QueryDefinitionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryDefinitionResponse) XXX_Merge(src proto.Message) + func (m *QueryDefinitionResponse) XXX_Size() int + func (m *QueryDefinitionResponse) XXX_Unmarshal(b []byte) error + type QueryEarnedFeesParams struct + Provider sdk.AccAddress + type QueryEarnedFeesRequest struct + Provider string + func (*QueryEarnedFeesRequest) Descriptor() ([]byte, []int) + func (*QueryEarnedFeesRequest) ProtoMessage() + func (m *QueryEarnedFeesRequest) GetProvider() string + func (m *QueryEarnedFeesRequest) Marshal() (dAtA []byte, err error) + func (m *QueryEarnedFeesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryEarnedFeesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryEarnedFeesRequest) Reset() + func (m *QueryEarnedFeesRequest) Size() (n int) + func (m *QueryEarnedFeesRequest) String() string + func (m *QueryEarnedFeesRequest) Unmarshal(dAtA []byte) error + func (m *QueryEarnedFeesRequest) XXX_DiscardUnknown() + func (m *QueryEarnedFeesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryEarnedFeesRequest) XXX_Merge(src proto.Message) + func (m *QueryEarnedFeesRequest) XXX_Size() int + func (m *QueryEarnedFeesRequest) XXX_Unmarshal(b []byte) error + type QueryEarnedFeesResponse struct + Fees github_com_cosmos_cosmos_sdk_types.Coins + func (*QueryEarnedFeesResponse) Descriptor() ([]byte, []int) + func (*QueryEarnedFeesResponse) ProtoMessage() + func (m *QueryEarnedFeesResponse) GetFees() github_com_cosmos_cosmos_sdk_types.Coins + func (m *QueryEarnedFeesResponse) Marshal() (dAtA []byte, err error) + func (m *QueryEarnedFeesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryEarnedFeesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryEarnedFeesResponse) Reset() + func (m *QueryEarnedFeesResponse) Size() (n int) + func (m *QueryEarnedFeesResponse) String() string + func (m *QueryEarnedFeesResponse) Unmarshal(dAtA []byte) error + func (m *QueryEarnedFeesResponse) XXX_DiscardUnknown() + func (m *QueryEarnedFeesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryEarnedFeesResponse) XXX_Merge(src proto.Message) + func (m *QueryEarnedFeesResponse) XXX_Size() int + func (m *QueryEarnedFeesResponse) XXX_Unmarshal(b []byte) error + type QueryParamsRequest struct + func (*QueryParamsRequest) Descriptor() ([]byte, []int) + func (*QueryParamsRequest) ProtoMessage() + func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error) + func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryParamsRequest) Reset() + func (m *QueryParamsRequest) Size() (n int) + func (m *QueryParamsRequest) String() string + func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error + func (m *QueryParamsRequest) XXX_DiscardUnknown() + func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryParamsRequest) XXX_Merge(src proto.Message) + func (m *QueryParamsRequest) XXX_Size() int + func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error + type QueryParamsResponse struct + Params Params + Res *query.PageResponse + func (*QueryParamsResponse) Descriptor() ([]byte, []int) + func (*QueryParamsResponse) ProtoMessage() + func (m *QueryParamsResponse) GetParams() Params + func (m *QueryParamsResponse) GetRes() *query.PageResponse + func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryParamsResponse) Reset() + func (m *QueryParamsResponse) Size() (n int) + func (m *QueryParamsResponse) String() string + func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error + func (m *QueryParamsResponse) XXX_DiscardUnknown() + func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryParamsResponse) XXX_Merge(src proto.Message) + func (m *QueryParamsResponse) XXX_Size() int + func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error + type QueryRequestContextParams struct + RequestContextID tmbytes.HexBytes + type QueryRequestContextRequest struct + RequestContextId string + func (*QueryRequestContextRequest) Descriptor() ([]byte, []int) + func (*QueryRequestContextRequest) ProtoMessage() + func (m *QueryRequestContextRequest) GetRequestContextId() string + func (m *QueryRequestContextRequest) Marshal() (dAtA []byte, err error) + func (m *QueryRequestContextRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestContextRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestContextRequest) Reset() + func (m *QueryRequestContextRequest) Size() (n int) + func (m *QueryRequestContextRequest) String() string + func (m *QueryRequestContextRequest) Unmarshal(dAtA []byte) error + func (m *QueryRequestContextRequest) XXX_DiscardUnknown() + func (m *QueryRequestContextRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestContextRequest) XXX_Merge(src proto.Message) + func (m *QueryRequestContextRequest) XXX_Size() int + func (m *QueryRequestContextRequest) XXX_Unmarshal(b []byte) error + type QueryRequestContextResponse struct + RequestContext *RequestContext + func (*QueryRequestContextResponse) Descriptor() ([]byte, []int) + func (*QueryRequestContextResponse) ProtoMessage() + func (m *QueryRequestContextResponse) GetRequestContext() *RequestContext + func (m *QueryRequestContextResponse) Marshal() (dAtA []byte, err error) + func (m *QueryRequestContextResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestContextResponse) Reset() + func (m *QueryRequestContextResponse) Size() (n int) + func (m *QueryRequestContextResponse) String() string + func (m *QueryRequestContextResponse) Unmarshal(dAtA []byte) error + func (m *QueryRequestContextResponse) XXX_DiscardUnknown() + func (m *QueryRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestContextResponse) XXX_Merge(src proto.Message) + func (m *QueryRequestContextResponse) XXX_Size() int + func (m *QueryRequestContextResponse) XXX_Unmarshal(b []byte) error + type QueryRequestParams struct + RequestID []byte + type QueryRequestRequest struct + RequestId string + func (*QueryRequestRequest) Descriptor() ([]byte, []int) + func (*QueryRequestRequest) ProtoMessage() + func (m *QueryRequestRequest) GetRequestId() string + func (m *QueryRequestRequest) Marshal() (dAtA []byte, err error) + func (m *QueryRequestRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestRequest) Reset() + func (m *QueryRequestRequest) Size() (n int) + func (m *QueryRequestRequest) String() string + func (m *QueryRequestRequest) Unmarshal(dAtA []byte) error + func (m *QueryRequestRequest) XXX_DiscardUnknown() + func (m *QueryRequestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestRequest) XXX_Merge(src proto.Message) + func (m *QueryRequestRequest) XXX_Size() int + func (m *QueryRequestRequest) XXX_Unmarshal(b []byte) error + type QueryRequestResponse struct + Request *Request + func (*QueryRequestResponse) Descriptor() ([]byte, []int) + func (*QueryRequestResponse) ProtoMessage() + func (m *QueryRequestResponse) GetRequest() *Request + func (m *QueryRequestResponse) Marshal() (dAtA []byte, err error) + func (m *QueryRequestResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestResponse) Reset() + func (m *QueryRequestResponse) Size() (n int) + func (m *QueryRequestResponse) String() string + func (m *QueryRequestResponse) Unmarshal(dAtA []byte) error + func (m *QueryRequestResponse) XXX_DiscardUnknown() + func (m *QueryRequestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestResponse) XXX_Merge(src proto.Message) + func (m *QueryRequestResponse) XXX_Size() int + func (m *QueryRequestResponse) XXX_Unmarshal(b []byte) error + type QueryRequestsByReqCtxParams struct + BatchCounter uint64 + RequestContextID tmbytes.HexBytes + type QueryRequestsByReqCtxRequest struct + BatchCounter uint64 + Pagination *query.PageRequest + RequestContextId string + func (*QueryRequestsByReqCtxRequest) Descriptor() ([]byte, []int) + func (*QueryRequestsByReqCtxRequest) ProtoMessage() + func (m *QueryRequestsByReqCtxRequest) GetBatchCounter() uint64 + func (m *QueryRequestsByReqCtxRequest) GetPagination() *query.PageRequest + func (m *QueryRequestsByReqCtxRequest) GetRequestContextId() string + func (m *QueryRequestsByReqCtxRequest) Marshal() (dAtA []byte, err error) + func (m *QueryRequestsByReqCtxRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestsByReqCtxRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestsByReqCtxRequest) Reset() + func (m *QueryRequestsByReqCtxRequest) Size() (n int) + func (m *QueryRequestsByReqCtxRequest) String() string + func (m *QueryRequestsByReqCtxRequest) Unmarshal(dAtA []byte) error + func (m *QueryRequestsByReqCtxRequest) XXX_DiscardUnknown() + func (m *QueryRequestsByReqCtxRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestsByReqCtxRequest) XXX_Merge(src proto.Message) + func (m *QueryRequestsByReqCtxRequest) XXX_Size() int + func (m *QueryRequestsByReqCtxRequest) XXX_Unmarshal(b []byte) error + type QueryRequestsByReqCtxResponse struct + Pagination *query.PageResponse + Requests []*Request + func (*QueryRequestsByReqCtxResponse) Descriptor() ([]byte, []int) + func (*QueryRequestsByReqCtxResponse) ProtoMessage() + func (m *QueryRequestsByReqCtxResponse) GetPagination() *query.PageResponse + func (m *QueryRequestsByReqCtxResponse) GetRequests() []*Request + func (m *QueryRequestsByReqCtxResponse) Marshal() (dAtA []byte, err error) + func (m *QueryRequestsByReqCtxResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestsByReqCtxResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestsByReqCtxResponse) Reset() + func (m *QueryRequestsByReqCtxResponse) Size() (n int) + func (m *QueryRequestsByReqCtxResponse) String() string + func (m *QueryRequestsByReqCtxResponse) Unmarshal(dAtA []byte) error + func (m *QueryRequestsByReqCtxResponse) XXX_DiscardUnknown() + func (m *QueryRequestsByReqCtxResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestsByReqCtxResponse) XXX_Merge(src proto.Message) + func (m *QueryRequestsByReqCtxResponse) XXX_Size() int + func (m *QueryRequestsByReqCtxResponse) XXX_Unmarshal(b []byte) error + type QueryRequestsParams struct + Provider sdk.AccAddress + ServiceName string + type QueryRequestsRequest struct + Pagination *query.PageRequest + Provider string + ServiceName string + func (*QueryRequestsRequest) Descriptor() ([]byte, []int) + func (*QueryRequestsRequest) ProtoMessage() + func (m *QueryRequestsRequest) GetPagination() *query.PageRequest + func (m *QueryRequestsRequest) GetProvider() string + func (m *QueryRequestsRequest) GetServiceName() string + func (m *QueryRequestsRequest) Marshal() (dAtA []byte, err error) + func (m *QueryRequestsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestsRequest) Reset() + func (m *QueryRequestsRequest) Size() (n int) + func (m *QueryRequestsRequest) String() string + func (m *QueryRequestsRequest) Unmarshal(dAtA []byte) error + func (m *QueryRequestsRequest) XXX_DiscardUnknown() + func (m *QueryRequestsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestsRequest) XXX_Merge(src proto.Message) + func (m *QueryRequestsRequest) XXX_Size() int + func (m *QueryRequestsRequest) XXX_Unmarshal(b []byte) error + type QueryRequestsResponse struct + Pagination *query.PageResponse + Requests []*Request + func (*QueryRequestsResponse) Descriptor() ([]byte, []int) + func (*QueryRequestsResponse) ProtoMessage() + func (m *QueryRequestsResponse) GetPagination() *query.PageResponse + func (m *QueryRequestsResponse) GetRequests() []*Request + func (m *QueryRequestsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryRequestsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestsResponse) Reset() + func (m *QueryRequestsResponse) Size() (n int) + func (m *QueryRequestsResponse) String() string + func (m *QueryRequestsResponse) Unmarshal(dAtA []byte) error + func (m *QueryRequestsResponse) XXX_DiscardUnknown() + func (m *QueryRequestsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestsResponse) XXX_Merge(src proto.Message) + func (m *QueryRequestsResponse) XXX_Size() int + func (m *QueryRequestsResponse) XXX_Unmarshal(b []byte) error + type QueryResponseParams struct + RequestID tmbytes.HexBytes + type QueryResponseRequest struct + RequestId string + func (*QueryResponseRequest) Descriptor() ([]byte, []int) + func (*QueryResponseRequest) ProtoMessage() + func (m *QueryResponseRequest) GetRequestId() string + func (m *QueryResponseRequest) Marshal() (dAtA []byte, err error) + func (m *QueryResponseRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponseRequest) Reset() + func (m *QueryResponseRequest) Size() (n int) + func (m *QueryResponseRequest) String() string + func (m *QueryResponseRequest) Unmarshal(dAtA []byte) error + func (m *QueryResponseRequest) XXX_DiscardUnknown() + func (m *QueryResponseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResponseRequest) XXX_Merge(src proto.Message) + func (m *QueryResponseRequest) XXX_Size() int + func (m *QueryResponseRequest) XXX_Unmarshal(b []byte) error + type QueryResponseResponse struct + Response *Response + func (*QueryResponseResponse) Descriptor() ([]byte, []int) + func (*QueryResponseResponse) ProtoMessage() + func (m *QueryResponseResponse) GetResponse() *Response + func (m *QueryResponseResponse) Marshal() (dAtA []byte, err error) + func (m *QueryResponseResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponseResponse) Reset() + func (m *QueryResponseResponse) Size() (n int) + func (m *QueryResponseResponse) String() string + func (m *QueryResponseResponse) Unmarshal(dAtA []byte) error + func (m *QueryResponseResponse) XXX_DiscardUnknown() + func (m *QueryResponseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResponseResponse) XXX_Merge(src proto.Message) + func (m *QueryResponseResponse) XXX_Size() int + func (m *QueryResponseResponse) XXX_Unmarshal(b []byte) error + type QueryResponsesParams struct + BatchCounter uint64 + RequestContextID tmbytes.HexBytes + type QueryResponsesRequest struct + BatchCounter uint64 + Pagination *query.PageRequest + RequestContextId string + func (*QueryResponsesRequest) Descriptor() ([]byte, []int) + func (*QueryResponsesRequest) ProtoMessage() + func (m *QueryResponsesRequest) GetBatchCounter() uint64 + func (m *QueryResponsesRequest) GetPagination() *query.PageRequest + func (m *QueryResponsesRequest) GetRequestContextId() string + func (m *QueryResponsesRequest) Marshal() (dAtA []byte, err error) + func (m *QueryResponsesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponsesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponsesRequest) Reset() + func (m *QueryResponsesRequest) Size() (n int) + func (m *QueryResponsesRequest) String() string + func (m *QueryResponsesRequest) Unmarshal(dAtA []byte) error + func (m *QueryResponsesRequest) XXX_DiscardUnknown() + func (m *QueryResponsesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResponsesRequest) XXX_Merge(src proto.Message) + func (m *QueryResponsesRequest) XXX_Size() int + func (m *QueryResponsesRequest) XXX_Unmarshal(b []byte) error + type QueryResponsesResponse struct + Pagination *query.PageResponse + Responses []*Response + func (*QueryResponsesResponse) Descriptor() ([]byte, []int) + func (*QueryResponsesResponse) ProtoMessage() + func (m *QueryResponsesResponse) GetPagination() *query.PageResponse + func (m *QueryResponsesResponse) GetResponses() []*Response + func (m *QueryResponsesResponse) Marshal() (dAtA []byte, err error) + func (m *QueryResponsesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponsesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponsesResponse) Reset() + func (m *QueryResponsesResponse) Size() (n int) + func (m *QueryResponsesResponse) String() string + func (m *QueryResponsesResponse) Unmarshal(dAtA []byte) error + func (m *QueryResponsesResponse) XXX_DiscardUnknown() + func (m *QueryResponsesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResponsesResponse) XXX_Merge(src proto.Message) + func (m *QueryResponsesResponse) XXX_Size() int + func (m *QueryResponsesResponse) XXX_Unmarshal(b []byte) error + type QuerySchemaParams struct + SchemaName string + type QuerySchemaRequest struct + SchemaName string + func (*QuerySchemaRequest) Descriptor() ([]byte, []int) + func (*QuerySchemaRequest) ProtoMessage() + func (m *QuerySchemaRequest) GetSchemaName() string + func (m *QuerySchemaRequest) Marshal() (dAtA []byte, err error) + func (m *QuerySchemaRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QuerySchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuerySchemaRequest) Reset() + func (m *QuerySchemaRequest) Size() (n int) + func (m *QuerySchemaRequest) String() string + func (m *QuerySchemaRequest) Unmarshal(dAtA []byte) error + func (m *QuerySchemaRequest) XXX_DiscardUnknown() + func (m *QuerySchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QuerySchemaRequest) XXX_Merge(src proto.Message) + func (m *QuerySchemaRequest) XXX_Size() int + func (m *QuerySchemaRequest) XXX_Unmarshal(b []byte) error + type QuerySchemaResponse struct + Schema string + func (*QuerySchemaResponse) Descriptor() ([]byte, []int) + func (*QuerySchemaResponse) ProtoMessage() + func (m *QuerySchemaResponse) GetSchema() string + func (m *QuerySchemaResponse) Marshal() (dAtA []byte, err error) + func (m *QuerySchemaResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QuerySchemaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QuerySchemaResponse) Reset() + func (m *QuerySchemaResponse) Size() (n int) + func (m *QuerySchemaResponse) String() string + func (m *QuerySchemaResponse) Unmarshal(dAtA []byte) error + func (m *QuerySchemaResponse) XXX_DiscardUnknown() + func (m *QuerySchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QuerySchemaResponse) XXX_Merge(src proto.Message) + func (m *QuerySchemaResponse) XXX_Size() int + func (m *QuerySchemaResponse) XXX_Unmarshal(b []byte) error + type QueryServer interface + Binding func(context.Context, *QueryBindingRequest) (*QueryBindingResponse, error) + Bindings func(context.Context, *QueryBindingsRequest) (*QueryBindingsResponse, error) + Definition func(context.Context, *QueryDefinitionRequest) (*QueryDefinitionResponse, error) + EarnedFees func(context.Context, *QueryEarnedFeesRequest) (*QueryEarnedFeesResponse, error) + Params func(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) + Request func(context.Context, *QueryRequestRequest) (*QueryRequestResponse, error) + RequestContext func(context.Context, *QueryRequestContextRequest) (*QueryRequestContextResponse, error) + Requests func(context.Context, *QueryRequestsRequest) (*QueryRequestsResponse, error) + RequestsByReqCtx func(context.Context, *QueryRequestsByReqCtxRequest) (*QueryRequestsByReqCtxResponse, error) + Response func(context.Context, *QueryResponseRequest) (*QueryResponseResponse, error) + Responses func(context.Context, *QueryResponsesRequest) (*QueryResponsesResponse, error) + Schema func(context.Context, *QuerySchemaRequest) (*QuerySchemaResponse, error) + WithdrawAddress func(context.Context, *QueryWithdrawAddressRequest) (*QueryWithdrawAddressResponse, error) + type QueryWithdrawAddressParams struct + Owner sdk.AccAddress + type QueryWithdrawAddressRequest struct + Owner string + func (*QueryWithdrawAddressRequest) Descriptor() ([]byte, []int) + func (*QueryWithdrawAddressRequest) ProtoMessage() + func (m *QueryWithdrawAddressRequest) GetOwner() string + func (m *QueryWithdrawAddressRequest) Marshal() (dAtA []byte, err error) + func (m *QueryWithdrawAddressRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryWithdrawAddressRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryWithdrawAddressRequest) Reset() + func (m *QueryWithdrawAddressRequest) Size() (n int) + func (m *QueryWithdrawAddressRequest) String() string + func (m *QueryWithdrawAddressRequest) Unmarshal(dAtA []byte) error + func (m *QueryWithdrawAddressRequest) XXX_DiscardUnknown() + func (m *QueryWithdrawAddressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryWithdrawAddressRequest) XXX_Merge(src proto.Message) + func (m *QueryWithdrawAddressRequest) XXX_Size() int + func (m *QueryWithdrawAddressRequest) XXX_Unmarshal(b []byte) error + type QueryWithdrawAddressResponse struct + WithdrawAddress string + func (*QueryWithdrawAddressResponse) Descriptor() ([]byte, []int) + func (*QueryWithdrawAddressResponse) ProtoMessage() + func (m *QueryWithdrawAddressResponse) GetWithdrawAddress() string + func (m *QueryWithdrawAddressResponse) Marshal() (dAtA []byte, err error) + func (m *QueryWithdrawAddressResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryWithdrawAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryWithdrawAddressResponse) Reset() + func (m *QueryWithdrawAddressResponse) Size() (n int) + func (m *QueryWithdrawAddressResponse) String() string + func (m *QueryWithdrawAddressResponse) Unmarshal(dAtA []byte) error + func (m *QueryWithdrawAddressResponse) XXX_DiscardUnknown() + func (m *QueryWithdrawAddressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryWithdrawAddressResponse) XXX_Merge(src proto.Message) + func (m *QueryWithdrawAddressResponse) XXX_Size() int + func (m *QueryWithdrawAddressResponse) XXX_Unmarshal(b []byte) error + type RawPricing struct + Price string + PromotionsByTime []PromotionByTime + PromotionsByVolume []PromotionByVolume + type Request struct + Consumer string + ExpirationHeight int64 + Id string + Input string + Provider string + RequestContextBatchCounter uint64 + RequestContextId string + RequestHeight int64 + ServiceFee github_com_cosmos_cosmos_sdk_types.Coins + ServiceName string + func NewRequest(id tmbytes.HexBytes, serviceName string, provider, consumer sdk.AccAddress, ...) Request + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + func (r Request) Empty() bool + type RequestContext struct + BatchCounter uint64 + BatchRequestCount uint32 + BatchResponseCount uint32 + BatchResponseThreshold uint32 + BatchState RequestContextBatchState + Consumer string + Input string + ModuleName string + Providers []string + Repeated bool + RepeatedFrequency uint64 + RepeatedTotal int64 + ResponseThreshold uint32 + ServiceFeeCap github_com_cosmos_cosmos_sdk_types.Coins + ServiceName string + State RequestContextState + Timeout int64 + func NewRequestContext(serviceName string, providers []sdk.AccAddress, consumer sdk.AccAddress, ...) RequestContext + func (*RequestContext) Descriptor() ([]byte, []int) + func (*RequestContext) ProtoMessage() + func (m *RequestContext) Marshal() (dAtA []byte, err error) + func (m *RequestContext) MarshalTo(dAtA []byte) (int, error) + func (m *RequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RequestContext) Reset() + func (m *RequestContext) Size() (n int) + func (m *RequestContext) String() string + func (m *RequestContext) Unmarshal(dAtA []byte) error + func (m *RequestContext) XXX_DiscardUnknown() + func (m *RequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RequestContext) XXX_Merge(src proto.Message) + func (m *RequestContext) XXX_Size() int + func (m *RequestContext) XXX_Unmarshal(b []byte) error + func (rc RequestContext) Empty() bool + func (rc RequestContext) Validate() error + type RequestContextBatchState int32 + const BATCHCOMPLETED + const BATCHRUNNING + func (RequestContextBatchState) EnumDescriptor() ([]byte, []int) + func (state *RequestContextBatchState) Unmarshal(data []byte) error + func (state RequestContextBatchState) Marshal() ([]byte, error) + func (x RequestContextBatchState) String() string + type RequestContextState int32 + const COMPLETED + const PAUSED + const RUNNING + func RequestContextStateFromString(str string) (RequestContextState, error) + func (RequestContextState) EnumDescriptor() ([]byte, []int) + func (state *RequestContextState) Unmarshal(data []byte) error + func (state RequestContextState) Marshal() ([]byte, error) + func (x RequestContextState) String() string + type Response struct + Consumer string + Output string + Provider string + RequestContextBatchCounter uint64 + RequestContextId string + Result string + func NewResponse(provider, consumer sdk.AccAddress, result, output string, ...) Response + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + func (r Response) Empty() bool + type ResponseCallback func(ctx sdk.Context, requestContextID tmbytes.HexBytes, responses []string, ...) + type Result struct + Code ResultCode + Message string + func ParseResult(result string) (Result, error) + type ResultCode uint16 + const ResultBadRequest + const ResultOK + const ResultServerError + type ServiceBinding struct + Available bool + Deposit github_com_cosmos_cosmos_sdk_types.Coins + DisabledTime time.Time + Options string + Owner string + Pricing string + Provider string + QoS uint64 + ServiceName string + func GenOraclePriceSvcBinding(baseDenom string) ServiceBinding + func NewServiceBinding(serviceName string, provider sdk.AccAddress, deposit sdk.Coins, pricing string, ...) ServiceBinding + func (*ServiceBinding) Descriptor() ([]byte, []int) + func (*ServiceBinding) ProtoMessage() + func (binding ServiceBinding) Validate() error + func (m *ServiceBinding) Marshal() (dAtA []byte, err error) + func (m *ServiceBinding) MarshalTo(dAtA []byte) (int, error) + func (m *ServiceBinding) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServiceBinding) Reset() + func (m *ServiceBinding) Size() (n int) + func (m *ServiceBinding) String() string + func (m *ServiceBinding) Unmarshal(dAtA []byte) error + func (m *ServiceBinding) XXX_DiscardUnknown() + func (m *ServiceBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServiceBinding) XXX_Merge(src proto.Message) + func (m *ServiceBinding) XXX_Size() int + func (m *ServiceBinding) XXX_Unmarshal(b []byte) error + type ServiceDefinition struct + Author string + AuthorDescription string + Description string + Name string + Schemas string + Tags []string + func GenOraclePriceSvcDefinition() ServiceDefinition + func NewServiceDefinition(name string, description string, tags []string, author sdk.AccAddress, ...) ServiceDefinition + func (*ServiceDefinition) Descriptor() ([]byte, []int) + func (*ServiceDefinition) ProtoMessage() + func (m *ServiceDefinition) Marshal() (dAtA []byte, err error) + func (m *ServiceDefinition) MarshalTo(dAtA []byte) (int, error) + func (m *ServiceDefinition) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServiceDefinition) Reset() + func (m *ServiceDefinition) Size() (n int) + func (m *ServiceDefinition) String() string + func (m *ServiceDefinition) Unmarshal(dAtA []byte) error + func (m *ServiceDefinition) XXX_DiscardUnknown() + func (m *ServiceDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServiceDefinition) XXX_Merge(src proto.Message) + func (m *ServiceDefinition) XXX_Size() int + func (m *ServiceDefinition) XXX_Unmarshal(b []byte) error + func (svcDef ServiceDefinition) Validate() error + type ServiceSchemas struct + Input map[string]interface{} + Output map[string]interface{} + type StateCallback func(ctx sdk.Context, requestContextID tmbytes.HexBytes, cause string) + type UnimplementedMsgServer struct + func (*UnimplementedMsgServer) BindService(ctx context.Context, req *MsgBindService) (*MsgBindServiceResponse, error) + func (*UnimplementedMsgServer) CallService(ctx context.Context, req *MsgCallService) (*MsgCallServiceResponse, error) + func (*UnimplementedMsgServer) DefineService(ctx context.Context, req *MsgDefineService) (*MsgDefineServiceResponse, error) + func (*UnimplementedMsgServer) DisableServiceBinding(ctx context.Context, req *MsgDisableServiceBinding) (*MsgDisableServiceBindingResponse, error) + func (*UnimplementedMsgServer) EnableServiceBinding(ctx context.Context, req *MsgEnableServiceBinding) (*MsgEnableServiceBindingResponse, error) + func (*UnimplementedMsgServer) KillRequestContext(ctx context.Context, req *MsgKillRequestContext) (*MsgKillRequestContextResponse, error) + func (*UnimplementedMsgServer) PauseRequestContext(ctx context.Context, req *MsgPauseRequestContext) (*MsgPauseRequestContextResponse, error) + func (*UnimplementedMsgServer) RefundServiceDeposit(ctx context.Context, req *MsgRefundServiceDeposit) (*MsgRefundServiceDepositResponse, error) + func (*UnimplementedMsgServer) RespondService(ctx context.Context, req *MsgRespondService) (*MsgRespondServiceResponse, error) + func (*UnimplementedMsgServer) SetWithdrawAddress(ctx context.Context, req *MsgSetWithdrawAddress) (*MsgSetWithdrawAddressResponse, error) + func (*UnimplementedMsgServer) StartRequestContext(ctx context.Context, req *MsgStartRequestContext) (*MsgStartRequestContextResponse, error) + func (*UnimplementedMsgServer) UpdateRequestContext(ctx context.Context, req *MsgUpdateRequestContext) (*MsgUpdateRequestContextResponse, error) + func (*UnimplementedMsgServer) UpdateServiceBinding(ctx context.Context, req *MsgUpdateServiceBinding) (*MsgUpdateServiceBindingResponse, error) + func (*UnimplementedMsgServer) WithdrawEarnedFees(ctx context.Context, req *MsgWithdrawEarnedFees) (*MsgWithdrawEarnedFeesResponse, error) + type UnimplementedQueryServer struct + func (*UnimplementedQueryServer) Binding(ctx context.Context, req *QueryBindingRequest) (*QueryBindingResponse, error) + func (*UnimplementedQueryServer) Bindings(ctx context.Context, req *QueryBindingsRequest) (*QueryBindingsResponse, error) + func (*UnimplementedQueryServer) Definition(ctx context.Context, req *QueryDefinitionRequest) (*QueryDefinitionResponse, error) + func (*UnimplementedQueryServer) EarnedFees(ctx context.Context, req *QueryEarnedFeesRequest) (*QueryEarnedFeesResponse, error) + func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error) + func (*UnimplementedQueryServer) Request(ctx context.Context, req *QueryRequestRequest) (*QueryRequestResponse, error) + func (*UnimplementedQueryServer) RequestContext(ctx context.Context, req *QueryRequestContextRequest) (*QueryRequestContextResponse, error) + func (*UnimplementedQueryServer) Requests(ctx context.Context, req *QueryRequestsRequest) (*QueryRequestsResponse, error) + func (*UnimplementedQueryServer) RequestsByReqCtx(ctx context.Context, req *QueryRequestsByReqCtxRequest) (*QueryRequestsByReqCtxResponse, error) + func (*UnimplementedQueryServer) Response(ctx context.Context, req *QueryResponseRequest) (*QueryResponseResponse, error) + func (*UnimplementedQueryServer) Responses(ctx context.Context, req *QueryResponsesRequest) (*QueryResponsesResponse, error) + func (*UnimplementedQueryServer) Schema(ctx context.Context, req *QuerySchemaRequest) (*QuerySchemaResponse, error) + func (*UnimplementedQueryServer) WithdrawAddress(ctx context.Context, req *QueryWithdrawAddressRequest) (*QueryWithdrawAddressResponse, error)
Go to main page