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 (
	ControlPlane_ListEdges_FullMethodName         = "/controlplane.ControlPlane/ListEdges"
	ControlPlane_GetEdge_FullMethodName           = "/controlplane.ControlPlane/GetEdge"
	ControlPlane_KickEdge_FullMethodName          = "/controlplane.ControlPlane/KickEdge"
	ControlPlane_ListEdgeRPCs_FullMethodName      = "/controlplane.ControlPlane/ListEdgeRPCs"
	ControlPlane_ListServices_FullMethodName      = "/controlplane.ControlPlane/ListServices"
	ControlPlane_GetService_FullMethodName        = "/controlplane.ControlPlane/GetService"
	ControlPlane_KickService_FullMethodName       = "/controlplane.ControlPlane/KickService"
	ControlPlane_ListServiceRPCs_FullMethodName   = "/controlplane.ControlPlane/ListServiceRPCs"
	ControlPlane_ListServiceTopics_FullMethodName = "/controlplane.ControlPlane/ListServiceTopics"
)
View Source 
const OperationControlPlaneGetEdge = "/controlplane.ControlPlane/GetEdge"
View Source 
const OperationControlPlaneGetService = "/controlplane.ControlPlane/GetService"
View Source 
const OperationControlPlaneKickEdge = "/controlplane.ControlPlane/KickEdge"
View Source 
const OperationControlPlaneKickService = "/controlplane.ControlPlane/KickService"
View Source 
const OperationControlPlaneListEdgeRPCs = "/controlplane.ControlPlane/ListEdgeRPCs"
View Source 
const OperationControlPlaneListEdges = "/controlplane.ControlPlane/ListEdges"
View Source 
const OperationControlPlaneListServiceRPCs = "/controlplane.ControlPlane/ListServiceRPCs"
View Source 
const OperationControlPlaneListServiceTopics = "/controlplane.ControlPlane/ListServiceTopics"
View Source 
const OperationControlPlaneListServices = "/controlplane.ControlPlane/ListServices"

Variables

View Source 
var ControlPlane_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "controlplane.ControlPlane",
	HandlerType: (*ControlPlaneServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListEdges",
			Handler:    _ControlPlane_ListEdges_Handler,
		},
		{
			MethodName: "GetEdge",
			Handler:    _ControlPlane_GetEdge_Handler,
		},
		{
			MethodName: "KickEdge",
			Handler:    _ControlPlane_KickEdge_Handler,
		},
		{
			MethodName: "ListEdgeRPCs",
			Handler:    _ControlPlane_ListEdgeRPCs_Handler,
		},
		{
			MethodName: "ListServices",
			Handler:    _ControlPlane_ListServices_Handler,
		},
		{
			MethodName: "GetService",
			Handler:    _ControlPlane_GetService_Handler,
		},
		{
			MethodName: "KickService",
			Handler:    _ControlPlane_KickService_Handler,
		},
		{
			MethodName: "ListServiceRPCs",
			Handler:    _ControlPlane_ListServiceRPCs_Handler,
		},
		{
			MethodName: "ListServiceTopics",
			Handler:    _ControlPlane_ListServiceTopics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "controlplane.proto",
}

ControlPlane_ServiceDesc is the grpc.ServiceDesc for ControlPlane 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_controlplane_proto protoreflect.FileDescriptor

Functions

func RegisterControlPlaneHTTPServer 

func RegisterControlPlaneHTTPServer(s *http.Server, srv ControlPlaneHTTPServer)

func RegisterControlPlaneServer 

func RegisterControlPlaneServer(s grpc.ServiceRegistrar, srv ControlPlaneServer)

Types

type ControlPlaneClient 

type ControlPlaneClient interface {
	// edge related
	ListEdges(ctx context.Context, in *ListEdgesRequest, opts ...grpc.CallOption) (*ListEdgesResponse, error)
	GetEdge(ctx context.Context, in *GetEdgeRequest, opts ...grpc.CallOption) (*Edge, error)
	KickEdge(ctx context.Context, in *KickEdgeRequest, opts ...grpc.CallOption) (*KickEdgeResponse, error)
	ListEdgeRPCs(ctx context.Context, in *ListEdgeRPCsRequest, opts ...grpc.CallOption) (*ListEdgeRPCsResponse, error)
	// service related
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error)
	GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*Service, error)
	KickService(ctx context.Context, in *KickServiceRequest, opts ...grpc.CallOption) (*KickServiceResponse, error)
	ListServiceRPCs(ctx context.Context, in *ListServiceRPCsRequest, opts ...grpc.CallOption) (*ListServiceRPCsResponse, error)
	ListServiceTopics(ctx context.Context, in *ListServiceTopicsRequest, opts ...grpc.CallOption) (*ListServiceTopicsResponse, error)
}

