Documentation ¶
Index ¶
- func RegisterGraphQueryServer(s *grpc.Server, srv GraphQueryServer)
- func RegisterS2CRegistryServer(s *grpc.Server, srv S2CRegistryServer)
- func RegisterS2SRegistryServer(s *grpc.Server, srv S2SRegistryServer)
- type C2SInfo
- func (*C2SInfo) Descriptor() ([]byte, []int)
- func (m *C2SInfo) GetClientInfo() *ClientInfo
- func (m *C2SInfo) GetResponseSendOption() *ResponseSendOption
- func (*C2SInfo) ProtoMessage()
- func (m *C2SInfo) Reset()
- func (m *C2SInfo) String() string
- func (info *C2SInfo) Unpack() (*message.C2SInfo, error)
- func (m *C2SInfo) XXX_DiscardUnknown()
- func (m *C2SInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *C2SInfo) XXX_Merge(src proto.Message)
- func (m *C2SInfo) XXX_Size() int
- func (m *C2SInfo) XXX_Unmarshal(b []byte) error
- type C2SRequest
- func (*C2SRequest) Descriptor() ([]byte, []int)
- func (m *C2SRequest) GetC2SInfo() *C2SInfo
- func (m *C2SRequest) GetDisconnect() bool
- func (*C2SRequest) ProtoMessage()
- func (m *C2SRequest) Reset()
- func (m *C2SRequest) String() string
- func (request *C2SRequest) Unpack() (*gogistryProto.Request, error)
- func (m *C2SRequest) XXX_DiscardUnknown()
- func (m *C2SRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *C2SRequest) XXX_Merge(src proto.Message)
- func (m *C2SRequest) XXX_Size() int
- func (m *C2SRequest) XXX_Unmarshal(b []byte) error
- type ClientInfo
- func (*ClientInfo) Descriptor() ([]byte, []int)
- func (m *ClientInfo) GetAdditionalInfo() []byte
- func (m *ClientInfo) GetClientID() string
- func (m *ClientInfo) GetServiceType() string
- func (*ClientInfo) ProtoMessage()
- func (m *ClientInfo) Reset()
- func (m *ClientInfo) String() string
- func (m *ClientInfo) XXX_DiscardUnknown()
- func (m *ClientInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientInfo) XXX_Merge(src proto.Message)
- func (m *ClientInfo) XXX_Size() int
- func (m *ClientInfo) XXX_Unmarshal(b []byte) error
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type GraphQueryClient
- type GraphQueryInfo
- func (*GraphQueryInfo) Descriptor() ([]byte, []int)
- func (m *GraphQueryInfo) GetClients() []*ClientInfo
- func (m *GraphQueryInfo) GetIndegree() []*ServerInfo
- func (m *GraphQueryInfo) GetOutdegree() []*ServerInfo
- func (m *GraphQueryInfo) GetServerInfo() *ServerInfo
- func (*GraphQueryInfo) ProtoMessage()
- func (m *GraphQueryInfo) Reset()
- func (m *GraphQueryInfo) String() string
- func (info *GraphQueryInfo) Unpack() (*message.GraphQueryInfo, error)
- func (m *GraphQueryInfo) XXX_DiscardUnknown()
- func (m *GraphQueryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GraphQueryInfo) XXX_Merge(src proto.Message)
- func (m *GraphQueryInfo) XXX_Size() int
- func (m *GraphQueryInfo) XXX_Unmarshal(b []byte) error
- type GraphQueryServer
- type RequestSendOption
- func (*RequestSendOption) Descriptor() ([]byte, []int)
- func (m *RequestSendOption) GetAddr() string
- func (m *RequestSendOption) GetOption() *any.Any
- func (*RequestSendOption) ProtoMessage()
- func (m *RequestSendOption) Reset()
- func (m *RequestSendOption) String() string
- func (m *RequestSendOption) XXX_DiscardUnknown()
- func (m *RequestSendOption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestSendOption) XXX_Merge(src proto.Message)
- func (m *RequestSendOption) XXX_Size() int
- func (m *RequestSendOption) XXX_Unmarshal(b []byte) error
- type ResponseSendOption
- func (*ResponseSendOption) Descriptor() ([]byte, []int)
- func (m *ResponseSendOption) GetOption() *any.Any
- func (*ResponseSendOption) ProtoMessage()
- func (m *ResponseSendOption) Reset()
- func (m *ResponseSendOption) String() string
- func (m *ResponseSendOption) XXX_DiscardUnknown()
- func (m *ResponseSendOption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseSendOption) XXX_Merge(src proto.Message)
- func (m *ResponseSendOption) XXX_Size() int
- func (m *ResponseSendOption) XXX_Unmarshal(b []byte) error
- type S2CInfo
- func (*S2CInfo) Descriptor() ([]byte, []int)
- func (m *S2CInfo) GetCandidates() []*S2CInfo
- func (m *S2CInfo) GetRequestSendOption() *RequestSendOption
- func (m *S2CInfo) GetServerInfo() *ServerInfo
- func (*S2CInfo) ProtoMessage()
- func (m *S2CInfo) Reset()
- func (m *S2CInfo) String() string
- func (info *S2CInfo) Unpack() (*message.S2CInfo, error)
- func (m *S2CInfo) XXX_DiscardUnknown()
- func (m *S2CInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S2CInfo) XXX_Merge(src proto.Message)
- func (m *S2CInfo) XXX_Size() int
- func (m *S2CInfo) XXX_Unmarshal(b []byte) error
- type S2CRegistryClient
- type S2CRegistryServer
- type S2CResponse
- func (*S2CResponse) Descriptor() ([]byte, []int)
- func (m *S2CResponse) GetReject() bool
- func (m *S2CResponse) GetS2CInfo() *S2CInfo
- func (m *S2CResponse) GetTimeout() int64
- func (*S2CResponse) ProtoMessage()
- func (m *S2CResponse) Reset()
- func (m *S2CResponse) String() string
- func (response *S2CResponse) Unpack() (*gogistryProto.Response, error)
- func (m *S2CResponse) XXX_DiscardUnknown()
- func (m *S2CResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S2CResponse) XXX_Merge(src proto.Message)
- func (m *S2CResponse) XXX_Size() int
- func (m *S2CResponse) XXX_Unmarshal(b []byte) error
- type S2SInfo
- func (*S2SInfo) Descriptor() ([]byte, []int)
- func (m *S2SInfo) GetCandidates() []*S2SInfo
- func (m *S2SInfo) GetRequestSendOption() *RequestSendOption
- func (m *S2SInfo) GetResponseSendOption() *ResponseSendOption
- func (m *S2SInfo) GetS2CInfo() *S2CInfo
- func (m *S2SInfo) GetServerInfo() *ServerInfo
- func (*S2SInfo) ProtoMessage()
- func (m *S2SInfo) Reset()
- func (m *S2SInfo) String() string
- func (info *S2SInfo) Unpack() (*message.S2SInfo, error)
- func (m *S2SInfo) XXX_DiscardUnknown()
- func (m *S2SInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S2SInfo) XXX_Merge(src proto.Message)
- func (m *S2SInfo) XXX_Size() int
- func (m *S2SInfo) XXX_Unmarshal(b []byte) error
- type S2SRegistryClient
- type S2SRegistryServer
- type S2SRequest
- func (*S2SRequest) Descriptor() ([]byte, []int)
- func (m *S2SRequest) GetDisconnect() bool
- func (m *S2SRequest) GetS2SInfo() *S2SInfo
- func (*S2SRequest) ProtoMessage()
- func (m *S2SRequest) Reset()
- func (m *S2SRequest) String() string
- func (request *S2SRequest) Unpack() (*gogistryProto.Request, error)
- func (m *S2SRequest) XXX_DiscardUnknown()
- func (m *S2SRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S2SRequest) XXX_Merge(src proto.Message)
- func (m *S2SRequest) XXX_Size() int
- func (m *S2SRequest) XXX_Unmarshal(b []byte) error
- type S2SResponse
- func (*S2SResponse) Descriptor() ([]byte, []int)
- func (m *S2SResponse) GetReject() bool
- func (m *S2SResponse) GetS2SInfo() *S2SInfo
- func (m *S2SResponse) GetTimeout() int64
- func (*S2SResponse) ProtoMessage()
- func (m *S2SResponse) Reset()
- func (m *S2SResponse) String() string
- func (response *S2SResponse) Unpack() (*gogistryProto.Response, error)
- func (m *S2SResponse) XXX_DiscardUnknown()
- func (m *S2SResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S2SResponse) XXX_Merge(src proto.Message)
- func (m *S2SResponse) XXX_Size() int
- func (m *S2SResponse) XXX_Unmarshal(b []byte) error
- type ServerInfo
- func (*ServerInfo) Descriptor() ([]byte, []int)
- func (m *ServerInfo) GetAdditionalInfo() []byte
- func (m *ServerInfo) GetGraphQueryAddr() string
- func (m *ServerInfo) GetServerID() string
- func (m *ServerInfo) GetServiceType() string
- func (*ServerInfo) ProtoMessage()
- func (m *ServerInfo) Reset()
- func (m *ServerInfo) String() string
- func (m *ServerInfo) XXX_DiscardUnknown()
- func (m *ServerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServerInfo) XXX_Merge(src proto.Message)
- func (m *ServerInfo) XXX_Size() int
- func (m *ServerInfo) XXX_Unmarshal(b []byte) error
- type Timestamp
- func (*Timestamp) Descriptor() ([]byte, []int)
- func (m *Timestamp) GetTimestamp() uint64
- func (*Timestamp) ProtoMessage()
- func (m *Timestamp) Reset()
- func (m *Timestamp) String() string
- func (m *Timestamp) XXX_DiscardUnknown()
- func (m *Timestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Timestamp) XXX_Merge(src proto.Message)
- func (m *Timestamp) XXX_Size() int
- func (m *Timestamp) XXX_Unmarshal(b []byte) error
- type UnimplementedGraphQueryServer
- type UnimplementedS2CRegistryServer
- type UnimplementedS2SRegistryServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterGraphQueryServer ¶
func RegisterGraphQueryServer(s *grpc.Server, srv GraphQueryServer)
func RegisterS2CRegistryServer ¶
func RegisterS2CRegistryServer(s *grpc.Server, srv S2CRegistryServer)
func RegisterS2SRegistryServer ¶
func RegisterS2SRegistryServer(s *grpc.Server, srv S2SRegistryServer)
Types ¶
type C2SInfo ¶
type C2SInfo struct { ClientInfo *ClientInfo `protobuf:"bytes,1,opt,name=ClientInfo,proto3" json:"ClientInfo,omitempty"` ResponseSendOption *ResponseSendOption `protobuf:"bytes,2,opt,name=ResponseSendOption,proto3" json:"ResponseSendOption,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*C2SInfo) Descriptor ¶
func (*C2SInfo) GetClientInfo ¶
func (m *C2SInfo) GetClientInfo() *ClientInfo
func (*C2SInfo) GetResponseSendOption ¶
func (m *C2SInfo) GetResponseSendOption() *ResponseSendOption
func (*C2SInfo) ProtoMessage ¶
func (*C2SInfo) ProtoMessage()
func (*C2SInfo) XXX_DiscardUnknown ¶
func (m *C2SInfo) XXX_DiscardUnknown()
func (*C2SInfo) XXX_Marshal ¶
func (*C2SInfo) XXX_Unmarshal ¶
type C2SRequest ¶
type C2SRequest struct { C2SInfo *C2SInfo `protobuf:"bytes,1,opt,name=C2SInfo,proto3" json:"C2SInfo,omitempty"` Disconnect bool `protobuf:"varint,2,opt,name=Disconnect,proto3" json:"Disconnect,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func C2SRequestPack ¶
func C2SRequestPack(request gogistryProto.Request) (i *C2SRequest, e error)
func (*C2SRequest) Descriptor ¶
func (*C2SRequest) Descriptor() ([]byte, []int)
func (*C2SRequest) GetC2SInfo ¶
func (m *C2SRequest) GetC2SInfo() *C2SInfo
func (*C2SRequest) GetDisconnect ¶
func (m *C2SRequest) GetDisconnect() bool
func (*C2SRequest) ProtoMessage ¶
func (*C2SRequest) ProtoMessage()
func (*C2SRequest) Reset ¶
func (m *C2SRequest) Reset()
func (*C2SRequest) String ¶
func (m *C2SRequest) String() string
func (*C2SRequest) Unpack ¶
func (request *C2SRequest) Unpack() (*gogistryProto.Request, error)
func (*C2SRequest) XXX_DiscardUnknown ¶
func (m *C2SRequest) XXX_DiscardUnknown()
func (*C2SRequest) XXX_Marshal ¶
func (m *C2SRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*C2SRequest) XXX_Merge ¶
func (m *C2SRequest) XXX_Merge(src proto.Message)
func (*C2SRequest) XXX_Size ¶
func (m *C2SRequest) XXX_Size() int
func (*C2SRequest) XXX_Unmarshal ¶
func (m *C2SRequest) XXX_Unmarshal(b []byte) error
type ClientInfo ¶
type ClientInfo struct { ClientID string `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"` ServiceType string `protobuf:"bytes,2,opt,name=ServiceType,proto3" json:"ServiceType,omitempty"` AdditionalInfo []byte `protobuf:"bytes,3,opt,name=AdditionalInfo,proto3" json:"AdditionalInfo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClientInfo) Descriptor ¶
func (*ClientInfo) Descriptor() ([]byte, []int)
func (*ClientInfo) GetAdditionalInfo ¶
func (m *ClientInfo) GetAdditionalInfo() []byte
func (*ClientInfo) GetClientID ¶
func (m *ClientInfo) GetClientID() string
func (*ClientInfo) GetServiceType ¶
func (m *ClientInfo) GetServiceType() string
func (*ClientInfo) ProtoMessage ¶
func (*ClientInfo) ProtoMessage()
func (*ClientInfo) Reset ¶
func (m *ClientInfo) Reset()
func (*ClientInfo) String ¶
func (m *ClientInfo) String() string
func (*ClientInfo) XXX_DiscardUnknown ¶
func (m *ClientInfo) XXX_DiscardUnknown()
func (*ClientInfo) XXX_Marshal ¶
func (m *ClientInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientInfo) XXX_Merge ¶
func (m *ClientInfo) XXX_Merge(src proto.Message)
func (*ClientInfo) XXX_Size ¶
func (m *ClientInfo) XXX_Size() int
func (*ClientInfo) XXX_Unmarshal ¶
func (m *ClientInfo) XXX_Unmarshal(b []byte) error
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type GraphQueryClient ¶
type GraphQueryClient interface {
Query(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GraphQueryInfo, error)
}
GraphQueryClient is the client API for GraphQuery service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewGraphQueryClient ¶
func NewGraphQueryClient(cc grpc.ClientConnInterface) GraphQueryClient
type GraphQueryInfo ¶
type GraphQueryInfo struct { ServerInfo *ServerInfo `protobuf:"bytes,1,opt,name=ServerInfo,proto3" json:"ServerInfo,omitempty"` Indegree []*ServerInfo `protobuf:"bytes,2,rep,name=Indegree,proto3" json:"Indegree,omitempty"` Outdegree []*ServerInfo `protobuf:"bytes,3,rep,name=Outdegree,proto3" json:"Outdegree,omitempty"` Clients []*ClientInfo `protobuf:"bytes,4,rep,name=Clients,proto3" json:"Clients,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func GraphQueryInfoPack ¶
func GraphQueryInfoPack(info message.GraphQueryInfo) (*GraphQueryInfo, error)
Convert a message.GraphQueryInfo into a protobuf GraphQueryInfo
func (*GraphQueryInfo) Descriptor ¶
func (*GraphQueryInfo) Descriptor() ([]byte, []int)
func (*GraphQueryInfo) GetClients ¶
func (m *GraphQueryInfo) GetClients() []*ClientInfo
func (*GraphQueryInfo) GetIndegree ¶
func (m *GraphQueryInfo) GetIndegree() []*ServerInfo
func (*GraphQueryInfo) GetOutdegree ¶
func (m *GraphQueryInfo) GetOutdegree() []*ServerInfo
func (*GraphQueryInfo) GetServerInfo ¶
func (m *GraphQueryInfo) GetServerInfo() *ServerInfo
func (*GraphQueryInfo) ProtoMessage ¶
func (*GraphQueryInfo) ProtoMessage()
func (*GraphQueryInfo) Reset ¶
func (m *GraphQueryInfo) Reset()
func (*GraphQueryInfo) String ¶
func (m *GraphQueryInfo) String() string
func (*GraphQueryInfo) Unpack ¶
func (info *GraphQueryInfo) Unpack() (*message.GraphQueryInfo, error)
Convert a protobuf GraphQueryInfo into a message.GraphQueryInfo
func (*GraphQueryInfo) XXX_DiscardUnknown ¶
func (m *GraphQueryInfo) XXX_DiscardUnknown()
func (*GraphQueryInfo) XXX_Marshal ¶
func (m *GraphQueryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GraphQueryInfo) XXX_Merge ¶
func (m *GraphQueryInfo) XXX_Merge(src proto.Message)
func (*GraphQueryInfo) XXX_Size ¶
func (m *GraphQueryInfo) XXX_Size() int
func (*GraphQueryInfo) XXX_Unmarshal ¶
func (m *GraphQueryInfo) XXX_Unmarshal(b []byte) error
type GraphQueryServer ¶
type GraphQueryServer interface {
Query(context.Context, *Empty) (*GraphQueryInfo, error)
}
GraphQueryServer is the server API for GraphQuery service.
type RequestSendOption ¶
type RequestSendOption struct { Option *any.Any `protobuf:"bytes,1,opt,name=Option,proto3" json:"Option,omitempty"` Addr string `protobuf:"bytes,2,opt,name=Addr,proto3" json:"Addr,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RequestSendOption) Descriptor ¶
func (*RequestSendOption) Descriptor() ([]byte, []int)
func (*RequestSendOption) GetAddr ¶
func (m *RequestSendOption) GetAddr() string
func (*RequestSendOption) GetOption ¶
func (m *RequestSendOption) GetOption() *any.Any
func (*RequestSendOption) ProtoMessage ¶
func (*RequestSendOption) ProtoMessage()
func (*RequestSendOption) Reset ¶
func (m *RequestSendOption) Reset()
func (*RequestSendOption) String ¶
func (m *RequestSendOption) String() string
func (*RequestSendOption) XXX_DiscardUnknown ¶
func (m *RequestSendOption) XXX_DiscardUnknown()
func (*RequestSendOption) XXX_Marshal ¶
func (m *RequestSendOption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestSendOption) XXX_Merge ¶
func (m *RequestSendOption) XXX_Merge(src proto.Message)
func (*RequestSendOption) XXX_Size ¶
func (m *RequestSendOption) XXX_Size() int
func (*RequestSendOption) XXX_Unmarshal ¶
func (m *RequestSendOption) XXX_Unmarshal(b []byte) error
type ResponseSendOption ¶
type ResponseSendOption struct { Option *any.Any `protobuf:"bytes,1,opt,name=Option,proto3" json:"Option,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ResponseSendOption) Descriptor ¶
func (*ResponseSendOption) Descriptor() ([]byte, []int)
func (*ResponseSendOption) GetOption ¶
func (m *ResponseSendOption) GetOption() *any.Any
func (*ResponseSendOption) ProtoMessage ¶
func (*ResponseSendOption) ProtoMessage()
func (*ResponseSendOption) Reset ¶
func (m *ResponseSendOption) Reset()
func (*ResponseSendOption) String ¶
func (m *ResponseSendOption) String() string
func (*ResponseSendOption) XXX_DiscardUnknown ¶
func (m *ResponseSendOption) XXX_DiscardUnknown()
func (*ResponseSendOption) XXX_Marshal ¶
func (m *ResponseSendOption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseSendOption) XXX_Merge ¶
func (m *ResponseSendOption) XXX_Merge(src proto.Message)
func (*ResponseSendOption) XXX_Size ¶
func (m *ResponseSendOption) XXX_Size() int
func (*ResponseSendOption) XXX_Unmarshal ¶
func (m *ResponseSendOption) XXX_Unmarshal(b []byte) error
type S2CInfo ¶
type S2CInfo struct { ServerInfo *ServerInfo `protobuf:"bytes,1,opt,name=ServerInfo,proto3" json:"ServerInfo,omitempty"` RequestSendOption *RequestSendOption `protobuf:"bytes,2,opt,name=RequestSendOption,proto3" json:"RequestSendOption,omitempty"` Candidates []*S2CInfo `protobuf:"bytes,3,rep,name=Candidates,proto3" json:"Candidates,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*S2CInfo) Descriptor ¶
func (*S2CInfo) GetCandidates ¶
func (*S2CInfo) GetRequestSendOption ¶
func (m *S2CInfo) GetRequestSendOption() *RequestSendOption
func (*S2CInfo) GetServerInfo ¶
func (m *S2CInfo) GetServerInfo() *ServerInfo
func (*S2CInfo) ProtoMessage ¶
func (*S2CInfo) ProtoMessage()
func (*S2CInfo) XXX_DiscardUnknown ¶
func (m *S2CInfo) XXX_DiscardUnknown()
func (*S2CInfo) XXX_Marshal ¶
func (*S2CInfo) XXX_Unmarshal ¶
type S2CRegistryClient ¶
type S2CRegistryClient interface { Poll(ctx context.Context, in *C2SRequest, opts ...grpc.CallOption) (*S2CResponse, error) PING(ctx context.Context, in *Timestamp, opts ...grpc.CallOption) (*Timestamp, error) }
S2CRegistryClient is the client API for S2CRegistry service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewS2CRegistryClient ¶
func NewS2CRegistryClient(cc grpc.ClientConnInterface) S2CRegistryClient
type S2CRegistryServer ¶
type S2CRegistryServer interface { Poll(context.Context, *C2SRequest) (*S2CResponse, error) PING(context.Context, *Timestamp) (*Timestamp, error) }
S2CRegistryServer is the server API for S2CRegistry service.
type S2CResponse ¶
type S2CResponse struct { S2CInfo *S2CInfo `protobuf:"bytes,1,opt,name=S2CInfo,proto3" json:"S2CInfo,omitempty"` Timeout int64 `protobuf:"varint,2,opt,name=Timeout,proto3" json:"Timeout,omitempty"` Reject bool `protobuf:"varint,3,opt,name=Reject,proto3" json:"Reject,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func S2CResponsePack ¶
func S2CResponsePack(response gogistryProto.Response) (i *S2CResponse, e error)
func (*S2CResponse) Descriptor ¶
func (*S2CResponse) Descriptor() ([]byte, []int)
func (*S2CResponse) GetReject ¶
func (m *S2CResponse) GetReject() bool
func (*S2CResponse) GetS2CInfo ¶
func (m *S2CResponse) GetS2CInfo() *S2CInfo
func (*S2CResponse) GetTimeout ¶
func (m *S2CResponse) GetTimeout() int64
func (*S2CResponse) ProtoMessage ¶
func (*S2CResponse) ProtoMessage()
func (*S2CResponse) Reset ¶
func (m *S2CResponse) Reset()
func (*S2CResponse) String ¶
func (m *S2CResponse) String() string
func (*S2CResponse) Unpack ¶
func (response *S2CResponse) Unpack() (*gogistryProto.Response, error)
func (*S2CResponse) XXX_DiscardUnknown ¶
func (m *S2CResponse) XXX_DiscardUnknown()
func (*S2CResponse) XXX_Marshal ¶
func (m *S2CResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*S2CResponse) XXX_Merge ¶
func (m *S2CResponse) XXX_Merge(src proto.Message)
func (*S2CResponse) XXX_Size ¶
func (m *S2CResponse) XXX_Size() int
func (*S2CResponse) XXX_Unmarshal ¶
func (m *S2CResponse) XXX_Unmarshal(b []byte) error
type S2SInfo ¶
type S2SInfo struct { ServerInfo *ServerInfo `protobuf:"bytes,1,opt,name=ServerInfo,proto3" json:"ServerInfo,omitempty"` ResponseSendOption *ResponseSendOption `protobuf:"bytes,2,opt,name=ResponseSendOption,proto3" json:"ResponseSendOption,omitempty"` RequestSendOption *RequestSendOption `protobuf:"bytes,3,opt,name=RequestSendOption,proto3" json:"RequestSendOption,omitempty"` Candidates []*S2SInfo `protobuf:"bytes,4,rep,name=Candidates,proto3" json:"Candidates,omitempty"` S2CInfo *S2CInfo `protobuf:"bytes,5,opt,name=S2CInfo,proto3" json:"S2CInfo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*S2SInfo) Descriptor ¶
func (*S2SInfo) GetCandidates ¶
func (*S2SInfo) GetRequestSendOption ¶
func (m *S2SInfo) GetRequestSendOption() *RequestSendOption
func (*S2SInfo) GetResponseSendOption ¶
func (m *S2SInfo) GetResponseSendOption() *ResponseSendOption
func (*S2SInfo) GetS2CInfo ¶
func (*S2SInfo) GetServerInfo ¶
func (m *S2SInfo) GetServerInfo() *ServerInfo
func (*S2SInfo) ProtoMessage ¶
func (*S2SInfo) ProtoMessage()
func (*S2SInfo) XXX_DiscardUnknown ¶
func (m *S2SInfo) XXX_DiscardUnknown()
func (*S2SInfo) XXX_Marshal ¶
func (*S2SInfo) XXX_Unmarshal ¶
type S2SRegistryClient ¶
type S2SRegistryClient interface { Poll(ctx context.Context, in *S2SRequest, opts ...grpc.CallOption) (*S2SResponse, error) PING(ctx context.Context, in *Timestamp, opts ...grpc.CallOption) (*Timestamp, error) }
S2SRegistryClient is the client API for S2SRegistry service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewS2SRegistryClient ¶
func NewS2SRegistryClient(cc grpc.ClientConnInterface) S2SRegistryClient
type S2SRegistryServer ¶
type S2SRegistryServer interface { Poll(context.Context, *S2SRequest) (*S2SResponse, error) PING(context.Context, *Timestamp) (*Timestamp, error) }
S2SRegistryServer is the server API for S2SRegistry service.
type S2SRequest ¶
type S2SRequest struct { S2SInfo *S2SInfo `protobuf:"bytes,1,opt,name=S2SInfo,proto3" json:"S2SInfo,omitempty"` Disconnect bool `protobuf:"varint,2,opt,name=Disconnect,proto3" json:"Disconnect,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func S2SRequestPack ¶
func S2SRequestPack(request gogistryProto.Request) (i *S2SRequest, e error)
func (*S2SRequest) Descriptor ¶
func (*S2SRequest) Descriptor() ([]byte, []int)
func (*S2SRequest) GetDisconnect ¶
func (m *S2SRequest) GetDisconnect() bool
func (*S2SRequest) GetS2SInfo ¶
func (m *S2SRequest) GetS2SInfo() *S2SInfo
func (*S2SRequest) ProtoMessage ¶
func (*S2SRequest) ProtoMessage()
func (*S2SRequest) Reset ¶
func (m *S2SRequest) Reset()
func (*S2SRequest) String ¶
func (m *S2SRequest) String() string
func (*S2SRequest) Unpack ¶
func (request *S2SRequest) Unpack() (*gogistryProto.Request, error)
func (*S2SRequest) XXX_DiscardUnknown ¶
func (m *S2SRequest) XXX_DiscardUnknown()
func (*S2SRequest) XXX_Marshal ¶
func (m *S2SRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*S2SRequest) XXX_Merge ¶
func (m *S2SRequest) XXX_Merge(src proto.Message)
func (*S2SRequest) XXX_Size ¶
func (m *S2SRequest) XXX_Size() int
func (*S2SRequest) XXX_Unmarshal ¶
func (m *S2SRequest) XXX_Unmarshal(b []byte) error
type S2SResponse ¶
type S2SResponse struct { S2SInfo *S2SInfo `protobuf:"bytes,1,opt,name=S2SInfo,proto3" json:"S2SInfo,omitempty"` Timeout int64 `protobuf:"varint,2,opt,name=Timeout,proto3" json:"Timeout,omitempty"` Reject bool `protobuf:"varint,3,opt,name=Reject,proto3" json:"Reject,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func S2SResponsePack ¶
func S2SResponsePack(response gogistryProto.Response) (i *S2SResponse, e error)
func (*S2SResponse) Descriptor ¶
func (*S2SResponse) Descriptor() ([]byte, []int)
func (*S2SResponse) GetReject ¶
func (m *S2SResponse) GetReject() bool
func (*S2SResponse) GetS2SInfo ¶
func (m *S2SResponse) GetS2SInfo() *S2SInfo
func (*S2SResponse) GetTimeout ¶
func (m *S2SResponse) GetTimeout() int64
func (*S2SResponse) ProtoMessage ¶
func (*S2SResponse) ProtoMessage()
func (*S2SResponse) Reset ¶
func (m *S2SResponse) Reset()
func (*S2SResponse) String ¶
func (m *S2SResponse) String() string
func (*S2SResponse) Unpack ¶
func (response *S2SResponse) Unpack() (*gogistryProto.Response, error)
func (*S2SResponse) XXX_DiscardUnknown ¶
func (m *S2SResponse) XXX_DiscardUnknown()
func (*S2SResponse) XXX_Marshal ¶
func (m *S2SResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*S2SResponse) XXX_Merge ¶
func (m *S2SResponse) XXX_Merge(src proto.Message)
func (*S2SResponse) XXX_Size ¶
func (m *S2SResponse) XXX_Size() int
func (*S2SResponse) XXX_Unmarshal ¶
func (m *S2SResponse) XXX_Unmarshal(b []byte) error
type ServerInfo ¶
type ServerInfo struct { ServerID string `protobuf:"bytes,1,opt,name=ServerID,proto3" json:"ServerID,omitempty"` ServiceType string `protobuf:"bytes,2,opt,name=ServiceType,proto3" json:"ServiceType,omitempty"` GraphQueryAddr string `protobuf:"bytes,3,opt,name=GraphQueryAddr,proto3" json:"GraphQueryAddr,omitempty"` AdditionalInfo []byte `protobuf:"bytes,4,opt,name=AdditionalInfo,proto3" json:"AdditionalInfo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServerInfo) Descriptor ¶
func (*ServerInfo) Descriptor() ([]byte, []int)
func (*ServerInfo) GetAdditionalInfo ¶
func (m *ServerInfo) GetAdditionalInfo() []byte
func (*ServerInfo) GetGraphQueryAddr ¶
func (m *ServerInfo) GetGraphQueryAddr() string
func (*ServerInfo) GetServerID ¶
func (m *ServerInfo) GetServerID() string
func (*ServerInfo) GetServiceType ¶
func (m *ServerInfo) GetServiceType() string
func (*ServerInfo) ProtoMessage ¶
func (*ServerInfo) ProtoMessage()
func (*ServerInfo) Reset ¶
func (m *ServerInfo) Reset()
func (*ServerInfo) String ¶
func (m *ServerInfo) String() string
func (*ServerInfo) XXX_DiscardUnknown ¶
func (m *ServerInfo) XXX_DiscardUnknown()
func (*ServerInfo) XXX_Marshal ¶
func (m *ServerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerInfo) XXX_Merge ¶
func (m *ServerInfo) XXX_Merge(src proto.Message)
func (*ServerInfo) XXX_Size ¶
func (m *ServerInfo) XXX_Size() int
func (*ServerInfo) XXX_Unmarshal ¶
func (m *ServerInfo) XXX_Unmarshal(b []byte) error
type Timestamp ¶
type Timestamp struct { Timestamp uint64 `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Timestamp) Descriptor ¶
func (*Timestamp) GetTimestamp ¶
func (*Timestamp) ProtoMessage ¶
func (*Timestamp) ProtoMessage()
func (*Timestamp) XXX_DiscardUnknown ¶
func (m *Timestamp) XXX_DiscardUnknown()
func (*Timestamp) XXX_Marshal ¶
func (*Timestamp) XXX_Unmarshal ¶
type UnimplementedGraphQueryServer ¶
type UnimplementedGraphQueryServer struct { }
UnimplementedGraphQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedGraphQueryServer) Query ¶
func (*UnimplementedGraphQueryServer) Query(ctx context.Context, req *Empty) (*GraphQueryInfo, error)
type UnimplementedS2CRegistryServer ¶
type UnimplementedS2CRegistryServer struct { }
UnimplementedS2CRegistryServer can be embedded to have forward compatible implementations.
func (*UnimplementedS2CRegistryServer) Poll ¶
func (*UnimplementedS2CRegistryServer) Poll(ctx context.Context, req *C2SRequest) (*S2CResponse, error)
type UnimplementedS2SRegistryServer ¶
type UnimplementedS2SRegistryServer struct { }
UnimplementedS2SRegistryServer can be embedded to have forward compatible implementations.
func (*UnimplementedS2SRegistryServer) Poll ¶
func (*UnimplementedS2SRegistryServer) Poll(ctx context.Context, req *S2SRequest) (*S2SResponse, error)