service

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Mar 10, 2023 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Overview

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	ModuleName = "service"
)

Variables

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 (
	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 (
	RequestContextStateToStringMap = map[RequestContextState]string{
		RUNNING:   "running",
		PAUSED:    "paused",
		COMPLETED: "completed",
	}
	StringToRequestContextStateMap = map[string]RequestContextState{
		"running":   RUNNING,
		"paused":    PAUSED,
		"completed": COMPLETED,
	}

	RequestContextBatchStateToStringMap = map[RequestContextBatchState]string{
		BATCHRUNNING:   "running",
		BATCHCOMPLETED: "completed",
	}
	StringToRequestContextBatchStateMap = map[string]RequestContextBatchState{
		"running":   BATCHRUNNING,
		"completed": BATCHCOMPLETED,
	}
)
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 RegisterInterfaces

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterMsgServer

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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type BindServiceRequest

type BindServiceRequest struct {
	ServiceName string       `json:"service_name"`
	Deposit     sdk.DecCoins `json:"deposit"`
	Pricing     string       `json:"pricing"`
	QoS         uint64       `json:"qos"`
	Options     string       `json:"options"`
	Provider    string       `json:"provider"`
}

BindServiceRequest defines the request parameters of the service binding

type Client

type Client interface {
	sdk.Module
	Tx
	Query
}

Client defines a set of interfaces in the service module

func NewClient

func NewClient(bc sdk.BaseClient, cdc codec.Marshaler) Client

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_gridironzone_service_sdk_go_types.Coins `` /* 164-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 (*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 DefineServiceRequest

type DefineServiceRequest struct {
	ServiceName       string   `json:"service_name"`
	Description       string   `json:"description"`
	Tags              []string `json:"tags"`
	AuthorDescription string   `json:"author_description"`
	Schemas           string   `json:"schemas"`
}

DefineServiceRequest defines the request parameters of the service definition

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 (*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 InvokeCallback

type InvokeCallback func(reqCtxID, reqID, responses string)

InvokeCallback defines the callback function for service calls

type InvokeServiceRequest

type InvokeServiceRequest struct {
	ServiceName       string       `json:"service_name"`
	Providers         []string     `json:"providers"`
	Input             string       `json:"input"`
	ServiceFeeCap     sdk.DecCoins `json:"service_fee_cap"`
	Timeout           int64        `json:"timeout"`
	Repeated          bool         `json:"repeated"`
	RepeatedFrequency uint64       `json:"repeated_frequency"`
	RepeatedTotal     int64        `json:"repeated_total"`
	Callback          InvokeCallback
}

InvokeServiceRequest defines the request parameters of the service call

type InvokeServiceResponseRequest

type InvokeServiceResponseRequest struct {
	RequestId string `json:"request_id"`
	Output    string `json:"output"`
	Result    string `json:"result"`
}

InvokeServiceResponseRequest defines the request parameters of the service response

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_gridironzone_service_sdk_go_types.Coins `protobuf:"bytes,3,rep,name=deposit,proto3,castrepeated=github.com/gridironzone/service-sdk-go/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 (*MsgBindService) Descriptor

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

func (MsgBindService) GetSignBytes

func (msg MsgBindService) GetSignBytes() []byte

func (MsgBindService) GetSigners

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

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

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

func (*MsgBindService) Unmarshal

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

func (MsgBindService) ValidateBasic

func (msg MsgBindService) ValidateBasic() error

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

type MsgBindServiceResponse struct {
}

MsgBindServiceResponse defines the Msg/BindService response type.

func (*MsgBindServiceResponse) Descriptor

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

func (*MsgBindServiceResponse) Marshal

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

func (*MsgBindServiceResponse) MarshalTo

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

func (*MsgBindServiceResponse) MarshalToSizedBuffer

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

func (*MsgBindServiceResponse) ProtoMessage

func (*MsgBindServiceResponse) ProtoMessage()

func (*MsgBindServiceResponse) Reset

func (m *MsgBindServiceResponse) Reset()

func (*MsgBindServiceResponse) Size

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

func (*MsgBindServiceResponse) String

func (m *MsgBindServiceResponse) String() string

func (*MsgBindServiceResponse) Unmarshal

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

func (*MsgBindServiceResponse) XXX_DiscardUnknown

func (m *MsgBindServiceResponse) XXX_DiscardUnknown()

func (*MsgBindServiceResponse) XXX_Marshal

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

func (*MsgBindServiceResponse) XXX_Merge

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

func (*MsgBindServiceResponse) XXX_Size

func (m *MsgBindServiceResponse) XXX_Size() int

func (*MsgBindServiceResponse) XXX_Unmarshal

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_gridironzone_service_sdk_go_types.Coins `` /* 179-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 (*MsgCallService) Descriptor

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

func (MsgCallService) GetSignBytes

func (msg MsgCallService) GetSignBytes() []byte

func (MsgCallService) GetSigners

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

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

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

func (*MsgCallService) Unmarshal

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

func (MsgCallService) ValidateBasic

func (msg MsgCallService) ValidateBasic() error

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

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

MsgCallServiceResponse defines the Msg/CallService response type.

func (*MsgCallServiceResponse) Descriptor

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

func (*MsgCallServiceResponse) Marshal

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

func (*MsgCallServiceResponse) MarshalTo

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

func (*MsgCallServiceResponse) MarshalToSizedBuffer

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

func (*MsgCallServiceResponse) ProtoMessage

func (*MsgCallServiceResponse) ProtoMessage()

func (*MsgCallServiceResponse) Reset

func (m *MsgCallServiceResponse) Reset()

func (*MsgCallServiceResponse) Size

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

func (*MsgCallServiceResponse) String

func (m *MsgCallServiceResponse) String() string

func (*MsgCallServiceResponse) Unmarshal

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

func (*MsgCallServiceResponse) XXX_DiscardUnknown

func (m *MsgCallServiceResponse) XXX_DiscardUnknown()

func (*MsgCallServiceResponse) XXX_Marshal

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

func (*MsgCallServiceResponse) XXX_Merge

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

func (*MsgCallServiceResponse) XXX_Size

func (m *MsgCallServiceResponse) XXX_Size() int

func (*MsgCallServiceResponse) XXX_Unmarshal

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

type MsgClient

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

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 (*MsgDefineService) Descriptor

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

func (MsgDefineService) GetSignBytes

func (msg MsgDefineService) GetSignBytes() []byte

func (MsgDefineService) GetSigners

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

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

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

func (*MsgDefineService) Unmarshal

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

func (MsgDefineService) ValidateBasic

func (msg MsgDefineService) ValidateBasic() error

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

type MsgDefineServiceResponse struct {
}

MsgDefineServiceResponse defines the Msg/DefineService response type.

func (*MsgDefineServiceResponse) Descriptor

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

func (*MsgDefineServiceResponse) Marshal

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

func (*MsgDefineServiceResponse) MarshalTo

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

func (*MsgDefineServiceResponse) MarshalToSizedBuffer

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

func (*MsgDefineServiceResponse) ProtoMessage

func (*MsgDefineServiceResponse) ProtoMessage()

func (*MsgDefineServiceResponse) Reset

func (m *MsgDefineServiceResponse) Reset()

func (*MsgDefineServiceResponse) Size

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

func (*MsgDefineServiceResponse) String

func (m *MsgDefineServiceResponse) String() string

func (*MsgDefineServiceResponse) Unmarshal

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

func (*MsgDefineServiceResponse) XXX_DiscardUnknown

func (m *MsgDefineServiceResponse) XXX_DiscardUnknown()

func (*MsgDefineServiceResponse) XXX_Marshal

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

func (*MsgDefineServiceResponse) XXX_Merge

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

func (*MsgDefineServiceResponse) XXX_Size

func (m *MsgDefineServiceResponse) XXX_Size() int

func (*MsgDefineServiceResponse) XXX_Unmarshal

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 (*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

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

type MsgDisableServiceBindingResponse struct {
}

MsgDisableServiceBindingResponse defines the Msg/DisableServiceBinding response type.

func (*MsgDisableServiceBindingResponse) Descriptor

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

func (*MsgDisableServiceBindingResponse) Marshal

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

func (*MsgDisableServiceBindingResponse) MarshalTo

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

func (*MsgDisableServiceBindingResponse) MarshalToSizedBuffer

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

func (*MsgDisableServiceBindingResponse) ProtoMessage

func (*MsgDisableServiceBindingResponse) ProtoMessage()

func (*MsgDisableServiceBindingResponse) Reset

func (*MsgDisableServiceBindingResponse) Size

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

func (*MsgDisableServiceBindingResponse) String

func (*MsgDisableServiceBindingResponse) Unmarshal

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

func (*MsgDisableServiceBindingResponse) XXX_DiscardUnknown

func (m *MsgDisableServiceBindingResponse) XXX_DiscardUnknown()

func (*MsgDisableServiceBindingResponse) XXX_Marshal

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

func (*MsgDisableServiceBindingResponse) XXX_Merge

func (*MsgDisableServiceBindingResponse) XXX_Size

func (m *MsgDisableServiceBindingResponse) XXX_Size() int

func (*MsgDisableServiceBindingResponse) XXX_Unmarshal

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_gridironzone_service_sdk_go_types.Coins `protobuf:"bytes,3,rep,name=deposit,proto3,castrepeated=github.com/gridironzone/service-sdk-go/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 (*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

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

type MsgEnableServiceBindingResponse struct {
}

MsgEnableServiceBindingResponse defines the Msg/EnableServiceBinding response type.

func (*MsgEnableServiceBindingResponse) Descriptor

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

func (*MsgEnableServiceBindingResponse) Marshal

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

func (*MsgEnableServiceBindingResponse) MarshalTo

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

func (*MsgEnableServiceBindingResponse) MarshalToSizedBuffer

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

func (*MsgEnableServiceBindingResponse) ProtoMessage

func (*MsgEnableServiceBindingResponse) ProtoMessage()

func (*MsgEnableServiceBindingResponse) Reset

func (*MsgEnableServiceBindingResponse) Size

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

func (*MsgEnableServiceBindingResponse) String

func (*MsgEnableServiceBindingResponse) Unmarshal

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

func (*MsgEnableServiceBindingResponse) XXX_DiscardUnknown

func (m *MsgEnableServiceBindingResponse) XXX_DiscardUnknown()

func (*MsgEnableServiceBindingResponse) XXX_Marshal

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

func (*MsgEnableServiceBindingResponse) XXX_Merge

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

func (*MsgEnableServiceBindingResponse) XXX_Size

func (m *MsgEnableServiceBindingResponse) XXX_Size() int

func (*MsgEnableServiceBindingResponse) XXX_Unmarshal

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 (*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

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

type MsgKillRequestContextResponse struct {
}

MsgKillRequestContextResponse defines the Msg/KillRequestContext response type.

func (*MsgKillRequestContextResponse) Descriptor

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

func (*MsgKillRequestContextResponse) Marshal

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

func (*MsgKillRequestContextResponse) MarshalTo

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

func (*MsgKillRequestContextResponse) MarshalToSizedBuffer

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

func (*MsgKillRequestContextResponse) ProtoMessage

func (*MsgKillRequestContextResponse) ProtoMessage()

func (*MsgKillRequestContextResponse) Reset

func (m *MsgKillRequestContextResponse) Reset()

func (*MsgKillRequestContextResponse) Size

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

func (*MsgKillRequestContextResponse) String

func (*MsgKillRequestContextResponse) Unmarshal

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

func (*MsgKillRequestContextResponse) XXX_DiscardUnknown

func (m *MsgKillRequestContextResponse) XXX_DiscardUnknown()

func (*MsgKillRequestContextResponse) XXX_Marshal

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

func (*MsgKillRequestContextResponse) XXX_Merge

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

func (*MsgKillRequestContextResponse) XXX_Size

func (m *MsgKillRequestContextResponse) XXX_Size() int

func (*MsgKillRequestContextResponse) XXX_Unmarshal

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 (*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

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

type MsgPauseRequestContextResponse struct {
}

MsgPauseRequestContextResponse defines the Msg/PauseRequestContext response type.

func (*MsgPauseRequestContextResponse) Descriptor

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

func (*MsgPauseRequestContextResponse) Marshal

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

func (*MsgPauseRequestContextResponse) MarshalTo

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

func (*MsgPauseRequestContextResponse) MarshalToSizedBuffer

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

func (*MsgPauseRequestContextResponse) ProtoMessage

func (*MsgPauseRequestContextResponse) ProtoMessage()

func (*MsgPauseRequestContextResponse) Reset

func (m *MsgPauseRequestContextResponse) Reset()

func (*MsgPauseRequestContextResponse) Size

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

func (*MsgPauseRequestContextResponse) String

func (*MsgPauseRequestContextResponse) Unmarshal

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

func (*MsgPauseRequestContextResponse) XXX_DiscardUnknown

func (m *MsgPauseRequestContextResponse) XXX_DiscardUnknown()

func (*MsgPauseRequestContextResponse) XXX_Marshal

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

func (*MsgPauseRequestContextResponse) XXX_Merge

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

func (*MsgPauseRequestContextResponse) XXX_Size

func (m *MsgPauseRequestContextResponse) XXX_Size() int

func (*MsgPauseRequestContextResponse) XXX_Unmarshal

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 (*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

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

type MsgRefundServiceDepositResponse struct {
}

MsgRefundServiceDepositResponse defines the Msg/RefundServiceDeposit response type.

func (*MsgRefundServiceDepositResponse) Descriptor

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

func (*MsgRefundServiceDepositResponse) Marshal

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

func (*MsgRefundServiceDepositResponse) MarshalTo

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

func (*MsgRefundServiceDepositResponse) MarshalToSizedBuffer

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

func (*MsgRefundServiceDepositResponse) ProtoMessage

func (*MsgRefundServiceDepositResponse) ProtoMessage()

func (*MsgRefundServiceDepositResponse) Reset

func (*MsgRefundServiceDepositResponse) Size

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

func (*MsgRefundServiceDepositResponse) String

func (*MsgRefundServiceDepositResponse) Unmarshal

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

func (*MsgRefundServiceDepositResponse) XXX_DiscardUnknown

func (m *MsgRefundServiceDepositResponse) XXX_DiscardUnknown()

func (*MsgRefundServiceDepositResponse) XXX_Marshal

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

func (*MsgRefundServiceDepositResponse) XXX_Merge

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

func (*MsgRefundServiceDepositResponse) XXX_Size

func (m *MsgRefundServiceDepositResponse) XXX_Size() int

func (*MsgRefundServiceDepositResponse) XXX_Unmarshal

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 (*MsgRespondService) Descriptor

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

func (MsgRespondService) GetSignBytes

func (msg MsgRespondService) GetSignBytes() []byte

func (MsgRespondService) GetSigners

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

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

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

func (*MsgRespondService) Unmarshal

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

func (MsgRespondService) ValidateBasic

func (msg MsgRespondService) ValidateBasic() error

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

type MsgRespondServiceResponse struct {
}

MsgRespondService defines the Msg/RespondService response type.

func (*MsgRespondServiceResponse) Descriptor

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

func (*MsgRespondServiceResponse) Marshal

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

func (*MsgRespondServiceResponse) MarshalTo

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

func (*MsgRespondServiceResponse) MarshalToSizedBuffer

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

func (*MsgRespondServiceResponse) ProtoMessage

func (*MsgRespondServiceResponse) ProtoMessage()

func (*MsgRespondServiceResponse) Reset

func (m *MsgRespondServiceResponse) Reset()

func (*MsgRespondServiceResponse) Size

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

func (*MsgRespondServiceResponse) String

func (m *MsgRespondServiceResponse) String() string

func (*MsgRespondServiceResponse) Unmarshal

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

func (*MsgRespondServiceResponse) XXX_DiscardUnknown

func (m *MsgRespondServiceResponse) XXX_DiscardUnknown()

func (*MsgRespondServiceResponse) XXX_Marshal

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

func (*MsgRespondServiceResponse) XXX_Merge

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

func (*MsgRespondServiceResponse) XXX_Size

func (m *MsgRespondServiceResponse) XXX_Size() int

func (*MsgRespondServiceResponse) XXX_Unmarshal

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

type MsgServer

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 (*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) ProtoMessage

func (*MsgSetWithdrawAddress) ProtoMessage()

func (*MsgSetWithdrawAddress) Reset

func (m *MsgSetWithdrawAddress) Reset()

func (MsgSetWithdrawAddress) Route

func (msg MsgSetWithdrawAddress) Route() string

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

type MsgSetWithdrawAddressResponse struct {
}

MsgSetWithdrawAddressResponse defines the Msg/SetWithdrawAddress response type.

func (*MsgSetWithdrawAddressResponse) Descriptor

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

func (*MsgSetWithdrawAddressResponse) Marshal

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

func (*MsgSetWithdrawAddressResponse) MarshalTo

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

func (*MsgSetWithdrawAddressResponse) MarshalToSizedBuffer

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

func (*MsgSetWithdrawAddressResponse) ProtoMessage

func (*MsgSetWithdrawAddressResponse) ProtoMessage()

func (*MsgSetWithdrawAddressResponse) Reset

func (m *MsgSetWithdrawAddressResponse) Reset()

func (*MsgSetWithdrawAddressResponse) Size

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

func (*MsgSetWithdrawAddressResponse) String

func (*MsgSetWithdrawAddressResponse) Unmarshal

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

func (*MsgSetWithdrawAddressResponse) XXX_DiscardUnknown

func (m *MsgSetWithdrawAddressResponse) XXX_DiscardUnknown()

func (*MsgSetWithdrawAddressResponse) XXX_Marshal

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

func (*MsgSetWithdrawAddressResponse) XXX_Merge

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

func (*MsgSetWithdrawAddressResponse) XXX_Size

func (m *MsgSetWithdrawAddressResponse) XXX_Size() int

func (*MsgSetWithdrawAddressResponse) XXX_Unmarshal

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 (*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

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

type MsgStartRequestContextResponse struct {
}

MsgStartRequestContextResponse defines the Msg/StartRequestContext response type.

func (*MsgStartRequestContextResponse) Descriptor

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

func (*MsgStartRequestContextResponse) Marshal

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

func (*MsgStartRequestContextResponse) MarshalTo

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

func (*MsgStartRequestContextResponse) MarshalToSizedBuffer

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

func (*MsgStartRequestContextResponse) ProtoMessage

func (*MsgStartRequestContextResponse) ProtoMessage()

func (*MsgStartRequestContextResponse) Reset

func (m *MsgStartRequestContextResponse) Reset()

func (*MsgStartRequestContextResponse) Size

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

func (*MsgStartRequestContextResponse) String

func (*MsgStartRequestContextResponse) Unmarshal

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

func (*MsgStartRequestContextResponse) XXX_DiscardUnknown

func (m *MsgStartRequestContextResponse) XXX_DiscardUnknown()

func (*MsgStartRequestContextResponse) XXX_Marshal

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

func (*MsgStartRequestContextResponse) XXX_Merge

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

func (*MsgStartRequestContextResponse) XXX_Size

func (m *MsgStartRequestContextResponse) XXX_Size() int

func (*MsgStartRequestContextResponse) XXX_Unmarshal

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_gridironzone_service_sdk_go_types.Coins `` /* 179-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 (*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

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

type MsgUpdateRequestContextResponse struct {
}

MsgUpdateRequestContextResponse defines the Msg/UpdateRequestContext response type.

func (*MsgUpdateRequestContextResponse) Descriptor

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

func (*MsgUpdateRequestContextResponse) Marshal

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

func (*MsgUpdateRequestContextResponse) MarshalTo

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

func (*MsgUpdateRequestContextResponse) MarshalToSizedBuffer

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

func (*MsgUpdateRequestContextResponse) ProtoMessage

func (*MsgUpdateRequestContextResponse) ProtoMessage()

func (*MsgUpdateRequestContextResponse) Reset

func (*MsgUpdateRequestContextResponse) Size

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

func (*MsgUpdateRequestContextResponse) String

func (*MsgUpdateRequestContextResponse) Unmarshal

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

func (*MsgUpdateRequestContextResponse) XXX_DiscardUnknown

func (m *MsgUpdateRequestContextResponse) XXX_DiscardUnknown()

func (*MsgUpdateRequestContextResponse) XXX_Marshal

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

func (*MsgUpdateRequestContextResponse) XXX_Merge

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

func (*MsgUpdateRequestContextResponse) XXX_Size

func (m *MsgUpdateRequestContextResponse) XXX_Size() int

func (*MsgUpdateRequestContextResponse) XXX_Unmarshal

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_gridironzone_service_sdk_go_types.Coins `protobuf:"bytes,3,rep,name=deposit,proto3,castrepeated=github.com/gridironzone/service-sdk-go/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 (*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

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

type MsgUpdateServiceBindingResponse struct {
}

MsgUpdateServiceBindingResponse defines the Msg/UpdateServiceBinding response type.

func (*MsgUpdateServiceBindingResponse) Descriptor

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

func (*MsgUpdateServiceBindingResponse) Marshal

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

func (*MsgUpdateServiceBindingResponse) MarshalTo

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

func (*MsgUpdateServiceBindingResponse) MarshalToSizedBuffer

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

func (*MsgUpdateServiceBindingResponse) ProtoMessage

func (*MsgUpdateServiceBindingResponse) ProtoMessage()

func (*MsgUpdateServiceBindingResponse) Reset

func (*MsgUpdateServiceBindingResponse) Size

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

func (*MsgUpdateServiceBindingResponse) String

func (*MsgUpdateServiceBindingResponse) Unmarshal

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

func (*MsgUpdateServiceBindingResponse) XXX_DiscardUnknown

func (m *MsgUpdateServiceBindingResponse) XXX_DiscardUnknown()

func (*MsgUpdateServiceBindingResponse) XXX_Marshal

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

func (*MsgUpdateServiceBindingResponse) XXX_Merge

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

func (*MsgUpdateServiceBindingResponse) XXX_Size

func (m *MsgUpdateServiceBindingResponse) XXX_Size() int

func (*MsgUpdateServiceBindingResponse) XXX_Unmarshal

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 (*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

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

type MsgWithdrawEarnedFeesResponse struct {
}

MsgWithdrawEarnedFeesResponse defines the Msg/WithdrawEarnedFees response type.

func (*MsgWithdrawEarnedFeesResponse) Descriptor

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

func (*MsgWithdrawEarnedFeesResponse) Marshal

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

func (*MsgWithdrawEarnedFeesResponse) MarshalTo

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

func (*MsgWithdrawEarnedFeesResponse) MarshalToSizedBuffer

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

func (*MsgWithdrawEarnedFeesResponse) ProtoMessage

func (*MsgWithdrawEarnedFeesResponse) ProtoMessage()

func (*MsgWithdrawEarnedFeesResponse) Reset

func (m *MsgWithdrawEarnedFeesResponse) Reset()

func (*MsgWithdrawEarnedFeesResponse) Size

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

func (*MsgWithdrawEarnedFeesResponse) String

func (*MsgWithdrawEarnedFeesResponse) Unmarshal

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

func (*MsgWithdrawEarnedFeesResponse) XXX_DiscardUnknown

func (m *MsgWithdrawEarnedFeesResponse) XXX_DiscardUnknown()

func (*MsgWithdrawEarnedFeesResponse) XXX_Marshal

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

func (*MsgWithdrawEarnedFeesResponse) XXX_Merge

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

func (*MsgWithdrawEarnedFeesResponse) XXX_Size

func (m *MsgWithdrawEarnedFeesResponse) XXX_Size() int

func (*MsgWithdrawEarnedFeesResponse) XXX_Unmarshal

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_gridironzone_service_sdk_go_types.Coins `` /* 145-byte string literal not displayed */
	ServiceFeeTax        github_com_gridironzone_service_sdk_go_types.Dec   `` /* 175-byte string literal not displayed */
	SlashFraction        github_com_gridironzone_service_sdk_go_types.Dec   `` /* 172-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"`
}

service parameters

func (Params) Convert

func (p Params) Convert() interface{}

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) 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 the stringer interface.

func (*Params) Unmarshal

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

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_gridironzone_service_sdk_go_types.Coins `protobuf:"bytes,6,rep,name=price,proto3,castrepeated=github.com/gridironzone/service-sdk-go/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 (*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_gridironzone_service_sdk_go_types.Dec `protobuf:"bytes,3,opt,name=discount,proto3,customtype=github.com/gridironzone/service-sdk-go/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_gridironzone_service_sdk_go_types.Dec `protobuf:"bytes,2,opt,name=discount,proto3,customtype=github.com/gridironzone/service-sdk-go/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 Query

type Query interface {
	QueryServiceDefinition(serviceName string) (QueryServiceDefinitionResponse, sdk.Error)
	QueryServiceBinding(serviceName string, provider string) (QueryServiceBindingResponse, sdk.Error)
	QueryServiceBindings(serviceName string) ([]QueryServiceBindingResponse, sdk.Error)
	QueryServiceRequest(requestID string) (QueryServiceRequestResponse, sdk.Error)
	QueryServiceRequests(serviceName string, provider string) ([]QueryServiceRequestResponse, sdk.Error)
	QueryRequestsByReqCtx(requestContextID string, batchCounter uint64) ([]QueryServiceRequestResponse, sdk.Error)
	QueryServiceResponse(requestID string) (QueryServiceResponseResponse, sdk.Error)
	QueryServiceResponses(requestContextID string, batchCounter uint64) ([]QueryServiceResponseResponse, sdk.Error)
	QueryRequestContext(requestContextID string) (QueryRequestContextResp, sdk.Error)
	QueryFees(provider string) (sdk.Coins, sdk.Error)
	QueryParams() (QueryParamsResp, sdk.Error)
}

Query defines a set of query interfaces in the service module

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 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

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

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 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 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_gridironzone_service_sdk_go_types.Coins `` /* 134-byte string literal not displayed */
}

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 QueryParamsResp