ControlPlaneClient is the client API for ControlPlane 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 NewControlPlaneClient 

func NewControlPlaneClient(cc grpc.ClientConnInterface) ControlPlaneClient

type ControlPlaneHTTPClient 

type ControlPlaneHTTPClient interface {
	GetEdge(ctx context.Context, req *GetEdgeRequest, opts ...http.CallOption) (rsp *Edge, err error)
	GetService(ctx context.Context, req *GetServiceRequest, opts ...http.CallOption) (rsp *Service, err error)
	KickEdge(ctx context.Context, req *KickEdgeRequest, opts ...http.CallOption) (rsp *KickEdgeResponse, err error)
	KickService(ctx context.Context, req *KickServiceRequest, opts ...http.CallOption) (rsp *KickServiceResponse, err error)
	ListEdgeRPCs(ctx context.Context, req *ListEdgeRPCsRequest, opts ...http.CallOption) (rsp *ListEdgeRPCsResponse, err error)
	ListEdges(ctx context.Context, req *ListEdgesRequest, opts ...http.CallOption) (rsp *ListEdgesResponse, err error)
	ListServiceRPCs(ctx context.Context, req *ListServiceRPCsRequest, opts ...http.CallOption) (rsp *ListServiceRPCsResponse, err error)
	ListServiceTopics(ctx context.Context, req *ListServiceTopicsRequest, opts ...http.CallOption) (rsp *ListServiceTopicsResponse, err error)
	ListServices(ctx context.Context, req *ListServicesRequest, opts ...http.CallOption) (rsp *ListServicesResponse, err error)
}

func NewControlPlaneHTTPClient 

func NewControlPlaneHTTPClient(client *http.Client) ControlPlaneHTTPClient

type ControlPlaneHTTPClientImpl 

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

func (*ControlPlaneHTTPClientImpl) GetEdge 

func (c *ControlPlaneHTTPClientImpl) GetEdge(ctx context.Context, in *GetEdgeRequest, opts ...http.CallOption) (*Edge, error)

func (*ControlPlaneHTTPClientImpl) GetService 

func (c *ControlPlaneHTTPClientImpl) GetService(ctx context.Context, in *GetServiceRequest, opts ...http.CallOption) (*Service, error)

func (*ControlPlaneHTTPClientImpl) KickEdge 

func (c *ControlPlaneHTTPClientImpl) KickEdge(ctx context.Context, in *KickEdgeRequest, opts ...http.CallOption) (*KickEdgeResponse, error)

func (*ControlPlaneHTTPClientImpl) KickService 

func (c *ControlPlaneHTTPClientImpl) KickService(ctx context.Context, in *KickServiceRequest, opts ...http.CallOption) (*KickServiceResponse, error)

func (*ControlPlaneHTTPClientImpl) ListEdgeRPCs 

func (c *ControlPlaneHTTPClientImpl) ListEdgeRPCs(ctx context.Context, in *ListEdgeRPCsRequest, opts ...http.CallOption) (*ListEdgeRPCsResponse, error)

func (*ControlPlaneHTTPClientImpl) ListEdges 

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

func (*ControlPlaneHTTPClientImpl) ListServiceRPCs 

func (c *ControlPlaneHTTPClientImpl) ListServiceRPCs(ctx context.Context, in *ListServiceRPCsRequest, opts ...http.CallOption) (*ListServiceRPCsResponse, error)

func (*ControlPlaneHTTPClientImpl) ListServiceTopics 

func (c *ControlPlaneHTTPClientImpl) ListServiceTopics(ctx context.Context, in *ListServiceTopicsRequest, opts ...http.CallOption) (*ListServiceTopicsResponse, error)

func (*ControlPlaneHTTPClientImpl) ListServices 

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

type ControlPlaneHTTPServer 

