v1

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: May 31, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClusterService_GetFrontierByEdge_FullMethodName = "/controlplane.ClusterService/GetFrontierByEdge"
	ClusterService_ListFrontiers_FullMethodName     = "/controlplane.ClusterService/ListFrontiers"
	ClusterService_ListEdges_FullMethodName         = "/controlplane.ClusterService/ListEdges"
	ClusterService_GetEdgeByID_FullMethodName       = "/controlplane.ClusterService/GetEdgeByID"
	ClusterService_GetEdgesCount_FullMethodName     = "/controlplane.ClusterService/GetEdgesCount"
	ClusterService_ListServices_FullMethodName      = "/controlplane.ClusterService/ListServices"
	ClusterService_GetServiceByID_FullMethodName    = "/controlplane.ClusterService/GetServiceByID"
	ClusterService_GetServicesCount_FullMethodName  = "/controlplane.ClusterService/GetServicesCount"
)
View Source 
const (
	Health_Check_FullMethodName = "/controlplane.Health/Check"
	Health_Watch_FullMethodName = "/controlplane.Health/Watch"
)
View Source 
const OperationClusterServiceGetEdgeByID = "/controlplane.ClusterService/GetEdgeByID"
View Source 
const OperationClusterServiceGetEdgesCount = "/controlplane.ClusterService/GetEdgesCount"
View Source 
const OperationClusterServiceGetFrontierByEdge = "/controlplane.ClusterService/GetFrontierByEdge"
View Source 
const OperationClusterServiceGetServiceByID = "/controlplane.ClusterService/GetServiceByID"
View Source 
const OperationClusterServiceGetServicesCount = "/controlplane.ClusterService/GetServicesCount"
View Source 
const OperationClusterServiceListEdges = "/controlplane.ClusterService/ListEdges"
View Source 
const OperationClusterServiceListFrontiers = "/controlplane.ClusterService/ListFrontiers"
View Source 
const OperationClusterServiceListServices = "/controlplane.ClusterService/ListServices"
View Source 
const OperationHealthCheck = "/controlplane.Health/Check"

Variables

View Source 
var (
	HealthCheckResponse_ServingStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "SERVING",
		2: "NOT_SERVING",
		3: "SERVICE_UNKNOWN",
	}
	HealthCheckResponse_ServingStatus_value = map[string]int32{
		"UNKNOWN":         0,
		"SERVING":         1,
		"NOT_SERVING":     2,
		"SERVICE_UNKNOWN": 3,
	}
)

Enum value maps for HealthCheckResponse_ServingStatus.

View Source 
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "controlplane.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetFrontierByEdge",
			Handler:    _ClusterService_GetFrontierByEdge_Handler,
		},
		{
			MethodName: "ListFrontiers",
			Handler:    _ClusterService_ListFrontiers_Handler,
		},
		{
			MethodName: "ListEdges",
			Handler:    _ClusterService_ListEdges_Handler,
		},
		{
			MethodName: "GetEdgeByID",
			Handler:    _ClusterService_GetEdgeByID_Handler,
		},
		{
			MethodName: "GetEdgesCount",
			Handler:    _ClusterService_GetEdgesCount_Handler,
		},
		{
			MethodName: "ListServices",
			Handler:    _ClusterService_ListServices_Handler,
		},
		{
			MethodName: "GetServiceByID",
			Handler:    _ClusterService_GetServiceByID_Handler,
		},
		{
			MethodName: "GetServicesCount",
			Handler:    _ClusterService_GetServicesCount_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cluster.proto",
}

ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService 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_cluster_proto protoreflect.FileDescriptor
View Source 
var File_health_proto protoreflect.FileDescriptor
View Source 
var Health_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "controlplane.Health",
	HandlerType: (*HealthServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Check",
			Handler:    _Health_Check_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _Health_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "health.proto",
}

Health_ServiceDesc is the grpc.ServiceDesc for Health service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterClusterServiceHTTPServer 

func RegisterClusterServiceHTTPServer(s *http.Server, srv ClusterServiceHTTPServer)

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

func RegisterHealthHTTPServer 

func RegisterHealthHTTPServer(s *http.Server, srv HealthHTTPServer)

func RegisterHealthServer 

func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)

Types

type ClusterServiceClient 

