Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func KeyContractTransactionState(txID crosstypes.TxID, txIndex crosstypes.TxIndex) []byte
- func KeyCoordinatorState(txID crosstypes.TxID) []byte
- func KeyPrefixBytes(prefix uint8) []byte
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type ChannelKeeper
- type ContractTransactionState
- func (*ContractTransactionState) Descriptor() ([]byte, []int)
- func (m *ContractTransactionState) Marshal() (dAtA []byte, err error)
- func (m *ContractTransactionState) MarshalTo(dAtA []byte) (int, error)
- func (m *ContractTransactionState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContractTransactionState) ProtoMessage()
- func (m *ContractTransactionState) Reset()
- func (m *ContractTransactionState) Size() (n int)
- func (m *ContractTransactionState) String() string
- func (m *ContractTransactionState) Unmarshal(dAtA []byte) error
- func (m *ContractTransactionState) XXX_DiscardUnknown()
- func (m *ContractTransactionState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContractTransactionState) XXX_Merge(src proto.Message)
- func (m *ContractTransactionState) XXX_Size() int
- func (m *ContractTransactionState) XXX_Unmarshal(b []byte) error
- type ContractTransactionStatus
- type CoordinatorDecision
- type CoordinatorPhase
- type CoordinatorState
- func (cs *CoordinatorState) AddAck(txIndex crosstypes.TxIndex) bool
- func (cs *CoordinatorState) Confirm(txIndex crosstypes.TxIndex, channel xcctypes.ChannelInfo) error
- func (*CoordinatorState) Descriptor() ([]byte, []int)
- func (cs *CoordinatorState) IsConfirmedALLCommits() bool
- func (cs CoordinatorState) IsConfirmedALLPrepares() bool
- func (m *CoordinatorState) Marshal() (dAtA []byte, err error)
- func (m *CoordinatorState) MarshalTo(dAtA []byte) (int, error)
- func (m *CoordinatorState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CoordinatorState) ProtoMessage()
- func (m *CoordinatorState) Reset()
- func (m *CoordinatorState) Size() (n int)
- func (m *CoordinatorState) String() string
- func (m *CoordinatorState) Unmarshal(dAtA []byte) error
- func (m *CoordinatorState) XXX_DiscardUnknown()
- func (m *CoordinatorState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CoordinatorState) XXX_Merge(src proto.Message)
- func (m *CoordinatorState) XXX_Size() int
- func (m *CoordinatorState) XXX_Unmarshal(b []byte) error
- type PortKeeper
- type PrepareResult
- type QueryClient
- type QueryCoordinatorStateRequest
- func (*QueryCoordinatorStateRequest) Descriptor() ([]byte, []int)
- func (m *QueryCoordinatorStateRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryCoordinatorStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryCoordinatorStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryCoordinatorStateRequest) ProtoMessage()
- func (m *QueryCoordinatorStateRequest) Reset()
- func (m *QueryCoordinatorStateRequest) Size() (n int)
- func (m *QueryCoordinatorStateRequest) String() string
- func (m *QueryCoordinatorStateRequest) Unmarshal(dAtA []byte) error
- func (m *QueryCoordinatorStateRequest) XXX_DiscardUnknown()
- func (m *QueryCoordinatorStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryCoordinatorStateRequest) XXX_Merge(src proto.Message)
- func (m *QueryCoordinatorStateRequest) XXX_Size() int
- func (m *QueryCoordinatorStateRequest) XXX_Unmarshal(b []byte) error
- type QueryCoordinatorStateResponse
- func (*QueryCoordinatorStateResponse) Descriptor() ([]byte, []int)
- func (m *QueryCoordinatorStateResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryCoordinatorStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryCoordinatorStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryCoordinatorStateResponse) ProtoMessage()
- func (m *QueryCoordinatorStateResponse) Reset()
- func (m *QueryCoordinatorStateResponse) Size() (n int)
- func (m *QueryCoordinatorStateResponse) String() string
- func (m *QueryCoordinatorStateResponse) Unmarshal(dAtA []byte) error
- func (m *QueryCoordinatorStateResponse) XXX_DiscardUnknown()
- func (m *QueryCoordinatorStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryCoordinatorStateResponse) XXX_Merge(src proto.Message)
- func (m *QueryCoordinatorStateResponse) XXX_Size() int
- func (m *QueryCoordinatorStateResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type UnimplementedQueryServer
Constants ¶
const ( KeyCoordinatorStatePrefix uint8 = iota KeyContractTransactionStatePrefix KeyContractCallResultPrefix )
const (
// ModuleName defines the module name
ModuleName = "cross-atomic"
)
Variables ¶
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group") )
var ContractTransactionStatus_name = map[int32]string{
0: "CONTRACT_TRANSACTION_STATUS_UNKNOWN",
1: "CONTRACT_TRANSACTION_STATUS_PREPARE",
2: "CONTRACT_TRANSACTION_STATUS_COMMIT",
3: "CONTRACT_TRANSACTION_STATUS_ABORT",
}
var ContractTransactionStatus_value = map[string]int32{
"CONTRACT_TRANSACTION_STATUS_UNKNOWN": 0,
"CONTRACT_TRANSACTION_STATUS_PREPARE": 1,
"CONTRACT_TRANSACTION_STATUS_COMMIT": 2,
"CONTRACT_TRANSACTION_STATUS_ABORT": 3,
}
var CoordinatorDecision_name = map[int32]string{
0: "COORDINATOR_DECISION_UNKNOWN",
1: "COORDINATOR_DECISION_COMMIT",
2: "COORDINATOR_DECISION_ABORT",
}
var CoordinatorDecision_value = map[string]int32{
"COORDINATOR_DECISION_UNKNOWN": 0,
"COORDINATOR_DECISION_COMMIT": 1,
"COORDINATOR_DECISION_ABORT": 2,
}
var CoordinatorPhase_name = map[int32]string{
0: "COORDINATOR_PHASE_UNKNOWN",
1: "COORDINATOR_PHASE_PREPARE",
2: "COORDINATOR_PHASE_COMMIT",
}
var CoordinatorPhase_value = map[string]int32{
"COORDINATOR_PHASE_UNKNOWN": 0,
"COORDINATOR_PHASE_PREPARE": 1,
"COORDINATOR_PHASE_COMMIT": 2,
}
var (
ErrFailedInitiateTx = sdkerrors.Register(crosstypes.ModuleName, 1200, "failed to initiate a cross-chain transaction")
)
var PrepareResult_name = map[int32]string{
0: "PREPARE_RESULT_UNKNOWN",
1: "PREPARE_RESULT_OK",
2: "PREPARE_RESULT_FAILED",
}
var PrepareResult_value = map[string]int32{
"PREPARE_RESULT_UNKNOWN": 0,
"PREPARE_RESULT_OK": 1,
"PREPARE_RESULT_FAILED": 2,
}
Functions ¶
func KeyContractTransactionState ¶
func KeyContractTransactionState(txID crosstypes.TxID, txIndex crosstypes.TxIndex) []byte
func KeyCoordinatorState ¶
func KeyCoordinatorState(txID crosstypes.TxID) []byte
func KeyPrefixBytes ¶
KeyPrefixBytes return the key prefix bytes from a URL string format
func RegisterQueryHandler ¶
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 ChannelKeeper ¶
type ChannelKeeper interface { GetChannel(ctx sdk.Context, srcPort, srcChan string) (channel channeltypes.Channel, found bool) GetNextSequenceSend(ctx sdk.Context, portID, channelID string) (uint64, bool) SendPacket(ctx sdk.Context, channelCap *capabilitytypes.Capability, packet ibcexported.PacketI) error ChanCloseInit(ctx sdk.Context, portID, channelID string, chanCap *capabilitytypes.Capability) error }
ChannelKeeper defines the expected IBC channel keeper
type ContractTransactionState ¶
type ContractTransactionState struct { Status ContractTransactionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=cross.core.atomic.ContractTransactionStatus" json:"status,omitempty"` PrepareResult PrepareResult `` /* 138-byte string literal not displayed */ CoordinatorChannel types1.ChannelInfo `protobuf:"bytes,3,opt,name=coordinator_channel,json=coordinatorChannel,proto3" json:"coordinator_channel"` }
func NewContractTransactionState ¶
func NewContractTransactionState(status ContractTransactionStatus, prepareResult PrepareResult, coordinatorChannel xcctypes.ChannelInfo) ContractTransactionState
NewContractTransactionState creates a new instance of ContractTransactionState
func (*ContractTransactionState) Descriptor ¶
func (*ContractTransactionState) Descriptor() ([]byte, []int)
func (*ContractTransactionState) Marshal ¶
func (m *ContractTransactionState) Marshal() (dAtA []byte, err error)
func (*ContractTransactionState) MarshalTo ¶
func (m *ContractTransactionState) MarshalTo(dAtA []byte) (int, error)
func (*ContractTransactionState) MarshalToSizedBuffer ¶
func (m *ContractTransactionState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContractTransactionState) ProtoMessage ¶
func (*ContractTransactionState) ProtoMessage()
func (*ContractTransactionState) Reset ¶
func (m *ContractTransactionState) Reset()
func (*ContractTransactionState) Size ¶
func (m *ContractTransactionState) Size() (n int)
func (*ContractTransactionState) String ¶
func (m *ContractTransactionState) String() string
func (*ContractTransactionState) Unmarshal ¶
func (m *ContractTransactionState) Unmarshal(dAtA []byte) error
func (*ContractTransactionState) XXX_DiscardUnknown ¶
func (m *ContractTransactionState) XXX_DiscardUnknown()
func (*ContractTransactionState) XXX_Marshal ¶
func (m *ContractTransactionState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContractTransactionState) XXX_Merge ¶
func (m *ContractTransactionState) XXX_Merge(src proto.Message)
func (*ContractTransactionState) XXX_Size ¶
func (m *ContractTransactionState) XXX_Size() int
func (*ContractTransactionState) XXX_Unmarshal ¶
func (m *ContractTransactionState) XXX_Unmarshal(b []byte) error
type ContractTransactionStatus ¶
type ContractTransactionStatus int32
const ( CONTRACT_TRANSACTION_STATUS_UNKNOWN ContractTransactionStatus = 0 CONTRACT_TRANSACTION_STATUS_PREPARE ContractTransactionStatus = 1 CONTRACT_TRANSACTION_STATUS_COMMIT ContractTransactionStatus = 2 CONTRACT_TRANSACTION_STATUS_ABORT ContractTransactionStatus = 3 )
func (ContractTransactionStatus) EnumDescriptor ¶
func (ContractTransactionStatus) EnumDescriptor() ([]byte, []int)
func (ContractTransactionStatus) String ¶
func (x ContractTransactionStatus) String() string
type CoordinatorDecision ¶
type CoordinatorDecision int32
const ( COORDINATOR_DECISION_UNKNOWN CoordinatorDecision = 0 COORDINATOR_DECISION_COMMIT CoordinatorDecision = 1 COORDINATOR_DECISION_ABORT CoordinatorDecision = 2 )
func (CoordinatorDecision) EnumDescriptor ¶
func (CoordinatorDecision) EnumDescriptor() ([]byte, []int)
func (CoordinatorDecision) String ¶
func (x CoordinatorDecision) String() string
type CoordinatorPhase ¶
type CoordinatorPhase int32
const ( COORDINATOR_PHASE_UNKNOWN CoordinatorPhase = 0 COORDINATOR_PHASE_PREPARE CoordinatorPhase = 1 COORDINATOR_PHASE_COMMIT CoordinatorPhase = 2 )
func (CoordinatorPhase) EnumDescriptor ¶
func (CoordinatorPhase) EnumDescriptor() ([]byte, []int)
func (CoordinatorPhase) String ¶
func (x CoordinatorPhase) String() string
type CoordinatorState ¶
type CoordinatorState struct { Type types.CommitProtocol `protobuf:"varint,1,opt,name=type,proto3,enum=cross.core.tx.CommitProtocol" json:"type,omitempty"` Channels []types1.ChannelInfo `protobuf:"bytes,2,rep,name=channels,proto3" json:"channels"` Phase CoordinatorPhase `protobuf:"varint,3,opt,name=phase,proto3,enum=cross.core.atomic.CoordinatorPhase" json:"phase,omitempty"` Decision CoordinatorDecision `protobuf:"varint,4,opt,name=decision,proto3,enum=cross.core.atomic.CoordinatorDecision" json:"decision,omitempty"` ConfirmedTxs []github_com_datachainlab_cross_x_core_types.TxIndex `` /* 165-byte string literal not displayed */ Acks []github_com_datachainlab_cross_x_core_types.TxIndex `` /* 129-byte string literal not displayed */ }
func NewCoordinatorState ¶
func NewCoordinatorState(cp txtypes.CommitProtocol, phase CoordinatorPhase, channels []xcctypes.ChannelInfo) CoordinatorState
NewCoordinatorState creates a new instance of CoordinatorState
func (*CoordinatorState) AddAck ¶
func (cs *CoordinatorState) AddAck(txIndex crosstypes.TxIndex) bool
AddAck adds txIndex to Acks if it doesn't exist
func (*CoordinatorState) Confirm ¶
func (cs *CoordinatorState) Confirm(txIndex crosstypes.TxIndex, channel xcctypes.ChannelInfo) error
Confirm append a given txIndex to confirmedTxs if it doesn't exist
func (*CoordinatorState) Descriptor ¶
func (*CoordinatorState) Descriptor() ([]byte, []int)
func (*CoordinatorState) IsConfirmedALLCommits ¶
func (cs *CoordinatorState) IsConfirmedALLCommits() bool
IsConfirmedALLCommits returns a boolean whether all acks are received
func (CoordinatorState) IsConfirmedALLPrepares ¶
func (cs CoordinatorState) IsConfirmedALLPrepares() bool
IsConfirmedALLPrepares returns a boolean value whether all txs are confirmed
func (*CoordinatorState) Marshal ¶
func (m *CoordinatorState) Marshal() (dAtA []byte, err error)
func (*CoordinatorState) MarshalToSizedBuffer ¶
func (m *CoordinatorState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CoordinatorState) ProtoMessage ¶
func (*CoordinatorState) ProtoMessage()
func (*CoordinatorState) Reset ¶
func (m *CoordinatorState) Reset()
func (*CoordinatorState) Size ¶
func (m *CoordinatorState) Size() (n int)
func (*CoordinatorState) String ¶
func (m *CoordinatorState) String() string
func (*CoordinatorState) Unmarshal ¶
func (m *CoordinatorState) Unmarshal(dAtA []byte) error
func (*CoordinatorState) XXX_DiscardUnknown ¶
func (m *CoordinatorState) XXX_DiscardUnknown()
func (*CoordinatorState) XXX_Marshal ¶
func (m *CoordinatorState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CoordinatorState) XXX_Merge ¶
func (m *CoordinatorState) XXX_Merge(src proto.Message)
func (*CoordinatorState) XXX_Size ¶
func (m *CoordinatorState) XXX_Size() int
func (*CoordinatorState) XXX_Unmarshal ¶
func (m *CoordinatorState) XXX_Unmarshal(b []byte) error
type PortKeeper ¶
type PortKeeper interface {
BindPort(ctx sdk.Context, portID string) *capabilitytypes.Capability
}
PortKeeper defines the expected IBC port keeper
type PrepareResult ¶
type PrepareResult int32
const ( PREPARE_RESULT_UNKNOWN PrepareResult = 0 PREPARE_RESULT_OK PrepareResult = 1 PREPARE_RESULT_FAILED PrepareResult = 2 )
func (PrepareResult) EnumDescriptor ¶
func (PrepareResult) EnumDescriptor() ([]byte, []int)
func (PrepareResult) String ¶
func (x PrepareResult) String() string
type QueryClient ¶
type QueryClient interface {
CoordinatorState(ctx context.Context, in *QueryCoordinatorStateRequest, opts ...grpc.CallOption) (*QueryCoordinatorStateResponse, 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 QueryCoordinatorStateRequest ¶
type QueryCoordinatorStateRequest struct {
TxId github_com_datachainlab_cross_x_core_types.TxID `` /* 130-byte string literal not displayed */
}
func (*QueryCoordinatorStateRequest) Descriptor ¶
func (*QueryCoordinatorStateRequest) Descriptor() ([]byte, []int)
func (*QueryCoordinatorStateRequest) Marshal ¶
func (m *QueryCoordinatorStateRequest) Marshal() (dAtA []byte, err error)
func (*QueryCoordinatorStateRequest) MarshalTo ¶
func (m *QueryCoordinatorStateRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryCoordinatorStateRequest) MarshalToSizedBuffer ¶
func (m *QueryCoordinatorStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryCoordinatorStateRequest) ProtoMessage ¶
func (*QueryCoordinatorStateRequest) ProtoMessage()
func (*QueryCoordinatorStateRequest) Reset ¶
func (m *QueryCoordinatorStateRequest) Reset()
func (*QueryCoordinatorStateRequest) Size ¶
func (m *QueryCoordinatorStateRequest) Size() (n int)
func (*QueryCoordinatorStateRequest) String ¶
func (m *QueryCoordinatorStateRequest) String() string
func (*QueryCoordinatorStateRequest) Unmarshal ¶
func (m *QueryCoordinatorStateRequest) Unmarshal(dAtA []byte) error
func (*QueryCoordinatorStateRequest) XXX_DiscardUnknown ¶
func (m *QueryCoordinatorStateRequest) XXX_DiscardUnknown()
func (*QueryCoordinatorStateRequest) XXX_Marshal ¶
func (m *QueryCoordinatorStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryCoordinatorStateRequest) XXX_Merge ¶
func (m *QueryCoordinatorStateRequest) XXX_Merge(src proto.Message)
func (*QueryCoordinatorStateRequest) XXX_Size ¶
func (m *QueryCoordinatorStateRequest) XXX_Size() int
func (*QueryCoordinatorStateRequest) XXX_Unmarshal ¶
func (m *QueryCoordinatorStateRequest) XXX_Unmarshal(b []byte) error
type QueryCoordinatorStateResponse ¶
type QueryCoordinatorStateResponse struct {
CoodinatorState CoordinatorState `protobuf:"bytes,1,opt,name=coodinator_state,json=coodinatorState,proto3" json:"coodinator_state"`
}
func (*QueryCoordinatorStateResponse) Descriptor ¶
func (*QueryCoordinatorStateResponse) Descriptor() ([]byte, []int)
func (*QueryCoordinatorStateResponse) Marshal ¶
func (m *QueryCoordinatorStateResponse) Marshal() (dAtA []byte, err error)
func (*QueryCoordinatorStateResponse) MarshalTo ¶
func (m *QueryCoordinatorStateResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryCoordinatorStateResponse) MarshalToSizedBuffer ¶
func (m *QueryCoordinatorStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryCoordinatorStateResponse) ProtoMessage ¶
func (*QueryCoordinatorStateResponse) ProtoMessage()
func (*QueryCoordinatorStateResponse) Reset ¶
func (m *QueryCoordinatorStateResponse) Reset()
func (*QueryCoordinatorStateResponse) Size ¶
func (m *QueryCoordinatorStateResponse) Size() (n int)
func (*QueryCoordinatorStateResponse) String ¶
func (m *QueryCoordinatorStateResponse) String() string
func (*QueryCoordinatorStateResponse) Unmarshal ¶
func (m *QueryCoordinatorStateResponse) Unmarshal(dAtA []byte) error
func (*QueryCoordinatorStateResponse) XXX_DiscardUnknown ¶
func (m *QueryCoordinatorStateResponse) XXX_DiscardUnknown()
func (*QueryCoordinatorStateResponse) XXX_Marshal ¶
func (m *QueryCoordinatorStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryCoordinatorStateResponse) XXX_Merge ¶
func (m *QueryCoordinatorStateResponse) XXX_Merge(src proto.Message)
func (*QueryCoordinatorStateResponse) XXX_Size ¶
func (m *QueryCoordinatorStateResponse) XXX_Size() int
func (*QueryCoordinatorStateResponse) XXX_Unmarshal ¶
func (m *QueryCoordinatorStateResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface {
CoordinatorState(context.Context, *QueryCoordinatorStateRequest) (*QueryCoordinatorStateResponse, error)
}
QueryServer is the server API for Query service.
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) CoordinatorState ¶
func (*UnimplementedQueryServer) CoordinatorState(ctx context.Context, req *QueryCoordinatorStateRequest) (*QueryCoordinatorStateResponse, error)