type ControlPlaneHTTPServer interface {
	GetEdge(context.Context, *GetEdgeRequest) (*Edge, error)
	GetService(context.Context, *GetServiceRequest) (*Service, error)
	KickEdge(context.Context, *KickEdgeRequest) (*KickEdgeResponse, error)
	KickService(context.Context, *KickServiceRequest) (*KickServiceResponse, error)
	ListEdgeRPCs(context.Context, *ListEdgeRPCsRequest) (*ListEdgeRPCsResponse, error)
	// ListEdges edge related
	ListEdges(context.Context, *ListEdgesRequest) (*ListEdgesResponse, error)
	ListServiceRPCs(context.Context, *ListServiceRPCsRequest) (*ListServiceRPCsResponse, error)
	ListServiceTopics(context.Context, *ListServiceTopicsRequest) (*ListServiceTopicsResponse, error)
	// ListServices service related
	ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
}

type ControlPlaneServer 

type ControlPlaneServer interface {
	// edge related
	ListEdges(context.Context, *ListEdgesRequest) (*ListEdgesResponse, error)
	GetEdge(context.Context, *GetEdgeRequest) (*Edge, error)
	KickEdge(context.Context, *KickEdgeRequest) (*KickEdgeResponse, error)
	ListEdgeRPCs(context.Context, *ListEdgeRPCsRequest) (*ListEdgeRPCsResponse, error)
	// service related
	ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
	GetService(context.Context, *GetServiceRequest) (*Service, error)
	KickService(context.Context, *KickServiceRequest) (*KickServiceResponse, error)
	ListServiceRPCs(context.Context, *ListServiceRPCsRequest) (*ListServiceRPCsResponse, error)
	ListServiceTopics(context.Context, *ListServiceTopicsRequest) (*ListServiceTopicsResponse, error)
	// contains filtered or unexported methods
}

ControlPlaneServer is the server API for ControlPlane service. All implementations must embed UnimplementedControlPlaneServer for forward compatibility

type Edge 

type Edge struct {
	EdgeId     uint64 `protobuf:"varint,1,opt,name=edge_id,proto3" json:"edge_id,omitempty"`
	Meta       string `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	Addr       string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	CreateTime int64  `protobuf:"varint,4,opt,name=create_time,proto3" json:"create_time,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) GetCreateTime 

func (x *Edge) GetCreateTime() int64

func (*Edge) GetEdgeId 

func (x *Edge) GetEdgeId() uint64

func (*Edge) GetMeta 

func (x *Edge) GetMeta() string

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 GetEdgeRequest 

type GetEdgeRequest 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 (*GetEdgeRequest) Descriptor deprecated 

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

Deprecated: Use GetEdgeRequest.ProtoReflect.Descriptor instead.

func (*GetEdgeRequest) GetEdgeId 

func (x *GetEdgeRequest) GetEdgeId() uint64

func (*GetEdgeRequest) ProtoMessage 

func (*GetEdgeRequest) ProtoMessage()

func (*GetEdgeRequest) ProtoReflect 

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

func (*GetEdgeRequest) Reset 

func (x *GetEdgeRequest) Reset()

func (*GetEdgeRequest) String 

func (x *GetEdgeRequest) String() string

type GetServiceRequest 

type GetServiceRequest 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 (*GetServiceRequest) Descriptor deprecated 

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

Deprecated: Use GetServiceRequest.ProtoReflect.Descriptor instead.

func (*GetServiceRequest) GetServiceId 

func (x *GetServiceRequest) GetServiceId() uint64

func (*GetServiceRequest) ProtoMessage 

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) ProtoReflect 

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

func (*GetServiceRequest) Reset 

func (x *GetServiceRequest) Reset()

func (*GetServiceRequest) String 

func (x *GetServiceRequest) String() string

type KickEdgeRequest 

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

kick edge

func (*KickEdgeRequest) Descriptor deprecated 

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

Deprecated: Use KickEdgeRequest.ProtoReflect.Descriptor instead.

func (*KickEdgeRequest) GetEdgeId 

func (x *KickEdgeRequest) GetEdgeId() uint64

func (*KickEdgeRequest) ProtoMessage 

func (*KickEdgeRequest) ProtoMessage()

func (*KickEdgeRequest) ProtoReflect 

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

func (*KickEdgeRequest) Reset 

func (x *KickEdgeRequest) Reset()

func (*KickEdgeRequest) String 

func (x *KickEdgeRequest) String() string

type KickEdgeResponse 

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

func (*KickEdgeResponse) Descriptor deprecated 

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