type ClusterServiceClient interface {
	GetFrontierByEdge(ctx context.Context, in *GetFrontierByEdgeIDRequest, opts ...grpc.CallOption) (*GetFrontierByEdgeIDResponse, error)
	ListFrontiers(ctx context.Context, in *ListFrontiersRequest, opts ...grpc.CallOption) (*ListFrontiersResponse, error)
	ListEdges(ctx context.Context, in *ListEdgesRequest, opts ...grpc.CallOption) (*ListEdgesResponse, error)
	GetEdgeByID(ctx context.Context, in *GetEdgeByIDRequest, opts ...grpc.CallOption) (*GetEdgeByIDResponse, error)
	GetEdgesCount(ctx context.Context, in *GetEdgesCountRequest, opts ...grpc.CallOption) (*GetEdgesCountResponse, error)
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error)
	GetServiceByID(ctx context.Context, in *GetServiceByIDRequest, opts ...grpc.CallOption) (*GetServiceByIDResponse, error)
	GetServicesCount(ctx context.Context, in *GetServicesCountRequest, opts ...grpc.CallOption) (*GetServicesCountResponse, error)
}

ClusterServiceClient is the client API for ClusterService 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 NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceHTTPClient 

type ClusterServiceHTTPClient interface {
	GetEdgeByID(ctx context.Context, req *GetEdgeByIDRequest, opts ...http.CallOption) (rsp *GetEdgeByIDResponse, err error)
	GetEdgesCount(ctx context.Context, req *GetEdgesCountRequest, opts ...http.CallOption) (rsp *GetEdgesCountResponse, err error)
	GetFrontierByEdge(ctx context.Context, req *GetFrontierByEdgeIDRequest, opts ...http.CallOption) (rsp *GetFrontierByEdgeIDResponse, err error)
	GetServiceByID(ctx context.Context, req *GetServiceByIDRequest, opts ...http.CallOption) (rsp *GetServiceByIDResponse, err error)
	GetServicesCount(ctx context.Context, req *GetServicesCountRequest, opts ...http.CallOption) (rsp *GetServicesCountResponse, err error)
	ListEdges(ctx context.Context, req *ListEdgesRequest, opts ...http.CallOption) (rsp *ListEdgesResponse, err error)
	ListFrontiers(ctx context.Context, req *ListFrontiersRequest, opts ...http.CallOption) (rsp *ListFrontiersResponse, err error)
	ListServices(ctx context.Context, req *ListServicesRequest, opts ...http.CallOption) (rsp *ListServicesResponse, err error)
}

func NewClusterServiceHTTPClient 

func NewClusterServiceHTTPClient(client *http.Client) ClusterServiceHTTPClient

type ClusterServiceHTTPClientImpl 

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

func (*ClusterServiceHTTPClientImpl) GetEdgeByID 

func (c *ClusterServiceHTTPClientImpl) GetEdgeByID(ctx context.Context, in *GetEdgeByIDRequest, opts ...http.CallOption) (*GetEdgeByIDResponse, error)

func (*ClusterServiceHTTPClientImpl) GetEdgesCount 

func (c *ClusterServiceHTTPClientImpl) GetEdgesCount(ctx context.Context, in *GetEdgesCountRequest, opts ...http.CallOption) (*GetEdgesCountResponse, error)

func (*ClusterServiceHTTPClientImpl) GetFrontierByEdge 

func (c *ClusterServiceHTTPClientImpl) GetFrontierByEdge(ctx context.Context, in *GetFrontierByEdgeIDRequest, opts ...http.CallOption) (*GetFrontierByEdgeIDResponse, error)

func (*ClusterServiceHTTPClientImpl) GetServiceByID 

func (c *ClusterServiceHTTPClientImpl) GetServiceByID(ctx context.Context, in *GetServiceByIDRequest, opts ...http.CallOption) (*GetServiceByIDResponse, error)

func (*ClusterServiceHTTPClientImpl) GetServicesCount 

func (c *ClusterServiceHTTPClientImpl) GetServicesCount(ctx context.Context, in *GetServicesCountRequest, opts ...http.CallOption) (*GetServicesCountResponse, error)

func (*ClusterServiceHTTPClientImpl) ListEdges 

func (c *ClusterServiceHTTPClientImpl) ListEdges(ctx context.Context, in *ListEdgesRequest, opts ...http.CallOption) (*ListEdgesResponse, error)

