agent

package
v0.0.0-...-d269b69 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
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"
	Agent_UpdateHangState_FullMethodName   = "/api.agent.Agent/UpdateHangState"
	Agent_UpdateKeyMetadata_FullMethodName = "/api.agent.Agent/UpdateKeyMetadata"
)
View Source 
const OperationAgentGetKey = "/api.agent.Agent/GetKey"
View Source 
const OperationAgentListCluster = "/api.agent.Agent/ListCluster"
View Source 
const OperationAgentListKey = "/api.agent.Agent/ListKey"
View Source 
const OperationAgentListService = "/api.agent.Agent/ListService"
View Source 
const OperationAgentListServiceGroup = "/api.agent.Agent/ListServiceGroup"
View Source 
const OperationAgentUpdateHangState = "/api.agent.Agent/UpdateHangState"
View Source 
const OperationAgentUpdateKeyMetadata = "/api.agent.Agent/UpdateKeyMetadata"

Variables

View Source 
var (
	SaveMode_name = map[int32]string{
		0: "REPLACE",
		1: "CLEANALL",
	}
	SaveMode_value = map[string]int32{
		"REPLACE":  0,
		"CLEANALL": 1,
	}
)

Enum value maps for SaveMode.

View Source 
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.

View Source 
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,
		},
		{
			MethodName: "UpdateHangState",
			Handler:    _Agent_UpdateHangState_Handler,
		},
		{
			MethodName: "UpdateKeyMetadata",
			Handler:    _Agent_UpdateKeyMetadata_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)

View Source 
var File_agent_agent_proto protoreflect.FileDescriptor
View Source 
var File_agent_error_reason_proto protoreflect.FileDescriptor
View Source 
var File_agent_kv_proto protoreflect.FileDescriptor
View Source 
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)
	UpdateHangState(ctx context.Context, in *UpdateHangStateRequest, opts ...grpc.CallOption) (*UpdateHangStateReply, error)
	UpdateKeyMetadata(ctx context.Context, in *UpdateKeyMetadataRequest, opts ...grpc.CallOption) (*UpdateKeyMetadataReply, 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)
	UpdateHangState(ctx context.Context, req *UpdateHangStateRequest, opts ...http.CallOption) (rsp *UpdateHangStateReply, err error)
	UpdateKeyMetadata(ctx context.Context, req *UpdateKeyMetadataRequest, opts ...http.CallOption) (rsp *UpdateKeyMetadataReply, 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)

func (*AgentHTTPClientImpl) UpdateHangState 

func (c *AgentHTTPClientImpl) UpdateHangState(ctx context.Context, in *UpdateHangStateRequest, opts ...http.CallOption) (*UpdateHangStateReply, error)

func (*AgentHTTPClientImpl) UpdateKeyMetadata 

func (c *AgentHTTPClientImpl) UpdateKeyMetadata(ctx context.Context, in *UpdateKeyMetadataRequest, opts ...http.CallOption) (*UpdateKeyMetadataReply, 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)
	UpdateHangState(context.Context, *UpdateHangStateRequest) (*UpdateHangStateReply, error)
	UpdateKeyMetadata(context.Context, *UpdateKeyMetadataRequest) (*UpdateKeyMetadataReply, 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)
	UpdateHangState(context.Context, *UpdateHangStateRequest) (*UpdateHangStateReply, error)
	UpdateKeyMetadata(context.Context, *UpdateKeyMetadataRequest) (*UpdateKeyMetadataReply, 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) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetHealthy 

func (x *Cluster) GetHealthy() bool

func (*Cluster) GetMembers 

func (x *Cluster) GetMembers() []*Cluster_Member

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

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

Deprecated: Use KV.ProtoReflect.Descriptor instead.

func (*KV) GetKey 

func (x *KV) GetKey() string

func (*KV) GetValue 

func (x *KV) GetValue() string

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) ProtoReflect 

func (x *KV) ProtoReflect() protoreflect.Message

func (*KV) Reset 

func (x *KV) Reset()

func (*KV) String 

func (x *KV) String() string

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

func (x *Microservice) HasHang() bool

HasHang 该组件是否挂起

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 SaveMode 

type SaveMode int32
const (
	// Replace the existing value
	SaveMode_REPLACE SaveMode = 0
	// Cleanall and save
	SaveMode_CLEANALL SaveMode = 1
)

func (SaveMode) Descriptor 

func (SaveMode) Descriptor() protoreflect.EnumDescriptor

func (SaveMode) Enum 

func (x SaveMode) Enum() *SaveMode

func (SaveMode) EnumDescriptor deprecated 

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