type QueryParamsResp struct {
	MaxRequestTimeout    int64         `json:"max_request_timeout"`
	MinDepositMultiple   int64         `json:"min_deposit_multiple"`
	MinDeposit           string        `json:"min_deposit"`
	ServiceFeeTax        string        `json:"service_fee_tax"`
	SlashFraction        string        `json:"slash_fraction"`
	ComplaintRetrospect  time.Duration `json:"complaint_retrospect"`
	ArbitrationTimeLimit time.Duration `json:"arbitration_time_limit"`
	TxSizeLimit          uint64        `json:"tx_size_limit"`
	BaseDenom            string        `json:"base_denom"`
}

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 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 QueryRequestContextResp

type QueryRequestContextResp struct {
	ServiceName        string    `json:"service_name"`
	Providers          []string  `json:"providers"`
	Consumer           string    `json:"consumer"`
	Input              string    `json:"input"`
	ServiceFeeCap      sdk.Coins `json:"service_fee_cap"`
	Timeout            int64     `json:"timeout"`
	Repeated           bool      `json:"repeated"`
	RepeatedFrequency  uint64    `json:"repeated_frequency"`
	RepeatedTotal      int64     `json:"repeated_total"`
	BatchCounter       uint64    `json:"batch_counter"`
	BatchRequestCount  uint32    `json:"batch_request_count"`
	BatchResponseCount uint32    `json:"batch_response_count"`
	BatchState         string    `json:"batch_state"`
	State              string    `json:"state"`
	ResponseThreshold  uint32    `json:"response_threshold"`
	ModuleName         string    `json:"module_name"`
}

