types

package
v1.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 15, 2022 License: Apache-2.0 Imports: 43 Imported by: 54

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeCreateDefinition        = "create_definition"
	EventTypeCreateBinding           = "create_binding"
	EventTypeUpdateBinding           = "update_binding"
	EventTypeDisableBinding          = "disable_binding"
	EventTypeEnableBinding           = "enable_binding"
	EventTypeRefundDeposit           = "refund_deposit"
	EventTypeSetWithdrawAddress      = "set_withdraw_address"
	EventTypeRespondService          = "respond_service"
	EventTypeCreateContext           = "create_context"
	EventTypePauseContext            = "pause_context"
	EventTypeStartContext            = "start_context"
	EventTypeKillContext             = "kill_context"
	EventTypeUpdateContext           = "update_context"
	EventTypeWithdrawEarnedFees      = "withdraw_earned_fees"
	EventTypeCompleteContext         = "complete_context"
	EventTypeNewBatch                = "new_batch"
	EventTypeNewBatchRequest         = "new_batch_request"
	EventTypeNewBatchRequestProvider = "new_batch_request_provider"
	EventTypeCompleteBatch           = "complete_batch"
	EventTypeServiceSlash            = "service_slash"
	EventTypeNoExchangeRate          = "no_exchange_rate"

	AttributeValueCategory = ModuleName

	AttributeKeyAuthor              = "author"
	AttributeKeyServiceName         = "service_name"
	AttributeKeyProvider            = "provider"
	AttributeKeyOwner               = "owner"
	AttributeKeyWithdrawAddress     = "withdraw_address"
	AttributeKeyConsumer            = "consumer"
	AttributeKeyModuleService       = "module_service"
	AttributeKeyRequestContextID    = "request_context_id"
	AttributeKeyRequestContextState = "request_context_state"
	AttributeKeyRequests            = "requests"
	AttributeKeyRequestID           = "request_id"
	AttributeKeyServiceFee          = "service_fee"
	AttributeKeyRequestHeight       = "request_height"
	AttributeKeyExpirationHeight    = "expiration_height"
	AttributeKeySlashedCoins        = "slashed_coins"
	AttributeKeyPriceDenom          = "price_denom"
)

service module event types

View Source 
const (
	RequestIDLen = 116
	ContextIDLen = 80
)
View Source 
const (
	// ModuleName is the name of the service module
	ModuleName = "service"

	// StoreKey is the string store representation
	StoreKey string = ModuleName

	// QuerierRoute is the querier route for the service module
	QuerierRoute string = ModuleName

	// RouterKey is the msg router key for the service module
	RouterKey string = ModuleName

	// DefaultParamspace is the default name for parameter store
	DefaultParamspace = ModuleName

	// DepositAccName is the root string for the service deposit account address
	DepositAccName = "service_deposit_account"

	// RequestAccName is the root string for the service request account address
	RequestAccName = "service_request_account"

	// FeeCollectorName is the root string for the service fee collector address used for testing
	FeeCollectorName = "service_fee_collector"
)
View Source 
const (
	TypeMsgDefineService         = "define_service"          // type for MsgDefineService
	TypeMsgBindService           = "bind_service"            // type for MsgBindService
	TypeMsgUpdateServiceBinding  = "update_service_binding"  // type for MsgUpdateServiceBinding
	TypeMsgSetWithdrawAddress    = "set_withdraw_address"    // type for MsgSetWithdrawAddress
	TypeMsgDisableServiceBinding = "disable_service_binding" // type for MsgDisableServiceBinding
	TypeMsgEnableServiceBinding  = "enable_service_binding"  // type for MsgEnableServiceBinding
	TypeMsgRefundServiceDeposit  = "refund_service_deposit"  // type for MsgRefundServiceDeposit
	TypeMsgCallService           = "call_service"            // type for MsgCallService
	TypeMsgRespondService        = "respond_service"         // type for MsgRespondService
	TypeMsgPauseRequestContext   = "pause_request_context"   // type for MsgPauseRequestContext
	TypeMsgStartRequestContext   = "start_request_context"   // type for MsgStartRequestContext
	TypeMsgKillRequestContext    = "kill_request_context"    // type for MsgKillRequestContext
	TypeMsgUpdateRequestContext  = "update_request_context"  // type for MsgUpdateRequestContext
	TypeMsgWithdrawEarnedFees    = "withdraw_earned_fees"    // type for MsgWithdrawEarnedFees
)

Message types for the service module

View Source 
const (
	RegisterModuleName           = "oracle"
	OraclePriceServiceName       = "oracle-price"
	OraclePriceValueJSONPath     = "rate"
	OraclePriceServiceDesc       = "system service definition of oracle module"
	OraclePriceAuthorDescription = "oracle module account"
	OraclePriceSchemas           = `` /* 877-byte string literal not displayed */

)
View Source 
const (
	QueryDefinition       = "definition"       // query definition
	QueryBinding          = "binding"          // query binding
	QueryBindings         = "bindings"         // query bindings
	QueryWithdrawAddress  = "withdraw_address" // query withdrawal address
	QueryRequest          = "request"          // query request
	QueryRequests         = "requests"         // query requests
	QueryResponse         = "response"         // query response
	QueryRequestContext   = "context"          // query request context
	QueryRequestsByReqCtx = "requests_by_ctx"  // query requests by the request context
	QueryResponses        = "responses"        // query responses
	QueryEarnedFees       = "fees"             // query earned fees
	QuerySchema           = "schema"           // query schema
	QueryParameters       = "parameters"       // query parameters
)
View Source 
const (
	// PricingSchema is the Pricing JSON Schema
	PricingSchema = `` /* 2009-byte string literal not displayed */

	// ResultSchema is the JSON Schema for the response result
	ResultSchema = `` /* 469-byte string literal not displayed */

	// InputSchema is the JSON Schema for the request input
	InputSchema = `` /* 355-byte string literal not displayed */

	// OutputSchema is the JSON Schema for the response output
	OutputSchema = `` /* 357-byte string literal not displayed */

)
View Source 
const (
	// MaxNameLength length of the service name
	MaxNameLength = 70
	// MaxDescriptionLength length of the service and author description
	MaxDescriptionLength = 280
	// MaxTagsNum total number of the tags
	MaxTagsNum = 10
	// MaxTagLength length of the tag
	MaxTagLength = 70
	// MaxProvidersNum total number of the providers to request
	MaxProvidersNum = 10
)
View Source 
const PATH_BODY = "body"

Variables

View Source 
var (
	ErrInvalidServiceName       = sdkerrors.Register(ModuleName, 2, "invalid service name, must contain alphanumeric characters, _ and - only，length greater than 0 and less than or equal to 70")
	ErrInvalidDescription       = sdkerrors.Register(ModuleName, 3, "invalid description")
	ErrInvalidTags              = sdkerrors.Register(ModuleName, 4, "invalid tags")
	ErrInvalidSchemas           = sdkerrors.Register(ModuleName, 5, "invalid schemas")
	ErrUnknownServiceDefinition = sdkerrors.Register(ModuleName, 6, "unknown service definition")
	ErrServiceDefinitionExists  = sdkerrors.Register(ModuleName, 7, "service definition already exists")

	ErrInvalidDeposit            = sdkerrors.Register(ModuleName, 8, "invalid deposit")
	ErrInvalidMinDeposit         = sdkerrors.Register(ModuleName, 9, "invalid minimum deposit")
	ErrInvalidPricing            = sdkerrors.Register(ModuleName, 10, "invalid pricing")
	ErrInvalidQoS                = sdkerrors.Register(ModuleName, 11, "invalid QoS")
	ErrInvalidOptions            = sdkerrors.Register(ModuleName, 12, "invalid options")
	ErrServiceBindingExists      = sdkerrors.Register(ModuleName, 13, "service binding already exists")
	ErrUnknownServiceBinding     = sdkerrors.Register(ModuleName, 14, "unknown service binding")
	ErrServiceBindingUnavailable = sdkerrors.Register(ModuleName, 15, "service binding unavailable")
	ErrServiceBindingAvailable   = sdkerrors.Register(ModuleName, 16, "service binding available")
	ErrIncorrectRefundTime       = sdkerrors.Register(ModuleName, 17, "incorrect refund time")

	ErrInvalidServiceFeeCap      = sdkerrors.Register(ModuleName, 18, "invalid service fee cap")
	ErrInvalidProviders          = sdkerrors.Register(ModuleName, 19, "invalid providers")
	ErrInvalidTimeout            = sdkerrors.Register(ModuleName, 20, "invalid timeout")
	ErrInvalidRepeatedFreq       = sdkerrors.Register(ModuleName, 21, "invalid repeated frequency")
	ErrInvalidRepeatedTotal      = sdkerrors.Register(ModuleName, 22, "invalid repeated total count")
	ErrInvalidResponseThreshold  = sdkerrors.Register(ModuleName, 23, "invalid response threshold")
	ErrInvalidResponse           = sdkerrors.Register(ModuleName, 24, "invalid response")
	ErrInvalidRequestID          = sdkerrors.Register(ModuleName, 25, "invalid request ID")
	ErrUnknownRequest            = sdkerrors.Register(ModuleName, 26, "unknown request")
	ErrUnknownResponse           = sdkerrors.Register(ModuleName, 27, "unknown response")
	ErrUnknownRequestContext     = sdkerrors.Register(ModuleName, 28, "unknown request context")
	ErrInvalidRequestContextID   = sdkerrors.Register(ModuleName, 29, "invalid request context ID")
	ErrRequestContextNonRepeated = sdkerrors.Register(ModuleName, 30, "request context non repeated")
	ErrRequestContextNotRunning  = sdkerrors.Register(ModuleName, 31, "request context not running")
	ErrRequestContextNotPaused   = sdkerrors.Register(ModuleName, 32, "request context not paused")
	ErrRequestContextCompleted   = sdkerrors.Register(ModuleName, 33, "request context completed")
	ErrCallbackRegistered        = sdkerrors.Register(ModuleName, 34, "callback registered")
	ErrCallbackNotRegistered     = sdkerrors.Register(ModuleName, 35, "callback not registered")
	ErrNoEarnedFees              = sdkerrors.Register(ModuleName, 36, "no earned fees")

	ErrInvalidRequestInput   = sdkerrors.Register(ModuleName, 37, "invalid request input")
	ErrInvalidResponseOutput = sdkerrors.Register(ModuleName, 38, "invalid response output")
	ErrInvalidResponseResult = sdkerrors.Register(ModuleName, 39, "invalid response result")

	ErrInvalidSchemaName = sdkerrors.Register(ModuleName, 40, "invalid service schema name")
	ErrNotAuthorized     = sdkerrors.Register(ModuleName, 41, "not authorized")

	ErrModuleServiceRegistered   = sdkerrors.Register(ModuleName, 42, "module service registered")
	ErrInvalidModuleService      = sdkerrors.Register(ModuleName, 43, "invalid module service")
	ErrBindModuleService         = sdkerrors.Register(ModuleName, 44, "can not bind module service")
	ErrInvalidRequestInputBody   = sdkerrors.Register(ModuleName, 45, "invalid request input body")
	ErrInvalidResponseOutputBody = sdkerrors.Register(ModuleName, 46, "invalid response output body")
)

service module sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// Separator for string key
	Delimiter = []byte{0x00}

	// Keys for store prefixes
	ServiceDefinitionKey         = []byte{0x01} // prefix for service definition
	ServiceBindingKey            = []byte{0x02} // prefix for service binding
	OwnerServiceBindingKey       = []byte{0x03} // prefix for owner service binding
	OwnerKey                     = []byte{0x04} // prefix for the owner of a provider
	OwnerProviderKey             = []byte{0x05} // prefix for the provider with an owner
	PricingKey                   = []byte{0x06} // prefix for pricing
	WithdrawAddrKey              = []byte{0x07} // prefix for withdrawal address
	RequestContextKey            = []byte{0x08} // prefix for request context
	ExpiredRequestBatchKey       = []byte{0x09} // prefix for expired request batch
	NewRequestBatchKey           = []byte{0x10} // prefix for new request batch
	ExpiredRequestBatchHeightKey = []byte{0x11} // prefix for expired request batch height
	NewRequestBatchHeightKey     = []byte{0x12} // prefix for new request batch height
	RequestKey                   = []byte{0x13} // prefix for request
	ActiveRequestKey             = []byte{0x14} // prefix for active request
	ActiveRequestByIDKey         = []byte{0x15} // prefix for active requests by ID
	ResponseKey                  = []byte{0x16} // prefix for response
	RequestVolumeKey             = []byte{0x17} // prefix for request volume
	EarnedFeesKey                = []byte{0x18} // prefix for provider earned fees
	OwnerEarnedFeesKey           = []byte{0x19} // prefix for owner earned fees
	InternalCounterKey           = []byte{0x20} // prefix for internal counter key
)
View Source 
var (
	OraclePriceServiceTags     = []string{"oracle"}
	OraclePriceServiceAuthor   = sdk.AccAddress(crypto.AddressHash([]byte(RegisterModuleName)))
	OraclePriceServiceProvider = sdk.AccAddress(crypto.AddressHash([]byte(RegisterModuleName)))
)
View Source 
var (
	DefaultMaxRequestTimeout         = int64(100)
	DefaultMinDepositMultiple        = int64(1000)
	DefaultMinDeposit                = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdk.NewInt(5000))) // 5000stake
	DefaultServiceFeeTax             = sdk.NewDecWithPrec(5, 2)                                          // 5%
	DefaultSlashFraction             = sdk.NewDecWithPrec(1, 3)                                          // 0.1%
	DefaultComplaintRetrospect       = 15 * 24 * time.Hour                                               // 15 days
	DefaultArbitrationTimeLimit      = 5 * 24 * time.Hour                                                // 5 days
	DefaultTxSizeLimit               = uint64(4000)
	DefaultBaseDenom                 = sdk.DefaultBondDenom
	DefaultRestrictedServiceFeeDenom = false
)

Service params default values

View Source 
var (
	KeyMaxRequestTimeout         = []byte("MaxRequestTimeout")
	KeyMinDepositMultiple        = []byte("MinDepositMultiple")
	KeyMinDeposit                = []byte("MinDeposit")
	KeyServiceFeeTax             = []byte("ServiceFeeTax")
	KeySlashFraction             = []byte("SlashFraction")
	KeyComplaintRetrospect       = []byte("ComplaintRetrospect")
	KeyArbitrationTimeLimit      = []byte("ArbitrationTimeLimit")
	KeyTxSizeLimit               = []byte("TxSizeLimit")
	KeyBaseDenom                 = []byte("BaseDenom")
	KeyRestrictedServiceFeeDenom = []byte("RestrictedServiceFeeDenom")
)

Keys for parameter access nolint

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)
View Source 
var RequestContextBatchState_name = map[int32]string{
	0: "BATCH_RUNNING",
	1: "BATCH_COMPLETED",
}
View Source 
var RequestContextBatchState_value = map[string]int32{
	"BATCH_RUNNING":   0,
	"BATCH_COMPLETED": 1,
}
View Source 
var RequestContextState_name = map[int32]string{
	0: "RUNNING",
	1: "PAUSED",
	2: "COMPLETED",
}
View Source 
var RequestContextState_value = map[string]int32{
	"RUNNING":   0,
	"PAUSED":    1,
	"COMPLETED": 2,
}

Functions

func ActionTag 

func ActionTag(action string, tagKeys ...string) string

ActionTag appends action and all tagKeys

func CheckPricing added in v1.4.0 

func CheckPricing(pricing Pricing) error

CheckPricing checks if the given pricing complies with the specific rules

func ConvertRequestID 

func ConvertRequestID(requestIDStr string) (tmbytes.HexBytes, error)

ConvertRequestID converts the given string to request ID

func GenerateRequestContextID 

func GenerateRequestContextID(txHash []byte, msgIndex int64) tmbytes.HexBytes

GenerateRequestContextID generates a unique ID for the request context from the specified params

func GenerateRequestID 

func GenerateRequestID(requestContextID tmbytes.HexBytes, requestContextBatchCounter uint64, requestHeight int64, batchRequestIndex int16) tmbytes.HexBytes

GenerateRequestID generates a unique request ID from the given params

func GetActiveRequestKey 

func GetActiveRequestKey(serviceName string, provider sdk.AccAddress, expirationHeight int64, requestID []byte) []byte

GetActiveRequestKey returns the key for the active request with the specified request ID in the given height

func GetActiveRequestKeyByID 

func GetActiveRequestKeyByID(requestID []byte) []byte

GetActiveRequestKeyByID returns the key for the active request with the specified request ID

func GetActiveRequestSubspace 

func GetActiveRequestSubspace(serviceName string, provider sdk.AccAddress) []byte

GetActiveRequestSubspace returns the key prefix for iterating through the active requests for the specified provider

func GetActiveRequestSubspaceByReqCtx 

func GetActiveRequestSubspaceByReqCtx(requestContextID []byte, batchCounter uint64) []byte

GetActiveRequestSubspaceByReqCtx returns the key prefix for iterating through the active requests for the specified request context

func GetBindingsSubspace 

func GetBindingsSubspace(serviceName string) []byte

GetBindingsSubspace gets the key prefix for iterating through all bindings of the specified service name

func GetDiscountByTime 

func GetDiscountByTime(pricing Pricing, time time.Time) sdk.Dec

GetDiscountByTime gets the discount level by the specified time

func GetDiscountByVolume 

func GetDiscountByVolume(pricing Pricing, volume uint64) sdk.Dec

GetDiscountByVolume gets the discount level by the specified volume Note: make sure that the promotions by volume are sorted in ascending order

func GetEarnedFeesKey 

func GetEarnedFeesKey(provider sdk.AccAddress, denom string) []byte

GetEarnedFeesKey gets the key for the earned fees of the specified provider and denom

func GetEarnedFeesSubspace 

func GetEarnedFeesSubspace(provider sdk.AccAddress) []byte

GetEarnedFeesSubspace gets the subspace for the earned fees of the specified provider

func GetExpiredRequestBatchHeightKey 

func GetExpiredRequestBatchHeightKey(requestContextID []byte) []byte

GetExpiredRequestBatchHeightKey returns the key for the current request batch expiration height of the specified request context

func GetExpiredRequestBatchKey 

func GetExpiredRequestBatchKey(requestContextID []byte, batchExpirationHeight int64) []byte

GetExpiredRequestBatchKey returns the key for the request batch expiration of the specified request context

func GetExpiredRequestBatchSubspace 

func GetExpiredRequestBatchSubspace(batchExpirationHeight int64) []byte

GetExpiredRequestBatchSubspace returns the key prefix for iterating through the expired request batch queue in the specified height

func GetNewRequestBatchHeightKey 

func GetNewRequestBatchHeightKey(requestContextID []byte) []byte

GetNewRequestBatchHeightKey returns the key for the new request batch height of the specified request context

func GetNewRequestBatchKey 

func GetNewRequestBatchKey(requestContextID []byte, requestBatchHeight int64) []byte

GetNewRequestBatchKey returns the key for the new batch request of the specified request context in the given height

func GetNewRequestBatchSubspace 

func GetNewRequestBatchSubspace(requestBatchHeight int64) []byte

GetNewRequestBatchSubspace returns the key prefix for iterating through the new request batch queue in the specified height

func GetOwnerBindingsSubspace 

func GetOwnerBindingsSubspace(owner sdk.AccAddress, serviceName string) []byte

GetOwnerBindingsSubspace gets the key prefix for iterating through all bindings of the specified service name and owner

func GetOwnerEarnedFeesKey 

func GetOwnerEarnedFeesKey(owner sdk.AccAddress, denom string) []byte

GetOwnerEarnedFeesKey returns the key for the earned fees of the specified owner and denom

func GetOwnerEarnedFeesSubspace 

func GetOwnerEarnedFeesSubspace(owner sdk.AccAddress) []byte

GetOwnerEarnedFeesSubspace gets the subspace for the earned fees of the specified owner

func GetOwnerKey 

func GetOwnerKey(provider sdk.AccAddress) []byte

GetOwnerKey gets the key for the specified provider VALUE: sdk.AccAddress

func GetOwnerProviderKey 

func GetOwnerProviderKey(owner, provider sdk.AccAddress) []byte

GetOwnerProviderKey gets the key for the specified owner and provider VALUE: []byte{}

func GetOwnerProvidersSubspace 

func GetOwnerProvidersSubspace(owner sdk.AccAddress) []byte

GetOwnerProvidersSubspace gets the key prefix for iterating through providers of the specified owner

func GetOwnerServiceBindingKey 

func GetOwnerServiceBindingKey(owner sdk.AccAddress, serviceName string, provider sdk.AccAddress) []byte

GetOwnerServiceBindingKey gets the key for the service binding with the specified owner VALUE: []byte{}

func GetPricingKey 

func GetPricingKey(serviceName string, provider sdk.AccAddress) []byte

GetPricingKey gets the key for the pricing of the specified binding VALUE: service/Pricing

func GetRequestContextKey 

func GetRequestContextKey(requestContextID []byte) []byte

GetRequestContextKey returns the key for the request context with the specified ID

func GetRequestKey 

func GetRequestKey(requestID []byte) []byte

GetRequestKey returns the key for the request with the specified request ID

func GetRequestSubspaceByReqCtx 

func GetRequestSubspaceByReqCtx(requestContextID []byte, batchCounter uint64) []byte

GetRequestSubspaceByReqCtx returns the key prefix for iterating through the requests of the specified request context

func GetRequestVolumeKey 

func GetRequestVolumeKey(consumer sdk.AccAddress, serviceName string, provider sdk.AccAddress) []byte

GetRequestVolumeKey returns the key for the request volume for the specified consumer and binding

func GetResponseKey 

func GetResponseKey(requestID []byte) []byte

GetResponseKey returns the key for the response for the given request ID

func GetResponseSubspaceByReqCtx 

func GetResponseSubspaceByReqCtx(requestContextID []byte, batchCounter uint64) []byte

GetResponseSubspaceByReqCtx returns the key prefix for iterating throuth responses for the specified request context and batch counter

func GetServiceBindingKey 

func GetServiceBindingKey(serviceName string, provider sdk.AccAddress) []byte

GetServiceBindingKey gets the key for the service binding with the specified service name and provider VALUE: service/ServiceBinding

func GetServiceDefinitionKey 

func GetServiceDefinitionKey(serviceName string) []byte

GetServiceDefinitionKey gets the key for the service definition with the specified service name VALUE: service/ServiceDefinition

func GetWithdrawAddrKey 

func GetWithdrawAddrKey(provider sdk.AccAddress) []byte

GetWithdrawAddrKey gets the key for the withdrawal address of the specified provider VALUE: withdrawal address ([]byte)

func HasDuplicate 

func HasDuplicate(arr []string) bool

HasDuplicate checks if the given array contains duplicate elements. Return true if there exist duplicate elements, false otherwise

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers concrete types on codec

func RegisterMsgServer added in v1.2.0 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func SplitRequestContextID 

func SplitRequestContextID(contextID tmbytes.HexBytes) (tmbytes.HexBytes, int64, error)

SplitRequestContextID splits the given contextID to txHash and msgIndex

func SplitRequestID 