func (*ClusterServiceHTTPClientImpl) ListFrontiers 

func (c *ClusterServiceHTTPClientImpl) ListFrontiers(ctx context.Context, in *ListFrontiersRequest, opts ...http.CallOption) (*ListFrontiersResponse, error)

func (*ClusterServiceHTTPClientImpl) ListServices 

func (c *ClusterServiceHTTPClientImpl) ListServices(ctx context.Context, in *ListServicesRequest, opts ...http.CallOption) (*ListServicesResponse, error)

type ClusterServiceHTTPServer 

type ClusterServiceHTTPServer interface {
	GetEdgeByID(context.Context, *GetEdgeByIDRequest) (*GetEdgeByIDResponse, error)
	GetEdgesCount(context.Context, *GetEdgesCountRequest) (*GetEdgesCountResponse, error)
	GetFrontierByEdge(context.Context, *GetFrontierByEdgeIDRequest) (*GetFrontierByEdgeIDResponse, error)
	GetServiceByID(context.Context, *GetServiceByIDRequest) (*GetServiceByIDResponse, error)
	GetServicesCount(context.Context, *GetServicesCountRequest) (*GetServicesCountResponse, error)
	ListEdges(context.Context, *ListEdgesRequest) (*ListEdgesResponse, error)
	ListFrontiers(context.Context, *ListFrontiersRequest) (*ListFrontiersResponse, error)
	ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
}

type ClusterServiceServer 

type ClusterServiceServer interface {
	GetFrontierByEdge(context.Context, *GetFrontierByEdgeIDRequest) (*GetFrontierByEdgeIDResponse, error)
	ListFrontiers(context.Context, *ListFrontiersRequest) (*ListFrontiersResponse, error)
	ListEdges(context.Context, *ListEdgesRequest) (*ListEdgesResponse, error)
	GetEdgeByID(context.Context, *GetEdgeByIDRequest) (*GetEdgeByIDResponse, error)
	GetEdgesCount(context.Context, *GetEdgesCountRequest) (*GetEdgesCountResponse, error)
	ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
	GetServiceByID(context.Context, *GetServiceByIDRequest) (*GetServiceByIDResponse, error)
	GetServicesCount(context.Context, *GetServicesCountRequest) (*GetServicesCountResponse, error)
	// contains filtered or unexported methods
}

ClusterServiceServer is the server API for ClusterService service. All implementations must embed UnimplementedClusterServiceServer for forward compatibility

type Edge 