Deprecated: Use KickEdgeResponse.ProtoReflect.Descriptor instead.

func (*KickEdgeResponse) ProtoMessage 

func (*KickEdgeResponse) ProtoMessage()

func (*KickEdgeResponse) ProtoReflect 

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

func (*KickEdgeResponse) Reset 

func (x *KickEdgeResponse) Reset()

func (*KickEdgeResponse) String 

func (x *KickEdgeResponse) String() string

type KickServiceRequest 

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

kick service

func (*KickServiceRequest) Descriptor deprecated 

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

Deprecated: Use KickServiceRequest.ProtoReflect.Descriptor instead.

func (*KickServiceRequest) GetServiceId 

func (x *KickServiceRequest) GetServiceId() uint64

func (*KickServiceRequest) ProtoMessage 

func (*KickServiceRequest) ProtoMessage()

func (*KickServiceRequest) ProtoReflect 

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

func (*KickServiceRequest) Reset 

func (x *KickServiceRequest) Reset()

func (*KickServiceRequest) String 

func (x *KickServiceRequest) String() string

type KickServiceResponse 

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

func (*KickServiceResponse) Descriptor deprecated 

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

Deprecated: Use KickServiceResponse.ProtoReflect.Descriptor instead.

func (*KickServiceResponse) ProtoMessage 

func (*KickServiceResponse) ProtoMessage()

func (*KickServiceResponse) ProtoReflect 

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

func (*KickServiceResponse) Reset 

func (x *KickServiceResponse) Reset()

func (*KickServiceResponse) String 

func (x *KickServiceResponse) String() string

type ListEdgeRPCsRequest 

type ListEdgeRPCsRequest struct {
	Meta      *string `protobuf:"bytes,1,opt,name=meta,proto3,oneof" json:"meta,omitempty"`
	EdgeId    *uint64 `protobuf:"varint,2,opt,name=edge_id,json=edgeId,proto3,oneof" json:"edge_id,omitempty"`
	Page      int64   `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	PageSize  int64   `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	StartTime *int64  `protobuf:"varint,5,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	EndTime   *int64  `protobuf:"varint,6,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	Order     *string `protobuf:"bytes,7,opt,name=order,proto3,oneof" json:"order,omitempty"`
	// contains filtered or unexported fields
}

list edge rpcs

func (*ListEdgeRPCsRequest) Descriptor deprecated 

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

Deprecated: Use ListEdgeRPCsRequest.ProtoReflect.Descriptor instead.

func (*ListEdgeRPCsRequest) GetEdgeId 

func (x *ListEdgeRPCsRequest) GetEdgeId() uint64

func (*ListEdgeRPCsRequest) GetEndTime 

func (x *ListEdgeRPCsRequest) GetEndTime() int64

func (*ListEdgeRPCsRequest) GetMeta 

func (x *ListEdgeRPCsRequest) GetMeta() string

func (*ListEdgeRPCsRequest) GetOrder 

func (x *ListEdgeRPCsRequest) GetOrder() string

func (*ListEdgeRPCsRequest) GetPage 

func (x *ListEdgeRPCsRequest) GetPage() int64

func (*ListEdgeRPCsRequest) GetPageSize 

func (x *ListEdgeRPCsRequest) GetPageSize() int64

func (*ListEdgeRPCsRequest) GetStartTime 

func (x *ListEdgeRPCsRequest) GetStartTime() int64

func (*ListEdgeRPCsRequest) ProtoMessage 

func (*ListEdgeRPCsRequest) ProtoMessage()

func (*ListEdgeRPCsRequest) ProtoReflect 

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

func (*ListEdgeRPCsRequest) Reset 

func (x *ListEdgeRPCsRequest) Reset()

func (*ListEdgeRPCsRequest) String 

func (x *ListEdgeRPCsRequest) String() string

type ListEdgeRPCsResponse 

type ListEdgeRPCsResponse struct {
	Rpcs  []string `protobuf:"bytes,1,rep,name=rpcs,proto3" json:"rpcs,omitempty"`
	Count int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEdgeRPCsResponse) Descriptor deprecated 

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

Deprecated: Use ListEdgeRPCsResponse.ProtoReflect.Descriptor instead.

func (*ListEdgeRPCsResponse) GetCount 

func (x *ListEdgeRPCsResponse) GetCount() int32

func (*ListEdgeRPCsResponse) GetRpcs 

