discovery

type DiscoveryClient interface {
	OnlineServices(ctx context.Context, in *OnlineServiceRequest, opts ...grpc.CallOption) (*OnlineServiceReply, error)
	KVListClusters(ctx context.Context, in *KVListClustersRequest, opts ...grpc.CallOption) (*KVListClustersReply, error)
	KVListKeys(ctx context.Context, in *KVListKeysRequest, opts ...grpc.CallOption) (*KVListKeysReply, error)
	KVGetValue(ctx context.Context, in *KVGetValueRequest, opts ...grpc.CallOption) (*KVGetValueReply, error)
	KVUpdateHang(ctx context.Context, in *KVUpdateHangRequest, opts ...grpc.CallOption) (*KVUpdateHangReply, error)
}

type DiscoveryHTTPClient interface {
	KVGetValue(ctx context.Context, req *KVGetValueRequest, opts ...http.CallOption) (rsp *KVGetValueReply, err error)
	KVListClusters(ctx context.Context, req *KVListClustersRequest, opts ...http.CallOption) (rsp *KVListClustersReply, err error)
	KVListKeys(ctx context.Context, req *KVListKeysRequest, opts ...http.CallOption) (rsp *KVListKeysReply, err error)
	KVUpdateHang(ctx context.Context, req *KVUpdateHangRequest, opts ...http.CallOption) (rsp *KVUpdateHangReply, err error)
	OnlineServices(ctx context.Context, req *OnlineServiceRequest, opts ...http.CallOption) (rsp *OnlineServiceReply, err error)
}

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

type DiscoveryHTTPServer interface {
	KVGetValue(context.Context, *KVGetValueRequest) (*KVGetValueReply, error)
	KVListClusters(context.Context, *KVListClustersRequest) (*KVListClustersReply, error)
	KVListKeys(context.Context, *KVListKeysRequest) (*KVListKeysReply, error)
	KVUpdateHang(context.Context, *KVUpdateHangRequest) (*KVUpdateHangReply, error)
	OnlineServices(context.Context, *OnlineServiceRequest) (*OnlineServiceReply, error)
}

type DiscoveryServer interface {
	OnlineServices(context.Context, *OnlineServiceRequest) (*OnlineServiceReply, error)
	KVListClusters(context.Context, *KVListClustersRequest) (*KVListClustersReply, error)
	KVListKeys(context.Context, *KVListKeysRequest) (*KVListKeysReply, error)
	KVGetValue(context.Context, *KVGetValueRequest) (*KVGetValueReply, error)
	KVUpdateHang(context.Context, *KVUpdateHangRequest) (*KVUpdateHangReply, error)
	// contains filtered or unexported methods
}

type KVGetValueReply struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type KVGetValueRequest 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
}

type KVListClustersReply struct {
	Clusters []string `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

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

type KVListKeysReply struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

type KVListKeysRequest struct {
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

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

type KVUpdateHangRequest struct {

	// 主键
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 挂起状态 true 为挂起1111
	Hang bool `protobuf:"varint,2,opt,name=hang,proto3" json:"hang,omitempty"`
	// contains filtered or unexported fields
}

type OnlineServiceReply struct {
	Pagination *protobuf.Pagination `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	Data       []*ServiceGroup      `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type OnlineServiceRequest struct {

	// pagination filter
	Pagination *protobuf.Pagination `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// service name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// service namespace
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

type Service struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// 唯一标识
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// 主机名
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// 服务名称
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// 版本
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// 服务地址
	Endpoints []string `protobuf:"bytes,6,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// 集群
	Cluster string `protobuf:"bytes,7,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// 挂起状态 true 为挂起
	Hang bool `protobuf:"varint,8,opt,name=hang,proto3" json:"hang,omitempty"`
	// 元信息
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// 命名空间
	Namespace string `protobuf:"bytes,10,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 上次心跳间隔
	LastHealthySec int32 `protobuf:"varint,11,opt,name=last_healthy_sec,json=lastHealthySec,proto3" json:"last_healthy_sec,omitempty"`
	// contains filtered or unexported fields
}

type ServiceGroup struct {

	// 唯一标识
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// 主机名
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,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"`
	// 服务地址
	Endpoints []string `protobuf:"bytes,5,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// 集群
	Clusters []string `protobuf:"bytes,6,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// 同服务，不同实例的数组信息
	Children []*Service `protobuf:"bytes,7,rep,name=children,proto3" json:"children,omitempty"`
	// 命名空间
	Namespace string `protobuf:"bytes,8,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 数据类型
	IsGroup bool `protobuf:"varint,9,opt,name=is_group,json=isGroup,proto3" json:"is_group,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedDiscoveryServer struct{}

type UnsafeDiscoveryServer interface {
	// contains filtered or unexported methods
}