type Edge struct {
	EdgeId     uint64 `protobuf:"varint,1,opt,name=edge_id,json=edgeId,proto3" json:"edge_id,omitempty"`
	Addr       string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	UpdateTime uint64 `protobuf:"varint,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	FrontierId string `protobuf:"bytes,4,opt,name=frontier_id,json=frontierId,proto3" json:"frontier_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Edge) Descriptor deprecated 

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

Deprecated: Use Edge.ProtoReflect.Descriptor instead.

func (*Edge) GetAddr 

func (x *Edge) GetAddr() string

func (*Edge) GetEdgeId 

func (x *Edge) GetEdgeId() uint64

func (*Edge) GetFrontierId 

func (x *Edge) GetFrontierId() string

func (*Edge) GetUpdateTime 

func (x *Edge) GetUpdateTime() uint64

func (*Edge) ProtoMessage 

func (*Edge) ProtoMessage()

func (*Edge) ProtoReflect 

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

func (*Edge) Reset 

func (x *Edge) Reset()

func (*Edge) String 

func (x *Edge) String() string

type Frontier 

type Frontier struct {
	FrontierId       string `protobuf:"bytes,1,opt,name=frontier_id,json=frontierId,proto3" json:"frontier_id,omitempty"`
	AdvertisedSbAddr string `protobuf:"bytes,2,opt,name=advertised_sb_addr,json=advertisedSbAddr,proto3" json:"advertised_sb_addr,omitempty"`
	AdvertisedEbAddr string `protobuf:"bytes,3,opt,name=advertised_eb_addr,json=advertisedEbAddr,proto3" json:"advertised_eb_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*Frontier) Descriptor deprecated 

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

Deprecated: Use Frontier.ProtoReflect.Descriptor instead.

func (*Frontier) GetAdvertisedEbAddr 

func (x *Frontier) GetAdvertisedEbAddr() string

func (*Frontier) GetAdvertisedSbAddr 

func (x *Frontier) GetAdvertisedSbAddr() string

func (*Frontier) GetFrontierId 

func (x *Frontier) GetFrontierId() string

func (*Frontier) ProtoMessage 

func (*Frontier) ProtoMessage()

func (*Frontier) ProtoReflect 

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

func (*Frontier) Reset 

func (x *Frontier) Reset()

func (*Frontier) String 

func (x *Frontier) String() string

type GetEdgeByIDRequest 

type GetEdgeByIDRequest struct {
	EdgeId uint64 `protobuf:"varint,1,opt,name=edge_id,json=edgeId,proto3" json:"edge_id,omitempty"`
	// contains filtered or unexported fields
}

get edge

func (*GetEdgeByIDRequest) Descriptor deprecated 

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

Deprecated: Use GetEdgeByIDRequest.ProtoReflect.Descriptor instead.

func (*GetEdgeByIDRequest) GetEdgeId 

func (x *GetEdgeByIDRequest) GetEdgeId() uint64

func (*GetEdgeByIDRequest) ProtoMessage 

func (*GetEdgeByIDRequest) ProtoMessage()

func (*GetEdgeByIDRequest) ProtoReflect 

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

func (*GetEdgeByIDRequest) Reset 

func (x *GetEdgeByIDRequest) Reset()

func (*GetEdgeByIDRequest) String 

func (x *GetEdgeByIDRequest) String() string

type GetEdgeByIDResponse 

type GetEdgeByIDResponse struct {
	Edge *Edge `protobuf:"bytes,1,opt,name=edge,proto3" json:"edge,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEdgeByIDResponse) Descriptor deprecated 

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

Deprecated: Use GetEdgeByIDResponse.ProtoReflect.Descriptor instead.

func (*GetEdgeByIDResponse) GetEdge 

func (x *GetEdgeByIDResponse) GetEdge() *Edge

func (*GetEdgeByIDResponse) ProtoMessage 

func (*GetEdgeByIDResponse) ProtoMessage()

func (*GetEdgeByIDResponse) ProtoReflect 

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

func (*GetEdgeByIDResponse) Reset 

func (x *GetEdgeByIDResponse) Reset()

func (*GetEdgeByIDResponse) String 

func (x *GetEdgeByIDResponse) String() string

type GetEdgesCountRequest 

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

get edges count

func (*GetEdgesCountRequest) Descriptor deprecated 

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

Deprecated: Use GetEdgesCountRequest.ProtoReflect.Descriptor instead.

func (*GetEdgesCountRequest) ProtoMessage 

func (*GetEdgesCountRequest) ProtoMessage()

func (*GetEdgesCountRequest) ProtoReflect 

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

func (*GetEdgesCountRequest) Reset 

func (x *GetEdgesCountRequest) Reset()

func (*GetEdgesCountRequest) String 

func (x *GetEdgesCountRequest) String() string

type GetEdgesCountResponse 

type GetEdgesCountResponse struct {
	Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEdgesCountResponse) Descriptor deprecated 

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

Deprecated: Use GetEdgesCountResponse.ProtoReflect.Descriptor instead.

func (*GetEdgesCountResponse) GetCount 

func (x *GetEdgesCountResponse) GetCount() uint64

func (*GetEdgesCountResponse) ProtoMessage 

func (*GetEdgesCountResponse) ProtoMessage()

func (*GetEdgesCountResponse) ProtoReflect 

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

func (*GetEdgesCountResponse) Reset 

func (x *GetEdgesCountResponse) Reset()

func (*GetEdgesCountResponse) String 

func (x *GetEdgesCountResponse) String() string

type GetFrontierByEdgeIDRequest 

type GetFrontierByEdgeIDRequest struct {
	EdgeId uint64 `protobuf:"varint,1,opt,name=edge_id,json=edgeId,proto3" json:"edge_id,omitempty"`
	// contains filtered or unexported fields
}

get frontier

func (*GetFrontierByEdgeIDRequest) Descriptor deprecated 

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

Deprecated: Use GetFrontierByEdgeIDRequest.ProtoReflect.Descriptor instead.

func (*GetFrontierByEdgeIDRequest) GetEdgeId 

func (x *GetFrontierByEdgeIDRequest) GetEdgeId() uint64

func (*GetFrontierByEdgeIDRequest) ProtoMessage 

func (*GetFrontierByEdgeIDRequest) ProtoMessage()

func (*GetFrontierByEdgeIDRequest) ProtoReflect 

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

func (*GetFrontierByEdgeIDRequest) Reset 

func (x *GetFrontierByEdgeIDRequest) Reset()

func (*GetFrontierByEdgeIDRequest) String 

func (x *GetFrontierByEdgeIDRequest) String() string

type GetFrontierByEdgeIDResponse 

type GetFrontierByEdgeIDResponse struct {
	Fontier *Frontier `protobuf:"bytes,1,opt,name=fontier,proto3" json:"fontier,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFrontierByEdgeIDResponse) Descriptor deprecated 

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

Deprecated: Use GetFrontierByEdgeIDResponse.ProtoReflect.Descriptor instead.

func (*GetFrontierByEdgeIDResponse) GetFontier 

func (x *GetFrontierByEdgeIDResponse) GetFontier() *Frontier

func (*GetFrontierByEdgeIDResponse) ProtoMessage 

func (*GetFrontierByEdgeIDResponse) ProtoMessage()

func (*GetFrontierByEdgeIDResponse) ProtoReflect 

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

func (*GetFrontierByEdgeIDResponse) Reset 

func (x *GetFrontierByEdgeIDResponse) Reset()

func (*GetFrontierByEdgeIDResponse) String 

func (x *GetFrontierByEdgeIDResponse) String() string

type GetServiceByIDRequest 

type GetServiceByIDRequest struct {
	ServiceId uint64 `protobuf:"varint,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// contains filtered or unexported fields
}

get service

func (*GetServiceByIDRequest) Descriptor deprecated 

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

Deprecated: Use GetServiceByIDRequest.ProtoReflect.Descriptor instead.

func (*GetServiceByIDRequest) GetServiceId 

func (x *GetServiceByIDRequest) GetServiceId() uint64

func (*GetServiceByIDRequest) ProtoMessage 

func (*GetServiceByIDRequest) ProtoMessage()

func (*GetServiceByIDRequest) ProtoReflect 

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

func (*GetServiceByIDRequest) Reset 

func (x *GetServiceByIDRequest) Reset()

func (*GetServiceByIDRequest) String 

func (x *GetServiceByIDRequest) String() string

type GetServiceByIDResponse 

type GetServiceByIDResponse struct {
	Service *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServiceByIDResponse) Descriptor deprecated 

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

Deprecated: Use GetServiceByIDResponse.ProtoReflect.Descriptor instead.

func (*GetServiceByIDResponse) GetService 

func (x *GetServiceByIDResponse) GetService() *Service

func (*GetServiceByIDResponse) ProtoMessage 

func (*GetServiceByIDResponse) ProtoMessage()

func (*GetServiceByIDResponse) ProtoReflect 

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

func (*GetServiceByIDResponse) Reset 

func (x *GetServiceByIDResponse) Reset()

func (*GetServiceByIDResponse) String 

func (x *GetServiceByIDResponse) String() string

type GetServicesCountRequest 

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

get services count

func (*GetServicesCountRequest) Descriptor deprecated 

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

Deprecated: Use GetServicesCountRequest.ProtoReflect.Descriptor instead.

func (*GetServicesCountRequest) ProtoMessage 

func (*GetServicesCountRequest) ProtoMessage()

func (*GetServicesCountRequest) ProtoReflect 

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

func (*GetServicesCountRequest) Reset 

func (x *GetServicesCountRequest) Reset()

func (*GetServicesCountRequest) String 

func (x *GetServicesCountRequest) String() string

type GetServicesCountResponse 

type GetServicesCountResponse struct {
	Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServicesCountResponse) Descriptor deprecated 

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

Deprecated: Use GetServicesCountResponse.ProtoReflect.Descriptor instead.

func (*GetServicesCountResponse) GetCount 

func (x *GetServicesCountResponse) GetCount() uint64

func (*GetServicesCountResponse) ProtoMessage 

func (*GetServicesCountResponse) ProtoMessage()

func (*GetServicesCountResponse) ProtoReflect 

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

func (*GetServicesCountResponse) Reset 

func (x *GetServicesCountResponse) Reset()

func (*GetServicesCountResponse) String 

func (x *GetServicesCountResponse) String() string

type HealthCheckRequest 

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

func (*HealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetService 

func (x *HealthCheckRequest) GetService() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=controlplane.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetStatus 

func (x *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect 

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

func (*HealthCheckResponse) Reset 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (x *HealthCheckResponse) String() string

type HealthCheckResponse_ServingStatus 

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN         HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING         HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING     HealthCheckResponse_ServingStatus = 2
	HealthCheckResponse_SERVICE_UNKNOWN HealthCheckResponse_ServingStatus = 3 // Used only by the Watch method.
)

func (HealthCheckResponse_ServingStatus) Descriptor 

func (HealthCheckResponse_ServingStatus) Descriptor() protoreflect.EnumDescriptor

func (HealthCheckResponse_ServingStatus) Enum 

func (x HealthCheckResponse_ServingStatus) Enum() *HealthCheckResponse_ServingStatus

func (HealthCheckResponse_ServingStatus) EnumDescriptor deprecated 

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

Deprecated: Use HealthCheckResponse_ServingStatus.Descriptor instead.

func (HealthCheckResponse_ServingStatus) Number 

func (x HealthCheckResponse_ServingStatus) Number() protoreflect.EnumNumber

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

func (HealthCheckResponse_ServingStatus) Type 

func (HealthCheckResponse_ServingStatus) Type() protoreflect.EnumType

type HealthClient 

type HealthClient interface {
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (Health_WatchClient, error)
}

HealthClient is the client API for Health 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 NewHealthClient 

func NewHealthClient(cc grpc.ClientConnInterface) HealthClient

type HealthHTTPClient 

type HealthHTTPClient interface {
	Check(ctx context.Context, req *HealthCheckRequest, opts ...http.CallOption) (rsp *HealthCheckResponse, err error)
}

func NewHealthHTTPClient 

func NewHealthHTTPClient(client *http.Client) HealthHTTPClient

type HealthHTTPClientImpl 

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

func (*HealthHTTPClientImpl) Check 

func (c *HealthHTTPClientImpl) Check(ctx context.Context, in *HealthCheckRequest, opts ...http.CallOption) (*HealthCheckResponse, error)

type HealthHTTPServer 

type HealthHTTPServer interface {
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
}

type HealthServer 

type HealthServer interface {
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	Watch(*HealthCheckRequest, Health_WatchServer) error
	// contains filtered or unexported methods
}

HealthServer is the server API for Health service. All implementations must embed UnimplementedHealthServer for forward compatibility

type Health_WatchClient 

type Health_WatchClient interface {
	Recv() (*HealthCheckResponse, error)
	grpc.ClientStream
}

type Health_WatchServer 

type Health_WatchServer interface {
	Send(*HealthCheckResponse) error
	grpc.ServerStream
}

type ListEdgesRequest 

type ListEdgesRequest struct {
	Cursor  *uint32  `protobuf:"varint,1,opt,name=cursor,proto3,oneof" json:"cursor,omitempty"`
	Count   *uint32  `protobuf:"varint,2,opt,name=count,proto3,oneof" json:"count,omitempty"`
	EdgeIds []uint64 `protobuf:"varint,3,rep,packed,name=edge_ids,json=edgeIds,proto3" json:"edge_ids,omitempty"`
	// contains filtered or unexported fields
}

list edges

func (*ListEdgesRequest) Descriptor deprecated 

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

Deprecated: Use ListEdgesRequest.ProtoReflect.Descriptor instead.

func (*ListEdgesRequest) GetCount 

func (x *ListEdgesRequest) GetCount() uint32

func (*ListEdgesRequest) GetCursor 

func (x *ListEdgesRequest) GetCursor() uint32

func (*ListEdgesRequest) GetEdgeIds 

func (x *ListEdgesRequest) GetEdgeIds() []uint64

func (*ListEdgesRequest) ProtoMessage 

func (*ListEdgesRequest) ProtoMessage()

func (*ListEdgesRequest) ProtoReflect 

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

func (*ListEdgesRequest) Reset 

func (x *ListEdgesRequest) Reset()

func (*ListEdgesRequest) String 

func (x *ListEdgesRequest) String() string

type ListEdgesResponse 

type ListEdgesResponse struct {
	Cursor *uint32 `protobuf:"varint,1,opt,name=cursor,proto3,oneof" json:"cursor,omitempty"`
	Edges  []*Edge `protobuf:"bytes,2,rep,name=edges,proto3" json:"edges,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEdgesResponse) Descriptor deprecated 

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

Deprecated: Use ListEdgesResponse.ProtoReflect.Descriptor instead.

func (*ListEdgesResponse) GetCursor 

func (x *ListEdgesResponse) GetCursor() uint32

func (*ListEdgesResponse) GetEdges 

func (x *ListEdgesResponse) GetEdges() []*Edge

func (*ListEdgesResponse) ProtoMessage 

func (*ListEdgesResponse) ProtoMessage()

func (*ListEdgesResponse) ProtoReflect 

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

func (*ListEdgesResponse) Reset 

func (x *ListEdgesResponse) Reset()

func (*ListEdgesResponse) String 

func (x *ListEdgesResponse) String() string

type ListFrontiersRequest 

type ListFrontiersRequest struct {
	Cursor      *uint32  `protobuf:"varint,1,opt,name=cursor,proto3,oneof" json:"cursor,omitempty"`
	Count       *uint32  `protobuf:"varint,2,opt,name=count,proto3,oneof" json:"count,omitempty"`
	EdgeIds     []uint64 `protobuf:"varint,3,rep,packed,name=edge_ids,json=edgeIds,proto3" json:"edge_ids,omitempty"`
	FrontierIds []string `protobuf:"bytes,4,rep,name=frontier_ids,json=frontierIds,proto3" json:"frontier_ids,omitempty"`
	// contains filtered or unexported fields
}

list frontiers

func (*ListFrontiersRequest) Descriptor deprecated 

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

Deprecated: Use ListFrontiersRequest.ProtoReflect.Descriptor instead.

func (*ListFrontiersRequest) GetCount 

func (x *ListFrontiersRequest) GetCount() uint32

func (*ListFrontiersRequest) GetCursor 

func (x *ListFrontiersRequest) GetCursor() uint32

func (*ListFrontiersRequest) GetEdgeIds 

func (x *ListFrontiersRequest) GetEdgeIds() []uint64

func (*ListFrontiersRequest) GetFrontierIds 

func (x *ListFrontiersRequest) GetFrontierIds() []string

func (*ListFrontiersRequest) ProtoMessage 

func (*ListFrontiersRequest) ProtoMessage()

func (*ListFrontiersRequest) ProtoReflect 

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

func (*ListFrontiersRequest) Reset 

func (x *ListFrontiersRequest) Reset()

func (*ListFrontiersRequest) String 

func (x *ListFrontiersRequest) String() string

type ListFrontiersResponse 

type ListFrontiersResponse struct {
	Cursor    *uint32     `protobuf:"varint,1,opt,name=cursor,proto3,oneof" json:"cursor,omitempty"`
	Frontiers []*Frontier `protobuf:"bytes,2,rep,name=frontiers,proto3" json:"frontiers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFrontiersResponse) Descriptor deprecated 

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

Deprecated: Use ListFrontiersResponse.ProtoReflect.Descriptor instead.

func (*ListFrontiersResponse) GetCursor 

func (x *ListFrontiersResponse) GetCursor() uint32

func (*ListFrontiersResponse) GetFrontiers 

func (x *ListFrontiersResponse) GetFrontiers() []*Frontier

func (*ListFrontiersResponse) ProtoMessage 

func (*ListFrontiersResponse) ProtoMessage()

func (*ListFrontiersResponse) ProtoReflect 

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

func (*ListFrontiersResponse) Reset 

func (x *ListFrontiersResponse) Reset()

func (*ListFrontiersResponse) String 

func (x *ListFrontiersResponse) String() string

type ListServicesRequest 

type ListServicesRequest struct {
	Cursor     *uint32  `protobuf:"varint,1,opt,name=cursor,proto3,oneof" json:"cursor,omitempty"`
	Count      *uint32  `protobuf:"varint,2,opt,name=count,proto3,oneof" json:"count,omitempty"`
	ServiceIds []uint64 `protobuf:"varint,3,rep,packed,name=service_ids,json=serviceIds,proto3" json:"service_ids,omitempty"`
	// contains filtered or unexported fields
}

list services

func (*ListServicesRequest) Descriptor deprecated 

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

Deprecated: Use ListServicesRequest.ProtoReflect.Descriptor instead.

func (*ListServicesRequest) GetCount 

func (x *ListServicesRequest) GetCount() uint32

func (*ListServicesRequest) GetCursor 

func (x *ListServicesRequest) GetCursor() uint32

func (*ListServicesRequest) GetServiceIds 

func (x *ListServicesRequest) GetServiceIds() []uint64

func (*ListServicesRequest) ProtoMessage 

func (*ListServicesRequest) ProtoMessage()

func (*ListServicesRequest) ProtoReflect 

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

func (*ListServicesRequest) Reset 

func (x *ListServicesRequest) Reset()

func (*ListServicesRequest) String 

func (x *ListServicesRequest) String() string

type ListServicesResponse 

type ListServicesResponse struct {
	Cursor   *uint32    `protobuf:"varint,1,opt,name=cursor,proto3,oneof" json:"cursor,omitempty"`
	Services []*Service `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServicesResponse) Descriptor deprecated 

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

Deprecated: Use ListServicesResponse.ProtoReflect.Descriptor instead.

func (*ListServicesResponse) GetCursor 

func (x *ListServicesResponse) GetCursor() uint32

func (*ListServicesResponse) GetServices 

func (x *ListServicesResponse) GetServices() []*Service

func (*ListServicesResponse) ProtoMessage 

func (*ListServicesResponse) ProtoMessage()

func (*ListServicesResponse) ProtoReflect 

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

func (*ListServicesResponse) Reset 

func (x *ListServicesResponse) Reset()

func (*ListServicesResponse) String 

func (x *ListServicesResponse) String() string

type Service 

type Service struct {
	Service    string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Addr       string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	UpdateTime uint64 `protobuf:"varint,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	FrontierId string `protobuf:"bytes,4,opt,name=frontier_id,json=frontierId,proto3" json:"frontier_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetAddr 

func (x *Service) GetAddr() string

func (*Service) GetFrontierId 

func (x *Service) GetFrontierId() string

func (*Service) GetService 

func (x *Service) GetService() string

func (*Service) GetUpdateTime 

func (x *Service) GetUpdateTime() uint64

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type UnimplementedClusterServiceServer 

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) GetEdgeByID 

func (UnimplementedClusterServiceServer) GetEdgeByID(context.Context, *GetEdgeByIDRequest) (*GetEdgeByIDResponse, error)

func (UnimplementedClusterServiceServer) GetEdgesCount 

func (UnimplementedClusterServiceServer) GetEdgesCount(context.Context, *GetEdgesCountRequest) (*GetEdgesCountResponse, error)

func (UnimplementedClusterServiceServer) GetFrontierByEdge 

func (UnimplementedClusterServiceServer) GetFrontierByEdge(context.Context, *GetFrontierByEdgeIDRequest) (*GetFrontierByEdgeIDResponse, error)

func (UnimplementedClusterServiceServer) GetServiceByID 

func (UnimplementedClusterServiceServer) GetServiceByID(context.Context, *GetServiceByIDRequest) (*GetServiceByIDResponse, error)

func (UnimplementedClusterServiceServer) GetServicesCount 

func (UnimplementedClusterServiceServer) GetServicesCount(context.Context, *GetServicesCountRequest) (*GetServicesCountResponse, error)

func (UnimplementedClusterServiceServer) ListEdges 

func (UnimplementedClusterServiceServer) ListEdges(context.Context, *ListEdgesRequest) (*ListEdgesResponse, error)

func (UnimplementedClusterServiceServer) ListFrontiers 

func (UnimplementedClusterServiceServer) ListFrontiers(context.Context, *ListFrontiersRequest) (*ListFrontiersResponse, error)

func (UnimplementedClusterServiceServer) ListServices 

func (UnimplementedClusterServiceServer) ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)

type UnimplementedHealthServer 

type UnimplementedHealthServer struct {
}

UnimplementedHealthServer must be embedded to have forward compatible implementations.

func (UnimplementedHealthServer) Check 

func (UnimplementedHealthServer) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

func (UnimplementedHealthServer) Watch 

func (UnimplementedHealthServer) Watch(*HealthCheckRequest, Health_WatchServer) error

type UnsafeClusterServiceServer 

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

UnsafeClusterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServiceServer will result in compilation errors.

type UnsafeHealthServer 

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

UnsafeHealthServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthServer will result in compilation errors.

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.