func (x *ListEdgeRPCsResponse) GetRpcs() []string

func (*ListEdgeRPCsResponse) ProtoMessage 

func (*ListEdgeRPCsResponse) ProtoMessage()

func (*ListEdgeRPCsResponse) ProtoReflect 

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

func (*ListEdgeRPCsResponse) Reset 

func (x *ListEdgeRPCsResponse) Reset()

func (*ListEdgeRPCsResponse) String 

func (x *ListEdgeRPCsResponse) String() string

type ListEdgesRequest 

type ListEdgesRequest struct {
	Meta      *string `protobuf:"bytes,1,opt,name=meta,proto3,oneof" json:"meta,omitempty"`
	Addr      *string `protobuf:"bytes,2,opt,name=addr,proto3,oneof" json:"addr,omitempty"`
	Rpc       *string `protobuf:"bytes,3,opt,name=rpc,proto3,oneof" json:"rpc,omitempty"`
	EdgeId    *uint64 `protobuf:"varint,4,opt,name=edge_id,json=edgeId,proto3,oneof" json:"edge_id,omitempty"`
	Page      int64   `protobuf:"varint,5,opt,name=page,proto3" json:"page,omitempty"`
	PageSize  int64   `protobuf:"varint,6,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	StartTime *int64  `protobuf:"varint,7,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	EndTime   *int64  `protobuf:"varint,8,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	Order     *string `protobuf:"bytes,9,opt,name=order,proto3,oneof" json:"order,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) GetAddr 

func (x *ListEdgesRequest) GetAddr() string

func (*ListEdgesRequest) GetEdgeId 

func (x *ListEdgesRequest) GetEdgeId() uint64

func (*ListEdgesRequest) GetEndTime 

func (x *ListEdgesRequest) GetEndTime() int64

func (*ListEdgesRequest) GetMeta 

func (x *ListEdgesRequest) GetMeta() string

func (*ListEdgesRequest) GetOrder 

func (x *ListEdgesRequest) GetOrder() string

func (*ListEdgesRequest) GetPage 

func (x *ListEdgesRequest) GetPage() int64

func (*ListEdgesRequest) GetPageSize 

func (x *ListEdgesRequest) GetPageSize() int64

func (*ListEdgesRequest) GetRpc 

func (x *ListEdgesRequest) GetRpc() string

func (*ListEdgesRequest) GetStartTime 

func (x *ListEdgesRequest) GetStartTime() int64

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 {
	Edges []*Edge `protobuf:"bytes,1,rep,name=edges,proto3" json:"edges,omitempty"`
	Count int32   `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEdgesResponse) Descriptor deprecated 

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

Deprecated: Use ListEdgesResponse.ProtoReflect.Descriptor instead.

func (*ListEdgesResponse) GetCount 

func (x *ListEdgesResponse) GetCount() int32

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 ListServiceRPCsRequest 

type ListServiceRPCsRequest struct {
	Service   *string `protobuf:"bytes,1,opt,name=service,proto3,oneof" json:"service,omitempty"`
	ServiceId *uint64 `protobuf:"varint,2,opt,name=service_id,json=serviceId,proto3,oneof" json:"service_id,omitempty"`
	Page      int64   `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	PageSize  int64   `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	StartTime *int64  `protobuf:"varint,5,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	EndTime   *int64  `protobuf:"varint,6,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	Order     *string `protobuf:"bytes,7,opt,name=order,proto3,oneof" json:"order,omitempty"`
	// contains filtered or unexported fields
}

list service rpcs

func (*ListServiceRPCsRequest) Descriptor deprecated 

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

Deprecated: Use ListServiceRPCsRequest.ProtoReflect.Descriptor instead.

func (*ListServiceRPCsRequest) GetEndTime 

func (x *ListServiceRPCsRequest) GetEndTime() int64

func (*ListServiceRPCsRequest) GetOrder 

func (x *ListServiceRPCsRequest) GetOrder() string

func (*ListServiceRPCsRequest) GetPage 

func (x *ListServiceRPCsRequest) GetPage() int64

func (*ListServiceRPCsRequest) GetPageSize 

func (x *ListServiceRPCsRequest) GetPageSize() int64

func (*ListServiceRPCsRequest) GetService 

func (x *ListServiceRPCsRequest) GetService() string

func (*ListServiceRPCsRequest) GetServiceId 

func (x *ListServiceRPCsRequest) GetServiceId() uint64