Deprecated: Use SaveMode.Descriptor instead.

func (SaveMode) Number 

func (x SaveMode) Number() protoreflect.EnumNumber

func (SaveMode) String 

func (x SaveMode) String() string

func (SaveMode) Type 

func (SaveMode) Type() protoreflect.EnumType

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)

func (UnimplementedAgentServer) UpdateHangState 

func (UnimplementedAgentServer) UpdateHangState(context.Context, *UpdateHangStateRequest) (*UpdateHangStateReply, error)

func (UnimplementedAgentServer) UpdateKeyMetadata 

func (UnimplementedAgentServer) UpdateKeyMetadata(context.Context, *UpdateKeyMetadataRequest) (*UpdateKeyMetadataReply, 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.

type UpdateHangStateReply 

type UpdateHangStateReply struct {
	// contains filtered or unexported fields
}

func (*UpdateHangStateReply) Descriptor deprecated 

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

Deprecated: Use UpdateHangStateReply.ProtoReflect.Descriptor instead.

func (*UpdateHangStateReply) ProtoMessage 

func (*UpdateHangStateReply) ProtoMessage()

func (*UpdateHangStateReply) ProtoReflect 

func (x *UpdateHangStateReply) ProtoReflect() protoreflect.Message

func (*UpdateHangStateReply) Reset 

func (x *UpdateHangStateReply) Reset()

func (*UpdateHangStateReply) String 

func (x *UpdateHangStateReply) String() string

type UpdateHangStateRequest 

type UpdateHangStateRequest 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"`
	Hang    bool   `protobuf:"varint,3,opt,name=hang,proto3" json:"hang,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateHangStateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateHangStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateHangStateRequest) GetCluster 

func (x *UpdateHangStateRequest) GetCluster() string

func (*UpdateHangStateRequest) GetHang 

func (x *UpdateHangStateRequest) GetHang() bool

func (*UpdateHangStateRequest) GetKey 

func (x *UpdateHangStateRequest) GetKey() string

func (*UpdateHangStateRequest) ProtoMessage 

func (*UpdateHangStateRequest) ProtoMessage()

func (*UpdateHangStateRequest) ProtoReflect 

func (x *UpdateHangStateRequest) ProtoReflect() protoreflect.Message

func (*UpdateHangStateRequest) Reset 

func (x *UpdateHangStateRequest) Reset()

func (*UpdateHangStateRequest) String 

func (x *UpdateHangStateRequest) String() string

type UpdateKeyMetadataReply 

type UpdateKeyMetadataReply struct {
	// contains filtered or unexported fields
}

func (*UpdateKeyMetadataReply) Descriptor deprecated 

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

Deprecated: Use UpdateKeyMetadataReply.ProtoReflect.Descriptor instead.

func (*UpdateKeyMetadataReply) ProtoMessage 

func (*UpdateKeyMetadataReply) ProtoMessage()

func (*UpdateKeyMetadataReply) ProtoReflect 

func (x *UpdateKeyMetadataReply) ProtoReflect() protoreflect.Message

func (*UpdateKeyMetadataReply) Reset 

func (x *UpdateKeyMetadataReply) Reset()

func (*UpdateKeyMetadataReply) String 

func (x *UpdateKeyMetadataReply) String() string

type UpdateKeyMetadataRequest 

type UpdateKeyMetadataRequest struct {
	Key      string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Mode     SaveMode          `protobuf:"varint,2,opt,name=mode,proto3,enum=api.agent.SaveMode" json:"mode,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateKeyMetadataRequest) Descriptor deprecated 

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

Deprecated: Use UpdateKeyMetadataRequest.ProtoReflect.Descriptor instead.

func (*UpdateKeyMetadataRequest) GetKey 

func (x *UpdateKeyMetadataRequest) GetKey() string

func (*UpdateKeyMetadataRequest) GetMetadata 

func (x *UpdateKeyMetadataRequest) GetMetadata() map[string]string

func (*UpdateKeyMetadataRequest) GetMode 

func (x *UpdateKeyMetadataRequest) GetMode() SaveMode

func (*UpdateKeyMetadataRequest) ProtoMessage 

func (*UpdateKeyMetadataRequest) ProtoMessage()

func (*UpdateKeyMetadataRequest) ProtoReflect 

func (x *UpdateKeyMetadataRequest) ProtoReflect() protoreflect.Message

func (*UpdateKeyMetadataRequest) Reset 

func (x *UpdateKeyMetadataRequest) Reset()

func (*UpdateKeyMetadataRequest) String 

func (x *UpdateKeyMetadataRequest) String() string

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.