Versions in this module Expand all Collapse all v1 v1.1.0 May 31, 2024 Changes in this version + const ControlPlane_GetEdge_FullMethodName + const ControlPlane_GetService_FullMethodName + const ControlPlane_KickEdge_FullMethodName + const ControlPlane_KickService_FullMethodName + const ControlPlane_ListEdgeRPCs_FullMethodName + const ControlPlane_ListEdges_FullMethodName + const ControlPlane_ListServiceRPCs_FullMethodName + const ControlPlane_ListServiceTopics_FullMethodName + const ControlPlane_ListServices_FullMethodName + const OperationControlPlaneGetEdge + const OperationControlPlaneGetService + const OperationControlPlaneKickEdge + const OperationControlPlaneKickService + const OperationControlPlaneListEdgeRPCs + const OperationControlPlaneListEdges + const OperationControlPlaneListServiceRPCs + const OperationControlPlaneListServiceTopics + const OperationControlPlaneListServices + var ControlPlane_ServiceDesc = grpc.ServiceDesc + var File_controlplane_proto protoreflect.FileDescriptor + func RegisterControlPlaneHTTPServer(s *http.Server, srv ControlPlaneHTTPServer) + func RegisterControlPlaneServer(s grpc.ServiceRegistrar, srv ControlPlaneServer) + type ControlPlaneClient interface + GetEdge func(ctx context.Context, in *GetEdgeRequest, opts ...grpc.CallOption) (*Edge, error) + GetService func(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*Service, error) + KickEdge func(ctx context.Context, in *KickEdgeRequest, opts ...grpc.CallOption) (*KickEdgeResponse, error) + KickService func(ctx context.Context, in *KickServiceRequest, opts ...grpc.CallOption) (*KickServiceResponse, error) + ListEdgeRPCs func(ctx context.Context, in *ListEdgeRPCsRequest, opts ...grpc.CallOption) (*ListEdgeRPCsResponse, error) + ListEdges func(ctx context.Context, in *ListEdgesRequest, opts ...grpc.CallOption) (*ListEdgesResponse, error) + ListServiceRPCs func(ctx context.Context, in *ListServiceRPCsRequest, opts ...grpc.CallOption) (*ListServiceRPCsResponse, error) + ListServiceTopics func(ctx context.Context, in *ListServiceTopicsRequest, opts ...grpc.CallOption) (*ListServiceTopicsResponse, error) + ListServices func(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error) + func NewControlPlaneClient(cc grpc.ClientConnInterface) ControlPlaneClient + type ControlPlaneHTTPClient interface + GetEdge func(ctx context.Context, req *GetEdgeRequest, opts ...http.CallOption) (rsp *Edge, err error) + GetService func(ctx context.Context, req *GetServiceRequest, opts ...http.CallOption) (rsp *Service, err error) + KickEdge func(ctx context.Context, req *KickEdgeRequest, opts ...http.CallOption) (rsp *KickEdgeResponse, err error) + KickService func(ctx context.Context, req *KickServiceRequest, opts ...http.CallOption) (rsp *KickServiceResponse, err error) + ListEdgeRPCs func(ctx context.Context, req *ListEdgeRPCsRequest, opts ...http.CallOption) (rsp *ListEdgeRPCsResponse, err error) + ListEdges func(ctx context.Context, req *ListEdgesRequest, opts ...http.CallOption) (rsp *ListEdgesResponse, err error) + ListServiceRPCs func(ctx context.Context, req *ListServiceRPCsRequest, opts ...http.CallOption) (rsp *ListServiceRPCsResponse, err error) + ListServiceTopics func(ctx context.Context, req *ListServiceTopicsRequest, opts ...http.CallOption) (rsp *ListServiceTopicsResponse, err error) + ListServices func(ctx context.Context, req *ListServicesRequest, opts ...http.CallOption) (rsp *ListServicesResponse, err error) + func NewControlPlaneHTTPClient(client *http.Client) ControlPlaneHTTPClient + type ControlPlaneHTTPClientImpl struct + func (c *ControlPlaneHTTPClientImpl) GetEdge(ctx context.Context, in *GetEdgeRequest, opts ...http.CallOption) (*Edge, error) + func (c *ControlPlaneHTTPClientImpl) GetService(ctx context.Context, in *GetServiceRequest, opts ...http.CallOption) (*Service, error) + func (c *ControlPlaneHTTPClientImpl) KickEdge(ctx context.Context, in *KickEdgeRequest, opts ...http.CallOption) (*KickEdgeResponse, error) + func (c *ControlPlaneHTTPClientImpl) KickService(ctx context.Context, in *KickServiceRequest, opts ...http.CallOption) (*KickServiceResponse, error) + func (c *ControlPlaneHTTPClientImpl) ListEdgeRPCs(ctx context.Context, in *ListEdgeRPCsRequest, opts ...http.CallOption) (*ListEdgeRPCsResponse, error) + func (c *ControlPlaneHTTPClientImpl) ListEdges(ctx context.Context, in *ListEdgesRequest, opts ...http.CallOption) (*ListEdgesResponse, error) + func (c *ControlPlaneHTTPClientImpl) ListServiceRPCs(ctx context.Context, in *ListServiceRPCsRequest, opts ...http.CallOption) (*ListServiceRPCsResponse, error) + func (c *ControlPlaneHTTPClientImpl) ListServiceTopics(ctx context.Context, in *ListServiceTopicsRequest, opts ...http.CallOption) (*ListServiceTopicsResponse, error) + func (c *ControlPlaneHTTPClientImpl) ListServices(ctx context.Context, in *ListServicesRequest, opts ...http.CallOption) (*ListServicesResponse, error) + type ControlPlaneHTTPServer interface + GetEdge func(context.Context, *GetEdgeRequest) (*Edge, error) + GetService func(context.Context, *GetServiceRequest) (*Service, error) + KickEdge func(context.Context, *KickEdgeRequest) (*KickEdgeResponse, error) + KickService func(context.Context, *KickServiceRequest) (*KickServiceResponse, error) + ListEdgeRPCs func(context.Context, *ListEdgeRPCsRequest) (*ListEdgeRPCsResponse, error) + ListEdges func(context.Context, *ListEdgesRequest) (*ListEdgesResponse, error) + ListServiceRPCs func(context.Context, *ListServiceRPCsRequest) (*ListServiceRPCsResponse, error) + ListServiceTopics func(context.Context, *ListServiceTopicsRequest) (*ListServiceTopicsResponse, error) + ListServices func(context.Context, *ListServicesRequest) (*ListServicesResponse, error) + type ControlPlaneServer interface + GetEdge func(context.Context, *GetEdgeRequest) (*Edge, error) + GetService func(context.Context, *GetServiceRequest) (*Service, error) + KickEdge func(context.Context, *KickEdgeRequest) (*KickEdgeResponse, error) + KickService func(context.Context, *KickServiceRequest) (*KickServiceResponse, error) + ListEdgeRPCs func(context.Context, *ListEdgeRPCsRequest) (*ListEdgeRPCsResponse, error) + ListEdges func(context.Context, *ListEdgesRequest) (*ListEdgesResponse, error) + ListServiceRPCs func(context.Context, *ListServiceRPCsRequest) (*ListServiceRPCsResponse, error) + ListServiceTopics func(context.Context, *ListServiceTopicsRequest) (*ListServiceTopicsResponse, error) + ListServices func(context.Context, *ListServicesRequest) (*ListServicesResponse, error) + type Edge struct + Addr string + CreateTime int64 + EdgeId uint64 + Meta string + func (*Edge) Descriptor() ([]byte, []int) + func (*Edge) ProtoMessage() + func (x *Edge) GetAddr() string + func (x *Edge) GetCreateTime() int64 + func (x *Edge) GetEdgeId() uint64 + func (x *Edge) GetMeta() string + func (x *Edge) ProtoReflect() protoreflect.Message + func (x *Edge) Reset() + func (x *Edge) String() string + type GetEdgeRequest struct + EdgeId uint64 + func (*GetEdgeRequest) Descriptor() ([]byte, []int) + func (*GetEdgeRequest) ProtoMessage() + func (x *GetEdgeRequest) GetEdgeId() uint64 + func (x *GetEdgeRequest) ProtoReflect() protoreflect.Message + func (x *GetEdgeRequest) Reset() + func (x *GetEdgeRequest) String() string + type GetServiceRequest struct + ServiceId uint64 + func (*GetServiceRequest) Descriptor() ([]byte, []int) + func (*GetServiceRequest) ProtoMessage() + func (x *GetServiceRequest) GetServiceId() uint64 + func (x *GetServiceRequest) ProtoReflect() protoreflect.Message + func (x *GetServiceRequest) Reset() + func (x *GetServiceRequest) String() string + type KickEdgeRequest struct + EdgeId uint64 + func (*KickEdgeRequest) Descriptor() ([]byte, []int) + func (*KickEdgeRequest) ProtoMessage() + func (x *KickEdgeRequest) GetEdgeId() uint64 + func (x *KickEdgeRequest) ProtoReflect() protoreflect.Message + func (x *KickEdgeRequest) Reset() + func (x *KickEdgeRequest) String() string + type KickEdgeResponse struct + func (*KickEdgeResponse) Descriptor() ([]byte, []int) + func (*KickEdgeResponse) ProtoMessage() + func (x *KickEdgeResponse) ProtoReflect() protoreflect.Message + func (x *KickEdgeResponse) Reset() + func (x *KickEdgeResponse) String() string + type KickServiceRequest struct + ServiceId uint64 + func (*KickServiceRequest) Descriptor() ([]byte, []int) + func (*KickServiceRequest) ProtoMessage() + func (x *KickServiceRequest) GetServiceId() uint64 + func (x *KickServiceRequest) ProtoReflect() protoreflect.Message + func (x *KickServiceRequest) Reset() + func (x *KickServiceRequest) String() string + type KickServiceResponse struct + func (*KickServiceResponse) Descriptor() ([]byte, []int) + func (*KickServiceResponse) ProtoMessage() + func (x *KickServiceResponse) ProtoReflect() protoreflect.Message + func (x *KickServiceResponse) Reset() + func (x *KickServiceResponse) String() string + type ListEdgeRPCsRequest struct + EdgeId *uint64 + EndTime *int64 + Meta *string + Order *string + Page int64 + PageSize int64 + StartTime *int64 + func (*ListEdgeRPCsRequest) Descriptor() ([]byte, []int) + func (*ListEdgeRPCsRequest) ProtoMessage() + func (x *ListEdgeRPCsRequest) GetEdgeId() uint64 + func (x *ListEdgeRPCsRequest) GetEndTime() int64 + func (x *ListEdgeRPCsRequest) GetMeta() string + func (x *ListEdgeRPCsRequest) GetOrder() string + func (x *ListEdgeRPCsRequest) GetPage() int64 + func (x *ListEdgeRPCsRequest) GetPageSize() int64 + func (x *ListEdgeRPCsRequest) GetStartTime() int64 + func (x *ListEdgeRPCsRequest) ProtoReflect() protoreflect.Message + func (x *ListEdgeRPCsRequest) Reset() + func (x *ListEdgeRPCsRequest) String() string + type ListEdgeRPCsResponse struct + Count int32 + Rpcs []string + func (*ListEdgeRPCsResponse) Descriptor() ([]byte, []int) + func (*ListEdgeRPCsResponse) ProtoMessage() + func (x *ListEdgeRPCsResponse) GetCount() int32 + func (x *ListEdgeRPCsResponse) GetRpcs() []string + func (x *ListEdgeRPCsResponse) ProtoReflect() protoreflect.Message + func (x *ListEdgeRPCsResponse) Reset() + func (x *ListEdgeRPCsResponse) String() string + type ListEdgesRequest struct + Addr *string + EdgeId *uint64 + EndTime *int64 + Meta *string + Order *string + Page int64 + PageSize int64 + Rpc *string + StartTime *int64 + func (*ListEdgesRequest) Descriptor() ([]byte, []int) + func (*ListEdgesRequest) ProtoMessage() + func (x *ListEdgesRequest) GetAddr() string + func (x *ListEdgesRequest) GetEdgeId() uint64 + func (x *ListEdgesRequest) GetEndTime() int64 + func (x *ListEdgesRequest) GetMeta() string + func (x *ListEdgesRequest) GetOrder() string + func (x *ListEdgesRequest) GetPage() int64 + func (x *ListEdgesRequest) GetPageSize() int64 + func (x *ListEdgesRequest) GetRpc() string + func (x *ListEdgesRequest) GetStartTime() int64 + func (x *ListEdgesRequest) ProtoReflect() protoreflect.Message + func (x *ListEdgesRequest) Reset() + func (x *ListEdgesRequest) String() string + type ListEdgesResponse struct + Count int32 + Edges []*Edge + func (*ListEdgesResponse) Descriptor() ([]byte, []int) + func (*ListEdgesResponse) ProtoMessage() + func (x *ListEdgesResponse) GetCount() int32 + func (x *ListEdgesResponse) GetEdges() []*Edge + func (x *ListEdgesResponse) ProtoReflect() protoreflect.Message + func (x *ListEdgesResponse) Reset() + func (x *ListEdgesResponse) String() string + type ListServiceRPCsRequest struct + EndTime *int64 + Order *string + Page int64 + PageSize int64 + Service *string + ServiceId *uint64 + StartTime *int64 + func (*ListServiceRPCsRequest) Descriptor() ([]byte, []int) + func (*ListServiceRPCsRequest) ProtoMessage() + func (x *ListServiceRPCsRequest) GetEndTime() int64 + func (x *ListServiceRPCsRequest) GetOrder() string + func (x *ListServiceRPCsRequest) GetPage() int64 + func (x *ListServiceRPCsRequest) GetPageSize() int64 + func (x *ListServiceRPCsRequest) GetService() string + func (x *ListServiceRPCsRequest) GetServiceId() uint64 + func (x *ListServiceRPCsRequest) GetStartTime() int64 + func (x *ListServiceRPCsRequest) ProtoReflect() protoreflect.Message + func (x *ListServiceRPCsRequest) Reset() + func (x *ListServiceRPCsRequest) String() string + type ListServiceRPCsResponse struct + Count int32 + Rpcs []string + func (*ListServiceRPCsResponse) Descriptor() ([]byte, []int) + func (*ListServiceRPCsResponse) ProtoMessage() + func (x *ListServiceRPCsResponse) GetCount() int32 + func (x *ListServiceRPCsResponse) GetRpcs() []string + func (x *ListServiceRPCsResponse) ProtoReflect() protoreflect.Message + func (x *ListServiceRPCsResponse) Reset() + func (x *ListServiceRPCsResponse) String() string + type ListServiceTopicsRequest struct + EndTime *int64 + Order *string + Page int64 + PageSize int64 + Service *string + ServiceId *uint64 + StartTime *int64 + func (*ListServiceTopicsRequest) Descriptor() ([]byte, []int) + func (*ListServiceTopicsRequest) ProtoMessage() + func (x *ListServiceTopicsRequest) GetEndTime() int64 + func (x *ListServiceTopicsRequest) GetOrder() string + func (x *ListServiceTopicsRequest) GetPage() int64 + func (x *ListServiceTopicsRequest) GetPageSize() int64 + func (x *ListServiceTopicsRequest) GetService() string + func (x *ListServiceTopicsRequest) GetServiceId() uint64 + func (x *ListServiceTopicsRequest) GetStartTime() int64 + func (x *ListServiceTopicsRequest) ProtoReflect() protoreflect.Message + func (x *ListServiceTopicsRequest) Reset() + func (x *ListServiceTopicsRequest) String() string + type ListServiceTopicsResponse struct + Count int32 + Topics []string + func (*ListServiceTopicsResponse) Descriptor() ([]byte, []int) + func (*ListServiceTopicsResponse) ProtoMessage() + func (x *ListServiceTopicsResponse) GetCount() int32 + func (x *ListServiceTopicsResponse) GetTopics() []string + func (x *ListServiceTopicsResponse) ProtoReflect() protoreflect.Message + func (x *ListServiceTopicsResponse) Reset() + func (x *ListServiceTopicsResponse) String() string + type ListServicesRequest struct + Addr *string + EndTime *int64 + Order *string + Page int64 + PageSize int64 + Rpc *string + Service *string + StartTime *int64 + Topic *string + func (*ListServicesRequest) Descriptor() ([]byte, []int) + func (*ListServicesRequest) ProtoMessage() + func (x *ListServicesRequest) GetAddr() string + func (x *ListServicesRequest) GetEndTime() int64 + func (x *ListServicesRequest) GetOrder() string + func (x *ListServicesRequest) GetPage() int64 + func (x *ListServicesRequest) GetPageSize() int64 + func (x *ListServicesRequest) GetRpc() string + func (x *ListServicesRequest) GetService() string + func (x *ListServicesRequest) GetStartTime() int64 + func (x *ListServicesRequest) GetTopic() string + func (x *ListServicesRequest) ProtoReflect() protoreflect.Message + func (x *ListServicesRequest) Reset() + func (x *ListServicesRequest) String() string + type ListServicesResponse struct + Count int32 + Services []*Service + func (*ListServicesResponse) Descriptor() ([]byte, []int) + func (*ListServicesResponse) ProtoMessage() + func (x *ListServicesResponse) GetCount() int32 + func (x *ListServicesResponse) GetServices() []*Service + func (x *ListServicesResponse) ProtoReflect() protoreflect.Message + func (x *ListServicesResponse) Reset() + func (x *ListServicesResponse) String() string + type Service struct + Addr string + CreateTime int64 + Service string + ServiceId uint64 + func (*Service) Descriptor() ([]byte, []int) + func (*Service) ProtoMessage() + func (x *Service) GetAddr() string + func (x *Service) GetCreateTime() int64 + func (x *Service) GetService() string + func (x *Service) GetServiceId() uint64 + func (x *Service) ProtoReflect() protoreflect.Message + func (x *Service) Reset() + func (x *Service) String() string + type UnimplementedControlPlaneServer struct + func (UnimplementedControlPlaneServer) GetEdge(context.Context, *GetEdgeRequest) (*Edge, error) + func (UnimplementedControlPlaneServer) GetService(context.Context, *GetServiceRequest) (*Service, error) + func (UnimplementedControlPlaneServer) KickEdge(context.Context, *KickEdgeRequest) (*KickEdgeResponse, error) + func (UnimplementedControlPlaneServer) KickService(context.Context, *KickServiceRequest) (*KickServiceResponse, error) + func (UnimplementedControlPlaneServer) ListEdgeRPCs(context.Context, *ListEdgeRPCsRequest) (*ListEdgeRPCsResponse, error) + func (UnimplementedControlPlaneServer) ListEdges(context.Context, *ListEdgesRequest) (*ListEdgesResponse, error) + func (UnimplementedControlPlaneServer) ListServiceRPCs(context.Context, *ListServiceRPCsRequest) (*ListServiceRPCsResponse, error) + func (UnimplementedControlPlaneServer) ListServiceTopics(context.Context, *ListServiceTopicsRequest) (*ListServiceTopicsResponse, error) + func (UnimplementedControlPlaneServer) ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error) + type UnsafeControlPlaneServer interface
Go to main page