func (*ListServiceRPCsRequest) GetStartTime 

func (x *ListServiceRPCsRequest) GetStartTime() int64

func (*ListServiceRPCsRequest) ProtoMessage 

func (*ListServiceRPCsRequest) ProtoMessage()

func (*ListServiceRPCsRequest) ProtoReflect 

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

func (*ListServiceRPCsRequest) Reset 

func (x *ListServiceRPCsRequest) Reset()

func (*ListServiceRPCsRequest) String 

func (x *ListServiceRPCsRequest) String() string

type ListServiceRPCsResponse 

type ListServiceRPCsResponse struct {
	Rpcs  []string `protobuf:"bytes,1,rep,name=rpcs,proto3" json:"rpcs,omitempty"`
	Count int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServiceRPCsResponse) Descriptor deprecated 

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

Deprecated: Use ListServiceRPCsResponse.ProtoReflect.Descriptor instead.

func (*ListServiceRPCsResponse) GetCount 

func (x *ListServiceRPCsResponse) GetCount() int32

func (*ListServiceRPCsResponse) GetRpcs 

func (x *ListServiceRPCsResponse) GetRpcs() []string

func (*ListServiceRPCsResponse) ProtoMessage 

func (*ListServiceRPCsResponse) ProtoMessage()

func (*ListServiceRPCsResponse) ProtoReflect 

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

func (*ListServiceRPCsResponse) Reset 

func (x *ListServiceRPCsResponse) Reset()

func (*ListServiceRPCsResponse) String 

func (x *ListServiceRPCsResponse) String() string

type ListServiceTopicsRequest 

type ListServiceTopicsRequest struct {
	Service   *string `protobuf:"bytes,1,opt,name=service,proto3,oneof" json:"service,omitempty"`
	ServiceId *uint64 `protobuf:"varint,2,opt,name=service_id,json=serviceId,proto3,oneof" json:"service_id,omitempty"`
	Page      int64   `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	PageSize  int64   `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	StartTime *int64  `protobuf:"varint,5,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	EndTime   *int64  `protobuf:"varint,6,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	Order     *string `protobuf:"bytes,7,opt,name=order,proto3,oneof" json:"order,omitempty"`
	// contains filtered or unexported fields
}

list service topics

func (*ListServiceTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListServiceTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListServiceTopicsRequest) GetEndTime 

func (x *ListServiceTopicsRequest) GetEndTime() int64

func (*ListServiceTopicsRequest) GetOrder 

func (x *ListServiceTopicsRequest) GetOrder() string

func (*ListServiceTopicsRequest) GetPage 

func (x *ListServiceTopicsRequest) GetPage() int64

func (*ListServiceTopicsRequest) GetPageSize 

func (x *ListServiceTopicsRequest) GetPageSize() int64

func (*ListServiceTopicsRequest) GetService 

func (x *ListServiceTopicsRequest) GetService() string

func (*ListServiceTopicsRequest) GetServiceId 

func (x *ListServiceTopicsRequest) GetServiceId() uint64

func (*ListServiceTopicsRequest) GetStartTime 

func (x *ListServiceTopicsRequest) GetStartTime() int64

func (*ListServiceTopicsRequest) ProtoMessage 

func (*ListServiceTopicsRequest) ProtoMessage()

func (*ListServiceTopicsRequest) ProtoReflect 

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

func (*ListServiceTopicsRequest) Reset 

func (x *ListServiceTopicsRequest) Reset()

func (*ListServiceTopicsRequest) String 

func (x *ListServiceTopicsRequest) String() string

type ListServiceTopicsResponse 

