Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterAgentHTTPServer(s *http.Server, srv AgentHTTPServer)
- func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
- type AgentClient
- type AgentHTTPClient
- type AgentHTTPClientImpl
- func (c *AgentHTTPClientImpl) GetKey(ctx context.Context, in *GetKeyRequest, opts ...http.CallOption) (*GetKeyReply, error)
- func (c *AgentHTTPClientImpl) ListCluster(ctx context.Context, in *ListClusterRequest, opts ...http.CallOption) (*ListClusterReply, error)
- func (c *AgentHTTPClientImpl) ListKey(ctx context.Context, in *ListKeyRequest, opts ...http.CallOption) (*ListKeyReply, error)
- func (c *AgentHTTPClientImpl) ListService(ctx context.Context, in *ListServiceRequest, opts ...http.CallOption) (*ListServiceReply, error)
- func (c *AgentHTTPClientImpl) ListServiceGroup(ctx context.Context, in *ListServiceGroupRequest, opts ...http.CallOption) (*ListServiceGroupReply, error)
- type AgentHTTPServer
- type AgentServer
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster) GetHealthy() bool
- func (x *Cluster) GetMembers() []*Cluster_Member
- func (x *Cluster) GetName() string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (x *Cluster) String() string
- type ClusterMicroservice
- func (*ClusterMicroservice) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterMicroservice) GetName() string
- func (x *ClusterMicroservice) GetServices() []*Microservice
- func (*ClusterMicroservice) ProtoMessage()
- func (x *ClusterMicroservice) ProtoReflect() protoreflect.Message
- func (x *ClusterMicroservice) Reset()
- func (x *ClusterMicroservice) String() string
- type Cluster_Member
- func (*Cluster_Member) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster_Member) GetClientUrls() []string
- func (x *Cluster_Member) GetIsLearner() bool
- func (x *Cluster_Member) GetName() string
- func (x *Cluster_Member) GetPeerUrls() []string
- func (*Cluster_Member) ProtoMessage()
- func (x *Cluster_Member) ProtoReflect() protoreflect.Message
- func (x *Cluster_Member) Reset()
- func (x *Cluster_Member) String() string
- type ErrorReason
- func (ErrorReason) Descriptor() protoreflect.EnumDescriptor
- func (x ErrorReason) Enum() *ErrorReason
- func (ErrorReason) EnumDescriptor() ([]byte, []int)deprecated
- func (x ErrorReason) Number() protoreflect.EnumNumber
- func (x ErrorReason) String() string
- func (ErrorReason) Type() protoreflect.EnumType
- type GetKeyReply
- type GetKeyRequest
- func (*GetKeyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetKeyRequest) GetCluster() string
- func (x *GetKeyRequest) GetKey() string
- func (*GetKeyRequest) ProtoMessage()
- func (x *GetKeyRequest) ProtoReflect() protoreflect.Message
- func (x *GetKeyRequest) Reset()
- func (x *GetKeyRequest) String() string
- type KV
- type ListClusterReply
- type ListClusterRequest
- type ListKeyReply
- type ListKeyRequest
- func (*ListKeyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListKeyRequest) GetCluster() string
- func (x *ListKeyRequest) GetPrefix() string
- func (*ListKeyRequest) ProtoMessage()
- func (x *ListKeyRequest) ProtoReflect() protoreflect.Message
- func (x *ListKeyRequest) Reset()
- func (x *ListKeyRequest) String() string
- type ListServiceGroupReply
- func (*ListServiceGroupReply) Descriptor() ([]byte, []int)deprecated
- func (x *ListServiceGroupReply) GetData() []*MicroserviceGroup
- func (*ListServiceGroupReply) ProtoMessage()
- func (x *ListServiceGroupReply) ProtoReflect() protoreflect.Message
- func (x *ListServiceGroupReply) Reset()
- func (x *ListServiceGroupReply) String() string
- type ListServiceGroupRequest
- type ListServiceReply
- type ListServiceRequest
- type Microservice
- func (*Microservice) Descriptor() ([]byte, []int)deprecated
- func (x *Microservice) GetCluster() string
- func (x *Microservice) GetEndpoints() []string
- func (x *Microservice) GetId() string
- func (x *Microservice) GetKey() string
- func (x *Microservice) GetMetadata() map[string]string
- func (x *Microservice) GetName() string
- func (x *Microservice) GetNamespace() string
- func (x *Microservice) GetVersion() string
- func (x *Microservice) HasHang() bool
- func (*Microservice) ProtoMessage()
- func (x *Microservice) ProtoReflect() protoreflect.Message
- func (x *Microservice) Reset()
- func (x *Microservice) String() string
- type MicroserviceGroup
- func (*MicroserviceGroup) Descriptor() ([]byte, []int)deprecated
- func (x *MicroserviceGroup) GetClusters() []string
- func (x *MicroserviceGroup) GetEndpoints() []string
- func (x *MicroserviceGroup) GetHostnames() []string
- func (x *MicroserviceGroup) GetKeys() []string
- func (x *MicroserviceGroup) GetName() string
- func (*MicroserviceGroup) ProtoMessage()
- func (x *MicroserviceGroup) ProtoReflect() protoreflect.Message
- func (x *MicroserviceGroup) Reset()
- func (x *MicroserviceGroup) String() string
- type UnimplementedAgentServer
- func (UnimplementedAgentServer) GetKey(context.Context, *GetKeyRequest) (*GetKeyReply, error)
- func (UnimplementedAgentServer) ListCluster(context.Context, *ListClusterRequest) (*ListClusterReply, error)
- func (UnimplementedAgentServer) ListKey(context.Context, *ListKeyRequest) (*ListKeyReply, error)
- func (UnimplementedAgentServer) ListService(context.Context, *ListServiceRequest) (*ListServiceReply, error)
- func (UnimplementedAgentServer) ListServiceGroup(context.Context, *ListServiceGroupRequest) (*ListServiceGroupReply, error)
- type UnsafeAgentServer
Constants ¶
const ( Agent_ListCluster_FullMethodName = "/api.agent.Agent/ListCluster" Agent_ListService_FullMethodName = "/api.agent.Agent/ListService" Agent_ListServiceGroup_FullMethodName = "/api.agent.Agent/ListServiceGroup" Agent_ListKey_FullMethodName = "/api.agent.Agent/ListKey" Agent_GetKey_FullMethodName = "/api.agent.Agent/GetKey" )
const OperationAgentGetKey = "/api.agent.Agent/GetKey"
const OperationAgentListCluster = "/api.agent.Agent/ListCluster"
const OperationAgentListKey = "/api.agent.Agent/ListKey"
const OperationAgentListService = "/api.agent.Agent/ListService"
const OperationAgentListServiceGroup = "/api.agent.Agent/ListServiceGroup"
Variables ¶
var ( ErrorReason_name = map[int32]string{ 0: "GREETER_UNSPECIFIED", 1: "USER_NOT_FOUND", } ErrorReason_value = map[string]int32{ "GREETER_UNSPECIFIED": 0, "USER_NOT_FOUND": 1, } )
Enum value maps for ErrorReason.
var Agent_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.agent.Agent", HandlerType: (*AgentServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListCluster", Handler: _Agent_ListCluster_Handler, }, { MethodName: "ListService", Handler: _Agent_ListService_Handler, }, { MethodName: "ListServiceGroup", Handler: _Agent_ListServiceGroup_Handler, }, { MethodName: "ListKey", Handler: _Agent_ListKey_Handler, }, { MethodName: "GetKey", Handler: _Agent_GetKey_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "agent/agent.proto", }
Agent_ServiceDesc is the grpc.ServiceDesc for Agent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_agent_agent_proto protoreflect.FileDescriptor
var File_agent_error_reason_proto protoreflect.FileDescriptor
var File_agent_kv_proto protoreflect.FileDescriptor
var File_agent_microservice_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAgentHTTPServer ¶
func RegisterAgentHTTPServer(s *http.Server, srv AgentHTTPServer)
func RegisterAgentServer ¶
func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
Types ¶
type AgentClient ¶
type AgentClient interface { // ListCluster 获取集群列表 // // returns a list of clusters ListCluster(ctx context.Context, in *ListClusterRequest, opts ...grpc.CallOption) (*ListClusterReply, error) // ListService 获取服务列表 // // returns a list of services ListService(ctx context.Context, in *ListServiceRequest, opts ...grpc.CallOption) (*ListServiceReply, error) // ListServiceGroup 获取服务分组列表 // // returns a list of group by service. ListServiceGroup(ctx context.Context, in *ListServiceGroupRequest, opts ...grpc.CallOption) (*ListServiceGroupReply, error) ListKey(ctx context.Context, in *ListKeyRequest, opts ...grpc.CallOption) (*ListKeyReply, error) GetKey(ctx context.Context, in *GetKeyRequest, opts ...grpc.CallOption) (*GetKeyReply, error) }
AgentClient is the client API for Agent service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAgentClient ¶
func NewAgentClient(cc grpc.ClientConnInterface) AgentClient
type AgentHTTPClient ¶
type AgentHTTPClient interface { GetKey(ctx context.Context, req *GetKeyRequest, opts ...http.CallOption) (rsp *GetKeyReply, err error) ListCluster(ctx context.Context, req *ListClusterRequest, opts ...http.CallOption) (rsp *ListClusterReply, err error) ListKey(ctx context.Context, req *ListKeyRequest, opts ...http.CallOption) (rsp *ListKeyReply, err error) ListService(ctx context.Context, req *ListServiceRequest, opts ...http.CallOption) (rsp *ListServiceReply, err error) ListServiceGroup(ctx context.Context, req *ListServiceGroupRequest, opts ...http.CallOption) (rsp *ListServiceGroupReply, err error) }
func NewAgentHTTPClient ¶
func NewAgentHTTPClient(client *http.Client) AgentHTTPClient
type AgentHTTPClientImpl ¶
type AgentHTTPClientImpl struct {
// contains filtered or unexported fields
}
func (*AgentHTTPClientImpl) GetKey ¶
func (c *AgentHTTPClientImpl) GetKey(ctx context.Context, in *GetKeyRequest, opts ...http.CallOption) (*GetKeyReply, error)
func (*AgentHTTPClientImpl) ListCluster ¶
func (c *AgentHTTPClientImpl) ListCluster(ctx context.Context, in *ListClusterRequest, opts ...http.CallOption) (*ListClusterReply, error)
func (*AgentHTTPClientImpl) ListKey ¶
func (c *AgentHTTPClientImpl) ListKey(ctx context.Context, in *ListKeyRequest, opts ...http.CallOption) (*ListKeyReply, error)
func (*AgentHTTPClientImpl) ListService ¶
func (c *AgentHTTPClientImpl) ListService(ctx context.Context, in *ListServiceRequest, opts ...http.CallOption) (*ListServiceReply, error)
func (*AgentHTTPClientImpl) ListServiceGroup ¶
func (c *AgentHTTPClientImpl) ListServiceGroup(ctx context.Context, in *ListServiceGroupRequest, opts ...http.CallOption) (*ListServiceGroupReply, error)
type AgentHTTPServer ¶
type AgentHTTPServer interface { GetKey(context.Context, *GetKeyRequest) (*GetKeyReply, error) // ListCluster ListCluster 获取集群列表 // // returns a list of clusters ListCluster(context.Context, *ListClusterRequest) (*ListClusterReply, error) ListKey(context.Context, *ListKeyRequest) (*ListKeyReply, error) // ListService ListService 获取服务列表 // // returns a list of services ListService(context.Context, *ListServiceRequest) (*ListServiceReply, error) // ListServiceGroup ListServiceGroup 获取服务分组列表 // // returns a list of group by service. ListServiceGroup(context.Context, *ListServiceGroupRequest) (*ListServiceGroupReply, error) }
type AgentServer ¶
type AgentServer interface { // ListCluster 获取集群列表 // // returns a list of clusters ListCluster(context.Context, *ListClusterRequest) (*ListClusterReply, error) // ListService 获取服务列表 // // returns a list of services ListService(context.Context, *ListServiceRequest) (*ListServiceReply, error) // ListServiceGroup 获取服务分组列表 // // returns a list of group by service. ListServiceGroup(context.Context, *ListServiceGroupRequest) (*ListServiceGroupReply, error) ListKey(context.Context, *ListKeyRequest) (*ListKeyReply, error) GetKey(context.Context, *GetKeyRequest) (*GetKeyReply, error) // contains filtered or unexported methods }
AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility
type Cluster ¶
type Cluster struct { // 集群名称 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 集群健康状态 Healthy bool `protobuf:"varint,2,opt,name=healthy,proto3" json:"healthy,omitempty"` // 集群成员 Members []*Cluster_Member `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"` // contains filtered or unexported fields }
func (*Cluster) Descriptor
deprecated
func (*Cluster) GetHealthy ¶
func (*Cluster) GetMembers ¶
func (x *Cluster) GetMembers() []*Cluster_Member
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
type ClusterMicroservice ¶
type ClusterMicroservice struct { // 集群名称 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 集群服务 Services []*Microservice `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
func (*ClusterMicroservice) Descriptor
deprecated
func (*ClusterMicroservice) Descriptor() ([]byte, []int)
Deprecated: Use ClusterMicroservice.ProtoReflect.Descriptor instead.
func (*ClusterMicroservice) GetName ¶
func (x *ClusterMicroservice) GetName() string
func (*ClusterMicroservice) GetServices ¶
func (x *ClusterMicroservice) GetServices() []*Microservice
func (*ClusterMicroservice) ProtoMessage ¶
func (*ClusterMicroservice) ProtoMessage()
func (*ClusterMicroservice) ProtoReflect ¶
func (x *ClusterMicroservice) ProtoReflect() protoreflect.Message
func (*ClusterMicroservice) Reset ¶
func (x *ClusterMicroservice) Reset()
func (*ClusterMicroservice) String ¶
func (x *ClusterMicroservice) String() string
type Cluster_Member ¶
type Cluster_Member struct { // 成员名称 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 是否为 learner IsLearner bool `protobuf:"varint,2,opt,name=is_learner,json=isLearner,proto3" json:"is_learner,omitempty"` // 成员地址 PeerUrls []string `protobuf:"bytes,3,rep,name=peer_urls,json=peerUrls,proto3" json:"peer_urls,omitempty"` // 客户端地址 ClientUrls []string `protobuf:"bytes,4,rep,name=client_urls,json=clientUrls,proto3" json:"client_urls,omitempty"` // contains filtered or unexported fields }
集群成员信息
func (*Cluster_Member) Descriptor
deprecated
func (*Cluster_Member) Descriptor() ([]byte, []int)
Deprecated: Use Cluster_Member.ProtoReflect.Descriptor instead.
func (*Cluster_Member) GetClientUrls ¶
func (x *Cluster_Member) GetClientUrls() []string
func (*Cluster_Member) GetIsLearner ¶
func (x *Cluster_Member) GetIsLearner() bool
func (*Cluster_Member) GetName ¶
func (x *Cluster_Member) GetName() string
func (*Cluster_Member) GetPeerUrls ¶
func (x *Cluster_Member) GetPeerUrls() []string
func (*Cluster_Member) ProtoMessage ¶
func (*Cluster_Member) ProtoMessage()
func (*Cluster_Member) ProtoReflect ¶
func (x *Cluster_Member) ProtoReflect() protoreflect.Message
func (*Cluster_Member) Reset ¶
func (x *Cluster_Member) Reset()
func (*Cluster_Member) String ¶
func (x *Cluster_Member) String() string
type ErrorReason ¶
type ErrorReason int32
const ( ErrorReason_GREETER_UNSPECIFIED ErrorReason = 0 ErrorReason_USER_NOT_FOUND ErrorReason = 1 )
func (ErrorReason) Descriptor ¶
func (ErrorReason) Descriptor() protoreflect.EnumDescriptor
func (ErrorReason) Enum ¶
func (x ErrorReason) Enum() *ErrorReason
func (ErrorReason) EnumDescriptor
deprecated
func (ErrorReason) EnumDescriptor() ([]byte, []int)
Deprecated: Use ErrorReason.Descriptor instead.
func (ErrorReason) Number ¶
func (x ErrorReason) Number() protoreflect.EnumNumber
func (ErrorReason) String ¶
func (x ErrorReason) String() string
func (ErrorReason) Type ¶
func (ErrorReason) Type() protoreflect.EnumType
type GetKeyReply ¶
type GetKeyReply struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*GetKeyReply) Descriptor
deprecated
func (*GetKeyReply) Descriptor() ([]byte, []int)
Deprecated: Use GetKeyReply.ProtoReflect.Descriptor instead.
func (*GetKeyReply) GetValue ¶
func (x *GetKeyReply) GetValue() string
func (*GetKeyReply) ProtoMessage ¶
func (*GetKeyReply) ProtoMessage()
func (*GetKeyReply) ProtoReflect ¶
func (x *GetKeyReply) ProtoReflect() protoreflect.Message
func (*GetKeyReply) Reset ¶
func (x *GetKeyReply) Reset()
func (*GetKeyReply) String ¶
func (x *GetKeyReply) String() string
type GetKeyRequest ¶
type GetKeyRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` // contains filtered or unexported fields }
func (*GetKeyRequest) Descriptor
deprecated
func (*GetKeyRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetKeyRequest.ProtoReflect.Descriptor instead.
func (*GetKeyRequest) GetCluster ¶
func (x *GetKeyRequest) GetCluster() string
func (*GetKeyRequest) GetKey ¶
func (x *GetKeyRequest) GetKey() string
func (*GetKeyRequest) ProtoMessage ¶
func (*GetKeyRequest) ProtoMessage()
func (*GetKeyRequest) ProtoReflect ¶
func (x *GetKeyRequest) ProtoReflect() protoreflect.Message
func (*GetKeyRequest) Reset ¶
func (x *GetKeyRequest) Reset()
func (*GetKeyRequest) String ¶
func (x *GetKeyRequest) String() string
type KV ¶
type KV struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*KV) Descriptor
deprecated
func (*KV) ProtoMessage ¶
func (*KV) ProtoMessage()
func (*KV) ProtoReflect ¶
func (x *KV) ProtoReflect() protoreflect.Message
type ListClusterReply ¶
type ListClusterReply struct { Data []*Cluster `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ListClusterReply) Descriptor
deprecated
func (*ListClusterReply) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterReply.ProtoReflect.Descriptor instead.
func (*ListClusterReply) GetData ¶
func (x *ListClusterReply) GetData() []*Cluster
func (*ListClusterReply) ProtoMessage ¶
func (*ListClusterReply) ProtoMessage()
func (*ListClusterReply) ProtoReflect ¶
func (x *ListClusterReply) ProtoReflect() protoreflect.Message
func (*ListClusterReply) Reset ¶
func (x *ListClusterReply) Reset()
func (*ListClusterReply) String ¶
func (x *ListClusterReply) String() string
type ListClusterRequest ¶
type ListClusterRequest struct {
// contains filtered or unexported fields
}
func (*ListClusterRequest) Descriptor
deprecated
func (*ListClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterRequest.ProtoReflect.Descriptor instead.
func (*ListClusterRequest) ProtoMessage ¶
func (*ListClusterRequest) ProtoMessage()
func (*ListClusterRequest) ProtoReflect ¶
func (x *ListClusterRequest) ProtoReflect() protoreflect.Message
func (*ListClusterRequest) Reset ¶
func (x *ListClusterRequest) Reset()
func (*ListClusterRequest) String ¶
func (x *ListClusterRequest) String() string
type ListKeyReply ¶
type ListKeyReply struct { Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // contains filtered or unexported fields }
func (*ListKeyReply) Descriptor
deprecated
func (*ListKeyReply) Descriptor() ([]byte, []int)
Deprecated: Use ListKeyReply.ProtoReflect.Descriptor instead.
func (*ListKeyReply) GetKeys ¶
func (x *ListKeyReply) GetKeys() []string
func (*ListKeyReply) ProtoMessage ¶
func (*ListKeyReply) ProtoMessage()
func (*ListKeyReply) ProtoReflect ¶
func (x *ListKeyReply) ProtoReflect() protoreflect.Message
func (*ListKeyReply) Reset ¶
func (x *ListKeyReply) Reset()
func (*ListKeyReply) String ¶
func (x *ListKeyReply) String() string
type ListKeyRequest ¶
type ListKeyRequest struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` // contains filtered or unexported fields }
func (*ListKeyRequest) Descriptor
deprecated
func (*ListKeyRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListKeyRequest.ProtoReflect.Descriptor instead.
func (*ListKeyRequest) GetCluster ¶
func (x *ListKeyRequest) GetCluster() string
func (*ListKeyRequest) GetPrefix ¶
func (x *ListKeyRequest) GetPrefix() string
func (*ListKeyRequest) ProtoMessage ¶
func (*ListKeyRequest) ProtoMessage()
func (*ListKeyRequest) ProtoReflect ¶
func (x *ListKeyRequest) ProtoReflect() protoreflect.Message
func (*ListKeyRequest) Reset ¶
func (x *ListKeyRequest) Reset()
func (*ListKeyRequest) String ¶
func (x *ListKeyRequest) String() string
type ListServiceGroupReply ¶
type ListServiceGroupReply struct { Data []*MicroserviceGroup `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ListServiceGroupReply) Descriptor
deprecated
func (*ListServiceGroupReply) Descriptor() ([]byte, []int)
Deprecated: Use ListServiceGroupReply.ProtoReflect.Descriptor instead.
func (*ListServiceGroupReply) GetData ¶
func (x *ListServiceGroupReply) GetData() []*MicroserviceGroup
func (*ListServiceGroupReply) ProtoMessage ¶
func (*ListServiceGroupReply) ProtoMessage()
func (*ListServiceGroupReply) ProtoReflect ¶
func (x *ListServiceGroupReply) ProtoReflect() protoreflect.Message
func (*ListServiceGroupReply) Reset ¶
func (x *ListServiceGroupReply) Reset()
func (*ListServiceGroupReply) String ¶
func (x *ListServiceGroupReply) String() string
type ListServiceGroupRequest ¶
type ListServiceGroupRequest struct {
// contains filtered or unexported fields
}
func (*ListServiceGroupRequest) Descriptor
deprecated
func (*ListServiceGroupRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListServiceGroupRequest.ProtoReflect.Descriptor instead.
func (*ListServiceGroupRequest) ProtoMessage ¶
func (*ListServiceGroupRequest) ProtoMessage()
func (*ListServiceGroupRequest) ProtoReflect ¶
func (x *ListServiceGroupRequest) ProtoReflect() protoreflect.Message
func (*ListServiceGroupRequest) Reset ¶
func (x *ListServiceGroupRequest) Reset()
func (*ListServiceGroupRequest) String ¶
func (x *ListServiceGroupRequest) String() string
type ListServiceReply ¶
type ListServiceReply struct { Data []*Microservice `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ListServiceReply) Descriptor
deprecated
func (*ListServiceReply) Descriptor() ([]byte, []int)
Deprecated: Use ListServiceReply.ProtoReflect.Descriptor instead.
func (*ListServiceReply) GetData ¶
func (x *ListServiceReply) GetData() []*Microservice
func (*ListServiceReply) ProtoMessage ¶
func (*ListServiceReply) ProtoMessage()
func (*ListServiceReply) ProtoReflect ¶
func (x *ListServiceReply) ProtoReflect() protoreflect.Message
func (*ListServiceReply) Reset ¶
func (x *ListServiceReply) Reset()
func (*ListServiceReply) String ¶
func (x *ListServiceReply) String() string
type ListServiceRequest ¶
type ListServiceRequest struct {
// contains filtered or unexported fields
}
func (*ListServiceRequest) Descriptor
deprecated
func (*ListServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListServiceRequest.ProtoReflect.Descriptor instead.
func (*ListServiceRequest) ProtoMessage ¶
func (*ListServiceRequest) ProtoMessage()
func (*ListServiceRequest) ProtoReflect ¶
func (x *ListServiceRequest) ProtoReflect() protoreflect.Message
func (*ListServiceRequest) Reset ¶
func (x *ListServiceRequest) Reset()
func (*ListServiceRequest) String ¶
func (x *ListServiceRequest) String() string
type Microservice ¶
type Microservice struct { // 唯一键 Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // 服务id Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // 服务名称 Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // 服务版本 Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"` // 服务端点IP Endpoints []string `protobuf:"bytes,5,rep,name=endpoints,proto3" json:"endpoints,omitempty"` // 服务元数据 Metadata map[string]string `` /* 157-byte string literal not displayed */ // 所属集群 Cluster string `protobuf:"bytes,7,opt,name=cluster,proto3" json:"cluster,omitempty"` // 命名空间 Namespace string `protobuf:"bytes,8,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*Microservice) Descriptor
deprecated
func (*Microservice) Descriptor() ([]byte, []int)
Deprecated: Use Microservice.ProtoReflect.Descriptor instead.
func (*Microservice) GetCluster ¶
func (x *Microservice) GetCluster() string
func (*Microservice) GetEndpoints ¶
func (x *Microservice) GetEndpoints() []string
func (*Microservice) GetId ¶
func (x *Microservice) GetId() string
func (*Microservice) GetKey ¶
func (x *Microservice) GetKey() string
func (*Microservice) GetMetadata ¶
func (x *Microservice) GetMetadata() map[string]string
func (*Microservice) GetName ¶
func (x *Microservice) GetName() string
func (*Microservice) GetNamespace ¶
func (x *Microservice) GetNamespace() string
func (*Microservice) GetVersion ¶
func (x *Microservice) GetVersion() string
func (*Microservice) ProtoMessage ¶
func (*Microservice) ProtoMessage()
func (*Microservice) ProtoReflect ¶
func (x *Microservice) ProtoReflect() protoreflect.Message
func (*Microservice) Reset ¶
func (x *Microservice) Reset()
func (*Microservice) String ¶
func (x *Microservice) String() string
type MicroserviceGroup ¶
type MicroserviceGroup struct { // 服务名称 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 服务IP Endpoints []string `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"` // 服务唯一键 Keys []string `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"` // 运行主机名 Hostnames []string `protobuf:"bytes,4,rep,name=hostnames,proto3" json:"hostnames,omitempty"` // 运行所属集群 Clusters []string `protobuf:"bytes,5,rep,name=clusters,proto3" json:"clusters,omitempty"` // contains filtered or unexported fields }
func (*MicroserviceGroup) Descriptor
deprecated
func (*MicroserviceGroup) Descriptor() ([]byte, []int)
Deprecated: Use MicroserviceGroup.ProtoReflect.Descriptor instead.
func (*MicroserviceGroup) GetClusters ¶
func (x *MicroserviceGroup) GetClusters() []string
func (*MicroserviceGroup) GetEndpoints ¶
func (x *MicroserviceGroup) GetEndpoints() []string
func (*MicroserviceGroup) GetHostnames ¶
func (x *MicroserviceGroup) GetHostnames() []string
func (*MicroserviceGroup) GetKeys ¶
func (x *MicroserviceGroup) GetKeys() []string
func (*MicroserviceGroup) GetName ¶
func (x *MicroserviceGroup) GetName() string
func (*MicroserviceGroup) ProtoMessage ¶
func (*MicroserviceGroup) ProtoMessage()
func (*MicroserviceGroup) ProtoReflect ¶
func (x *MicroserviceGroup) ProtoReflect() protoreflect.Message
func (*MicroserviceGroup) Reset ¶
func (x *MicroserviceGroup) Reset()
func (*MicroserviceGroup) String ¶
func (x *MicroserviceGroup) String() string
type UnimplementedAgentServer ¶
type UnimplementedAgentServer struct { }
UnimplementedAgentServer must be embedded to have forward compatible implementations.
func (UnimplementedAgentServer) GetKey ¶
func (UnimplementedAgentServer) GetKey(context.Context, *GetKeyRequest) (*GetKeyReply, error)
func (UnimplementedAgentServer) ListCluster ¶
func (UnimplementedAgentServer) ListCluster(context.Context, *ListClusterRequest) (*ListClusterReply, error)
func (UnimplementedAgentServer) ListKey ¶
func (UnimplementedAgentServer) ListKey(context.Context, *ListKeyRequest) (*ListKeyReply, error)
func (UnimplementedAgentServer) ListService ¶
func (UnimplementedAgentServer) ListService(context.Context, *ListServiceRequest) (*ListServiceReply, error)
func (UnimplementedAgentServer) ListServiceGroup ¶
func (UnimplementedAgentServer) ListServiceGroup(context.Context, *ListServiceGroupRequest) (*ListServiceGroupReply, error)
type UnsafeAgentServer ¶
type UnsafeAgentServer interface {
// contains filtered or unexported methods
}
UnsafeAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServer will result in compilation errors.