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 (*MsgDisableServiceBindingResponse) Size added in v1.2.0

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

func (*MsgDisableServiceBindingResponse) String added in v1.2.0

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 (*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 (*MsgEnableServiceBindingResponse) Size added in v1.2.0

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

func (*MsgEnableServiceBindingResponse) String added in v1.2.0

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 (*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 (*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 (*MsgRefundServiceDepositResponse) Size added in v1.2.0

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

func (*MsgRefundServiceDepositResponse) String added in v1.2.0

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

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 (*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 (*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 (*MsgUpdateRequestContextResponse) Size added in v1.2.0

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

func (*MsgUpdateRequestContextResponse) String added in v1.2.0

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 (*MsgUpdateServiceBindingResponse) Size added in v1.2.0

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

func (*MsgUpdateServiceBindingResponse) String added in v1.2.0

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 (*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 (*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 (*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 (*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 (*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) CallService added in v1.2.0

func (*UnimplementedMsgServer) DefineService added in v1.2.0

func (*UnimplementedMsgServer) DisableServiceBinding added in v1.2.0

func (*UnimplementedMsgServer) EnableServiceBinding added in v1.2.0

func (*UnimplementedMsgServer) KillRequestContext added in v1.2.0

func (*UnimplementedMsgServer) PauseRequestContext added in v1.2.0

func (*UnimplementedMsgServer) RefundServiceDeposit added in v1.2.0

func (*UnimplementedMsgServer) RespondService added in v1.2.0

func (*UnimplementedMsgServer) SetWithdrawAddress added in v1.2.0

func (*UnimplementedMsgServer) StartRequestContext added in v1.2.0

func (*UnimplementedMsgServer) UpdateRequestContext added in v1.2.0

func (*UnimplementedMsgServer) UpdateServiceBinding added in v1.2.0

func (*UnimplementedMsgServer) WithdrawEarnedFees added in v1.2.0

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Binding

func (*UnimplementedQueryServer) Bindings

func (*UnimplementedQueryServer) Definition

func (*UnimplementedQueryServer) EarnedFees

func (*UnimplementedQueryServer) Params

func (*UnimplementedQueryServer) Request

func (*UnimplementedQueryServer) RequestContext

func (*UnimplementedQueryServer) Requests

func (*UnimplementedQueryServer) RequestsByReqCtx

func (*UnimplementedQueryServer) Response

func (*UnimplementedQueryServer) Responses

func (*UnimplementedQueryServer) Schema

func (*UnimplementedQueryServer) WithdrawAddress

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL