protocol

package
v0.0.0-...-1f93a72 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

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 C2SInfoPack 

func C2SInfoPack(info message.C2SInfo) (i *C2SInfo, e error)

func (*C2SInfo) Descriptor 

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

func (*C2SInfo) GetClientInfo 

func (m *C2SInfo) GetClientInfo() *ClientInfo

func (*C2SInfo) GetResponseSendOption 

func (m *C2SInfo) GetResponseSendOption() *ResponseSendOption

func (*C2SInfo) ProtoMessage 

func (*C2SInfo) ProtoMessage()

func (*C2SInfo) Reset 

func (m *C2SInfo) Reset()

func (*C2SInfo) String 

func (m *C2SInfo) String() string

func (*C2SInfo) Unpack 

func (info *C2SInfo) Unpack() (*message.C2SInfo, error)

func (*C2SInfo) XXX_DiscardUnknown 

func (m *C2SInfo) XXX_DiscardUnknown()

func (*C2SInfo) XXX_Marshal 

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

func (*C2SInfo) XXX_Merge 

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

func (*C2SInfo) XXX_Size 

func (m *C2SInfo) XXX_Size() int

func (*C2SInfo) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

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 S2CInfoPack 

func S2CInfoPack(info message.S2CInfo) (i *S2CInfo, e error)

func (*S2CInfo) Descriptor 

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

func (*S2CInfo) GetCandidates 

func (m *S2CInfo) GetCandidates() []*S2CInfo

func (*S2CInfo) GetRequestSendOption 

func (m *S2CInfo) GetRequestSendOption() *RequestSendOption

func (*S2CInfo) GetServerInfo 

func (m *S2CInfo) GetServerInfo() *ServerInfo

func (*S2CInfo) ProtoMessage 

func (*S2CInfo) ProtoMessage()

func (*S2CInfo) Reset 

func (m *S2CInfo) Reset()

func (*S2CInfo) String 

func (m *S2CInfo) String() string

func (*S2CInfo) Unpack 

func (info *S2CInfo) Unpack() (*message.S2CInfo, error)

func (*S2CInfo) XXX_DiscardUnknown 

func (m *S2CInfo) XXX_DiscardUnknown()

func (*S2CInfo) XXX_Marshal 

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

func (*S2CInfo) XXX_Merge 

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

func (*S2CInfo) XXX_Size 

func (m *S2CInfo) XXX_Size() int

func (*S2CInfo) XXX_Unmarshal 

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

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 S2SInfoPack 

func S2SInfoPack(info message.S2SInfo) (i *S2SInfo, e error)

func (*S2SInfo) Descriptor 

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

func (*S2SInfo) GetCandidates 

func (m *S2SInfo) GetCandidates() []*S2SInfo

func (*S2SInfo) GetRequestSendOption 

func (m *S2SInfo) GetRequestSendOption() *RequestSendOption

func (*S2SInfo) GetResponseSendOption 

func (m *S2SInfo) GetResponseSendOption() *ResponseSendOption

func (*S2SInfo) GetS2CInfo 

func (m *S2SInfo) GetS2CInfo() *S2CInfo

func (*S2SInfo) GetServerInfo 

func (m *S2SInfo) GetServerInfo() *ServerInfo

func (*S2SInfo) ProtoMessage 

func (*S2SInfo) ProtoMessage()

func (*S2SInfo) Reset 

func (m *S2SInfo) Reset()

func (*S2SInfo) String 

func (m *S2SInfo) String() string

func (*S2SInfo) Unpack 

func (info *S2SInfo) Unpack() (*message.S2SInfo, error)

func (*S2SInfo) XXX_DiscardUnknown 

func (m *S2SInfo) XXX_DiscardUnknown()

func (*S2SInfo) XXX_Marshal 

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

func (*S2SInfo) XXX_Merge 

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

func (*S2SInfo) XXX_Size 

func (m *S2SInfo) XXX_Size() int

func (*S2SInfo) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*Timestamp) GetTimestamp 

func (m *Timestamp) GetTimestamp() uint64

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) Reset 

func (m *Timestamp) Reset()

func (*Timestamp) String 

func (m *Timestamp) String() string

func (*Timestamp) XXX_DiscardUnknown 

func (m *Timestamp) XXX_DiscardUnknown()

func (*Timestamp) XXX_Marshal 

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

func (*Timestamp) XXX_Merge 

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

func (*Timestamp) XXX_Size 

func (m *Timestamp) XXX_Size() int

func (*Timestamp) XXX_Unmarshal 

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

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

func (*UnimplementedS2CRegistryServer) PING(ctx context.Context, req *Timestamp) (*Timestamp, error)

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

func (*UnimplementedS2SRegistryServer) PING(ctx context.Context, req *Timestamp) (*Timestamp, error)

func (*UnimplementedS2SRegistryServer) Poll 

func (*UnimplementedS2SRegistryServer) Poll(ctx context.Context, req *S2SRequest) (*S2SResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.