QueryRequestContextResp defines a context which holds request-related data

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 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 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

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

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 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

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

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 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 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

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

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 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 QueryServiceBindingResponse

type QueryServiceBindingResponse struct {
	ServiceName  string    `json:"service_name"`
	Provider     string    `json:"provider"`
	Deposit      sdk.Coins `json:"deposit"`
	Pricing      string    `json:"pricing"`
	QoS          uint64    `json:"qos"`
	Options      string    `json:"options"`
	Available    bool      `json:"available"`
	DisabledTime time.Time `json:"disabled_time"`
	Owner        string    `json:"owner"`
}

QueryServiceBindingResponse defines a struct for service binding

type QueryServiceDefinitionResponse

type QueryServiceDefinitionResponse struct {
	Name              string   `json:"name"`
	Description       string   `json:"description"`
	Tags              []string `json:"tags"`
	Author            string   `json:"author"`
	AuthorDescription string   `json:"author_description"`
	Schemas           string   `json:"schemas"`
}

QueryServiceDefinitionResponse represents a service definition

type QueryServiceRequestResponse

type QueryServiceRequestResponse struct {
	ID                         string    `json:"id"`
	ServiceName                string    `json:"service_name"`
	Provider                   string    `json:"provider"`
	Consumer                   string    `json:"consumer"`
	Input                      string    `json:"input"`
	ServiceFee                 sdk.Coins `json:"service_fee"`
	RequestHeight              int64     `json:"request_height"`
	ExpirationHeight           int64     `json:"expiration_height"`
	RequestContextID           string    `json:"request_context_id"`
	RequestContextBatchCounter uint64    `json:"request_context_batch_counter"`
}