func SplitRequestID(requestID tmbytes.HexBytes) (tmbytes.HexBytes, uint64, int64, int16, error)

SplitRequestID splits the given requestID to contextID, batchCounter, requestHeight, batchRequestIndex

func ValidateAuthor 

func ValidateAuthor(author string) error

ValidateAuthor verifies whether the parameters are legal

func ValidateAuthorDescription 

func ValidateAuthorDescription(authorDescription string) error

ValidateAuthorDescription verifies whether the parameters are legal

func ValidateBindingPricing 

func ValidateBindingPricing(pricing string) error

ValidateBindingPricing validates the given pricing against the Pricing JSON Schema

func ValidateConsumer 

func ValidateConsumer(consumer string) error

ValidateConsumer verifies whether the parameters are legal

func ValidateContextID 

func ValidateContextID(contextID string) error

ValidateContextID verifies whether the parameters are legal

func ValidateGenesis 

func ValidateGenesis(data GenesisState) error

ValidateGenesis validates the provided service genesis state to ensure the expected invariants holds.

func ValidateInput 

func ValidateInput(input string) error

ValidateInput verifies whether the parameters are legal

func ValidateOptions 

func ValidateOptions(options string) error

ValidateOptions verifies whether the parameters are legal

func ValidateOutput 

func ValidateOutput(code ResultCode, output string) error

ValidateOutput verifies whether the parameters are legal

func ValidateOwner 

func ValidateOwner(owner string) error

ValidateOwner verifies whether the parameters are legal

func ValidatePricing 

func ValidatePricing(pricing string) error

func ValidateProvider 

func ValidateProvider(provider string) error

ValidateProvider verifies whether the parameters are legal

func ValidateProviders added in v1.2.0 

func ValidateProviders(providers []sdk.AccAddress) error

ValidateProviders verifies whether the parameters are legal

func ValidateProvidersCanEmpty 

func ValidateProvidersCanEmpty(providers []sdk.AccAddress) error

ValidateProvidersCanEmpty verifies whether the parameters are legal

func ValidateQoS 

func ValidateQoS(qos uint64) error

ValidateQoS verifies whether the parameters are legal

func ValidateRequest 

func ValidateRequest(
	serviceName string,
	serviceFeeCap sdk.Coins,
	providers []sdk.AccAddress,
	input string,
	timeout int64,
	repeated bool,
	repeatedFrequency uint64,
	repeatedTotal int64,
) error

ValidateRequest validates the request params

func ValidateRequestContextUpdating 

func ValidateRequestContextUpdating(
	providers []sdk.AccAddress,
	serviceFeeCap sdk.Coins,
	timeout int64,
	repeatedFrequency uint64,
	repeatedTotal int64,
) error

ValidateRequestContextUpdating validates the request context updating operation

func ValidateRequestID 

func ValidateRequestID(reqID string) error

ValidateRequestID verifies whether the parameters are legal

func ValidateRequestInput 

func ValidateRequestInput(input string) error

ValidateRequestInput validates the request input against the input schema

func ValidateRequestInputBody 

func ValidateRequestInputBody(schemas string, inputBody string) error

func ValidateResponseOutput 

func ValidateResponseOutput(output string) error

ValidateResponseOutput validates the response output against the output schema

func ValidateResponseOutputBody 

func ValidateResponseOutputBody(schemas string, outputBody string) error

func ValidateResponseResult 

func ValidateResponseResult(result string) error

ValidateResponseResult validates the response result against the result schema

func ValidateServiceDeposit 

func ValidateServiceDeposit(deposit sdk.Coins) error

ValidateServiceDeposit verifies whether the parameters are legal

func ValidateServiceDescription 

func ValidateServiceDescription(svcDescription string) error

ValidateServiceDescription verifies whether the parameters are legal

func ValidateServiceFeeCap 

func ValidateServiceFeeCap(serviceFeeCap sdk.Coins) error

ValidateServiceFeeCap verifies whether the parameters are legal

func ValidateServiceName 

func ValidateServiceName(name string) error

ValidateServiceName validates the service name

func ValidateServiceSchemas 

func ValidateServiceSchemas(schemas string) error

ValidateServiceSchemas validates the given service schemas

func ValidateTags 

func ValidateTags(tags []string) error

ValidateTags verifies whether the given tags are legal

func ValidateWithdrawAddress 

func ValidateWithdrawAddress(withdrawAddress string) error

ValidateWithdrawAddress verifies whether the parameters are legal

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetModuleAddress(name string) sdk.AccAddress
	GetModuleAccount(ctx sdk.Context, name string) authtypes.ModuleAccountI
}

AccountKeeper defines the expected account keeper (noalias)

type BankKeeper 

type BankKeeper interface {
	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error

	GetSupply(ctx sdk.Context, denom string) sdk.Coin
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin

	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error

	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
}

BankKeeper defines the expected bank keeper (noalias)

type BatchState 

type BatchState struct {
	BatchCounter           uint64                   `json:"batch_counter"`
	State                  RequestContextBatchState `json:"state"`
	BatchResponseThreshold uint32                   `json:"batch_response_threshold"`
	BatchRequestCount      uint32                   `json:"batch_request_count"`
	BatchResponseCount     uint32                   `json:"batch_response_count"`
}

type CompactRequest 

type CompactRequest struct {
	RequestContextId           string                                   `` /* 137-byte string literal not displayed */
	RequestContextBatchCounter uint64                                   `` /* 181-byte string literal not displayed */
	Provider                   string                                   `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"`
	ServiceFee                 github_com_cosmos_cosmos_sdk_types.Coins `` /* 154-byte string literal not displayed */
	RequestHeight              int64                                    `protobuf:"varint,5,opt,name=request_height,json=requestHeight,proto3" json:"request_height,omitempty" yaml:"request_height"`
	ExpirationHeight           int64                                    `` /* 135-byte string literal not displayed */
}

CompactRequest defines a standard for compact request

func NewCompactRequest 

func NewCompactRequest(
	requestContextID tmbytes.HexBytes,
	batchCounter uint64,
	provider sdk.AccAddress,
	serviceFee sdk.Coins,
	requestHeight int64,
	expirationHeight int64,
) CompactRequest

NewCompactRequest creates a new CompactRequest instance

func (*CompactRequest) Descriptor 

func (*CompactRequest) Descriptor() ([]byte, []int)

func (*CompactRequest) Marshal 

func (m *CompactRequest) Marshal() (dAtA []byte, err error)

func (*CompactRequest) MarshalTo 

func (m *CompactRequest) MarshalTo(dAtA []byte) (int, error)

func (*CompactRequest) MarshalToSizedBuffer 

func (m *CompactRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CompactRequest) ProtoMessage 

func (*CompactRequest) ProtoMessage()

func (*CompactRequest) Reset 

func (m *CompactRequest) Reset()

func (*CompactRequest) Size 

func (m *CompactRequest) Size() (n int)

func (*CompactRequest) String 

func (m *CompactRequest) String() string

func (*CompactRequest) Unmarshal 

func (m *CompactRequest) Unmarshal(dAtA []byte) error

func (*CompactRequest) XXX_DiscardUnknown 

func (m *CompactRequest) XXX_DiscardUnknown()

func (*CompactRequest) XXX_Marshal 

func (m *CompactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompactRequest) XXX_Merge 

func (m *CompactRequest) XXX_Merge(src proto.Message)

func (*CompactRequest) XXX_Size 

func (m *CompactRequest) XXX_Size() int

func (*CompactRequest) XXX_Unmarshal 

func (m *CompactRequest) XXX_Unmarshal(b []byte) error

type GenesisState 

type GenesisState struct {
	Params            Params                     `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	Definitions       []ServiceDefinition        `protobuf:"bytes,2,rep,name=definitions,proto3" json:"definitions"`
	Bindings          []ServiceBinding           `protobuf:"bytes,3,rep,name=bindings,proto3" json:"bindings"`
	WithdrawAddresses map[string]string          `` /* 226-byte string literal not displayed */
	RequestContexts   map[string]*RequestContext `` /* 218-byte string literal not displayed */
}

GenesisState defines the service module's genesis state

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState gets the default genesis state for testing

func NewGenesisState 

func NewGenesisState(
	params Params,
	definitions []ServiceDefinition,
	bindings []ServiceBinding,
	withdrawAddresses map[string]string,
	requestContexts map[string]*RequestContext,
) *GenesisState

NewGenesisState constructs a new GenesisState instance

func (*GenesisState) Descriptor 

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) GetBindings 

func (m *GenesisState) GetBindings() []ServiceBinding

func (*GenesisState) GetDefinitions 

func (m *GenesisState) GetDefinitions() []ServiceDefinition

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetRequestContexts 

func (m *GenesisState) GetRequestContexts() map[string]*RequestContext

func (*GenesisState) GetWithdrawAddresses 

func (m *GenesisState) GetWithdrawAddresses() map[string]string

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer 

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

func (m *GenesisState) Size() (n int)

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisState) XXX_Merge 

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

func (m *GenesisState) XXX_Unmarshal(b []byte) error

type ModuleService 

type ModuleService struct {
	ServiceName     string
	Provider        sdk.AccAddress
	ReuquestService func(ctx sdk.Context, input string) (result string, output string)
}

type MsgBindService 

type MsgBindService struct {
	ServiceName string                                   `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Provider    string                                   `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Deposit     github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=deposit,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"deposit"`
	Pricing     string                                   `protobuf:"bytes,4,opt,name=pricing,proto3" json:"pricing,omitempty"`
	QoS         uint64                                   `protobuf:"varint,5,opt,name=qos,proto3" json:"qos,omitempty"`
	Options     string                                   `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	Owner       string                                   `protobuf:"bytes,7,opt,name=owner,proto3" json:"owner,omitempty"`
}

MsgBindService defines an SDK message for binding to an existing service

func NewMsgBindService 

func NewMsgBindService(
	serviceName string,
	provider string,
	deposit sdk.Coins,
	pricing string,
	qos uint64,
	options string,
	owner string,
) *MsgBindService

NewMsgBindService creates a new MsgBindService instance

func (*MsgBindService) Descriptor 

func (*MsgBindService) Descriptor() ([]byte, []int)

func (MsgBindService) GetSignBytes 

func (msg MsgBindService) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgBindService) GetSigners 

func (msg MsgBindService) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgBindService) Marshal 

func (m *MsgBindService) Marshal() (dAtA []byte, err error)

func (*MsgBindService) MarshalTo 

func (m *MsgBindService) MarshalTo(dAtA []byte) (int, error)

func (*MsgBindService) MarshalToSizedBuffer 

func (m *MsgBindService) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgBindService) ProtoMessage 

func (*MsgBindService) ProtoMessage()

func (*MsgBindService) Reset 

func (m *MsgBindService) Reset()

func (MsgBindService) Route 

func (msg MsgBindService) Route() string

Route implements Msg.

func (*MsgBindService) Size 

func (m *MsgBindService) Size() (n int)

func (*MsgBindService) String 

func (m *MsgBindService) String() string

func (MsgBindService) Type 

func (msg MsgBindService) Type() string

Type implements Msg.

func (*MsgBindService) Unmarshal 

func (m *MsgBindService) Unmarshal(dAtA []byte) error

func (MsgBindService) ValidateBasic 

func (msg MsgBindService) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgBindService) XXX_DiscardUnknown 

func (m *MsgBindService) XXX_DiscardUnknown()

func (*MsgBindService) XXX_Marshal 

func (m *MsgBindService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgBindService) XXX_Merge 

func (m *MsgBindService) XXX_Merge(src proto.Message)

func (*MsgBindService) XXX_Size 

func (m *MsgBindService) XXX_Size() int

func (*MsgBindService) XXX_Unmarshal 

func (m *MsgBindService) XXX_Unmarshal(b []byte) error

type MsgBindServiceResponse added in v1.2.0 

type MsgBindServiceResponse struct {
}

MsgBindServiceResponse defines the Msg/BindService response type

func (*MsgBindServiceResponse) Descriptor added in v1.2.0 

func (*MsgBindServiceResponse) Descriptor() ([]byte, []int)

func (*MsgBindServiceResponse) Marshal added in v1.2.0 

func (m *MsgBindServiceResponse) Marshal() (dAtA []byte, err error)

func (*MsgBindServiceResponse) MarshalTo added in v1.2.0 

func (m *MsgBindServiceResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgBindServiceResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgBindServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgBindServiceResponse) ProtoMessage added in v1.2.0 

func (*MsgBindServiceResponse) ProtoMessage()

func (*MsgBindServiceResponse) Reset added in v1.2.0 

func (m *MsgBindServiceResponse) Reset()

func (*MsgBindServiceResponse) Size added in v1.2.0 

func (m *MsgBindServiceResponse) Size() (n int)

func (*MsgBindServiceResponse) String added in v1.2.0 

func (m *MsgBindServiceResponse) String() string

func (*MsgBindServiceResponse) Unmarshal added in v1.2.0 

func (m *MsgBindServiceResponse) Unmarshal(dAtA []byte) error

func (*MsgBindServiceResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgBindServiceResponse) XXX_DiscardUnknown()

func (*MsgBindServiceResponse) XXX_Marshal added in v1.2.0 

func (m *MsgBindServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgBindServiceResponse) XXX_Merge added in v1.2.0 

func (m *MsgBindServiceResponse) XXX_Merge(src proto.Message)

func (*MsgBindServiceResponse) XXX_Size added in v1.2.0 

func (m *MsgBindServiceResponse) XXX_Size() int

func (*MsgBindServiceResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgBindServiceResponse) XXX_Unmarshal(b []byte) error

type MsgCallService 

type MsgCallService struct {
	ServiceName       string                                   `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Providers         []string                                 `protobuf:"bytes,2,rep,name=providers,proto3" json:"providers,omitempty"`
	Consumer          string                                   `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
	Input             string                                   `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ServiceFeeCap     github_com_cosmos_cosmos_sdk_types.Coins `` /* 169-byte string literal not displayed */
	Timeout           int64                                    `protobuf:"varint,6,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Repeated          bool                                     `protobuf:"varint,7,opt,name=repeated,proto3" json:"repeated,omitempty"`
	RepeatedFrequency uint64                                   `` /* 139-byte string literal not displayed */
	RepeatedTotal     int64                                    `protobuf:"varint,9,opt,name=repeated_total,json=repeatedTotal,proto3" json:"repeated_total,omitempty" yaml:"repeated_total"`
}

MsgCallService defines an SDK message to initiate a service request context

func NewMsgCallService 

func NewMsgCallService(
	serviceName string,
	providers []string,
	consumer string,
	input string,
	serviceFeeCap sdk.Coins,
	timeout int64,
	repeated bool,
	repeatedFrequency uint64,
	repeatedTotal int64,
) *MsgCallService

NewMsgCallService creates a new MsgCallService instance

func (*MsgCallService) Descriptor 

func (*MsgCallService) Descriptor() ([]byte, []int)

func (MsgCallService) GetSignBytes 

func (msg MsgCallService) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgCallService) GetSigners 

func (msg MsgCallService) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgCallService) Marshal 

func (m *MsgCallService) Marshal() (dAtA []byte, err error)

func (*MsgCallService) MarshalTo 

func (m *MsgCallService) MarshalTo(dAtA []byte) (int, error)

func (*MsgCallService) MarshalToSizedBuffer 

func (m *MsgCallService) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCallService) ProtoMessage 

func (*MsgCallService) ProtoMessage()

func (*MsgCallService) Reset 

func (m *MsgCallService) Reset()

func (MsgCallService) Route 

func (msg MsgCallService) Route() string

Route implements Msg.

func (*MsgCallService) Size 

func (m *MsgCallService) Size() (n int)

func (*MsgCallService) String 

func (m *MsgCallService) String() string

func (MsgCallService) Type 

func (msg MsgCallService) Type() string

Type implements Msg.

func (*MsgCallService) Unmarshal 

func (m *MsgCallService) Unmarshal(dAtA []byte) error

func (MsgCallService) ValidateBasic 

func (msg MsgCallService) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgCallService) XXX_DiscardUnknown 

func (m *MsgCallService) XXX_DiscardUnknown()

func (*MsgCallService) XXX_Marshal 

func (m *MsgCallService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCallService) XXX_Merge 

func (m *MsgCallService) XXX_Merge(src proto.Message)

func (*MsgCallService) XXX_Size 

func (m *MsgCallService) XXX_Size() int

func (*MsgCallService) XXX_Unmarshal 

func (m *MsgCallService) XXX_Unmarshal(b []byte) error

type MsgCallServiceResponse added in v1.2.0 

type MsgCallServiceResponse struct {
	RequestContextId string `` /* 137-byte string literal not displayed */
}

MsgCallServiceResponse defines the Msg/CallService response type

func (*MsgCallServiceResponse) Descriptor added in v1.2.0 

func (*MsgCallServiceResponse) Descriptor() ([]byte, []int)

func (*MsgCallServiceResponse) Marshal added in v1.2.0 

func (m *MsgCallServiceResponse) Marshal() (dAtA []byte, err error)

func (*MsgCallServiceResponse) MarshalTo added in v1.2.0 

func (m *MsgCallServiceResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCallServiceResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgCallServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCallServiceResponse) ProtoMessage added in v1.2.0 

func (*MsgCallServiceResponse) ProtoMessage()

func (*MsgCallServiceResponse) Reset added in v1.2.0 

func (m *MsgCallServiceResponse) Reset()

func (*MsgCallServiceResponse) Size added in v1.2.0 

func (m *MsgCallServiceResponse) Size() (n int)

func (*MsgCallServiceResponse) String added in v1.2.0 

func (m *MsgCallServiceResponse) String() string

func (*MsgCallServiceResponse) Unmarshal added in v1.2.0 

func (m *MsgCallServiceResponse) Unmarshal(dAtA []byte) error

func (*MsgCallServiceResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgCallServiceResponse) XXX_DiscardUnknown()

func (*MsgCallServiceResponse) XXX_Marshal added in v1.2.0 

func (m *MsgCallServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCallServiceResponse) XXX_Merge added in v1.2.0 

func (m *MsgCallServiceResponse) XXX_Merge(src proto.Message)

func (*MsgCallServiceResponse) XXX_Size added in v1.2.0 

func (m *MsgCallServiceResponse) XXX_Size() int

func (*MsgCallServiceResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgCallServiceResponse) XXX_Unmarshal(b []byte) error

type MsgClient added in v1.2.0 

type MsgClient interface {
	// DefineService defines a method for define a new service
	DefineService(ctx context.Context, in *MsgDefineService, opts ...grpc.CallOption) (*MsgDefineServiceResponse, error)
	// BindService defines a method for bind a server
	BindService(ctx context.Context, in *MsgBindService, opts ...grpc.CallOption) (*MsgBindServiceResponse, error)
	// UpdateServiceBinding defines a method for update a service binding
	UpdateServiceBinding(ctx context.Context, in *MsgUpdateServiceBinding, opts ...grpc.CallOption) (*MsgUpdateServiceBindingResponse, error)
	// SetWithdrawAddress defines a method for setting a withdraw address
	SetWithdrawAddress(ctx context.Context, in *MsgSetWithdrawAddress, opts ...grpc.CallOption) (*MsgSetWithdrawAddressResponse, error)
	// EnableServiceBinding defines a method for enabling a service binding
	EnableServiceBinding(ctx context.Context, in *MsgEnableServiceBinding, opts ...grpc.CallOption) (*MsgEnableServiceBindingResponse, error)
	// DisableServiceBinding defines a method for disabling a service binding
	DisableServiceBinding(ctx context.Context, in *MsgDisableServiceBinding, opts ...grpc.CallOption) (*MsgDisableServiceBindingResponse, error)
	// RefundServiceDeposit defines a method for refunding a fee
	RefundServiceDeposit(ctx context.Context, in *MsgRefundServiceDeposit, opts ...grpc.CallOption) (*MsgRefundServiceDepositResponse, error)
	// CallService defines a method for calling a service
	CallService(ctx context.Context, in *MsgCallService, opts ...grpc.CallOption) (*MsgCallServiceResponse, error)
	// RespondService defines a method for responding a service
	RespondService(ctx context.Context, in *MsgRespondService, opts ...grpc.CallOption) (*MsgRespondServiceResponse, error)
	// PauseRequestContext defines a method for pausing a service call
	PauseRequestContext(ctx context.Context, in *MsgPauseRequestContext, opts ...grpc.CallOption) (*MsgPauseRequestContextResponse, error)
	// StartRequestContext defines a method for starting a service call
	StartRequestContext(ctx context.Context, in *MsgStartRequestContext, opts ...grpc.CallOption) (*MsgStartRequestContextResponse, error)
	// KillRequestContext defines a method for killing a service call
	KillRequestContext(ctx context.Context, in *MsgKillRequestContext, opts ...grpc.CallOption) (*MsgKillRequestContextResponse, error)
	// UpdateRequestContext defines a method for updating a service call
	UpdateRequestContext(ctx context.Context, in *MsgUpdateRequestContext, opts ...grpc.CallOption) (*MsgUpdateRequestContextResponse, error)
	// WithdrawEarnedFees defines a method for Withdrawing a earned fees
	WithdrawEarnedFees(ctx context.Context, in *MsgWithdrawEarnedFees, opts ...grpc.CallOption) (*MsgWithdrawEarnedFeesResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient added in v1.2.0 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgDefineService 

type MsgDefineService struct {
	Name              string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description       string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Tags              []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Author            string   `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
	AuthorDescription string   `` /* 138-byte string literal not displayed */
	Schemas           string   `protobuf:"bytes,6,opt,name=schemas,proto3" json:"schemas,omitempty"`
}

MsgDefineService defines an SDK message for defining a new service

func NewMsgDefineService 

func NewMsgDefineService(
	name string,
	description string,
	tags []string,
	author string,
	authorDescription,
	schemas string,
) *MsgDefineService

NewMsgDefineService creates a new MsgDefineService instance

func (*MsgDefineService) Descriptor 

func (*MsgDefineService) Descriptor() ([]byte, []int)

func (MsgDefineService) GetSignBytes 

func (msg MsgDefineService) GetSignBytes() []byte

GetSignBytes implements Msg

func (MsgDefineService) GetSigners 

func (msg MsgDefineService) GetSigners() []sdk.AccAddress

GetSigners implements Msg

func (*MsgDefineService) Marshal 

func (m *MsgDefineService) Marshal() (dAtA []byte, err error)

func (*MsgDefineService) MarshalTo 

func (m *MsgDefineService) MarshalTo(dAtA []byte) (int, error)

func (*MsgDefineService) MarshalToSizedBuffer 

func (m *MsgDefineService) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgDefineService) ProtoMessage 

func (*MsgDefineService) ProtoMessage()

func (*MsgDefineService) Reset 

func (m *MsgDefineService) Reset()

func (MsgDefineService) Route 

func (msg MsgDefineService) Route() string

Route implements Msg

func (*MsgDefineService) Size 

func (m *MsgDefineService) Size() (n int)

func (*MsgDefineService) String 

func (m *MsgDefineService) String() string

func (MsgDefineService) Type 

func (msg MsgDefineService) Type() string

Type implements Msg

func (*MsgDefineService) Unmarshal 