type ListServiceTopicsResponse struct {
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	Count  int32    `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServiceTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListServiceTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListServiceTopicsResponse) GetCount 

func (x *ListServiceTopicsResponse) GetCount() int32

func (*ListServiceTopicsResponse) GetTopics 

func (x *ListServiceTopicsResponse) GetTopics() []string

func (*ListServiceTopicsResponse) ProtoMessage 

func (*ListServiceTopicsResponse) ProtoMessage()

func (*ListServiceTopicsResponse) ProtoReflect 

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

func (*ListServiceTopicsResponse) Reset 

func (x *ListServiceTopicsResponse) Reset()

func (*ListServiceTopicsResponse) String 

func (x *ListServiceTopicsResponse) String() string

type ListServicesRequest 

type ListServicesRequest struct {
	Service   *string `protobuf:"bytes,1,opt,name=service,proto3,oneof" json:"service,omitempty"`
	Addr      *string `protobuf:"bytes,2,opt,name=addr,proto3,oneof" json:"addr,omitempty"`
	Rpc       *string `protobuf:"bytes,3,opt,name=rpc,proto3,oneof" json:"rpc,omitempty"`
	Topic     *string `protobuf:"bytes,4,opt,name=topic,proto3,oneof" json:"topic,omitempty"`
	Page      int64   `protobuf:"varint,5,opt,name=page,proto3" json:"page,omitempty"`
	PageSize  int64   `protobuf:"varint,6,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	StartTime *int64  `protobuf:"varint,7,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	EndTime   *int64  `protobuf:"varint,8,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	Order     *string `protobuf:"bytes,9,opt,name=order,proto3,oneof" json:"order,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) GetAddr 

func (x *ListServicesRequest) GetAddr() string

func (*ListServicesRequest) GetEndTime 

func (x *ListServicesRequest) GetEndTime() int64

func (*ListServicesRequest) GetOrder 

func (x *ListServicesRequest) GetOrder() string

func (*ListServicesRequest) GetPage 

func (x *ListServicesRequest) GetPage() int64

func (*ListServicesRequest) GetPageSize 

func (x *ListServicesRequest) GetPageSize() int64

func (*ListServicesRequest) GetRpc 

func (x *ListServicesRequest) GetRpc() string

func (*ListServicesRequest) GetService 

func (x *ListServicesRequest) GetService() string

func (*ListServicesRequest) GetStartTime 

func (x *ListServicesRequest) GetStartTime() int64

func (*ListServicesRequest) GetTopic 

func (x *ListServicesRequest) GetTopic() string

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 {
	Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	Count    int32      `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServicesResponse) Descriptor deprecated 

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

Deprecated: Use ListServicesResponse.ProtoReflect.Descriptor instead.

func (*ListServicesResponse) GetCount 

func (x *ListServicesResponse) GetCount() int32

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 {
	ServiceId  uint64 `protobuf:"varint,1,opt,name=service_id,proto3" json:"service_id,omitempty"`
	Service    string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Addr       string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	CreateTime int64  `protobuf:"varint,4,opt,name=create_time,proto3" json:"create_time,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) GetCreateTime 

func (x *Service) GetCreateTime() int64

func (*Service) GetService 

func (x *Service) GetService() string

func (*Service) GetServiceId 

func (x *Service) GetServiceId() 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 UnimplementedControlPlaneServer 

type UnimplementedControlPlaneServer struct {
}

UnimplementedControlPlaneServer must be embedded to have forward compatible implementations.

func (UnimplementedControlPlaneServer) GetEdge 

func (UnimplementedControlPlaneServer) GetEdge(context.Context, *GetEdgeRequest) (*Edge, error)

func (UnimplementedControlPlaneServer) GetService 

func (UnimplementedControlPlaneServer) GetService(context.Context, *GetServiceRequest) (*Service, error)

func (UnimplementedControlPlaneServer) KickEdge 

func (UnimplementedControlPlaneServer) KickEdge(context.Context, *KickEdgeRequest) (*KickEdgeResponse, error)

func (UnimplementedControlPlaneServer) KickService 

func (UnimplementedControlPlaneServer) KickService(context.Context, *KickServiceRequest) (*KickServiceResponse, error)

func (UnimplementedControlPlaneServer) ListEdgeRPCs 

func (UnimplementedControlPlaneServer) ListEdgeRPCs(context.Context, *ListEdgeRPCsRequest) (*ListEdgeRPCsResponse, error)

func (UnimplementedControlPlaneServer) ListEdges 

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

func (UnimplementedControlPlaneServer) ListServiceRPCs 

func (UnimplementedControlPlaneServer) ListServiceRPCs(context.Context, *ListServiceRPCsRequest) (*ListServiceRPCsResponse, error)

func (UnimplementedControlPlaneServer) ListServiceTopics 

func (UnimplementedControlPlaneServer) ListServiceTopics(context.Context, *ListServiceTopicsRequest) (*ListServiceTopicsResponse, error)

func (UnimplementedControlPlaneServer) ListServices 

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

type UnsafeControlPlaneServer 

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

UnsafeControlPlaneServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlPlaneServer 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.