Request defines a request which contains the detailed request data

type QueryServiceResponseResponse

type QueryServiceResponseResponse struct {
	Provider                   string `json:"provider"`
	Consumer                   string `json:"consumer"`
	Output                     string `json:"output"`
	Result                     string `json:"error"`
	RequestContextID           string `json:"request_context_id"`
	RequestContextBatchCounter uint64 `json:"request_context_batch_counter"`
}

Response defines a response

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 Registry

type Registry map[string]RespondCallback

Registry defines a set of service invocation interfaces

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_gridironzone_service_sdk_go_types.Coins `` /* 164-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 (Request) Convert

func (r Request) Convert() interface{}

func (*Request) Descriptor

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

func (Request) Empty

func (r Request) Empty() bool

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_gridironzone_service_sdk_go_types.Coins `` /* 179-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 (RequestContext) Convert

func (r RequestContext) Convert() interface{}

func (*RequestContext) Descriptor

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

func (RequestContext) Empty

func (r 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) 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 RequestContextBatchStateFromString

func RequestContextBatchStateFromString(str string) (RequestContextBatchState, error)

func (RequestContextBatchState) EnumDescriptor

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

func (RequestContextBatchState) MarshalJSON

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

MarshalJSON returns the JSON representation

func (RequestContextBatchState) String

func (x RequestContextBatchState) String() string

func (*RequestContextBatchState) UnmarshalJSON

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

UnmarshalJSON unmarshals raw JSON bytes into a RequestContextBatchState

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) MarshalJSON

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

MarshalJSON returns the JSON representation

func (RequestContextState) String

func (x RequestContextState) String() string

func (*RequestContextState) UnmarshalJSON

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

UnmarshalJSON unmarshals raw JSON bytes into a RequestContextState.

type RespondCallback

type RespondCallback func(reqCtxID, reqID, input string) (output string, result string)

RespondCallback defines the callback function of the service response

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 (Response) Convert

func (r Response) Convert() interface{}

func (*Response) Descriptor

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

func (Response) Empty

func (r Response) Empty() bool

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 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_gridironzone_service_sdk_go_types.Coins `protobuf:"bytes,3,rep,name=deposit,proto3,castrepeated=github.com/gridironzone/service-sdk-go/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 (ServiceBinding) Convert

func (b ServiceBinding) Convert() interface{}

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) 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 ServiceClient

type ServiceClient struct {
	sdk.BaseClient
	codec.Marshaler
}

func (ServiceClient) BindService

func (s ServiceClient) BindService(request BindServiceRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

BindService is responsible for binding a new service definition

func (ServiceClient) DefineService

func (s ServiceClient) DefineService(request DefineServiceRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

DefineService is responsible for creating a new service definition

func (ServiceClient) DisableServiceBinding

func (s ServiceClient) DisableServiceBinding(serviceName, provider string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

DisableServiceBinding disables the specified service binding

func (ServiceClient) EnableServiceBinding

func (s ServiceClient) EnableServiceBinding(serviceName, provider string, deposit sdk.DecCoins, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

EnableServiceBinding enables the specified service binding

func (ServiceClient) GenServiceResponseMsgs

func (s ServiceClient) GenServiceResponseMsgs(events sdk.StringEvents, serviceName string,
	provider sdk.AccAddress,
	handler RespondCallback) (msgs []sdk.Msg)

func (ServiceClient) InvokeService

func (s ServiceClient) InvokeService(request InvokeServiceRequest, baseTx sdk.BaseTx) (string, sdk.ResultTx, sdk.Error)

InvokeService is responsible for invoke a new service and callback `handler`

func (ServiceClient) InvokeServiceResponse

func (s ServiceClient) InvokeServiceResponse(req InvokeServiceResponseRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

func (ServiceClient) KillRequestContext

func (s ServiceClient) KillRequestContext(requestContextID string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

KillRequestContext terminates the specified request context

func (ServiceClient) Name

func (s ServiceClient) Name() string

func (ServiceClient) PauseRequestContext

func (s ServiceClient) PauseRequestContext(requestContextID string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

PauseRequestContext suspends the specified request context

func (ServiceClient) QueryFees

func (s ServiceClient) QueryFees(provider string) (sdk.Coins, sdk.Error)

QueryFees return the earned fees for a provider

func (ServiceClient) QueryParams

func (s ServiceClient) QueryParams() (QueryParamsResp, sdk.Error)

func (ServiceClient) QueryRequestContext

func (s ServiceClient) QueryRequestContext(reqCtxID string) (QueryRequestContextResp, sdk.Error)

QueryRequestContext return the specified request context

func (ServiceClient) QueryRequestsByReqCtx

func (s ServiceClient) QueryRequestsByReqCtx(reqCtxID string, batchCounter uint64) ([]QueryServiceRequestResponse, sdk.Error)

QueryRequestsByReqCtx returns all requests of the specified request context ID and batch counter

func (ServiceClient) QueryServiceBinding

func (s ServiceClient) QueryServiceBinding(serviceName string, provider string) (QueryServiceBindingResponse, sdk.Error)

QueryBinding return the specified service binding

func (ServiceClient) QueryServiceBindings

func (s ServiceClient) QueryServiceBindings(serviceName string) ([]QueryServiceBindingResponse, sdk.Error)

QueryBindings returns all bindings of the specified service

func (ServiceClient) QueryServiceDefinition

func (s ServiceClient) QueryServiceDefinition(serviceName string) (QueryServiceDefinitionResponse, sdk.Error)

QueryDefinition return a service definition of the specified name

func (ServiceClient) QueryServiceRequest

func (s ServiceClient) QueryServiceRequest(requestID string) (QueryServiceRequestResponse, sdk.Error)

QueryRequest returns the active request of the specified requestID

func (ServiceClient) QueryServiceRequests

func (s ServiceClient) QueryServiceRequests(serviceName string, provider string) ([]QueryServiceRequestResponse, sdk.Error)

QueryRequest returns all the active requests of the specified service binding

func (ServiceClient) QueryServiceResponse

func (s ServiceClient) QueryServiceResponse(requestID string) (QueryServiceResponseResponse, sdk.Error)

QueryResponse returns a response with the speicified request ID

func (ServiceClient) QueryServiceResponses

func (s ServiceClient) QueryServiceResponses(reqCtxID string, batchCounter uint64) ([]QueryServiceResponseResponse, sdk.Error)

QueryResponses returns all responses of the specified request context and batch counter

func (ServiceClient) RefundServiceDeposit

func (s ServiceClient) RefundServiceDeposit(serviceName, provider string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

RefundServiceDeposit refunds the deposit from the specified service binding

func (ServiceClient) RegisterInterfaceTypes

func (s ServiceClient) RegisterInterfaceTypes(registry types.InterfaceRegistry)

func (ServiceClient) SetWithdrawAddress

func (s ServiceClient) SetWithdrawAddress(withdrawAddress string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

SetWithdrawAddress sets a new withdrawal address for the specified service binding

func (ServiceClient) StartRequestContext

func (s ServiceClient) StartRequestContext(requestContextID string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

StartRequestContext starts the specified request context

func (ServiceClient) SubscribeServiceRequest

func (s ServiceClient) SubscribeServiceRequest(serviceName string,
	callback RespondCallback,
	baseTx sdk.BaseTx) (subscription sdk.Subscription, err sdk.Error)

SubscribeSingleServiceRequest is responsible for registering a single service handler

func (ServiceClient) SubscribeServiceResponse

func (s ServiceClient) SubscribeServiceResponse(reqCtxID string,
	callback InvokeCallback) (subscription sdk.Subscription, err sdk.Error)

func (ServiceClient) UpdateRequestContext

func (s ServiceClient) UpdateRequestContext(request UpdateRequestContextRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

UpdateRequestContext updates the specified request context

func (ServiceClient) UpdateServiceBinding

func (s ServiceClient) UpdateServiceBinding(request UpdateServiceBindingRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

UpdateServiceBinding updates the specified service binding

func (ServiceClient) WithdrawEarnedFees

func (s ServiceClient) WithdrawEarnedFees(provider string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)

WithdrawEarnedFees withdraws the earned fees to the specified provider

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 (ServiceDefinition) Convert

func (r ServiceDefinition) Convert() interface{}

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) 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 Tx

type Tx interface {
	DefineService(request DefineServiceRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	BindService(request BindServiceRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	InvokeService(request InvokeServiceRequest, baseTx sdk.BaseTx) (string, sdk.ResultTx, sdk.Error)
	InvokeServiceResponse(request InvokeServiceResponseRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	SetWithdrawAddress(withdrawAddress string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	UpdateServiceBinding(request UpdateServiceBindingRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	DisableServiceBinding(serviceName, provider string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	EnableServiceBinding(serviceName, provider string, deposit sdk.DecCoins, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	RefundServiceDeposit(serviceName, provider string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	PauseRequestContext(requestContextID string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	StartRequestContext(requestContextID string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	KillRequestContext(requestContextID string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	UpdateRequestContext(request UpdateRequestContextRequest, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	WithdrawEarnedFees(provider string, baseTx sdk.BaseTx) (sdk.ResultTx, sdk.Error)
	SubscribeServiceRequest(serviceName string, callback RespondCallback, baseTx sdk.BaseTx) (sdk.Subscription, sdk.Error)
	SubscribeServiceResponse(reqCtxID string, callback InvokeCallback) (sdk.Subscription, sdk.Error)
}

Tx defines a set of transaction interfaces in the service module

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) BindService

func (*UnimplementedMsgServer) CallService

func (*UnimplementedMsgServer) DefineService

func (*UnimplementedMsgServer) DisableServiceBinding

func (*UnimplementedMsgServer) EnableServiceBinding

func (*UnimplementedMsgServer) KillRequestContext

func (*UnimplementedMsgServer) PauseRequestContext

func (*UnimplementedMsgServer) RefundServiceDeposit

func (*UnimplementedMsgServer) RespondService

func (*UnimplementedMsgServer) SetWithdrawAddress

func (*UnimplementedMsgServer) StartRequestContext

func (*UnimplementedMsgServer) UpdateRequestContext

func (*UnimplementedMsgServer) UpdateServiceBinding

func (*UnimplementedMsgServer) WithdrawEarnedFees

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

type UpdateRequestContextRequest

type UpdateRequestContextRequest struct {
	RequestContextID  string       `json:"request_context_id"`
	Providers         []string     `json:"providers"`
	ServiceFeeCap     sdk.DecCoins `json:"service_fee_cap"`
	Timeout           int64        `json:"timeout"`
	RepeatedFrequency uint64       `json:"repeated_frequency"`
	RepeatedTotal     int64        `json:"repeated_total"`
}

UpdateRequestContextRequest defines a message to update a request context

type UpdateServiceBindingRequest

type UpdateServiceBindingRequest struct {
	ServiceName string       `json:"service_name"`
	Deposit     sdk.DecCoins `json:"deposit"`
	Pricing     string       `json:"pricing"`
	QoS         uint64       `json:"qos"`
	Provider    string       `json:"provider"`
}

UpdateServiceBindingRequest defines a message to update a service binding

Jump to

Keyboard shortcuts

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