func (m *MsgDefineService) Unmarshal(dAtA []byte) error

func (MsgDefineService) ValidateBasic 

func (msg MsgDefineService) ValidateBasic() error

ValidateBasic implements Msg

func (*MsgDefineService) XXX_DiscardUnknown 

func (m *MsgDefineService) XXX_DiscardUnknown()

func (*MsgDefineService) XXX_Marshal 

func (m *MsgDefineService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgDefineService) XXX_Merge 

func (m *MsgDefineService) XXX_Merge(src proto.Message)

func (*MsgDefineService) XXX_Size 

func (m *MsgDefineService) XXX_Size() int

func (*MsgDefineService) XXX_Unmarshal 

func (m *MsgDefineService) XXX_Unmarshal(b []byte) error

type MsgDefineServiceResponse added in v1.2.0 

type MsgDefineServiceResponse struct {
}

MsgDefineServiceResponse defines the Msg/DefineService response type

func (*MsgDefineServiceResponse) Descriptor added in v1.2.0 

func (*MsgDefineServiceResponse) Descriptor() ([]byte, []int)

func (*MsgDefineServiceResponse) Marshal added in v1.2.0 

func (m *MsgDefineServiceResponse) Marshal() (dAtA []byte, err error)

func (*MsgDefineServiceResponse) MarshalTo added in v1.2.0 

func (m *MsgDefineServiceResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgDefineServiceResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgDefineServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgDefineServiceResponse) ProtoMessage added in v1.2.0 

func (*MsgDefineServiceResponse) ProtoMessage()

func (*MsgDefineServiceResponse) Reset added in v1.2.0 

func (m *MsgDefineServiceResponse) Reset()

func (*MsgDefineServiceResponse) Size added in v1.2.0 

func (m *MsgDefineServiceResponse) Size() (n int)

func (*MsgDefineServiceResponse) String added in v1.2.0 

func (m *MsgDefineServiceResponse) String() string

func (*MsgDefineServiceResponse) Unmarshal added in v1.2.0 

func (m *MsgDefineServiceResponse) Unmarshal(dAtA []byte) error

func (*MsgDefineServiceResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgDefineServiceResponse) XXX_DiscardUnknown()

func (*MsgDefineServiceResponse) XXX_Marshal added in v1.2.0 

func (m *MsgDefineServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgDefineServiceResponse) XXX_Merge added in v1.2.0 

func (m *MsgDefineServiceResponse) XXX_Merge(src proto.Message)

func (*MsgDefineServiceResponse) XXX_Size added in v1.2.0 

func (m *MsgDefineServiceResponse) XXX_Size() int

func (*MsgDefineServiceResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgDefineServiceResponse) XXX_Unmarshal(b []byte) error

type MsgDisableServiceBinding 

type MsgDisableServiceBinding struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Provider    string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Owner       string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
}

MsgDisableServiceBinding defines an SDK message to disable a service binding

func NewMsgDisableServiceBinding 

func NewMsgDisableServiceBinding(serviceName, provider, owner string) *MsgDisableServiceBinding

NewMsgDisableServiceBinding creates a new MsgDisableServiceBinding instance

func (*MsgDisableServiceBinding) Descriptor 

func (*MsgDisableServiceBinding) Descriptor() ([]byte, []int)

func (MsgDisableServiceBinding) GetSignBytes 

func (msg MsgDisableServiceBinding) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgDisableServiceBinding) GetSigners 

func (msg MsgDisableServiceBinding) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgDisableServiceBinding) Marshal 

func (m *MsgDisableServiceBinding) Marshal() (dAtA []byte, err error)

func (*MsgDisableServiceBinding) MarshalTo 

func (m *MsgDisableServiceBinding) MarshalTo(dAtA []byte) (int, error)

func (*MsgDisableServiceBinding) MarshalToSizedBuffer 

func (m *MsgDisableServiceBinding) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgDisableServiceBinding) ProtoMessage 

func (*MsgDisableServiceBinding) ProtoMessage()

func (*MsgDisableServiceBinding) Reset 

func (m *MsgDisableServiceBinding) Reset()

func (MsgDisableServiceBinding) Route 

func (msg MsgDisableServiceBinding) Route() string

Route implements Msg.

func (*MsgDisableServiceBinding) Size 

func (m *MsgDisableServiceBinding) Size() (n int)

func (*MsgDisableServiceBinding) String 

func (m *MsgDisableServiceBinding) String() string

func (MsgDisableServiceBinding) Type 

func (msg MsgDisableServiceBinding) Type() string

Type implements Msg.

func (*MsgDisableServiceBinding) Unmarshal 

func (m *MsgDisableServiceBinding) Unmarshal(dAtA []byte) error

func (MsgDisableServiceBinding) ValidateBasic 

func (msg MsgDisableServiceBinding) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgDisableServiceBinding) XXX_DiscardUnknown 

func (m *MsgDisableServiceBinding) XXX_DiscardUnknown()

func (*MsgDisableServiceBinding) XXX_Marshal 

func (m *MsgDisableServiceBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgDisableServiceBinding) XXX_Merge 

func (m *MsgDisableServiceBinding) XXX_Merge(src proto.Message)

func (*MsgDisableServiceBinding) XXX_Size 

func (m *MsgDisableServiceBinding) XXX_Size() int

func (*MsgDisableServiceBinding) XXX_Unmarshal 

func (m *MsgDisableServiceBinding) XXX_Unmarshal(b []byte) error

type MsgDisableServiceBindingResponse added in v1.2.0 

type MsgDisableServiceBindingResponse struct {
}

MsgDisableServiceBindingResponse defines the Msg/DisableServiceBinding response type

func (*MsgDisableServiceBindingResponse) Descriptor added in v1.2.0 

func (*MsgDisableServiceBindingResponse) Descriptor() ([]byte, []int)

func (*MsgDisableServiceBindingResponse) Marshal added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) Marshal() (dAtA []byte, err error)

func (*MsgDisableServiceBindingResponse) MarshalTo added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgDisableServiceBindingResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgDisableServiceBindingResponse) ProtoMessage added in v1.2.0 

func (*MsgDisableServiceBindingResponse) ProtoMessage()

func (*MsgDisableServiceBindingResponse) Reset added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) Reset()

func (*MsgDisableServiceBindingResponse) Size added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) Size() (n int)

func (*MsgDisableServiceBindingResponse) String added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) String() string

func (*MsgDisableServiceBindingResponse) Unmarshal added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) Unmarshal(dAtA []byte) error

func (*MsgDisableServiceBindingResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) XXX_DiscardUnknown()

func (*MsgDisableServiceBindingResponse) XXX_Marshal added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgDisableServiceBindingResponse) XXX_Merge added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) XXX_Merge(src proto.Message)

func (*MsgDisableServiceBindingResponse) XXX_Size added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) XXX_Size() int

func (*MsgDisableServiceBindingResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgDisableServiceBindingResponse) XXX_Unmarshal(b []byte) error

type MsgEnableServiceBinding 

type MsgEnableServiceBinding struct {
	ServiceName string                                   `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Provider    string                                   `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Deposit     github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=deposit,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"deposit"`
	Owner       string                                   `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`
}

MsgEnableServiceBinding defines an SDK message to enable a service binding

func NewMsgEnableServiceBinding 

func NewMsgEnableServiceBinding(
	serviceName string,
	provider string,
	deposit sdk.Coins,
	owner string,
) *MsgEnableServiceBinding

NewMsgEnableServiceBinding creates a new MsgEnableServiceBinding instance

func (*MsgEnableServiceBinding) Descriptor 

func (*MsgEnableServiceBinding) Descriptor() ([]byte, []int)

func (MsgEnableServiceBinding) GetSignBytes 

func (msg MsgEnableServiceBinding) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgEnableServiceBinding) GetSigners 

func (msg MsgEnableServiceBinding) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgEnableServiceBinding) Marshal 

func (m *MsgEnableServiceBinding) Marshal() (dAtA []byte, err error)

func (*MsgEnableServiceBinding) MarshalTo 

func (m *MsgEnableServiceBinding) MarshalTo(dAtA []byte) (int, error)

func (*MsgEnableServiceBinding) MarshalToSizedBuffer 

func (m *MsgEnableServiceBinding) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgEnableServiceBinding) ProtoMessage 

func (*MsgEnableServiceBinding) ProtoMessage()

func (*MsgEnableServiceBinding) Reset 

func (m *MsgEnableServiceBinding) Reset()

func (MsgEnableServiceBinding) Route 

func (msg MsgEnableServiceBinding) Route() string

Route implements Msg.

func (*MsgEnableServiceBinding) Size 

func (m *MsgEnableServiceBinding) Size() (n int)

func (*MsgEnableServiceBinding) String 

func (m *MsgEnableServiceBinding) String() string

func (MsgEnableServiceBinding) Type 

func (msg MsgEnableServiceBinding) Type() string

Type implements Msg.

func (*MsgEnableServiceBinding) Unmarshal 

func (m *MsgEnableServiceBinding) Unmarshal(dAtA []byte) error

func (MsgEnableServiceBinding) ValidateBasic 

func (msg MsgEnableServiceBinding) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgEnableServiceBinding) XXX_DiscardUnknown 

func (m *MsgEnableServiceBinding) XXX_DiscardUnknown()

func (*MsgEnableServiceBinding) XXX_Marshal 

func (m *MsgEnableServiceBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgEnableServiceBinding) XXX_Merge 

func (m *MsgEnableServiceBinding) XXX_Merge(src proto.Message)

func (*MsgEnableServiceBinding) XXX_Size 

func (m *MsgEnableServiceBinding) XXX_Size() int

func (*MsgEnableServiceBinding) XXX_Unmarshal 

func (m *MsgEnableServiceBinding) XXX_Unmarshal(b []byte) error

type MsgEnableServiceBindingResponse added in v1.2.0 

type MsgEnableServiceBindingResponse struct {
}

MsgEnableServiceBindingResponse defines the Msg/EnableServiceBinding response type

func (*MsgEnableServiceBindingResponse) Descriptor added in v1.2.0 

func (*MsgEnableServiceBindingResponse) Descriptor() ([]byte, []int)

func (*MsgEnableServiceBindingResponse) Marshal added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) Marshal() (dAtA []byte, err error)

func (*MsgEnableServiceBindingResponse) MarshalTo added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgEnableServiceBindingResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgEnableServiceBindingResponse) ProtoMessage added in v1.2.0 

func (*MsgEnableServiceBindingResponse) ProtoMessage()

func (*MsgEnableServiceBindingResponse) Reset added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) Reset()

func (*MsgEnableServiceBindingResponse) Size added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) Size() (n int)

func (*MsgEnableServiceBindingResponse) String added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) String() string

func (*MsgEnableServiceBindingResponse) Unmarshal added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) Unmarshal(dAtA []byte) error

func (*MsgEnableServiceBindingResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) XXX_DiscardUnknown()

func (*MsgEnableServiceBindingResponse) XXX_Marshal added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgEnableServiceBindingResponse) XXX_Merge added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) XXX_Merge(src proto.Message)

func (*MsgEnableServiceBindingResponse) XXX_Size added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) XXX_Size() int

func (*MsgEnableServiceBindingResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgEnableServiceBindingResponse) XXX_Unmarshal(b []byte) error

type MsgKillRequestContext 

type MsgKillRequestContext struct {
	RequestContextId string `` /* 137-byte string literal not displayed */
	Consumer         string `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
}

MsgKillRequestContext defines an SDK message to terminate a service request

func NewMsgKillRequestContext 

func NewMsgKillRequestContext(requestContextID, consumer string) *MsgKillRequestContext

NewMsgKillRequestContext creates a new MsgKillRequestContext instance

func (*MsgKillRequestContext) Descriptor 

func (*MsgKillRequestContext) Descriptor() ([]byte, []int)

func (MsgKillRequestContext) GetSignBytes 

func (msg MsgKillRequestContext) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgKillRequestContext) GetSigners 

func (msg MsgKillRequestContext) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgKillRequestContext) Marshal 

func (m *MsgKillRequestContext) Marshal() (dAtA []byte, err error)

func (*MsgKillRequestContext) MarshalTo 

func (m *MsgKillRequestContext) MarshalTo(dAtA []byte) (int, error)

func (*MsgKillRequestContext) MarshalToSizedBuffer 

func (m *MsgKillRequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgKillRequestContext) ProtoMessage 

func (*MsgKillRequestContext) ProtoMessage()

func (*MsgKillRequestContext) Reset 

func (m *MsgKillRequestContext) Reset()

func (MsgKillRequestContext) Route 

func (msg MsgKillRequestContext) Route() string

Route implements Msg.

func (*MsgKillRequestContext) Size 

func (m *MsgKillRequestContext) Size() (n int)

func (*MsgKillRequestContext) String 

func (m *MsgKillRequestContext) String() string

func (MsgKillRequestContext) Type 

func (msg MsgKillRequestContext) Type() string

Type implements Msg.

func (*MsgKillRequestContext) Unmarshal 

func (m *MsgKillRequestContext) Unmarshal(dAtA []byte) error

func (MsgKillRequestContext) ValidateBasic 

func (msg MsgKillRequestContext) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgKillRequestContext) XXX_DiscardUnknown 

func (m *MsgKillRequestContext) XXX_DiscardUnknown()

func (*MsgKillRequestContext) XXX_Marshal 

func (m *MsgKillRequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgKillRequestContext) XXX_Merge 

func (m *MsgKillRequestContext) XXX_Merge(src proto.Message)

func (*MsgKillRequestContext) XXX_Size 

func (m *MsgKillRequestContext) XXX_Size() int

func (*MsgKillRequestContext) XXX_Unmarshal 

func (m *MsgKillRequestContext) XXX_Unmarshal(b []byte) error

type MsgKillRequestContextResponse added in v1.2.0 

type MsgKillRequestContextResponse struct {
}

MsgKillRequestContextResponse defines the Msg/KillRequestContext response type

func (*MsgKillRequestContextResponse) Descriptor added in v1.2.0 

func (*MsgKillRequestContextResponse) Descriptor() ([]byte, []int)

func (*MsgKillRequestContextResponse) Marshal added in v1.2.0 

func (m *MsgKillRequestContextResponse) Marshal() (dAtA []byte, err error)

func (*MsgKillRequestContextResponse) MarshalTo added in v1.2.0 

func (m *MsgKillRequestContextResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgKillRequestContextResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgKillRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgKillRequestContextResponse) ProtoMessage added in v1.2.0 

func (*MsgKillRequestContextResponse) ProtoMessage()

func (*MsgKillRequestContextResponse) Reset added in v1.2.0 

func (m *MsgKillRequestContextResponse) Reset()

func (*MsgKillRequestContextResponse) Size added in v1.2.0 

func (m *MsgKillRequestContextResponse) Size() (n int)

func (*MsgKillRequestContextResponse) String added in v1.2.0 

func (m *MsgKillRequestContextResponse) String() string

func (*MsgKillRequestContextResponse) Unmarshal added in v1.2.0 

func (m *MsgKillRequestContextResponse) Unmarshal(dAtA []byte) error

func (*MsgKillRequestContextResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgKillRequestContextResponse) XXX_DiscardUnknown()

func (*MsgKillRequestContextResponse) XXX_Marshal added in v1.2.0 

func (m *MsgKillRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgKillRequestContextResponse) XXX_Merge added in v1.2.0 

func (m *MsgKillRequestContextResponse) XXX_Merge(src proto.Message)

func (*MsgKillRequestContextResponse) XXX_Size added in v1.2.0 

func (m *MsgKillRequestContextResponse) XXX_Size() int

func (*MsgKillRequestContextResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgKillRequestContextResponse) XXX_Unmarshal(b []byte) error

type MsgPauseRequestContext 

type MsgPauseRequestContext struct {
	RequestContextId string `` /* 137-byte string literal not displayed */
	Consumer         string `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
}

MsgPauseRequestContext defines an SDK message to pause a service request

func NewMsgPauseRequestContext 

func NewMsgPauseRequestContext(requestContextID, consumer string) *MsgPauseRequestContext

NewMsgPauseRequestContext creates a new MsgPauseRequestContext instance

func (*MsgPauseRequestContext) Descriptor 

func (*MsgPauseRequestContext) Descriptor() ([]byte, []int)

func (MsgPauseRequestContext) GetSignBytes 

func (msg MsgPauseRequestContext) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgPauseRequestContext) GetSigners 

func (msg MsgPauseRequestContext) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgPauseRequestContext) Marshal 

func (m *MsgPauseRequestContext) Marshal() (dAtA []byte, err error)

func (*MsgPauseRequestContext) MarshalTo 

func (m *MsgPauseRequestContext) MarshalTo(dAtA []byte) (int, error)

func (*MsgPauseRequestContext) MarshalToSizedBuffer 

func (m *MsgPauseRequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgPauseRequestContext) ProtoMessage 

func (*MsgPauseRequestContext) ProtoMessage()

func (*MsgPauseRequestContext) Reset 

func (m *MsgPauseRequestContext) Reset()

func (MsgPauseRequestContext) Route 

func (msg MsgPauseRequestContext) Route() string

Route implements Msg.

func (*MsgPauseRequestContext) Size 

func (m *MsgPauseRequestContext) Size() (n int)

func (*MsgPauseRequestContext) String 

func (m *MsgPauseRequestContext) String() string

func (MsgPauseRequestContext) Type 

func (msg MsgPauseRequestContext) Type() string

Type implements Msg.

func (*MsgPauseRequestContext) Unmarshal 

func (m *MsgPauseRequestContext) Unmarshal(dAtA []byte) error

func (MsgPauseRequestContext) ValidateBasic 

func (msg MsgPauseRequestContext) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgPauseRequestContext) XXX_DiscardUnknown 

func (m *MsgPauseRequestContext) XXX_DiscardUnknown()

func (*MsgPauseRequestContext) XXX_Marshal 

func (m *MsgPauseRequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgPauseRequestContext) XXX_Merge 

func (m *MsgPauseRequestContext) XXX_Merge(src proto.Message)

func (*MsgPauseRequestContext) XXX_Size 

func (m *MsgPauseRequestContext) XXX_Size() int

func (*MsgPauseRequestContext) XXX_Unmarshal 

func (m *MsgPauseRequestContext) XXX_Unmarshal(b []byte) error

type MsgPauseRequestContextResponse added in v1.2.0 

type MsgPauseRequestContextResponse struct {
}

MsgPauseRequestContextResponse defines the Msg/PauseRequestContext response type

func (*MsgPauseRequestContextResponse) Descriptor added in v1.2.0 

func (*MsgPauseRequestContextResponse) Descriptor() ([]byte, []int)

func (*MsgPauseRequestContextResponse) Marshal added in v1.2.0 

func (m *MsgPauseRequestContextResponse) Marshal() (dAtA []byte, err error)

func (*MsgPauseRequestContextResponse) MarshalTo added in v1.2.0 

func (m *MsgPauseRequestContextResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgPauseRequestContextResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgPauseRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgPauseRequestContextResponse) ProtoMessage added in v1.2.0 

func (*MsgPauseRequestContextResponse) ProtoMessage()

func (*MsgPauseRequestContextResponse) Reset added in v1.2.0 

func (m *MsgPauseRequestContextResponse) Reset()

func (*MsgPauseRequestContextResponse) Size added in v1.2.0 

func (m *MsgPauseRequestContextResponse) Size() (n int)

func (*MsgPauseRequestContextResponse) String added in v1.2.0 

func (m *MsgPauseRequestContextResponse) String() string

func (*MsgPauseRequestContextResponse) Unmarshal added in v1.2.0 

func (m *MsgPauseRequestContextResponse) Unmarshal(dAtA []byte) error

func (*MsgPauseRequestContextResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgPauseRequestContextResponse) XXX_DiscardUnknown()

func (*MsgPauseRequestContextResponse) XXX_Marshal added in v1.2.0 

func (m *MsgPauseRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgPauseRequestContextResponse) XXX_Merge added in v1.2.0 

func (m *MsgPauseRequestContextResponse) XXX_Merge(src proto.Message)

func (*MsgPauseRequestContextResponse) XXX_Size added in v1.2.0 

func (m *MsgPauseRequestContextResponse) XXX_Size() int

func (*MsgPauseRequestContextResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgPauseRequestContextResponse) XXX_Unmarshal(b []byte) error

type MsgRefundServiceDeposit 

type MsgRefundServiceDeposit struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Provider    string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Owner       string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
}

MsgRefundServiceDeposit defines an SDK message to refund deposit from a service binding

func NewMsgRefundServiceDeposit 

func NewMsgRefundServiceDeposit(serviceName, provider, owner string) *MsgRefundServiceDeposit

NewMsgRefundServiceDeposit creates a new MsgRefundServiceDeposit instance

func (*MsgRefundServiceDeposit) Descriptor 

func (*MsgRefundServiceDeposit) Descriptor() ([]byte, []int)

func (MsgRefundServiceDeposit) GetSignBytes 

func (msg MsgRefundServiceDeposit) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgRefundServiceDeposit) GetSigners 

func (msg MsgRefundServiceDeposit) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgRefundServiceDeposit) Marshal 

func (m *MsgRefundServiceDeposit) Marshal() (dAtA []byte, err error)

func (*MsgRefundServiceDeposit) MarshalTo 

func (m *MsgRefundServiceDeposit) MarshalTo(dAtA []byte) (int, error)

func (*MsgRefundServiceDeposit) MarshalToSizedBuffer 

func (m *MsgRefundServiceDeposit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRefundServiceDeposit) ProtoMessage 

func (*MsgRefundServiceDeposit) ProtoMessage()

func (*MsgRefundServiceDeposit) Reset 

func (m *MsgRefundServiceDeposit) Reset()

func (MsgRefundServiceDeposit) Route 

func (msg MsgRefundServiceDeposit) Route() string

Route implements Msg.

func (*MsgRefundServiceDeposit) Size 

func (m *MsgRefundServiceDeposit) Size() (n int)

func (*MsgRefundServiceDeposit) String 

func (m *MsgRefundServiceDeposit) String() string

func (MsgRefundServiceDeposit) Type 

func (msg MsgRefundServiceDeposit) Type() string

Type implements Msg.

func (*MsgRefundServiceDeposit) Unmarshal 

func (m *MsgRefundServiceDeposit) Unmarshal(dAtA []byte) error

func (MsgRefundServiceDeposit) ValidateBasic 

func (msg MsgRefundServiceDeposit) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgRefundServiceDeposit) XXX_DiscardUnknown 

func (m *MsgRefundServiceDeposit) XXX_DiscardUnknown()

func (*MsgRefundServiceDeposit) XXX_Marshal 

func (m *MsgRefundServiceDeposit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRefundServiceDeposit) XXX_Merge 

func (m *MsgRefundServiceDeposit) XXX_Merge(src proto.Message)

func (*MsgRefundServiceDeposit) XXX_Size 

func (m *MsgRefundServiceDeposit) XXX_Size() int

func (*MsgRefundServiceDeposit) XXX_Unmarshal 

func (m *MsgRefundServiceDeposit) XXX_Unmarshal(b []byte) error

type MsgRefundServiceDepositResponse added in v1.2.0 

type MsgRefundServiceDepositResponse struct {
}

MsgRefundServiceDepositResponse defines the Msg/RefundServiceDeposit response type

func (*MsgRefundServiceDepositResponse) Descriptor added in v1.2.0 

func (*MsgRefundServiceDepositResponse) Descriptor() ([]byte, []int)

func (*MsgRefundServiceDepositResponse) Marshal added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) Marshal() (dAtA []byte, err error)

func (*MsgRefundServiceDepositResponse) MarshalTo added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgRefundServiceDepositResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRefundServiceDepositResponse) ProtoMessage added in v1.2.0 

func (*MsgRefundServiceDepositResponse) ProtoMessage()

func (*MsgRefundServiceDepositResponse) Reset added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) Reset()

func (*MsgRefundServiceDepositResponse) Size added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) Size() (n int)

func (*MsgRefundServiceDepositResponse) String added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) String() string

func (*MsgRefundServiceDepositResponse) Unmarshal added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) Unmarshal(dAtA []byte) error

func (*MsgRefundServiceDepositResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) XXX_DiscardUnknown()

func (*MsgRefundServiceDepositResponse) XXX_Marshal added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRefundServiceDepositResponse) XXX_Merge added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) XXX_Merge(src proto.Message)

func (*MsgRefundServiceDepositResponse) XXX_Size added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) XXX_Size() int

func (*MsgRefundServiceDepositResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgRefundServiceDepositResponse) XXX_Unmarshal(b []byte) error

type MsgRespondService 

type MsgRespondService struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty" yaml:"request_id"`
	Provider  string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Result    string `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	Output    string `protobuf:"bytes,4,opt,name=output,proto3" json:"output,omitempty"`
}

MsgRespondService defines an SDK message to respond a service request

func NewMsgRespondService 

func NewMsgRespondService(requestID, provider, result, output string) *MsgRespondService

NewMsgRespondService creates a new MsgRespondService instance

func (*MsgRespondService) Descriptor 

func (*MsgRespondService) Descriptor() ([]byte, []int)

func (MsgRespondService) GetSignBytes 

func (msg MsgRespondService) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgRespondService) GetSigners 

func (msg MsgRespondService) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgRespondService) Marshal 

func (m *MsgRespondService) Marshal() (dAtA []byte, err error)

func (*MsgRespondService) MarshalTo 

func (m *MsgRespondService) MarshalTo(dAtA []byte) (int, error)

func (*MsgRespondService) MarshalToSizedBuffer 

func (m *MsgRespondService) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRespondService) ProtoMessage 

func (*MsgRespondService) ProtoMessage()

func (*MsgRespondService) Reset 

func (m *MsgRespondService) Reset()

func (MsgRespondService) Route 

func (msg MsgRespondService) Route() string

Route implements Msg.

func (*MsgRespondService) Size 

func (m *MsgRespondService) Size() (n int)

func (*MsgRespondService) String 

func (m *MsgRespondService) String() string

func (MsgRespondService) Type 

func (msg MsgRespondService) Type() string

Type implements Msg.

func (*MsgRespondService) Unmarshal 

func (m *MsgRespondService) Unmarshal(dAtA []byte) error

func (MsgRespondService) ValidateBasic 

func (msg MsgRespondService) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgRespondService) XXX_DiscardUnknown 

func (m *MsgRespondService) XXX_DiscardUnknown()

func (*MsgRespondService) XXX_Marshal 

func (m *MsgRespondService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRespondService) XXX_Merge 

func (m *MsgRespondService) XXX_Merge(src proto.Message)

func (*MsgRespondService) XXX_Size 

func (m *MsgRespondService) XXX_Size() int

func (*MsgRespondService) XXX_Unmarshal 

func (m *MsgRespondService) XXX_Unmarshal(b []byte) error

type MsgRespondServiceResponse added in v1.2.0 

type MsgRespondServiceResponse struct {
}

MsgRespondServiceResponse defines the Msg/RespondService response type

func (*MsgRespondServiceResponse) Descriptor added in v1.2.0 

func (*MsgRespondServiceResponse) Descriptor() ([]byte, []int)

func (*MsgRespondServiceResponse) Marshal added in v1.2.0 

func (m *MsgRespondServiceResponse) Marshal() (dAtA []byte, err error)

func (*MsgRespondServiceResponse) MarshalTo added in v1.2.0 

func (m *MsgRespondServiceResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgRespondServiceResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgRespondServiceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRespondServiceResponse) ProtoMessage added in v1.2.0 

func (*MsgRespondServiceResponse) ProtoMessage()

func (*MsgRespondServiceResponse) Reset added in v1.2.0 

func (m *MsgRespondServiceResponse) Reset()

func (*MsgRespondServiceResponse) Size added in v1.2.0 

func (m *MsgRespondServiceResponse) Size() (n int)

func (*MsgRespondServiceResponse) String added in v1.2.0 

func (m *MsgRespondServiceResponse) String() string

func (*MsgRespondServiceResponse) Unmarshal added in v1.2.0 

func (m *MsgRespondServiceResponse) Unmarshal(dAtA []byte) error

func (*MsgRespondServiceResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgRespondServiceResponse) XXX_DiscardUnknown()

func (*MsgRespondServiceResponse) XXX_Marshal added in v1.2.0 

func (m *MsgRespondServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRespondServiceResponse) XXX_Merge added in v1.2.0 

func (m *MsgRespondServiceResponse) XXX_Merge(src proto.Message)

func (*MsgRespondServiceResponse) XXX_Size added in v1.2.0 

func (m *MsgRespondServiceResponse) XXX_Size() int

func (*MsgRespondServiceResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgRespondServiceResponse) XXX_Unmarshal(b []byte) error

type MsgServer added in v1.2.0 

type MsgServer interface {
	// DefineService defines a method for define a new service
	DefineService(context.Context, *MsgDefineService) (*MsgDefineServiceResponse, error)
	// BindService defines a method for bind a server
	BindService(context.Context, *MsgBindService) (*MsgBindServiceResponse, error)
	// UpdateServiceBinding defines a method for update a service binding
	UpdateServiceBinding(context.Context, *MsgUpdateServiceBinding) (*MsgUpdateServiceBindingResponse, error)
	// SetWithdrawAddress defines a method for setting a withdraw address
	SetWithdrawAddress(context.Context, *MsgSetWithdrawAddress) (*MsgSetWithdrawAddressResponse, error)
	// EnableServiceBinding defines a method for enabling a service binding
	EnableServiceBinding(context.Context, *MsgEnableServiceBinding) (*MsgEnableServiceBindingResponse, error)
	// DisableServiceBinding defines a method for disabling a service binding
	DisableServiceBinding(context.Context, *MsgDisableServiceBinding) (*MsgDisableServiceBindingResponse, error)
	// RefundServiceDeposit defines a method for refunding a fee
	RefundServiceDeposit(context.Context, *MsgRefundServiceDeposit) (*MsgRefundServiceDepositResponse, error)
	// CallService defines a method for calling a service
	CallService(context.Context, *MsgCallService) (*MsgCallServiceResponse, error)
	// RespondService defines a method for responding a service
	RespondService(context.Context, *MsgRespondService) (*MsgRespondServiceResponse, error)
	// PauseRequestContext defines a method for pausing a service call
	PauseRequestContext(context.Context, *MsgPauseRequestContext) (*MsgPauseRequestContextResponse, error)
	// StartRequestContext defines a method for starting a service call
	StartRequestContext(context.Context, *MsgStartRequestContext) (*MsgStartRequestContextResponse, error)
	// KillRequestContext defines a method for killing a service call
	KillRequestContext(context.Context, *MsgKillRequestContext) (*MsgKillRequestContextResponse, error)
	// UpdateRequestContext defines a method for updating a service call
	UpdateRequestContext(context.Context, *MsgUpdateRequestContext) (*MsgUpdateRequestContextResponse, error)
	// WithdrawEarnedFees defines a method for Withdrawing a earned fees
	WithdrawEarnedFees(context.Context, *MsgWithdrawEarnedFees) (*MsgWithdrawEarnedFeesResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetWithdrawAddress 

type MsgSetWithdrawAddress struct {
	Owner           string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	WithdrawAddress string `` /* 130-byte string literal not displayed */
}

MsgSetWithdrawAddress defines an SDK message to set the withdrawal address for a provider

func NewMsgSetWithdrawAddress 

func NewMsgSetWithdrawAddress(owner, withdrawAddr string) *MsgSetWithdrawAddress

NewMsgSetWithdrawAddress creates a new MsgSetWithdrawAddress instance

func (*MsgSetWithdrawAddress) Descriptor 

func (*MsgSetWithdrawAddress) Descriptor() ([]byte, []int)

func (MsgSetWithdrawAddress) GetSignBytes 

func (msg MsgSetWithdrawAddress) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgSetWithdrawAddress) GetSigners 

func (msg MsgSetWithdrawAddress) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgSetWithdrawAddress) Marshal 

func (m *MsgSetWithdrawAddress) Marshal() (dAtA []byte, err error)

func (*MsgSetWithdrawAddress) MarshalTo 

func (m *MsgSetWithdrawAddress) MarshalTo(dAtA []byte) (int, error)

func (*MsgSetWithdrawAddress) MarshalToSizedBuffer 

func (m *MsgSetWithdrawAddress) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (MsgSetWithdrawAddress) Normalize added in v1.2.1 

func (msg MsgSetWithdrawAddress) Normalize() MsgSetWithdrawAddress

Normalize return a string with spaces removed and lowercase

func (*MsgSetWithdrawAddress) ProtoMessage 

func (*MsgSetWithdrawAddress) ProtoMessage()

func (*MsgSetWithdrawAddress) Reset 

func (m *MsgSetWithdrawAddress) Reset()

func (MsgSetWithdrawAddress) Route 

func (msg MsgSetWithdrawAddress) Route() string

Route implements Msg.

func (*MsgSetWithdrawAddress) Size 

func (m *MsgSetWithdrawAddress) Size() (n int)

func (*MsgSetWithdrawAddress) String 

func (m *MsgSetWithdrawAddress) String() string

func (MsgSetWithdrawAddress) Type 

func (msg MsgSetWithdrawAddress) Type() string

Type implements Msg.

func (*MsgSetWithdrawAddress) Unmarshal 

func (m *MsgSetWithdrawAddress) Unmarshal(dAtA []byte) error

func (MsgSetWithdrawAddress) ValidateBasic 

func (msg MsgSetWithdrawAddress) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgSetWithdrawAddress) XXX_DiscardUnknown 

func (m *MsgSetWithdrawAddress) XXX_DiscardUnknown()

func (*MsgSetWithdrawAddress) XXX_Marshal 

func (m *MsgSetWithdrawAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgSetWithdrawAddress) XXX_Merge 

func (m *MsgSetWithdrawAddress) XXX_Merge(src proto.Message)

func (*MsgSetWithdrawAddress) XXX_Size 

func (m *MsgSetWithdrawAddress) XXX_Size() int

func (*MsgSetWithdrawAddress) XXX_Unmarshal 

func (m *MsgSetWithdrawAddress) XXX_Unmarshal(b []byte) error

type MsgSetWithdrawAddressResponse added in v1.2.0 

type MsgSetWithdrawAddressResponse struct {
}

MsgSetWithdrawAddressResponse defines the Msg/SetWithdrawAddress response type

func (*MsgSetWithdrawAddressResponse) Descriptor added in v1.2.0 

func (*MsgSetWithdrawAddressResponse) Descriptor() ([]byte, []int)

func (*MsgSetWithdrawAddressResponse) Marshal added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) Marshal() (dAtA []byte, err error)

func (*MsgSetWithdrawAddressResponse) MarshalTo added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgSetWithdrawAddressResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgSetWithdrawAddressResponse) ProtoMessage added in v1.2.0 

func (*MsgSetWithdrawAddressResponse) ProtoMessage()

func (*MsgSetWithdrawAddressResponse) Reset added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) Reset()

func (*MsgSetWithdrawAddressResponse) Size added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) Size() (n int)

func (*MsgSetWithdrawAddressResponse) String added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) String() string

func (*MsgSetWithdrawAddressResponse) Unmarshal added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) Unmarshal(dAtA []byte) error

func (*MsgSetWithdrawAddressResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) XXX_DiscardUnknown()

func (*MsgSetWithdrawAddressResponse) XXX_Marshal added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgSetWithdrawAddressResponse) XXX_Merge added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) XXX_Merge(src proto.Message)

func (*MsgSetWithdrawAddressResponse) XXX_Size added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) XXX_Size() int

func (*MsgSetWithdrawAddressResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgSetWithdrawAddressResponse) XXX_Unmarshal(b []byte) error

type MsgStartRequestContext 

type MsgStartRequestContext struct {
	RequestContextId string `` /* 137-byte string literal not displayed */
	Consumer         string `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
}

MsgStartRequestContext defines an SDK message to resume a service request

func NewMsgStartRequestContext 

func NewMsgStartRequestContext(requestContextID, consumer string) *MsgStartRequestContext

NewMsgStartRequestContext creates a new MsgStartRequestContext instance

func (*MsgStartRequestContext) Descriptor 

func (*MsgStartRequestContext) Descriptor() ([]byte, []int)

func (MsgStartRequestContext) GetSignBytes 

func (msg MsgStartRequestContext) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgStartRequestContext) GetSigners 

func (msg MsgStartRequestContext) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgStartRequestContext) Marshal 

func (m *MsgStartRequestContext) Marshal() (dAtA []byte, err error)

func (*MsgStartRequestContext) MarshalTo 

func (m *MsgStartRequestContext) MarshalTo(dAtA []byte) (int, error)

func (*MsgStartRequestContext) MarshalToSizedBuffer 

func (m *MsgStartRequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgStartRequestContext) ProtoMessage 

func (*MsgStartRequestContext) ProtoMessage()

func (*MsgStartRequestContext) Reset 

func (m *MsgStartRequestContext) Reset()

func (MsgStartRequestContext) Route 

func (msg MsgStartRequestContext) Route() string

Route implements Msg.

func (*MsgStartRequestContext) Size 

func (m *MsgStartRequestContext) Size() (n int)

func (*MsgStartRequestContext) String 

func (m *MsgStartRequestContext) String() string

func (MsgStartRequestContext) Type 

func (msg MsgStartRequestContext) Type() string

Type implements Msg.

func (*MsgStartRequestContext) Unmarshal 

func (m *MsgStartRequestContext) Unmarshal(dAtA []byte) error

func (MsgStartRequestContext) ValidateBasic 

func (msg MsgStartRequestContext) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgStartRequestContext) XXX_DiscardUnknown 

func (m *MsgStartRequestContext) XXX_DiscardUnknown()

func (*MsgStartRequestContext) XXX_Marshal 

func (m *MsgStartRequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgStartRequestContext) XXX_Merge 

func (m *MsgStartRequestContext) XXX_Merge(src proto.Message)

func (*MsgStartRequestContext) XXX_Size 

func (m *MsgStartRequestContext) XXX_Size() int

func (*MsgStartRequestContext) XXX_Unmarshal 

func (m *MsgStartRequestContext) XXX_Unmarshal(b []byte) error

type MsgStartRequestContextResponse added in v1.2.0 

type MsgStartRequestContextResponse struct {
}

MsgStartRequestContextResponse defines the Msg/StartRequestContext response type

func (*MsgStartRequestContextResponse) Descriptor added in v1.2.0 

func (*MsgStartRequestContextResponse) Descriptor() ([]byte, []int)

func (*MsgStartRequestContextResponse) Marshal added in v1.2.0 

func (m *MsgStartRequestContextResponse) Marshal() (dAtA []byte, err error)

func (*MsgStartRequestContextResponse) MarshalTo added in v1.2.0 

func (m *MsgStartRequestContextResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgStartRequestContextResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgStartRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgStartRequestContextResponse) ProtoMessage added in v1.2.0 

func (*MsgStartRequestContextResponse) ProtoMessage()

func (*MsgStartRequestContextResponse) Reset added in v1.2.0 

func (m *MsgStartRequestContextResponse) Reset()

func (*MsgStartRequestContextResponse) Size added in v1.2.0 

func (m *MsgStartRequestContextResponse) Size() (n int)

func (*MsgStartRequestContextResponse) String added in v1.2.0 

func (m *MsgStartRequestContextResponse) String() string

func (*MsgStartRequestContextResponse) Unmarshal added in v1.2.0 

func (m *MsgStartRequestContextResponse) Unmarshal(dAtA []byte) error

func (*MsgStartRequestContextResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgStartRequestContextResponse) XXX_DiscardUnknown()

func (*MsgStartRequestContextResponse) XXX_Marshal added in v1.2.0 

func (m *MsgStartRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgStartRequestContextResponse) XXX_Merge added in v1.2.0 

func (m *MsgStartRequestContextResponse) XXX_Merge(src proto.Message)

func (*MsgStartRequestContextResponse) XXX_Size added in v1.2.0 

func (m *MsgStartRequestContextResponse) XXX_Size() int

func (*MsgStartRequestContextResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgStartRequestContextResponse) XXX_Unmarshal(b []byte) error

type MsgUpdateRequestContext 

type MsgUpdateRequestContext struct {
	RequestContextId  string                                   `` /* 137-byte string literal not displayed */
	Providers         []string                                 `protobuf:"bytes,2,rep,name=providers,proto3" json:"providers,omitempty"`
	Consumer          string                                   `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
	ServiceFeeCap     github_com_cosmos_cosmos_sdk_types.Coins `` /* 169-byte string literal not displayed */
	Timeout           int64                                    `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	RepeatedFrequency uint64                                   `` /* 139-byte string literal not displayed */
	RepeatedTotal     int64                                    `protobuf:"varint,7,opt,name=repeated_total,json=repeatedTotal,proto3" json:"repeated_total,omitempty" yaml:"repeated_total"`
}

MsgUpdateRequestContext defines an SDK message to update a service request context

func NewMsgUpdateRequestContext 

func NewMsgUpdateRequestContext(
	requestContextID string,
	providers []string,
	serviceFeeCap sdk.Coins,
	timeout int64,
	repeatedFrequency uint64,
	repeatedTotal int64,
	consumer string,
) *MsgUpdateRequestContext

NewMsgUpdateRequestContext creates a new MsgUpdateRequestContext instance

func (*MsgUpdateRequestContext) Descriptor 

func (*MsgUpdateRequestContext) Descriptor() ([]byte, []int)

func (MsgUpdateRequestContext) GetSignBytes 

func (msg MsgUpdateRequestContext) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgUpdateRequestContext) GetSigners 

func (msg MsgUpdateRequestContext) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgUpdateRequestContext) Marshal 

func (m *MsgUpdateRequestContext) Marshal() (dAtA []byte, err error)

func (*MsgUpdateRequestContext) MarshalTo 

func (m *MsgUpdateRequestContext) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateRequestContext) MarshalToSizedBuffer 

func (m *MsgUpdateRequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateRequestContext) ProtoMessage 

func (*MsgUpdateRequestContext) ProtoMessage()

func (*MsgUpdateRequestContext) Reset 

func (m *MsgUpdateRequestContext) Reset()

func (MsgUpdateRequestContext) Route 

func (msg MsgUpdateRequestContext) Route() string

Route implements Msg.

func (*MsgUpdateRequestContext) Size 

func (m *MsgUpdateRequestContext) Size() (n int)

func (*MsgUpdateRequestContext) String 

func (m *MsgUpdateRequestContext) String() string

func (MsgUpdateRequestContext) Type 

func (msg MsgUpdateRequestContext) Type() string

Type implements Msg.

func (*MsgUpdateRequestContext) Unmarshal 

func (m *MsgUpdateRequestContext) Unmarshal(dAtA []byte) error

func (MsgUpdateRequestContext) ValidateBasic 

func (msg MsgUpdateRequestContext) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgUpdateRequestContext) XXX_DiscardUnknown 

func (m *MsgUpdateRequestContext) XXX_DiscardUnknown()

func (*MsgUpdateRequestContext) XXX_Marshal 

func (m *MsgUpdateRequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateRequestContext) XXX_Merge 

func (m *MsgUpdateRequestContext) XXX_Merge(src proto.Message)

func (*MsgUpdateRequestContext) XXX_Size 

func (m *MsgUpdateRequestContext) XXX_Size() int

func (*MsgUpdateRequestContext) XXX_Unmarshal 

func (m *MsgUpdateRequestContext) XXX_Unmarshal(b []byte) error

type MsgUpdateRequestContextResponse added in v1.2.0 

type MsgUpdateRequestContextResponse struct {
}

MsgUpdateRequestContextResponse defines the Msg/UpdateRequestContext response type

func (*MsgUpdateRequestContextResponse) Descriptor added in v1.2.0 

func (*MsgUpdateRequestContextResponse) Descriptor() ([]byte, []int)

func (*MsgUpdateRequestContextResponse) Marshal added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpdateRequestContextResponse) MarshalTo added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateRequestContextResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateRequestContextResponse) ProtoMessage added in v1.2.0 

func (*MsgUpdateRequestContextResponse) ProtoMessage()

func (*MsgUpdateRequestContextResponse) Reset added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) Reset()

func (*MsgUpdateRequestContextResponse) Size added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) Size() (n int)

func (*MsgUpdateRequestContextResponse) String added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) String() string

func (*MsgUpdateRequestContextResponse) Unmarshal added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) Unmarshal(dAtA []byte) error

func (*MsgUpdateRequestContextResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) XXX_DiscardUnknown()

func (*MsgUpdateRequestContextResponse) XXX_Marshal added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateRequestContextResponse) XXX_Merge added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) XXX_Merge(src proto.Message)

func (*MsgUpdateRequestContextResponse) XXX_Size added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) XXX_Size() int

func (*MsgUpdateRequestContextResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgUpdateRequestContextResponse) XXX_Unmarshal(b []byte) error

type MsgUpdateServiceBinding 

type MsgUpdateServiceBinding struct {
	ServiceName string                                   `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Provider    string                                   `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Deposit     github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=deposit,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"deposit"`
	Pricing     string                                   `protobuf:"bytes,4,opt,name=pricing,proto3" json:"pricing,omitempty"`
	QoS         uint64                                   `protobuf:"varint,5,opt,name=qos,proto3" json:"qos,omitempty"`
	Options     string                                   `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	Owner       string                                   `protobuf:"bytes,7,opt,name=owner,proto3" json:"owner,omitempty"`
}

MsgUpdateServiceBinding defines an SDK message for updating an existing service binding

func NewMsgUpdateServiceBinding 

func NewMsgUpdateServiceBinding(
	serviceName string,
	provider string,
	deposit sdk.Coins,
	pricing string,
	qos uint64,
	options string,
	owner string,
) *MsgUpdateServiceBinding

NewMsgUpdateServiceBinding creates a new MsgUpdateServiceBinding instance

func (*MsgUpdateServiceBinding) Descriptor 

func (*MsgUpdateServiceBinding) Descriptor() ([]byte, []int)

func (MsgUpdateServiceBinding) GetSignBytes 

func (msg MsgUpdateServiceBinding) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgUpdateServiceBinding) GetSigners 

func (msg MsgUpdateServiceBinding) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgUpdateServiceBinding) Marshal 

func (m *MsgUpdateServiceBinding) Marshal() (dAtA []byte, err error)

func (*MsgUpdateServiceBinding) MarshalTo 

func (m *MsgUpdateServiceBinding) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateServiceBinding) MarshalToSizedBuffer 

func (m *MsgUpdateServiceBinding) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateServiceBinding) ProtoMessage 

func (*MsgUpdateServiceBinding) ProtoMessage()

func (*MsgUpdateServiceBinding) Reset 

func (m *MsgUpdateServiceBinding) Reset()

func (MsgUpdateServiceBinding) Route 

func (msg MsgUpdateServiceBinding) Route() string

Route implements Msg.

func (*MsgUpdateServiceBinding) Size 

func (m *MsgUpdateServiceBinding) Size() (n int)

func (*MsgUpdateServiceBinding) String 

func (m *MsgUpdateServiceBinding) String() string

func (MsgUpdateServiceBinding) Type 

func (msg MsgUpdateServiceBinding) Type() string

Type implements Msg.

func (*MsgUpdateServiceBinding) Unmarshal 

func (m *MsgUpdateServiceBinding) Unmarshal(dAtA []byte) error

func (MsgUpdateServiceBinding) ValidateBasic 

func (msg MsgUpdateServiceBinding) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgUpdateServiceBinding) XXX_DiscardUnknown 

func (m *MsgUpdateServiceBinding) XXX_DiscardUnknown()

func (*MsgUpdateServiceBinding) XXX_Marshal 

func (m *MsgUpdateServiceBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateServiceBinding) XXX_Merge 

func (m *MsgUpdateServiceBinding) XXX_Merge(src proto.Message)

func (*MsgUpdateServiceBinding) XXX_Size 

func (m *MsgUpdateServiceBinding) XXX_Size() int

func (*MsgUpdateServiceBinding) XXX_Unmarshal 

func (m *MsgUpdateServiceBinding) XXX_Unmarshal(b []byte) error

type MsgUpdateServiceBindingResponse added in v1.2.0 

type MsgUpdateServiceBindingResponse struct {
}

MsgUpdateServiceBindingResponse defines the Msg/UpdateServiceBinding response type

func (*MsgUpdateServiceBindingResponse) Descriptor added in v1.2.0 

func (*MsgUpdateServiceBindingResponse) Descriptor() ([]byte, []int)

func (*MsgUpdateServiceBindingResponse) Marshal added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpdateServiceBindingResponse) MarshalTo added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateServiceBindingResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateServiceBindingResponse) ProtoMessage added in v1.2.0 

func (*MsgUpdateServiceBindingResponse) ProtoMessage()

func (*MsgUpdateServiceBindingResponse) Reset added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) Reset()

func (*MsgUpdateServiceBindingResponse) Size added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) Size() (n int)

func (*MsgUpdateServiceBindingResponse) String added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) String() string

func (*MsgUpdateServiceBindingResponse) Unmarshal added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) Unmarshal(dAtA []byte) error

func (*MsgUpdateServiceBindingResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) XXX_DiscardUnknown()

func (*MsgUpdateServiceBindingResponse) XXX_Marshal added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateServiceBindingResponse) XXX_Merge added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) XXX_Merge(src proto.Message)

func (*MsgUpdateServiceBindingResponse) XXX_Size added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) XXX_Size() int

func (*MsgUpdateServiceBindingResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgUpdateServiceBindingResponse) XXX_Unmarshal(b []byte) error

type MsgWithdrawEarnedFees 

type MsgWithdrawEarnedFees struct {
	Owner    string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Provider string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
}

MsgWithdrawEarnedFees defines an SDK message to withdraw the fees earned by the provider or owner

func NewMsgWithdrawEarnedFees 

func NewMsgWithdrawEarnedFees(owner, provider string) *MsgWithdrawEarnedFees

NewMsgWithdrawEarnedFees creates a new MsgWithdrawEarnedFees instance

func (*MsgWithdrawEarnedFees) Descriptor 

func (*MsgWithdrawEarnedFees) Descriptor() ([]byte, []int)

func (MsgWithdrawEarnedFees) GetSignBytes 

func (msg MsgWithdrawEarnedFees) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgWithdrawEarnedFees) GetSigners 

func (msg MsgWithdrawEarnedFees) GetSigners() []sdk.AccAddress

GetSigners implements Msg.

func (*MsgWithdrawEarnedFees) Marshal 

func (m *MsgWithdrawEarnedFees) Marshal() (dAtA []byte, err error)

func (*MsgWithdrawEarnedFees) MarshalTo 

func (m *MsgWithdrawEarnedFees) MarshalTo(dAtA []byte) (int, error)

func (*MsgWithdrawEarnedFees) MarshalToSizedBuffer 

func (m *MsgWithdrawEarnedFees) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgWithdrawEarnedFees) ProtoMessage 

func (*MsgWithdrawEarnedFees) ProtoMessage()

func (*MsgWithdrawEarnedFees) Reset 

func (m *MsgWithdrawEarnedFees) Reset()

func (MsgWithdrawEarnedFees) Route 

func (msg MsgWithdrawEarnedFees) Route() string

Route implements Msg.

func (*MsgWithdrawEarnedFees) Size 

func (m *MsgWithdrawEarnedFees) Size() (n int)

func (*MsgWithdrawEarnedFees) String 

func (m *MsgWithdrawEarnedFees) String() string

func (MsgWithdrawEarnedFees) Type 

func (msg MsgWithdrawEarnedFees) Type() string

Type implements Msg.

func (*MsgWithdrawEarnedFees) Unmarshal 

func (m *MsgWithdrawEarnedFees) Unmarshal(dAtA []byte) error

func (MsgWithdrawEarnedFees) ValidateBasic 

func (msg MsgWithdrawEarnedFees) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgWithdrawEarnedFees) XXX_DiscardUnknown 

func (m *MsgWithdrawEarnedFees) XXX_DiscardUnknown()

func (*MsgWithdrawEarnedFees) XXX_Marshal 

func (m *MsgWithdrawEarnedFees) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgWithdrawEarnedFees) XXX_Merge 

func (m *MsgWithdrawEarnedFees) XXX_Merge(src proto.Message)

func (*MsgWithdrawEarnedFees) XXX_Size 

func (m *MsgWithdrawEarnedFees) XXX_Size() int

func (*MsgWithdrawEarnedFees) XXX_Unmarshal 

func (m *MsgWithdrawEarnedFees) XXX_Unmarshal(b []byte) error

type MsgWithdrawEarnedFeesResponse added in v1.2.0 

type MsgWithdrawEarnedFeesResponse struct {
}

MsgWithdrawEarnedFeesResponse defines the Msg/WithdrawEarnedFees response type

func (*MsgWithdrawEarnedFeesResponse) Descriptor added in v1.2.0 

func (*MsgWithdrawEarnedFeesResponse) Descriptor() ([]byte, []int)

func (*MsgWithdrawEarnedFeesResponse) Marshal added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) Marshal() (dAtA []byte, err error)

func (*MsgWithdrawEarnedFeesResponse) MarshalTo added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgWithdrawEarnedFeesResponse) MarshalToSizedBuffer added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgWithdrawEarnedFeesResponse) ProtoMessage added in v1.2.0 

func (*MsgWithdrawEarnedFeesResponse) ProtoMessage()

func (*MsgWithdrawEarnedFeesResponse) Reset added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) Reset()

func (*MsgWithdrawEarnedFeesResponse) Size added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) Size() (n int)

func (*MsgWithdrawEarnedFeesResponse) String added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) String() string

func (*MsgWithdrawEarnedFeesResponse) Unmarshal added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) Unmarshal(dAtA []byte) error

func (*MsgWithdrawEarnedFeesResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) XXX_DiscardUnknown()

func (*MsgWithdrawEarnedFeesResponse) XXX_Marshal added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgWithdrawEarnedFeesResponse) XXX_Merge added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) XXX_Merge(src proto.Message)

func (*MsgWithdrawEarnedFeesResponse) XXX_Size added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) XXX_Size() int

func (*MsgWithdrawEarnedFeesResponse) XXX_Unmarshal added in v1.2.0 

func (m *MsgWithdrawEarnedFeesResponse) XXX_Unmarshal(b []byte) error

type Params 

type Params struct {
	MaxRequestTimeout         int64                                    `` /* 142-byte string literal not displayed */
	MinDepositMultiple        int64                                    `` /* 146-byte string literal not displayed */
	MinDeposit                github_com_cosmos_cosmos_sdk_types.Coins `` /* 135-byte string literal not displayed */
	ServiceFeeTax             github_com_cosmos_cosmos_sdk_types.Dec   `` /* 165-byte string literal not displayed */
	SlashFraction             github_com_cosmos_cosmos_sdk_types.Dec   `` /* 162-byte string literal not displayed */
	ComplaintRetrospect       time.Duration                            `` /* 148-byte string literal not displayed */
	ArbitrationTimeLimit      time.Duration                            `` /* 155-byte string literal not displayed */
	TxSizeLimit               uint64                                   `protobuf:"varint,8,opt,name=tx_size_limit,json=txSizeLimit,proto3" json:"tx_size_limit,omitempty" yaml:"tx_size_limit"`
	BaseDenom                 string                                   `protobuf:"bytes,9,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty" yaml:"base_denom"`
	RestrictedServiceFeeDenom bool                                     `` /* 178-byte string literal not displayed */
}

Params defines service module's parameters

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters.

func NewParams 

func NewParams(
	maxRequestTimeout,
	minDepositMultiple int64,
	minDeposit sdk.Coins,
	serviceFeeTax,
	slashFraction sdk.Dec,
	complaintRetrospect,
	arbitrationTimeLimit time.Duration,
	txSizeLimit uint64,
	baseDenom string,
	restrictedServiceFeeDenom bool,
) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

func (*Params) Descriptor() ([]byte, []int)

func (*Params) Equal 

func (this *Params) Equal(that interface{}) bool

func (*Params) Marshal 

func (m *Params) Marshal() (dAtA []byte, err error)

func (*Params) MarshalTo 

func (m *Params) MarshalTo(dAtA []byte) (int, error)

func (*Params) MarshalToSizedBuffer 

func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Params) ParamSetPairs 

func (p *Params) ParamSetPairs() paramstypes.ParamSetPairs

ParamSetPairs implements paramstypes.ParamSet

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

func (m *Params) Size() (n int)

func (Params) String 

func (p Params) String() string

String implements stringer

func (*Params) Unmarshal 

func (m *Params) Unmarshal(dAtA []byte) error

func (Params) Validate 

func (p Params) Validate() error

Validate validates a set of params

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Params) XXX_Merge 

func (m *Params) XXX_Merge(src proto.Message)

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

func (m *Params) XXX_Unmarshal(b []byte) error

type Pricing 

type Pricing struct {
	Price              github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,6,rep,name=price,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"price"`
	PromotionsByTime   []PromotionByTime                        `` /* 127-byte string literal not displayed */
	PromotionsByVolume []PromotionByVolume                      `` /* 135-byte string literal not displayed */
}

Pricing defines a standard for service pricing

func ParsePricing added in v1.4.0 

func ParsePricing(pricing string) (p Pricing, err error)

ParsePricing parses the given string to Pricing

func (*Pricing) Descriptor 

func (*Pricing) Descriptor() ([]byte, []int)

func (*Pricing) Marshal 

func (m *Pricing) Marshal() (dAtA []byte, err error)

func (*Pricing) MarshalTo 

func (m *Pricing) MarshalTo(dAtA []byte) (int, error)

func (*Pricing) MarshalToSizedBuffer 

func (m *Pricing) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Pricing) ProtoMessage 

func (*Pricing) ProtoMessage()

func (*Pricing) Reset 

func (m *Pricing) Reset()

func (*Pricing) Size 

func (m *Pricing) Size() (n int)

func (*Pricing) String 

func (m *Pricing) String() string

func (*Pricing) Unmarshal 

func (m *Pricing) Unmarshal(dAtA []byte) error

func (*Pricing) XXX_DiscardUnknown 

func (m *Pricing) XXX_DiscardUnknown()

func (*Pricing) XXX_Marshal 

func (m *Pricing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pricing) XXX_Merge 

func (m *Pricing) XXX_Merge(src proto.Message)

func (*Pricing) XXX_Size 

func (m *Pricing) XXX_Size() int

func (*Pricing) XXX_Unmarshal 

func (m *Pricing) XXX_Unmarshal(b []byte) error

type PromotionByTime 

type PromotionByTime struct {
	StartTime time.Time                              `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	EndTime   time.Time                              `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time" yaml:"end_time"`
	Discount  github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,3,opt,name=discount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"discount"`
}

PromotionByTime defines a standard for service promotion by time

func (*PromotionByTime) Descriptor 

func (*PromotionByTime) Descriptor() ([]byte, []int)

func (*PromotionByTime) Marshal 

func (m *PromotionByTime) Marshal() (dAtA []byte, err error)

func (*PromotionByTime) MarshalTo 

func (m *PromotionByTime) MarshalTo(dAtA []byte) (int, error)

func (*PromotionByTime) MarshalToSizedBuffer 

func (m *PromotionByTime) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PromotionByTime) ProtoMessage 

func (*PromotionByTime) ProtoMessage()

func (*PromotionByTime) Reset 

func (m *PromotionByTime) Reset()

func (*PromotionByTime) Size 

func (m *PromotionByTime) Size() (n int)

func (*PromotionByTime) String 

func (m *PromotionByTime) String() string

func (*PromotionByTime) Unmarshal 

func (m *PromotionByTime) Unmarshal(dAtA []byte) error

func (*PromotionByTime) XXX_DiscardUnknown 

func (m *PromotionByTime) XXX_DiscardUnknown()

func (*PromotionByTime) XXX_Marshal 

func (m *PromotionByTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PromotionByTime) XXX_Merge 

func (m *PromotionByTime) XXX_Merge(src proto.Message)

func (*PromotionByTime) XXX_Size 

func (m *PromotionByTime) XXX_Size() int

func (*PromotionByTime) XXX_Unmarshal 

func (m *PromotionByTime) XXX_Unmarshal(b []byte) error

type PromotionByVolume 

type PromotionByVolume struct {
	Volume   uint64                                 `protobuf:"varint,1,opt,name=volume,proto3" json:"volume,omitempty"`
	Discount github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=discount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"discount"`
}

PromotionByVolume defines a standard for service promotion by volume

func (*PromotionByVolume) Descriptor 

func (*PromotionByVolume) Descriptor() ([]byte, []int)

func (*PromotionByVolume) Marshal 

func (m *PromotionByVolume) Marshal() (dAtA []byte, err error)

func (*PromotionByVolume) MarshalTo 

func (m *PromotionByVolume) MarshalTo(dAtA []byte) (int, error)

func (*PromotionByVolume) MarshalToSizedBuffer 

func (m *PromotionByVolume) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PromotionByVolume) ProtoMessage 

func (*PromotionByVolume) ProtoMessage()

func (*PromotionByVolume) Reset 

func (m *PromotionByVolume) Reset()

func (*PromotionByVolume) Size 

func (m *PromotionByVolume) Size() (n int)

func (*PromotionByVolume) String 

func (m *PromotionByVolume) String() string

func (*PromotionByVolume) Unmarshal 

func (m *PromotionByVolume) Unmarshal(dAtA []byte) error

func (*PromotionByVolume) XXX_DiscardUnknown 

func (m *PromotionByVolume) XXX_DiscardUnknown()

func (*PromotionByVolume) XXX_Marshal 

func (m *PromotionByVolume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PromotionByVolume) XXX_Merge 

func (m *PromotionByVolume) XXX_Merge(src proto.Message)

func (*PromotionByVolume) XXX_Size 

func (m *PromotionByVolume) XXX_Size() int

func (*PromotionByVolume) XXX_Unmarshal 

func (m *PromotionByVolume) XXX_Unmarshal(b []byte) error

type QueryBindingParams 

type QueryBindingParams struct {
	ServiceName string
	Provider    sdk.AccAddress
}

QueryBindingParams defines the params to query a service binding

type QueryBindingRequest 

type QueryBindingRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Provider    string `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
}

QueryBindingRequest is request type for the Query/Binding RPC method

func (*QueryBindingRequest) Descriptor 

func (*QueryBindingRequest) Descriptor() ([]byte, []int)

func (*QueryBindingRequest) GetProvider 

func (m *QueryBindingRequest) GetProvider() string

func (*QueryBindingRequest) GetServiceName 

func (m *QueryBindingRequest) GetServiceName() string

func (*QueryBindingRequest) Marshal 

func (m *QueryBindingRequest) Marshal() (dAtA []byte, err error)

func (*QueryBindingRequest) MarshalTo 

func (m *QueryBindingRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryBindingRequest) MarshalToSizedBuffer 

func (m *QueryBindingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryBindingRequest) ProtoMessage 

func (*QueryBindingRequest) ProtoMessage()

func (*QueryBindingRequest) Reset 

func (m *QueryBindingRequest) Reset()

func (*QueryBindingRequest) Size 

func (m *QueryBindingRequest) Size() (n int)

func (*QueryBindingRequest) String 

func (m *QueryBindingRequest) String() string

func (*QueryBindingRequest) Unmarshal 

func (m *QueryBindingRequest) Unmarshal(dAtA []byte) error

func (*QueryBindingRequest) XXX_DiscardUnknown 

func (m *QueryBindingRequest) XXX_DiscardUnknown()

func (*QueryBindingRequest) XXX_Marshal 

func (m *QueryBindingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryBindingRequest) XXX_Merge 

func (m *QueryBindingRequest) XXX_Merge(src proto.Message)

func (*QueryBindingRequest) XXX_Size 

func (m *QueryBindingRequest) XXX_Size() int

func (*QueryBindingRequest) XXX_Unmarshal 

func (m *QueryBindingRequest) XXX_Unmarshal(b []byte) error

type QueryBindingResponse 

type QueryBindingResponse struct {
	ServiceBinding *ServiceBinding `protobuf:"bytes,1,opt,name=service_binding,json=serviceBinding,proto3" json:"service_binding,omitempty"`
}

QueryDefinitionResponse is response type for the Query/Binding RPC method

func (*QueryBindingResponse) Descriptor 

func (*QueryBindingResponse) Descriptor() ([]byte, []int)

func (*QueryBindingResponse) GetServiceBinding 

func (m *QueryBindingResponse) GetServiceBinding() *ServiceBinding

func (*QueryBindingResponse) Marshal 

func (m *QueryBindingResponse) Marshal() (dAtA []byte, err error)

func (*QueryBindingResponse) MarshalTo 

func (m *QueryBindingResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryBindingResponse) MarshalToSizedBuffer 

func (m *QueryBindingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryBindingResponse) ProtoMessage 

func (*QueryBindingResponse) ProtoMessage()

func (*QueryBindingResponse) Reset 

func (m *QueryBindingResponse) Reset()

func (*QueryBindingResponse) Size 

func (m *QueryBindingResponse) Size() (n int)

func (*QueryBindingResponse) String 

func (m *QueryBindingResponse) String() string

func (*QueryBindingResponse) Unmarshal 

func (m *QueryBindingResponse) Unmarshal(dAtA []byte) error

func (*QueryBindingResponse) XXX_DiscardUnknown 

func (m *QueryBindingResponse) XXX_DiscardUnknown()

func (*QueryBindingResponse) XXX_Marshal 

func (m *QueryBindingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryBindingResponse) XXX_Merge 

func (m *QueryBindingResponse) XXX_Merge(src proto.Message)

func (*QueryBindingResponse) XXX_Size 

func (m *QueryBindingResponse) XXX_Size() int

func (*QueryBindingResponse) XXX_Unmarshal 

func (m *QueryBindingResponse) XXX_Unmarshal(b []byte) error

type QueryBindingsParams 

type QueryBindingsParams struct {
	ServiceName string
	Owner       sdk.AccAddress
}

QueryBindingsParams defines the params to query all bindings of a service definition with an optional owner

type QueryBindingsRequest 

type QueryBindingsRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Owner       string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// pagination defines an optional pagination for the request
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryBindingsRequest is request type for the Query/Bindings RPC method

func (*QueryBindingsRequest) Descriptor 

func (*QueryBindingsRequest) Descriptor() ([]byte, []int)

func (*QueryBindingsRequest) GetOwner 

func (m *QueryBindingsRequest) GetOwner() string

func (*QueryBindingsRequest) GetPagination added in v1.2.0 

func (m *QueryBindingsRequest) GetPagination() *query.PageRequest

func (*QueryBindingsRequest) GetServiceName 

func (m *QueryBindingsRequest) GetServiceName() string

func (*QueryBindingsRequest) Marshal 

func (m *QueryBindingsRequest) Marshal() (dAtA []byte, err error)

func (*QueryBindingsRequest) MarshalTo 

func (m *QueryBindingsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryBindingsRequest) MarshalToSizedBuffer 

func (m *QueryBindingsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryBindingsRequest) ProtoMessage 

func (*QueryBindingsRequest) ProtoMessage()

func (*QueryBindingsRequest) Reset 

func (m *QueryBindingsRequest) Reset()

func (*QueryBindingsRequest) Size 

func (m *QueryBindingsRequest) Size() (n int)

func (*QueryBindingsRequest) String 

func (m *QueryBindingsRequest) String() string

func (*QueryBindingsRequest) Unmarshal 

func (m *QueryBindingsRequest) Unmarshal(dAtA []byte) error

func (*QueryBindingsRequest) XXX_DiscardUnknown 

func (m *QueryBindingsRequest) XXX_DiscardUnknown()

func (*QueryBindingsRequest) XXX_Marshal 

func (m *QueryBindingsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryBindingsRequest) XXX_Merge 

func (m *QueryBindingsRequest) XXX_Merge(src proto.Message)

func (*QueryBindingsRequest) XXX_Size 

func (m *QueryBindingsRequest) XXX_Size() int

func (*QueryBindingsRequest) XXX_Unmarshal 

func (m *QueryBindingsRequest) XXX_Unmarshal(b []byte) error

type QueryBindingsResponse 

type QueryBindingsResponse struct {
	ServiceBindings []*ServiceBinding   `protobuf:"bytes,1,rep,name=service_bindings,json=serviceBindings,proto3" json:"service_bindings,omitempty"`
	Pagination      *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDefinitionsResponse is response type for the Query/Bindings RPC method

func (*QueryBindingsResponse) Descriptor 

func (*QueryBindingsResponse) Descriptor() ([]byte, []int)

func (*QueryBindingsResponse) GetPagination added in v1.2.0 

func (m *QueryBindingsResponse) GetPagination() *query.PageResponse

func (*QueryBindingsResponse) GetServiceBindings 

func (m *QueryBindingsResponse) GetServiceBindings() []*ServiceBinding

func (*QueryBindingsResponse) Marshal 

func (m *QueryBindingsResponse) Marshal() (dAtA []byte, err error)

func (*QueryBindingsResponse) MarshalTo 

func (m *QueryBindingsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryBindingsResponse) MarshalToSizedBuffer 

func (m *QueryBindingsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryBindingsResponse) ProtoMessage 

func (*QueryBindingsResponse) ProtoMessage()

func (*QueryBindingsResponse) Reset 

func (m *QueryBindingsResponse) Reset()

func (*QueryBindingsResponse) Size 

func (m *QueryBindingsResponse) Size() (n int)

func (*QueryBindingsResponse) String 

func (m *QueryBindingsResponse) String() string

func (*QueryBindingsResponse) Unmarshal 

func (m *QueryBindingsResponse) Unmarshal(dAtA []byte) error

func (*QueryBindingsResponse) XXX_DiscardUnknown 

func (m *QueryBindingsResponse) XXX_DiscardUnknown()

func (*QueryBindingsResponse) XXX_Marshal 

func (m *QueryBindingsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryBindingsResponse) XXX_Merge 

func (m *QueryBindingsResponse) XXX_Merge(src proto.Message)

func (*QueryBindingsResponse) XXX_Size 

func (m *QueryBindingsResponse) XXX_Size() int

func (*QueryBindingsResponse) XXX_Unmarshal 

func (m *QueryBindingsResponse) XXX_Unmarshal(b []byte) error

type QueryClient 

type QueryClient interface {
	// Definition returns service definition
	Definition(ctx context.Context, in *QueryDefinitionRequest, opts ...grpc.CallOption) (*QueryDefinitionResponse, error)
	// Binding returns service Binding with service name and provider
	Binding(ctx context.Context, in *QueryBindingRequest, opts ...grpc.CallOption) (*QueryBindingResponse, error)
	// Bindings returns all service Bindings with service name and owner
	Bindings(ctx context.Context, in *QueryBindingsRequest, opts ...grpc.CallOption) (*QueryBindingsResponse, error)
	// WithdrawAddress returns the withdraw address of the binding owner
	WithdrawAddress(ctx context.Context, in *QueryWithdrawAddressRequest, opts ...grpc.CallOption) (*QueryWithdrawAddressResponse, error)
	// RequestContext returns the request context
	RequestContext(ctx context.Context, in *QueryRequestContextRequest, opts ...grpc.CallOption) (*QueryRequestContextResponse, error)
	// Request returns the request
	Request(ctx context.Context, in *QueryRequestRequest, opts ...grpc.CallOption) (*QueryRequestResponse, error)
	// Request returns all requests of one service with provider
	Requests(ctx context.Context, in *QueryRequestsRequest, opts ...grpc.CallOption) (*QueryRequestsResponse, error)
	// RequestsByReqCtx returns all requests of one service call batch
	RequestsByReqCtx(ctx context.Context, in *QueryRequestsByReqCtxRequest, opts ...grpc.CallOption) (*QueryRequestsByReqCtxResponse, error)
	// Response returns the response of request
	Response(ctx context.Context, in *QueryResponseRequest, opts ...grpc.CallOption) (*QueryResponseResponse, error)
	// Responses returns all responses of one service call batch
	Responses(ctx context.Context, in *QueryResponsesRequest, opts ...grpc.CallOption) (*QueryResponsesResponse, error)
	// EarnedFees returns the earned service fee of one provider
	EarnedFees(ctx context.Context, in *QueryEarnedFeesRequest, opts ...grpc.CallOption) (*QueryEarnedFeesResponse, error)
	// Schema returns the schema
	Schema(ctx context.Context, in *QuerySchemaRequest, opts ...grpc.CallOption) (*QuerySchemaResponse, error)
	// Params queries the service parameters
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryDefinitionParams 

type QueryDefinitionParams struct {
	ServiceName string
}

QueryDefinitionParams defines the params to query a service definition

type QueryDefinitionRequest 

type QueryDefinitionRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
}

QueryDefinitionRequest is request type for the Query/Definition RPC method

func (*QueryDefinitionRequest) Descriptor 

func (*QueryDefinitionRequest) Descriptor() ([]byte, []int)

func (*QueryDefinitionRequest) GetServiceName 

func (m *QueryDefinitionRequest) GetServiceName() string

func (*QueryDefinitionRequest) Marshal 

func (m *QueryDefinitionRequest) Marshal() (dAtA []byte, err error)

func (*QueryDefinitionRequest) MarshalTo 

func (m *QueryDefinitionRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryDefinitionRequest) MarshalToSizedBuffer 

func (m *QueryDefinitionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDefinitionRequest) ProtoMessage 

func (*QueryDefinitionRequest) ProtoMessage()

func (*QueryDefinitionRequest) Reset 

func (m *QueryDefinitionRequest) Reset()

func (*QueryDefinitionRequest) Size 

func (m *QueryDefinitionRequest) Size() (n int)

func (*QueryDefinitionRequest) String 

func (m *QueryDefinitionRequest) String() string

func (*QueryDefinitionRequest) Unmarshal 

func (m *QueryDefinitionRequest) Unmarshal(dAtA []byte) error

func (*QueryDefinitionRequest) XXX_DiscardUnknown 

func (m *QueryDefinitionRequest) XXX_DiscardUnknown()

func (*QueryDefinitionRequest) XXX_Marshal 

func (m *QueryDefinitionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDefinitionRequest) XXX_Merge 

func (m *QueryDefinitionRequest) XXX_Merge(src proto.Message)

func (*QueryDefinitionRequest) XXX_Size 

func (m *QueryDefinitionRequest) XXX_Size() int

func (*QueryDefinitionRequest) XXX_Unmarshal 

func (m *QueryDefinitionRequest) XXX_Unmarshal(b []byte) error

type QueryDefinitionResponse 

type QueryDefinitionResponse struct {
	ServiceDefinition *ServiceDefinition `protobuf:"bytes,1,opt,name=service_definition,json=serviceDefinition,proto3" json:"service_definition,omitempty"`
}

QueryDefinitionResponse is response type for the Query/Definition RPC method

func (*QueryDefinitionResponse) Descriptor 

func (*QueryDefinitionResponse) Descriptor() ([]byte, []int)

func (*QueryDefinitionResponse) GetServiceDefinition 

func (m *QueryDefinitionResponse) GetServiceDefinition() *ServiceDefinition

func (*QueryDefinitionResponse) Marshal 

func (m *QueryDefinitionResponse) Marshal() (dAtA []byte, err error)

func (*QueryDefinitionResponse) MarshalTo 

func (m *QueryDefinitionResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryDefinitionResponse) MarshalToSizedBuffer 

func (m *QueryDefinitionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDefinitionResponse) ProtoMessage 

func (*QueryDefinitionResponse) ProtoMessage()

func (*QueryDefinitionResponse) Reset 

func (m *QueryDefinitionResponse) Reset()

func (*QueryDefinitionResponse) Size 

func (m *QueryDefinitionResponse) Size() (n int)

func (*QueryDefinitionResponse) String 

func (m *QueryDefinitionResponse) String() string

func (*QueryDefinitionResponse) Unmarshal 

func (m *QueryDefinitionResponse) Unmarshal(dAtA []byte) error

func (*QueryDefinitionResponse) XXX_DiscardUnknown 

func (m *QueryDefinitionResponse) XXX_DiscardUnknown()

func (*QueryDefinitionResponse) XXX_Marshal 

func (m *QueryDefinitionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDefinitionResponse) XXX_Merge 

func (m *QueryDefinitionResponse) XXX_Merge(src proto.Message)

func (*QueryDefinitionResponse) XXX_Size 

func (m *QueryDefinitionResponse) XXX_Size() int

func (*QueryDefinitionResponse) XXX_Unmarshal 

func (m *QueryDefinitionResponse) XXX_Unmarshal(b []byte) error

type QueryEarnedFeesParams 

type QueryEarnedFeesParams struct {
	Provider sdk.AccAddress
}

QueryEarnedFeesParams defines the params to query the earned fees for a provider

type QueryEarnedFeesRequest 

type QueryEarnedFeesRequest struct {
	Provider string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
}

QueryEarnedFeesRequest is request type for the Query/EarnedFees RPC method

func (*QueryEarnedFeesRequest) Descriptor 

func (*QueryEarnedFeesRequest) Descriptor() ([]byte, []int)

func (*QueryEarnedFeesRequest) GetProvider 

func (m *QueryEarnedFeesRequest) GetProvider() string

func (*QueryEarnedFeesRequest) Marshal 

func (m *QueryEarnedFeesRequest) Marshal() (dAtA []byte, err error)

func (*QueryEarnedFeesRequest) MarshalTo 

func (m *QueryEarnedFeesRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryEarnedFeesRequest) MarshalToSizedBuffer 

func (m *QueryEarnedFeesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryEarnedFeesRequest) ProtoMessage 

func (*QueryEarnedFeesRequest) ProtoMessage()

func (*QueryEarnedFeesRequest) Reset 

func (m *QueryEarnedFeesRequest) Reset()

func (*QueryEarnedFeesRequest) Size 

func (m *QueryEarnedFeesRequest) Size() (n int)

func (*QueryEarnedFeesRequest) String 

func (m *QueryEarnedFeesRequest) String() string

func (*QueryEarnedFeesRequest) Unmarshal 

func (m *QueryEarnedFeesRequest) Unmarshal(dAtA []byte) error

func (*QueryEarnedFeesRequest) XXX_DiscardUnknown 

func (m *QueryEarnedFeesRequest) XXX_DiscardUnknown()

func (*QueryEarnedFeesRequest) XXX_Marshal 

func (m *QueryEarnedFeesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryEarnedFeesRequest) XXX_Merge 

func (m *QueryEarnedFeesRequest) XXX_Merge(src proto.Message)

func (*QueryEarnedFeesRequest) XXX_Size 

func (m *QueryEarnedFeesRequest) XXX_Size() int

func (*QueryEarnedFeesRequest) XXX_Unmarshal 

func (m *QueryEarnedFeesRequest) XXX_Unmarshal(b []byte) error

type QueryEarnedFeesResponse 

type QueryEarnedFeesResponse struct {
	Fees github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=fees,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"fees" yaml:"service_fee"`
}

QueryEarnedFeesResponse is response type for the Query/EarnedFees RPC method

func (*QueryEarnedFeesResponse) Descriptor 

func (*QueryEarnedFeesResponse) Descriptor() ([]byte, []int)

func (*QueryEarnedFeesResponse) GetFees 

func (m *QueryEarnedFeesResponse) GetFees() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryEarnedFeesResponse) Marshal 

func (m *QueryEarnedFeesResponse) Marshal() (dAtA []byte, err error)

func (*QueryEarnedFeesResponse) MarshalTo 

func (m *QueryEarnedFeesResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryEarnedFeesResponse) MarshalToSizedBuffer 

func (m *QueryEarnedFeesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryEarnedFeesResponse) ProtoMessage 

func (*QueryEarnedFeesResponse) ProtoMessage()

func (*QueryEarnedFeesResponse) Reset 

func (m *QueryEarnedFeesResponse) Reset()

func (*QueryEarnedFeesResponse) Size 

func (m *QueryEarnedFeesResponse) Size() (n int)

func (*QueryEarnedFeesResponse) String 

func (m *QueryEarnedFeesResponse) String() string

func (*QueryEarnedFeesResponse) Unmarshal 

func (m *QueryEarnedFeesResponse) Unmarshal(dAtA []byte) error

func (*QueryEarnedFeesResponse) XXX_DiscardUnknown 

func (m *QueryEarnedFeesResponse) XXX_DiscardUnknown()

func (*QueryEarnedFeesResponse) XXX_Marshal 

func (m *QueryEarnedFeesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryEarnedFeesResponse) XXX_Merge 

func (m *QueryEarnedFeesResponse) XXX_Merge(src proto.Message)

func (*QueryEarnedFeesResponse) XXX_Size 

func (m *QueryEarnedFeesResponse) XXX_Size() int

func (*QueryEarnedFeesResponse) XXX_Unmarshal 

func (m *QueryEarnedFeesResponse) XXX_Unmarshal(b []byte) error

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParametersRequest is request type for the Query/Parameters RPC method

func (*QueryParamsRequest) Descriptor 

func (*QueryParamsRequest) Descriptor() ([]byte, []int)

func (*QueryParamsRequest) Marshal 

func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)

func (*QueryParamsRequest) MarshalTo 

func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryParamsRequest) MarshalToSizedBuffer 

func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

func (m *QueryParamsRequest) Size() (n int)

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryParamsRequest) XXX_Merge 

func (m *QueryParamsRequest) XXX_Merge(src proto.Message)

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error

type QueryParamsResponse 

type QueryParamsResponse struct {
	Params Params              `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	Res    *query.PageResponse `protobuf:"bytes,2,opt,name=res,proto3" json:"res,omitempty"`
}

QueryParametersResponse is response type for the Query/Parameters RPC method

func (*QueryParamsResponse) Descriptor 

func (*QueryParamsResponse) Descriptor() ([]byte, []int)

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) GetRes 

func (m *QueryParamsResponse) GetRes() *query.PageResponse

func (*QueryParamsResponse) Marshal 

func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)

func (*QueryParamsResponse) MarshalTo 

func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryParamsResponse) MarshalToSizedBuffer 

func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

func (m *QueryParamsResponse) Size() (n int)

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryParamsResponse) XXX_Merge 

func (m *QueryParamsResponse) XXX_Merge(src proto.Message)

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error

type QueryRequestContextParams 

type QueryRequestContextParams struct {
	RequestContextID tmbytes.HexBytes
}

QueryRequestContextParams defines the params to query the request context

type QueryRequestContextRequest 

type QueryRequestContextRequest struct {
	RequestContextId string `protobuf:"bytes,1,opt,name=request_context_id,json=requestContextId,proto3" json:"request_context_id,omitempty"`
}

QueryRequestContextRequest is request type for the Query/RequestContext RPC method

func (*QueryRequestContextRequest) Descriptor 

func (*QueryRequestContextRequest) Descriptor() ([]byte, []int)

func (*QueryRequestContextRequest) GetRequestContextId 

func (m *QueryRequestContextRequest) GetRequestContextId() string

func (*QueryRequestContextRequest) Marshal 

func (m *QueryRequestContextRequest) Marshal() (dAtA []byte, err error)

func (*QueryRequestContextRequest) MarshalTo 

func (m *QueryRequestContextRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequestContextRequest) MarshalToSizedBuffer 

func (m *QueryRequestContextRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequestContextRequest) ProtoMessage 

func (*QueryRequestContextRequest) ProtoMessage()

func (*QueryRequestContextRequest) Reset 

func (m *QueryRequestContextRequest) Reset()

func (*QueryRequestContextRequest) Size 

func (m *QueryRequestContextRequest) Size() (n int)

func (*QueryRequestContextRequest) String 

func (m *QueryRequestContextRequest) String() string

func (*QueryRequestContextRequest) Unmarshal 

func (m *QueryRequestContextRequest) Unmarshal(dAtA []byte) error

func (*QueryRequestContextRequest) XXX_DiscardUnknown 

func (m *QueryRequestContextRequest) XXX_DiscardUnknown()

func (*QueryRequestContextRequest) XXX_Marshal 

func (m *QueryRequestContextRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequestContextRequest) XXX_Merge 

func (m *QueryRequestContextRequest) XXX_Merge(src proto.Message)

func (*QueryRequestContextRequest) XXX_Size 

func (m *QueryRequestContextRequest) XXX_Size() int

func (*QueryRequestContextRequest) XXX_Unmarshal 

func (m *QueryRequestContextRequest) XXX_Unmarshal(b []byte) error

type QueryRequestContextResponse 

type QueryRequestContextResponse struct {
	RequestContext *RequestContext `protobuf:"bytes,1,opt,name=request_context,json=requestContext,proto3" json:"request_context,omitempty"`
}

QueryRequestContextResponse is response type for the Query/RequestContext RPC method

func (*QueryRequestContextResponse) Descriptor 

func (*QueryRequestContextResponse) Descriptor() ([]byte, []int)

func (*QueryRequestContextResponse) GetRequestContext 

func (m *QueryRequestContextResponse) GetRequestContext() *RequestContext

func (*QueryRequestContextResponse) Marshal 

func (m *QueryRequestContextResponse) Marshal() (dAtA []byte, err error)

func (*QueryRequestContextResponse) MarshalTo 

func (m *QueryRequestContextResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequestContextResponse) MarshalToSizedBuffer 

func (m *QueryRequestContextResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequestContextResponse) ProtoMessage 

func (*QueryRequestContextResponse) ProtoMessage()

func (*QueryRequestContextResponse) Reset 

func (m *QueryRequestContextResponse) Reset()

func (*QueryRequestContextResponse) Size 

func (m *QueryRequestContextResponse) Size() (n int)

func (*QueryRequestContextResponse) String 

func (m *QueryRequestContextResponse) String() string

func (*QueryRequestContextResponse) Unmarshal 

func (m *QueryRequestContextResponse) Unmarshal(dAtA []byte) error

func (*QueryRequestContextResponse) XXX_DiscardUnknown 

func (m *QueryRequestContextResponse) XXX_DiscardUnknown()

func (*QueryRequestContextResponse) XXX_Marshal 

func (m *QueryRequestContextResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequestContextResponse) XXX_Merge 

func (m *QueryRequestContextResponse) XXX_Merge(src proto.Message)

func (*QueryRequestContextResponse) XXX_Size 

func (m *QueryRequestContextResponse) XXX_Size() int

func (*QueryRequestContextResponse) XXX_Unmarshal 

func (m *QueryRequestContextResponse) XXX_Unmarshal(b []byte) error

type QueryRequestParams 

type QueryRequestParams struct {
	RequestID []byte
}

QueryRequestParams defines the params to query the request by ID

type QueryRequestRequest 

type QueryRequestRequest struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
}

QueryRequestRequest is request type for the Query/Request RPC method

func (*QueryRequestRequest) Descriptor 

func (*QueryRequestRequest) Descriptor() ([]byte, []int)

func (*QueryRequestRequest) GetRequestId 

func (m *QueryRequestRequest) GetRequestId() string

func (*QueryRequestRequest) Marshal 

func (m *QueryRequestRequest) Marshal() (dAtA []byte, err error)

func (*QueryRequestRequest) MarshalTo 

func (m *QueryRequestRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequestRequest) MarshalToSizedBuffer 

func (m *QueryRequestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequestRequest) ProtoMessage 

func (*QueryRequestRequest) ProtoMessage()

func (*QueryRequestRequest) Reset 

func (m *QueryRequestRequest) Reset()

func (*QueryRequestRequest) Size 

func (m *QueryRequestRequest) Size() (n int)

func (*QueryRequestRequest) String 

func (m *QueryRequestRequest) String() string

func (*QueryRequestRequest) Unmarshal 

func (m *QueryRequestRequest) Unmarshal(dAtA []byte) error

func (*QueryRequestRequest) XXX_DiscardUnknown 

func (m *QueryRequestRequest) XXX_DiscardUnknown()

func (*QueryRequestRequest) XXX_Marshal 

func (m *QueryRequestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequestRequest) XXX_Merge 

func (m *QueryRequestRequest) XXX_Merge(src proto.Message)

func (*QueryRequestRequest) XXX_Size 

func (m *QueryRequestRequest) XXX_Size() int

func (*QueryRequestRequest) XXX_Unmarshal 

func (m *QueryRequestRequest) XXX_Unmarshal(b []byte) error

type QueryRequestResponse 

type QueryRequestResponse struct {
	Request *Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
}

QueryRequestResponse is response type for the Query/Request RPC method

func (*QueryRequestResponse) Descriptor 

func (*QueryRequestResponse) Descriptor() ([]byte, []int)

func (*QueryRequestResponse) GetRequest 

func (m *QueryRequestResponse) GetRequest() *Request

func (*QueryRequestResponse) Marshal 

func (m *QueryRequestResponse) Marshal() (dAtA []byte, err error)

func (*QueryRequestResponse) MarshalTo 

func (m *QueryRequestResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequestResponse) MarshalToSizedBuffer 

func (m *QueryRequestResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequestResponse) ProtoMessage 

func (*QueryRequestResponse) ProtoMessage()

func (*QueryRequestResponse) Reset 

func (m *QueryRequestResponse) Reset()

func (*QueryRequestResponse) Size 

func (m *QueryRequestResponse) Size() (n int)

func (*QueryRequestResponse) String 

func (m *QueryRequestResponse) String() string

func (*QueryRequestResponse) Unmarshal 

func (m *QueryRequestResponse) Unmarshal(dAtA []byte) error

func (*QueryRequestResponse) XXX_DiscardUnknown 

func (m *QueryRequestResponse) XXX_DiscardUnknown()

func (*QueryRequestResponse) XXX_Marshal 

func (m *QueryRequestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequestResponse) XXX_Merge 

func (m *QueryRequestResponse) XXX_Merge(src proto.Message)

func (*QueryRequestResponse) XXX_Size 

func (m *QueryRequestResponse) XXX_Size() int

func (*QueryRequestResponse) XXX_Unmarshal 

func (m *QueryRequestResponse) XXX_Unmarshal(b []byte) error

type QueryRequestsByReqCtxParams 

type QueryRequestsByReqCtxParams struct {
	RequestContextID tmbytes.HexBytes
	BatchCounter     uint64
}

QueryRequestsByReqCtxParams defines the params to query active requests by the request context ID

type QueryRequestsByReqCtxRequest 

type QueryRequestsByReqCtxRequest struct {
	RequestContextId string             `protobuf:"bytes,1,opt,name=request_context_id,json=requestContextId,proto3" json:"request_context_id,omitempty"`
	BatchCounter     uint64             `protobuf:"varint,2,opt,name=batch_counter,json=batchCounter,proto3" json:"batch_counter,omitempty"`
	Pagination       *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRequestsByReqCtxRequest is request type for the Query/RequestsByReqCtx RPC method

func (*QueryRequestsByReqCtxRequest) Descriptor 

func (*QueryRequestsByReqCtxRequest) Descriptor() ([]byte, []int)

func (*QueryRequestsByReqCtxRequest) GetBatchCounter 

func (m *QueryRequestsByReqCtxRequest) GetBatchCounter() uint64

func (*QueryRequestsByReqCtxRequest) GetPagination added in v1.2.0 

func (m *QueryRequestsByReqCtxRequest) GetPagination() *query.PageRequest

func (*QueryRequestsByReqCtxRequest) GetRequestContextId 

func (m *QueryRequestsByReqCtxRequest) GetRequestContextId() string

func (*QueryRequestsByReqCtxRequest) Marshal 

func (m *QueryRequestsByReqCtxRequest) Marshal() (dAtA []byte, err error)

func (*QueryRequestsByReqCtxRequest) MarshalTo 

func (m *QueryRequestsByReqCtxRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequestsByReqCtxRequest) MarshalToSizedBuffer 

func (m *QueryRequestsByReqCtxRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequestsByReqCtxRequest) ProtoMessage 

func (*QueryRequestsByReqCtxRequest) ProtoMessage()

func (*QueryRequestsByReqCtxRequest) Reset 

func (m *QueryRequestsByReqCtxRequest) Reset()

func (*QueryRequestsByReqCtxRequest) Size 

func (m *QueryRequestsByReqCtxRequest) Size() (n int)

func (*QueryRequestsByReqCtxRequest) String 

func (m *QueryRequestsByReqCtxRequest) String() string

func (*QueryRequestsByReqCtxRequest) Unmarshal 

func (m *QueryRequestsByReqCtxRequest) Unmarshal(dAtA []byte) error

func (*QueryRequestsByReqCtxRequest) XXX_DiscardUnknown 

func (m *QueryRequestsByReqCtxRequest) XXX_DiscardUnknown()

func (*QueryRequestsByReqCtxRequest) XXX_Marshal 

func (m *QueryRequestsByReqCtxRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequestsByReqCtxRequest) XXX_Merge 

func (m *QueryRequestsByReqCtxRequest) XXX_Merge(src proto.Message)

func (*QueryRequestsByReqCtxRequest) XXX_Size 

func (m *QueryRequestsByReqCtxRequest) XXX_Size() int

func (*QueryRequestsByReqCtxRequest) XXX_Unmarshal 

func (m *QueryRequestsByReqCtxRequest) XXX_Unmarshal(b []byte) error

type QueryRequestsByReqCtxResponse 

type QueryRequestsByReqCtxResponse struct {
	Requests   []*Request          `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRequestsByReqCtxResponse is response type for the Query/RequestsByReqCtx RPC method

func (*QueryRequestsByReqCtxResponse) Descriptor 

func (*QueryRequestsByReqCtxResponse) Descriptor() ([]byte, []int)

func (*QueryRequestsByReqCtxResponse) GetPagination added in v1.2.0 

func (m *QueryRequestsByReqCtxResponse) GetPagination() *query.PageResponse

func (*QueryRequestsByReqCtxResponse) GetRequests 

func (m *QueryRequestsByReqCtxResponse) GetRequests() []*Request

func (*QueryRequestsByReqCtxResponse) Marshal 

func (m *QueryRequestsByReqCtxResponse) Marshal() (dAtA []byte, err error)

func (*QueryRequestsByReqCtxResponse) MarshalTo 

func (m *QueryRequestsByReqCtxResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequestsByReqCtxResponse) MarshalToSizedBuffer 

func (m *QueryRequestsByReqCtxResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequestsByReqCtxResponse) ProtoMessage 

func (*QueryRequestsByReqCtxResponse) ProtoMessage()

func (*QueryRequestsByReqCtxResponse) Reset 

func (m *QueryRequestsByReqCtxResponse) Reset()

func (*QueryRequestsByReqCtxResponse) Size 

func (m *QueryRequestsByReqCtxResponse) Size() (n int)

func (*QueryRequestsByReqCtxResponse) String 

func (m *QueryRequestsByReqCtxResponse) String() string

func (*QueryRequestsByReqCtxResponse) Unmarshal 

func (m *QueryRequestsByReqCtxResponse) Unmarshal(dAtA []byte) error

func (*QueryRequestsByReqCtxResponse) XXX_DiscardUnknown 

func (m *QueryRequestsByReqCtxResponse) XXX_DiscardUnknown()

func (*QueryRequestsByReqCtxResponse) XXX_Marshal 

func (m *QueryRequestsByReqCtxResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequestsByReqCtxResponse) XXX_Merge 

func (m *QueryRequestsByReqCtxResponse) XXX_Merge(src proto.Message)

func (*QueryRequestsByReqCtxResponse) XXX_Size 

func (m *QueryRequestsByReqCtxResponse) XXX_Size() int

func (*QueryRequestsByReqCtxResponse) XXX_Unmarshal 

func (m *QueryRequestsByReqCtxResponse) XXX_Unmarshal(b []byte) error

type QueryRequestsParams 

type QueryRequestsParams struct {
	ServiceName string
	Provider    sdk.AccAddress
}

QueryRequestsParams defines the params to query active requests for a service binding

type QueryRequestsRequest 

type QueryRequestsRequest struct {
	ServiceName string             `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Provider    string             `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Pagination  *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRequestsRequest is request type for the Query/Requests RPC method

func (*QueryRequestsRequest) Descriptor 

func (*QueryRequestsRequest) Descriptor() ([]byte, []int)

func (*QueryRequestsRequest) GetPagination added in v1.2.0 

func (m *QueryRequestsRequest) GetPagination() *query.PageRequest

func (*QueryRequestsRequest) GetProvider 

func (m *QueryRequestsRequest) GetProvider() string

func (*QueryRequestsRequest) GetServiceName 

func (m *QueryRequestsRequest) GetServiceName() string

func (*QueryRequestsRequest) Marshal 

func (m *QueryRequestsRequest) Marshal() (dAtA []byte, err error)

func (*QueryRequestsRequest) MarshalTo 

func (m *QueryRequestsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequestsRequest) MarshalToSizedBuffer 

func (m *QueryRequestsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequestsRequest) ProtoMessage 

func (*QueryRequestsRequest) ProtoMessage()

func (*QueryRequestsRequest) Reset 

func (m *QueryRequestsRequest) Reset()

func (*QueryRequestsRequest) Size 

func (m *QueryRequestsRequest) Size() (n int)

func (*QueryRequestsRequest) String 

func (m *QueryRequestsRequest) String() string

func (*QueryRequestsRequest) Unmarshal 

func (m *QueryRequestsRequest) Unmarshal(dAtA []byte) error

func (*QueryRequestsRequest) XXX_DiscardUnknown 

func (m *QueryRequestsRequest) XXX_DiscardUnknown()

func (*QueryRequestsRequest) XXX_Marshal 

func (m *QueryRequestsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequestsRequest) XXX_Merge 

func (m *QueryRequestsRequest) XXX_Merge(src proto.Message)

func (*QueryRequestsRequest) XXX_Size 

func (m *QueryRequestsRequest) XXX_Size() int

func (*QueryRequestsRequest) XXX_Unmarshal 

func (m *QueryRequestsRequest) XXX_Unmarshal(b []byte) error

type QueryRequestsResponse 

type QueryRequestsResponse struct {
	Requests   []*Request          `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryRequestsResponse is response type for the Query/Requests RPC method

func (*QueryRequestsResponse) Descriptor 

func (*QueryRequestsResponse) Descriptor() ([]byte, []int)

func (*QueryRequestsResponse) GetPagination added in v1.2.0 

func (m *QueryRequestsResponse) GetPagination() *query.PageResponse

func (*QueryRequestsResponse) GetRequests 

func (m *QueryRequestsResponse) GetRequests() []*Request

func (*QueryRequestsResponse) Marshal 

func (m *QueryRequestsResponse) Marshal() (dAtA []byte, err error)

func (*QueryRequestsResponse) MarshalTo 

func (m *QueryRequestsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequestsResponse) MarshalToSizedBuffer 

func (m *QueryRequestsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequestsResponse) ProtoMessage 

func (*QueryRequestsResponse) ProtoMessage()

func (*QueryRequestsResponse) Reset 

func (m *QueryRequestsResponse) Reset()

func (*QueryRequestsResponse) Size 

func (m *QueryRequestsResponse) Size() (n int)

func (*QueryRequestsResponse) String 

func (m *QueryRequestsResponse) String() string

func (*QueryRequestsResponse) Unmarshal 

func (m *QueryRequestsResponse) Unmarshal(dAtA []byte) error

func (*QueryRequestsResponse) XXX_DiscardUnknown 

func (m *QueryRequestsResponse) XXX_DiscardUnknown()

func (*QueryRequestsResponse) XXX_Marshal 

func (m *QueryRequestsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequestsResponse) XXX_Merge 

func (m *QueryRequestsResponse) XXX_Merge(src proto.Message)

func (*QueryRequestsResponse) XXX_Size 

func (m *QueryRequestsResponse) XXX_Size() int

func (*QueryRequestsResponse) XXX_Unmarshal 

func (m *QueryRequestsResponse) XXX_Unmarshal(b []byte) error

type QueryResponseParams 

type QueryResponseParams struct {
	RequestID tmbytes.HexBytes
}

QueryResponseParams defines the params to query the response to a request

type QueryResponseRequest 

type QueryResponseRequest struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
}

QueryResponseRequest is request type for the Query/Response RPC method

func (*QueryResponseRequest) Descriptor 

func (*QueryResponseRequest) Descriptor() ([]byte, []int)

func (*QueryResponseRequest) GetRequestId 

func (m *QueryResponseRequest) GetRequestId() string

func (*QueryResponseRequest) Marshal 

func (m *QueryResponseRequest) Marshal() (dAtA []byte, err error)

func (*QueryResponseRequest) MarshalTo 

func (m *QueryResponseRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponseRequest) MarshalToSizedBuffer 

func (m *QueryResponseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponseRequest) ProtoMessage 

func (*QueryResponseRequest) ProtoMessage()

func (*QueryResponseRequest) Reset 

func (m *QueryResponseRequest) Reset()

func (*QueryResponseRequest) Size 

func (m *QueryResponseRequest) Size() (n int)

func (*QueryResponseRequest) String 

func (m *QueryResponseRequest) String() string

func (*QueryResponseRequest) Unmarshal 

func (m *QueryResponseRequest) Unmarshal(dAtA []byte) error

func (*QueryResponseRequest) XXX_DiscardUnknown 

func (m *QueryResponseRequest) XXX_DiscardUnknown()

func (*QueryResponseRequest) XXX_Marshal 

func (m *QueryResponseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResponseRequest) XXX_Merge 

func (m *QueryResponseRequest) XXX_Merge(src proto.Message)

func (*QueryResponseRequest) XXX_Size 

func (m *QueryResponseRequest) XXX_Size() int

func (*QueryResponseRequest) XXX_Unmarshal 

func (m *QueryResponseRequest) XXX_Unmarshal(b []byte) error

type QueryResponseResponse 

type QueryResponseResponse struct {
	Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
}

QueryResponseResponse is response type for the Query/Response RPC method

func (*QueryResponseResponse) Descriptor 

func (*QueryResponseResponse) Descriptor() ([]byte, []int)

func (*QueryResponseResponse) GetResponse 

func (m *QueryResponseResponse) GetResponse() *Response

func (*QueryResponseResponse) Marshal 

func (m *QueryResponseResponse) Marshal() (dAtA []byte, err error)

func (*QueryResponseResponse) MarshalTo 

func (m *QueryResponseResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponseResponse) MarshalToSizedBuffer 

func (m *QueryResponseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponseResponse) ProtoMessage 

func (*QueryResponseResponse) ProtoMessage()

func (*QueryResponseResponse) Reset 

func (m *QueryResponseResponse) Reset()

func (*QueryResponseResponse) Size 

func (m *QueryResponseResponse) Size() (n int)

func (*QueryResponseResponse) String 

func (m *QueryResponseResponse) String() string

func (*QueryResponseResponse) Unmarshal 

func (m *QueryResponseResponse) Unmarshal(dAtA []byte) error

func (*QueryResponseResponse) XXX_DiscardUnknown 

func (m *QueryResponseResponse) XXX_DiscardUnknown()

func (*QueryResponseResponse) XXX_Marshal 

func (m *QueryResponseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResponseResponse) XXX_Merge 

func (m *QueryResponseResponse) XXX_Merge(src proto.Message)

func (*QueryResponseResponse) XXX_Size 

func (m *QueryResponseResponse) XXX_Size() int

func (*QueryResponseResponse) XXX_Unmarshal 

func (m *QueryResponseResponse) XXX_Unmarshal(b []byte) error

type QueryResponsesParams 

type QueryResponsesParams struct {
	RequestContextID tmbytes.HexBytes
	BatchCounter     uint64
}

QueryResponsesParams defines the params to query active responses by the request context ID

type QueryResponsesRequest 

type QueryResponsesRequest struct {
	RequestContextId string             `protobuf:"bytes,1,opt,name=request_context_id,json=requestContextId,proto3" json:"request_context_id,omitempty"`
	BatchCounter     uint64             `protobuf:"varint,2,opt,name=batch_counter,json=batchCounter,proto3" json:"batch_counter,omitempty"`
	Pagination       *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryResponsesRequest is request type for the Query/Responses RPC method

func (*QueryResponsesRequest) Descriptor 

func (*QueryResponsesRequest) Descriptor() ([]byte, []int)

func (*QueryResponsesRequest) GetBatchCounter 

func (m *QueryResponsesRequest) GetBatchCounter() uint64

func (*QueryResponsesRequest) GetPagination added in v1.2.0 

func (m *QueryResponsesRequest) GetPagination() *query.PageRequest

func (*QueryResponsesRequest) GetRequestContextId 

func (m *QueryResponsesRequest) GetRequestContextId() string

func (*QueryResponsesRequest) Marshal 

func (m *QueryResponsesRequest) Marshal() (dAtA []byte, err error)

func (*QueryResponsesRequest) MarshalTo 

func (m *QueryResponsesRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponsesRequest) MarshalToSizedBuffer 

func (m *QueryResponsesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponsesRequest) ProtoMessage 

func (*QueryResponsesRequest) ProtoMessage()

func (*QueryResponsesRequest) Reset 

func (m *QueryResponsesRequest) Reset()

func (*QueryResponsesRequest) Size 

func (m *QueryResponsesRequest) Size() (n int)

func (*QueryResponsesRequest) String 

func (m *QueryResponsesRequest) String() string

func (*QueryResponsesRequest) Unmarshal 

func (m *QueryResponsesRequest) Unmarshal(dAtA []byte) error

func (*QueryResponsesRequest) XXX_DiscardUnknown 

func (m *QueryResponsesRequest) XXX_DiscardUnknown()

func (*QueryResponsesRequest) XXX_Marshal 

func (m *QueryResponsesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResponsesRequest) XXX_Merge 

func (m *QueryResponsesRequest) XXX_Merge(src proto.Message)

func (*QueryResponsesRequest) XXX_Size 

func (m *QueryResponsesRequest) XXX_Size() int

func (*QueryResponsesRequest) XXX_Unmarshal 

func (m *QueryResponsesRequest) XXX_Unmarshal(b []byte) error

type QueryResponsesResponse 

type QueryResponsesResponse struct {
	Responses  []*Response         `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryResponsesResponse is response type for the Query/Responses RPC method

func (*QueryResponsesResponse) Descriptor 

func (*QueryResponsesResponse) Descriptor() ([]byte, []int)

func (*QueryResponsesResponse) GetPagination added in v1.2.0 

func (m *QueryResponsesResponse) GetPagination() *query.PageResponse

func (*QueryResponsesResponse) GetResponses 

func (m *QueryResponsesResponse) GetResponses() []*Response

func (*QueryResponsesResponse) Marshal 

func (m *QueryResponsesResponse) Marshal() (dAtA []byte, err error)

func (*QueryResponsesResponse) MarshalTo 

func (m *QueryResponsesResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponsesResponse) MarshalToSizedBuffer 

func (m *QueryResponsesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponsesResponse) ProtoMessage 

func (*QueryResponsesResponse) ProtoMessage()

func (*QueryResponsesResponse) Reset 

func (m *QueryResponsesResponse) Reset()

func (*QueryResponsesResponse) Size 

func (m *QueryResponsesResponse) Size() (n int)

func (*QueryResponsesResponse) String 

func (m *QueryResponsesResponse) String() string

func (*QueryResponsesResponse) Unmarshal 

func (m *QueryResponsesResponse) Unmarshal(dAtA []byte) error

func (*QueryResponsesResponse) XXX_DiscardUnknown 

func (m *QueryResponsesResponse) XXX_DiscardUnknown()

func (*QueryResponsesResponse) XXX_Marshal 

func (m *QueryResponsesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResponsesResponse) XXX_Merge 

func (m *QueryResponsesResponse) XXX_Merge(src proto.Message)

func (*QueryResponsesResponse) XXX_Size 

func (m *QueryResponsesResponse) XXX_Size() int

func (*QueryResponsesResponse) XXX_Unmarshal 

func (m *QueryResponsesResponse) XXX_Unmarshal(b []byte) error

type QuerySchemaParams 

type QuerySchemaParams struct {
	SchemaName string
}

QuerySchemaParams defines the params to query the system schemas by the schema name

type QuerySchemaRequest 

type QuerySchemaRequest struct {
	SchemaName string `protobuf:"bytes,1,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
}

QuerySchemaRequest is request type for the Query/Schema RPC method

func (*QuerySchemaRequest) Descriptor 

func (*QuerySchemaRequest) Descriptor() ([]byte, []int)

func (*QuerySchemaRequest) GetSchemaName 

func (m *QuerySchemaRequest) GetSchemaName() string

func (*QuerySchemaRequest) Marshal 

func (m *QuerySchemaRequest) Marshal() (dAtA []byte, err error)

func (*QuerySchemaRequest) MarshalTo 

func (m *QuerySchemaRequest) MarshalTo(dAtA []byte) (int, error)

func (*QuerySchemaRequest) MarshalToSizedBuffer 

func (m *QuerySchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QuerySchemaRequest) ProtoMessage 

func (*QuerySchemaRequest) ProtoMessage()

func (*QuerySchemaRequest) Reset 

func (m *QuerySchemaRequest) Reset()

func (*QuerySchemaRequest) Size 

func (m *QuerySchemaRequest) Size() (n int)

func (*QuerySchemaRequest) String 

func (m *QuerySchemaRequest) String() string

func (*QuerySchemaRequest) Unmarshal 

func (m *QuerySchemaRequest) Unmarshal(dAtA []byte) error

func (*QuerySchemaRequest) XXX_DiscardUnknown 

func (m *QuerySchemaRequest) XXX_DiscardUnknown()

func (*QuerySchemaRequest) XXX_Marshal 

func (m *QuerySchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QuerySchemaRequest) XXX_Merge 

func (m *QuerySchemaRequest) XXX_Merge(src proto.Message)

func (*QuerySchemaRequest) XXX_Size 

func (m *QuerySchemaRequest) XXX_Size() int

func (*QuerySchemaRequest) XXX_Unmarshal 

func (m *QuerySchemaRequest) XXX_Unmarshal(b []byte) error

type QuerySchemaResponse 

type QuerySchemaResponse struct {
	Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
}

QuerySchemaResponse is response type for the Query/Schema RPC method

func (*QuerySchemaResponse) Descriptor 

func (*QuerySchemaResponse) Descriptor() ([]byte, []int)

func (*QuerySchemaResponse) GetSchema 

func (m *QuerySchemaResponse) GetSchema() string

func (*QuerySchemaResponse) Marshal 

func (m *QuerySchemaResponse) Marshal() (dAtA []byte, err error)

func (*QuerySchemaResponse) MarshalTo 

func (m *QuerySchemaResponse) MarshalTo(dAtA []byte) (int, error)

func (*QuerySchemaResponse) MarshalToSizedBuffer 

func (m *QuerySchemaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QuerySchemaResponse) ProtoMessage 

func (*QuerySchemaResponse) ProtoMessage()

func (*QuerySchemaResponse) Reset 

func (m *QuerySchemaResponse) Reset()

func (*QuerySchemaResponse) Size 

func (m *QuerySchemaResponse) Size() (n int)

func (*QuerySchemaResponse) String 

func (m *QuerySchemaResponse) String() string

func (*QuerySchemaResponse) Unmarshal 

func (m *QuerySchemaResponse) Unmarshal(dAtA []byte) error

func (*QuerySchemaResponse) XXX_DiscardUnknown 

func (m *QuerySchemaResponse) XXX_DiscardUnknown()

func (*QuerySchemaResponse) XXX_Marshal 

func (m *QuerySchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QuerySchemaResponse) XXX_Merge 

func (m *QuerySchemaResponse) XXX_Merge(src proto.Message)

func (*QuerySchemaResponse) XXX_Size 

func (m *QuerySchemaResponse) XXX_Size() int

func (*QuerySchemaResponse) XXX_Unmarshal 

func (m *QuerySchemaResponse) XXX_Unmarshal(b []byte) error

type QueryServer 

type QueryServer interface {
	// Definition returns service definition
	Definition(context.Context, *QueryDefinitionRequest) (*QueryDefinitionResponse, error)
	// Binding returns service Binding with service name and provider
	Binding(context.Context, *QueryBindingRequest) (*QueryBindingResponse, error)
	// Bindings returns all service Bindings with service name and owner
	Bindings(context.Context, *QueryBindingsRequest) (*QueryBindingsResponse, error)
	// WithdrawAddress returns the withdraw address of the binding owner
	WithdrawAddress(context.Context, *QueryWithdrawAddressRequest) (*QueryWithdrawAddressResponse, error)
	// RequestContext returns the request context
	RequestContext(context.Context, *QueryRequestContextRequest) (*QueryRequestContextResponse, error)
	// Request returns the request
	Request(context.Context, *QueryRequestRequest) (*QueryRequestResponse, error)
	// Request returns all requests of one service with provider
	Requests(context.Context, *QueryRequestsRequest) (*QueryRequestsResponse, error)
	// RequestsByReqCtx returns all requests of one service call batch
	RequestsByReqCtx(context.Context, *QueryRequestsByReqCtxRequest) (*QueryRequestsByReqCtxResponse, error)
	// Response returns the response of request
	Response(context.Context, *QueryResponseRequest) (*QueryResponseResponse, error)
	// Responses returns all responses of one service call batch
	Responses(context.Context, *QueryResponsesRequest) (*QueryResponsesResponse, error)
	// EarnedFees returns the earned service fee of one provider
	EarnedFees(context.Context, *QueryEarnedFeesRequest) (*QueryEarnedFeesResponse, error)
	// Schema returns the schema
	Schema(context.Context, *QuerySchemaRequest) (*QuerySchemaResponse, error)
	// Params queries the service parameters
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type QueryWithdrawAddressParams 

type QueryWithdrawAddressParams struct {
	Owner sdk.AccAddress
}

QueryWithdrawAddressParams defines the params to query the withdrawal address of an owner

type QueryWithdrawAddressRequest 

type QueryWithdrawAddressRequest struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
}

QueryWithdrawAddressRequest is request type for the Query/WithdrawAddress RPC method

func (*QueryWithdrawAddressRequest) Descriptor 

func (*QueryWithdrawAddressRequest) Descriptor() ([]byte, []int)

func (*QueryWithdrawAddressRequest) GetOwner 

func (m *QueryWithdrawAddressRequest) GetOwner() string

func (*QueryWithdrawAddressRequest) Marshal 

func (m *QueryWithdrawAddressRequest) Marshal() (dAtA []byte, err error)

func (*QueryWithdrawAddressRequest) MarshalTo 

func (m *QueryWithdrawAddressRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryWithdrawAddressRequest) MarshalToSizedBuffer 

func (m *QueryWithdrawAddressRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWithdrawAddressRequest) ProtoMessage 

func (*QueryWithdrawAddressRequest) ProtoMessage()

func (*QueryWithdrawAddressRequest) Reset 

func (m *QueryWithdrawAddressRequest) Reset()

func (*QueryWithdrawAddressRequest) Size 

func (m *QueryWithdrawAddressRequest) Size() (n int)

func (*QueryWithdrawAddressRequest) String 

func (m *QueryWithdrawAddressRequest) String() string

func (*QueryWithdrawAddressRequest) Unmarshal 

func (m *QueryWithdrawAddressRequest) Unmarshal(dAtA []byte) error

func (*QueryWithdrawAddressRequest) XXX_DiscardUnknown 

func (m *QueryWithdrawAddressRequest) XXX_DiscardUnknown()

func (*QueryWithdrawAddressRequest) XXX_Marshal 

func (m *QueryWithdrawAddressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWithdrawAddressRequest) XXX_Merge 

func (m *QueryWithdrawAddressRequest) XXX_Merge(src proto.Message)

func (*QueryWithdrawAddressRequest) XXX_Size 

func (m *QueryWithdrawAddressRequest) XXX_Size() int

func (*QueryWithdrawAddressRequest) XXX_Unmarshal 

func (m *QueryWithdrawAddressRequest) XXX_Unmarshal(b []byte) error

type QueryWithdrawAddressResponse 

type QueryWithdrawAddressResponse struct {
	WithdrawAddress string `protobuf:"bytes,1,opt,name=withdraw_address,json=withdrawAddress,proto3" json:"withdraw_address,omitempty"`
}

QueryWithdrawAddressResponse is response type for the Query/WithdrawAddress RPC method

func (*QueryWithdrawAddressResponse) Descriptor 

func (*QueryWithdrawAddressResponse) Descriptor() ([]byte, []int)

func (*QueryWithdrawAddressResponse) GetWithdrawAddress 

func (m *QueryWithdrawAddressResponse) GetWithdrawAddress() string

func (*QueryWithdrawAddressResponse) Marshal 

func (m *QueryWithdrawAddressResponse) Marshal() (dAtA []byte, err error)

func (*QueryWithdrawAddressResponse) MarshalTo 

func (m *QueryWithdrawAddressResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryWithdrawAddressResponse) MarshalToSizedBuffer 

func (m *QueryWithdrawAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWithdrawAddressResponse) ProtoMessage 

func (*QueryWithdrawAddressResponse) ProtoMessage()

func (*QueryWithdrawAddressResponse) Reset 

func (m *QueryWithdrawAddressResponse) Reset()

func (*QueryWithdrawAddressResponse) Size 

func (m *QueryWithdrawAddressResponse) Size() (n int)

func (*QueryWithdrawAddressResponse) String 

func (m *QueryWithdrawAddressResponse) String() string

func (*QueryWithdrawAddressResponse) Unmarshal 

func (m *QueryWithdrawAddressResponse) Unmarshal(dAtA []byte) error

func (*QueryWithdrawAddressResponse) XXX_DiscardUnknown 

func (m *QueryWithdrawAddressResponse) XXX_DiscardUnknown()

func (*QueryWithdrawAddressResponse) XXX_Marshal 

func (m *QueryWithdrawAddressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWithdrawAddressResponse) XXX_Merge 

func (m *QueryWithdrawAddressResponse) XXX_Merge(src proto.Message)

func (*QueryWithdrawAddressResponse) XXX_Size 

func (m *QueryWithdrawAddressResponse) XXX_Size() int

func (*QueryWithdrawAddressResponse) XXX_Unmarshal 

func (m *QueryWithdrawAddressResponse) XXX_Unmarshal(b []byte) error

type RawPricing 

type RawPricing struct {
	Price              string              `json:"price"`                // base price string
	PromotionsByTime   []PromotionByTime   `json:"promotions_by_time"`   // promotions by time
	PromotionsByVolume []PromotionByVolume `json:"promotions_by_volume"` // promotions by volume
}

RawPricing represents the raw pricing of a service binding

type Request 

type Request struct {
	Id                         string                                   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ServiceName                string                                   `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Provider                   string                                   `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"`
	Consumer                   string                                   `protobuf:"bytes,4,opt,name=consumer,proto3" json:"consumer,omitempty"`
	Input                      string                                   `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	ServiceFee                 github_com_cosmos_cosmos_sdk_types.Coins `` /* 154-byte string literal not displayed */
	RequestHeight              int64                                    `protobuf:"varint,7,opt,name=request_height,json=requestHeight,proto3" json:"request_height,omitempty" yaml:"request_height"`
	ExpirationHeight           int64                                    `` /* 135-byte string literal not displayed */
	RequestContextId           string                                   `` /* 137-byte string literal not displayed */
	RequestContextBatchCounter uint64                                   `` /* 182-byte string literal not displayed */
}

Request defines a standard for request

func NewRequest 

func NewRequest(
	id tmbytes.HexBytes,
	serviceName string,
	provider,
	consumer sdk.AccAddress,
	input string,
	serviceFee sdk.Coins,
	requestHeight int64,
	expirationHeight int64,
	requestContextID tmbytes.HexBytes,
	batchCounter uint64,
) Request

NewRequest creates a new Request instance

func (*Request) Descriptor 

func (*Request) Descriptor() ([]byte, []int)

func (Request) Empty 

func (r Request) Empty() bool

Empty returns true if empty

func (*Request) Marshal 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) MarshalToSizedBuffer 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

func (m *Request) Size() (n int)

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

func (m *Request) XXX_Unmarshal(b []byte) error

type RequestContext 

type RequestContext struct {
	ServiceName            string                                   `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Providers              []string                                 `protobuf:"bytes,2,rep,name=providers,proto3" json:"providers,omitempty"`
	Consumer               string                                   `protobuf:"bytes,3,opt,name=consumer,proto3" json:"consumer,omitempty"`
	Input                  string                                   `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	ServiceFeeCap          github_com_cosmos_cosmos_sdk_types.Coins `` /* 169-byte string literal not displayed */
	ModuleName             string                                   `protobuf:"bytes,6,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty" yaml:"module_name"`
	Timeout                int64                                    `protobuf:"varint,7,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Repeated               bool                                     `protobuf:"varint,8,opt,name=repeated,proto3" json:"repeated,omitempty"`
	RepeatedFrequency      uint64                                   `` /* 139-byte string literal not displayed */
	RepeatedTotal          int64                                    `protobuf:"varint,10,opt,name=repeated_total,json=repeatedTotal,proto3" json:"repeated_total,omitempty" yaml:"repeated_total"`
	BatchCounter           uint64                                   `protobuf:"varint,11,opt,name=batch_counter,json=batchCounter,proto3" json:"batch_counter,omitempty" yaml:"batch_counter"`
	BatchRequestCount      uint32                                   `` /* 143-byte string literal not displayed */
	BatchResponseCount     uint32                                   `` /* 147-byte string literal not displayed */
	BatchResponseThreshold uint32                                   `` /* 163-byte string literal not displayed */
	ResponseThreshold      uint32                                   `` /* 140-byte string literal not displayed */
	BatchState             RequestContextBatchState                 `` /* 158-byte string literal not displayed */
	State                  RequestContextState                      `protobuf:"varint,17,opt,name=state,proto3,enum=irismod.service.RequestContextState" json:"state,omitempty"`
}

RequestContext defines a standard for request context

func NewRequestContext 

func NewRequestContext(
	serviceName string,
	providers []sdk.AccAddress,
	consumer sdk.AccAddress,
	input string,
	serviceFeeCap sdk.Coins,
	timeout int64,
	repeated bool,
	repeatedFrequency uint64,
	repeatedTotal int64,
	batchCounter uint64,
	batchRequestCount,
	batchResponseCount uint32,
	batchResponseThreshold uint32,
	batchState RequestContextBatchState,
	state RequestContextState,
	responseThreshold uint32,
	moduleName string,
) RequestContext

NewRequestContext creates a new RequestContext instance

func (*RequestContext) Descriptor 

func (*RequestContext) Descriptor() ([]byte, []int)

func (RequestContext) Empty 

func (rc RequestContext) Empty() bool

Empty returns true if empty

func (*RequestContext) Marshal 

func (m *RequestContext) Marshal() (dAtA []byte, err error)

func (*RequestContext) MarshalTo 

func (m *RequestContext) MarshalTo(dAtA []byte) (int, error)

func (*RequestContext) MarshalToSizedBuffer 

func (m *RequestContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestContext) ProtoMessage 

func (*RequestContext) ProtoMessage()

func (*RequestContext) Reset 

func (m *RequestContext) Reset()

func (*RequestContext) Size 

func (m *RequestContext) Size() (n int)

func (*RequestContext) String 

func (m *RequestContext) String() string

func (*RequestContext) Unmarshal 

func (m *RequestContext) Unmarshal(dAtA []byte) error

func (RequestContext) Validate 

func (rc RequestContext) Validate() error

Validate validates the request context

func (*RequestContext) XXX_DiscardUnknown 

func (m *RequestContext) XXX_DiscardUnknown()

func (*RequestContext) XXX_Marshal 

func (m *RequestContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestContext) XXX_Merge 

func (m *RequestContext) XXX_Merge(src proto.Message)

func (*RequestContext) XXX_Size 

func (m *RequestContext) XXX_Size() int

func (*RequestContext) XXX_Unmarshal 

func (m *RequestContext) XXX_Unmarshal(b []byte) error

type RequestContextBatchState 

type RequestContextBatchState int32

RequestContextBatchState is a type alias that represents a request batch status as a byte 

const (
	// BATCH_RUNNING defines the running batch status.
	BATCHRUNNING RequestContextBatchState = 0
	// BATCH_COMPLETED defines the completed batch status.
	BATCHCOMPLETED RequestContextBatchState = 1
)

func (RequestContextBatchState) EnumDescriptor 

func (RequestContextBatchState) EnumDescriptor() ([]byte, []int)

func (RequestContextBatchState) Marshal 

func (state RequestContextBatchState) Marshal() ([]byte, error)

Marshal needed for protobuf compatibility

func (RequestContextBatchState) String 

func (x RequestContextBatchState) String() string

func (*RequestContextBatchState) Unmarshal 

func (state *RequestContextBatchState) Unmarshal(data []byte) error

Unmarshal needed for protobuf compatibility

type RequestContextState 

type RequestContextState int32

RequestContextState is a type alias that represents a request status as a byte 

const (
	// RUNNING defines the running request context status
	RUNNING RequestContextState = 0
	// PAUSED defines the paused request context status
	PAUSED RequestContextState = 1
	// COMPLETED defines the completed request context status
	COMPLETED RequestContextState = 2
)

func RequestContextStateFromString 

func RequestContextStateFromString(str string) (RequestContextState, error)

func (RequestContextState) EnumDescriptor 

func (RequestContextState) EnumDescriptor() ([]byte, []int)

func (RequestContextState) Marshal 

func (state RequestContextState) Marshal() ([]byte, error)

Marshal needed for protobuf compatibility

func (RequestContextState) String 

func (x RequestContextState) String() string

func (*RequestContextState) Unmarshal 

func (state *RequestContextState) Unmarshal(data []byte) error

Unmarshal needed for protobuf compatibility

type Response 

type Response struct {
	Provider                   string `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
	Consumer                   string `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
	Result                     string `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	Output                     string `protobuf:"bytes,4,opt,name=output,proto3" json:"output,omitempty"`
	RequestContextId           string `` /* 137-byte string literal not displayed */
	RequestContextBatchCounter uint64 `` /* 181-byte string literal not displayed */
}

Response defines a standard for response

func NewResponse 

func NewResponse(
	provider,
	consumer sdk.AccAddress,
	result,
	output string,
	requestContextID tmbytes.HexBytes,
	batchCounter uint64,
) Response

NewResponse creates a new Response instance

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (Response) Empty 

func (r Response) Empty() bool

Empty returns true if empty

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type ResponseCallback 

type ResponseCallback func(ctx sdk.Context, requestContextID tmbytes.HexBytes, responses []string, err error)

ResponseCallback defines the response callback interface

type Result 

type Result struct {
	Code    ResultCode `json:"code"`
	Message string     `json:"message"`
}

Result defines a struct for the response result

func ParseResult 

func ParseResult(result string) (Result, error)

ParseResult parses the given string to Result

type ResultCode added in v1.2.0 

type ResultCode uint16

ResultCode defines the type for the result code 

const (
	// ResultOK means that the request is well processed
	ResultOK ResultCode = 200

	// ResultBadRequest means that the request is incorrect
	ResultBadRequest ResultCode = 400

	// ResultServerError is the code resulting from the internal server error
	ResultServerError ResultCode = 500
)

type ServiceBinding 

type ServiceBinding struct {
	ServiceName  string                                   `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty" yaml:"service_name"`
	Provider     string                                   `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Deposit      github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=deposit,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"deposit"`
	Pricing      string                                   `protobuf:"bytes,4,opt,name=pricing,proto3" json:"pricing,omitempty"`
	QoS          uint64                                   `protobuf:"varint,5,opt,name=qos,proto3" json:"qos,omitempty"`
	Options      string                                   `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	Available    bool                                     `protobuf:"varint,7,opt,name=available,proto3" json:"available,omitempty"`
	DisabledTime time.Time                                `protobuf:"bytes,8,opt,name=disabled_time,json=disabledTime,proto3,stdtime" json:"disabled_time" yaml:"disabled_time"`
	Owner        string                                   `protobuf:"bytes,9,opt,name=owner,proto3" json:"owner,omitempty"`
}

ServiceBinding defines a standard for service binding

func GenOraclePriceSvcBinding 

func GenOraclePriceSvcBinding(baseDenom string) ServiceBinding

func NewServiceBinding 

func NewServiceBinding(
	serviceName string,
	provider sdk.AccAddress,
	deposit sdk.Coins,
	pricing string,
	qos uint64,
	options string,
	available bool,
	disabledTime time.Time,
	owner sdk.AccAddress,
) ServiceBinding

NewServiceBinding creates a new ServiceBinding instance

func (*ServiceBinding) Descriptor 

func (*ServiceBinding) Descriptor() ([]byte, []int)

func (*ServiceBinding) Marshal 

func (m *ServiceBinding) Marshal() (dAtA []byte, err error)

func (*ServiceBinding) MarshalTo 

func (m *ServiceBinding) MarshalTo(dAtA []byte) (int, error)

func (*ServiceBinding) MarshalToSizedBuffer 

func (m *ServiceBinding) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceBinding) ProtoMessage 

func (*ServiceBinding) ProtoMessage()

func (*ServiceBinding) Reset 

func (m *ServiceBinding) Reset()

func (*ServiceBinding) Size 

func (m *ServiceBinding) Size() (n int)

func (*ServiceBinding) String 

func (m *ServiceBinding) String() string

func (*ServiceBinding) Unmarshal 

func (m *ServiceBinding) Unmarshal(dAtA []byte) error

func (ServiceBinding) Validate 

func (binding ServiceBinding) Validate() error

Validate validates the service binding

func (*ServiceBinding) XXX_DiscardUnknown 

func (m *ServiceBinding) XXX_DiscardUnknown()

func (*ServiceBinding) XXX_Marshal 

func (m *ServiceBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceBinding) XXX_Merge 

func (m *ServiceBinding) XXX_Merge(src proto.Message)

func (*ServiceBinding) XXX_Size 

func (m *ServiceBinding) XXX_Size() int

func (*ServiceBinding) XXX_Unmarshal 

func (m *ServiceBinding) XXX_Unmarshal(b []byte) error

type ServiceDefinition 

type ServiceDefinition struct {
	Name              string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description       string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Tags              []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Author            string   `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
	AuthorDescription string   `` /* 138-byte string literal not displayed */
	Schemas           string   `protobuf:"bytes,6,opt,name=schemas,proto3" json:"schemas,omitempty"`
}

ServiceDefinition defines a standard for service definition

func GenOraclePriceSvcDefinition 

func GenOraclePriceSvcDefinition() ServiceDefinition

func NewServiceDefinition 

func NewServiceDefinition(
	name string,
	description string,
	tags []string,
	author sdk.AccAddress,
	authorDescription string,
	schemas string,
) ServiceDefinition

NewServiceDefinition creates a new ServiceDefinition instance

func (*ServiceDefinition) Descriptor 

func (*ServiceDefinition) Descriptor() ([]byte, []int)

func (*ServiceDefinition) Marshal 

func (m *ServiceDefinition) Marshal() (dAtA []byte, err error)

func (*ServiceDefinition) MarshalTo 

func (m *ServiceDefinition) MarshalTo(dAtA []byte) (int, error)

func (*ServiceDefinition) MarshalToSizedBuffer 

func (m *ServiceDefinition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceDefinition) ProtoMessage 

func (*ServiceDefinition) ProtoMessage()

func (*ServiceDefinition) Reset 

func (m *ServiceDefinition) Reset()

func (*ServiceDefinition) Size 

func (m *ServiceDefinition) Size() (n int)

func (*ServiceDefinition) String 

func (m *ServiceDefinition) String() string

func (*ServiceDefinition) Unmarshal 

func (m *ServiceDefinition) Unmarshal(dAtA []byte) error

func (ServiceDefinition) Validate 

func (svcDef ServiceDefinition) Validate() error

Validate validates the service definition

func (*ServiceDefinition) XXX_DiscardUnknown 

func (m *ServiceDefinition) XXX_DiscardUnknown()

func (*ServiceDefinition) XXX_Marshal 

func (m *ServiceDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceDefinition) XXX_Merge 

func (m *ServiceDefinition) XXX_Merge(src proto.Message)

func (*ServiceDefinition) XXX_Size 

func (m *ServiceDefinition) XXX_Size() int

func (*ServiceDefinition) XXX_Unmarshal 

func (m *ServiceDefinition) XXX_Unmarshal(b []byte) error

type ServiceSchemas 

type ServiceSchemas struct {
	Input  map[string]interface{} `json:"input"`
	Output map[string]interface{} `json:"output"`
}

ServiceSchemas defines the service schemas

type StateCallback 

type StateCallback func(ctx sdk.Context, requestContextID tmbytes.HexBytes, cause string)

StateCallback defines the state callback interface

type UnimplementedMsgServer added in v1.2.0 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) BindService added in v1.2.0 

func (*UnimplementedMsgServer) BindService(ctx context.Context, req *MsgBindService) (*MsgBindServiceResponse, error)

func (*UnimplementedMsgServer) CallService added in v1.2.0 

func (*UnimplementedMsgServer) CallService(ctx context.Context, req *MsgCallService) (*MsgCallServiceResponse, error)

func (*UnimplementedMsgServer) DefineService added in v1.2.0 

func (*UnimplementedMsgServer) DefineService(ctx context.Context, req *MsgDefineService) (*MsgDefineServiceResponse, error)

func (*UnimplementedMsgServer) DisableServiceBinding added in v1.2.0 

func (*UnimplementedMsgServer) DisableServiceBinding(ctx context.Context, req *MsgDisableServiceBinding) (*MsgDisableServiceBindingResponse, error)

func (*UnimplementedMsgServer) EnableServiceBinding added in v1.2.0 

func (*UnimplementedMsgServer) EnableServiceBinding(ctx context.Context, req *MsgEnableServiceBinding) (*MsgEnableServiceBindingResponse, error)

func (*UnimplementedMsgServer) KillRequestContext added in v1.2.0 

func (*UnimplementedMsgServer) KillRequestContext(ctx context.Context, req *MsgKillRequestContext) (*MsgKillRequestContextResponse, error)

func (*UnimplementedMsgServer) PauseRequestContext added in v1.2.0 

func (*UnimplementedMsgServer) PauseRequestContext(ctx context.Context, req *MsgPauseRequestContext) (*MsgPauseRequestContextResponse, error)

func (*UnimplementedMsgServer) RefundServiceDeposit added in v1.2.0 

func (*UnimplementedMsgServer) RefundServiceDeposit(ctx context.Context, req *MsgRefundServiceDeposit) (*MsgRefundServiceDepositResponse, error)

func (*UnimplementedMsgServer) RespondService added in v1.2.0 

func (*UnimplementedMsgServer) RespondService(ctx context.Context, req *MsgRespondService) (*MsgRespondServiceResponse, error)

func (*UnimplementedMsgServer) SetWithdrawAddress added in v1.2.0 

func (*UnimplementedMsgServer) SetWithdrawAddress(ctx context.Context, req *MsgSetWithdrawAddress) (*MsgSetWithdrawAddressResponse, error)

func (*UnimplementedMsgServer) StartRequestContext added in v1.2.0 

func (*UnimplementedMsgServer) StartRequestContext(ctx context.Context, req *MsgStartRequestContext) (*MsgStartRequestContextResponse, error)

func (*UnimplementedMsgServer) UpdateRequestContext added in v1.2.0 

func (*UnimplementedMsgServer) UpdateRequestContext(ctx context.Context, req *MsgUpdateRequestContext) (*MsgUpdateRequestContextResponse, error)

func (*UnimplementedMsgServer) UpdateServiceBinding added in v1.2.0 

func (*UnimplementedMsgServer) UpdateServiceBinding(ctx context.Context, req *MsgUpdateServiceBinding) (*MsgUpdateServiceBindingResponse, error)

func (*UnimplementedMsgServer) WithdrawEarnedFees added in v1.2.0 

func (*UnimplementedMsgServer) WithdrawEarnedFees(ctx context.Context, req *MsgWithdrawEarnedFees) (*MsgWithdrawEarnedFeesResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Binding 

func (*UnimplementedQueryServer) Binding(ctx context.Context, req *QueryBindingRequest) (*QueryBindingResponse, error)

func (*UnimplementedQueryServer) Bindings 

func (*UnimplementedQueryServer) Bindings(ctx context.Context, req *QueryBindingsRequest) (*QueryBindingsResponse, error)

func (*UnimplementedQueryServer) Definition 

func (*UnimplementedQueryServer) Definition(ctx context.Context, req *QueryDefinitionRequest) (*QueryDefinitionResponse, error)

func (*UnimplementedQueryServer) EarnedFees 

func (*UnimplementedQueryServer) EarnedFees(ctx context.Context, req *QueryEarnedFeesRequest) (*QueryEarnedFeesResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServer) Request 

func (*UnimplementedQueryServer) Request(ctx context.Context, req *QueryRequestRequest) (*QueryRequestResponse, error)

func (*UnimplementedQueryServer) RequestContext 

func (*UnimplementedQueryServer) RequestContext(ctx context.Context, req *QueryRequestContextRequest) (*QueryRequestContextResponse, error)

func (*UnimplementedQueryServer) Requests 

func (*UnimplementedQueryServer) Requests(ctx context.Context, req *QueryRequestsRequest) (*QueryRequestsResponse, error)

func (*UnimplementedQueryServer) RequestsByReqCtx 

func (*UnimplementedQueryServer) RequestsByReqCtx(ctx context.Context, req *QueryRequestsByReqCtxRequest) (*QueryRequestsByReqCtxResponse, error)

func (*UnimplementedQueryServer) Response 

func (*UnimplementedQueryServer) Response(ctx context.Context, req *QueryResponseRequest) (*QueryResponseResponse, error)

func (*UnimplementedQueryServer) Responses 

func (*UnimplementedQueryServer) Responses(ctx context.Context, req *QueryResponsesRequest) (*QueryResponsesResponse, error)

func (*UnimplementedQueryServer) Schema 

func (*UnimplementedQueryServer) Schema(ctx context.Context, req *QuerySchemaRequest) (*QuerySchemaResponse, error)

func (*UnimplementedQueryServer) WithdrawAddress 

func (*UnimplementedQueryServer) WithdrawAddress(ctx context.Context, req *QueryWithdrawAddressRequest) (*QueryWithdrawAddressResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.