Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterControllerRegisterServiceServer(s grpc.ServiceRegistrar, srv ControllerRegisterServiceServer)
- type AgentInfo
- func (*AgentInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AgentInfo) GetNodeName() string
- func (x *AgentInfo) GetSupportTaskTypes() []TaskType
- func (x *AgentInfo) GetVersion() string
- func (*AgentInfo) ProtoMessage()
- func (x *AgentInfo) ProtoReflect() protoreflect.Message
- func (x *AgentInfo) Reset()
- func (x *AgentInfo) String() string
- type CaptureInfo
- func (*CaptureInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CaptureInfo) GetCaptureDurationSeconds() int32
- func (x *CaptureInfo) GetCaptureType() string
- func (x *CaptureInfo) GetFilter() string
- func (x *CaptureInfo) GetNode() *NodeInfo
- func (x *CaptureInfo) GetPod() *PodInfo
- func (*CaptureInfo) ProtoMessage()
- func (x *CaptureInfo) ProtoReflect() protoreflect.Message
- func (x *CaptureInfo) Reset()
- func (x *CaptureInfo) String() string
- type CaptureResult
- func (*CaptureResult) Descriptor() ([]byte, []int)deprecated
- func (x *CaptureResult) GetFileType() string
- func (x *CaptureResult) GetMessage() []byte
- func (*CaptureResult) ProtoMessage()
- func (x *CaptureResult) ProtoReflect() protoreflect.Message
- func (x *CaptureResult) Reset()
- func (x *CaptureResult) String() string
- type ControllerInfo
- type ControllerRegisterServiceClient
- type ControllerRegisterServiceServer
- type ControllerRegisterService_ReportEventsClient
- type ControllerRegisterService_ReportEventsServer
- type ControllerRegisterService_WatchTasksClient
- type ControllerRegisterService_WatchTasksServer
- type Event
- type EventReply
- type NodeInfo
- type PingInfo
- func (*PingInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PingInfo) GetDestination() string
- func (x *PingInfo) GetNode() *NodeInfo
- func (x *PingInfo) GetPod() *PodInfo
- func (*PingInfo) ProtoMessage()
- func (x *PingInfo) ProtoReflect() protoreflect.Message
- func (x *PingInfo) Reset()
- func (x *PingInfo) String() string
- type PingResult
- func (*PingResult) Descriptor() ([]byte, []int)deprecated
- func (x *PingResult) GetAvg() float32
- func (x *PingResult) GetMax() float32
- func (x *PingResult) GetMessage() []byte
- func (x *PingResult) GetMin() float32
- func (*PingResult) ProtoMessage()
- func (x *PingResult) ProtoReflect() protoreflect.Message
- func (x *PingResult) Reset()
- func (x *PingResult) String() string
- type PodInfo
- type ServerTask
- func (*ServerTask) Descriptor() ([]byte, []int)deprecated
- func (x *ServerTask) GetServer() *ControllerInfo
- func (x *ServerTask) GetTask() *Task
- func (*ServerTask) ProtoMessage()
- func (x *ServerTask) ProtoReflect() protoreflect.Message
- func (x *ServerTask) Reset()
- func (x *ServerTask) String() string
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetCapture() *CaptureInfo
- func (x *Task) GetId() string
- func (x *Task) GetPing() *PingInfo
- func (m *Task) GetTaskInfo() isTask_TaskInfo
- func (x *Task) GetType() TaskType
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- type TaskFilter
- type TaskResult
- func (*TaskResult) Descriptor() ([]byte, []int)deprecated
- func (x *TaskResult) GetCapture() *CaptureResult
- func (x *TaskResult) GetId() string
- func (x *TaskResult) GetMessage() string
- func (x *TaskResult) GetPing() *PingResult
- func (x *TaskResult) GetSuccess() bool
- func (x *TaskResult) GetTask() *CaptureInfo
- func (m *TaskResult) GetTaskResultInfo() isTaskResult_TaskResultInfo
- func (x *TaskResult) GetType() TaskType
- func (*TaskResult) ProtoMessage()
- func (x *TaskResult) ProtoReflect() protoreflect.Message
- func (x *TaskResult) Reset()
- func (x *TaskResult) String() string
- type TaskResultReply
- func (*TaskResultReply) Descriptor() ([]byte, []int)deprecated
- func (x *TaskResultReply) GetMessage() string
- func (x *TaskResultReply) GetSuccess() bool
- func (*TaskResultReply) ProtoMessage()
- func (x *TaskResultReply) ProtoReflect() protoreflect.Message
- func (x *TaskResultReply) Reset()
- func (x *TaskResultReply) String() string
- type TaskResult_Capture
- type TaskResult_Ping
- type TaskType
- type Task_Capture
- type Task_Ping
- type UnimplementedControllerRegisterServiceServer
- func (UnimplementedControllerRegisterServiceServer) RegisterAgent(context.Context, *AgentInfo) (*ControllerInfo, error)
- func (UnimplementedControllerRegisterServiceServer) ReportEvents(ControllerRegisterService_ReportEventsServer) error
- func (UnimplementedControllerRegisterServiceServer) UploadTaskResult(context.Context, *TaskResult) (*TaskResultReply, error)
- func (UnimplementedControllerRegisterServiceServer) WatchTasks(*TaskFilter, ControllerRegisterService_WatchTasksServer) error
- type UnsafeControllerRegisterServiceServer
Constants ¶
const ( ControllerRegisterService_RegisterAgent_FullMethodName = "/controller_rpc.ControllerRegisterService/RegisterAgent" ControllerRegisterService_ReportEvents_FullMethodName = "/controller_rpc.ControllerRegisterService/ReportEvents" ControllerRegisterService_WatchTasks_FullMethodName = "/controller_rpc.ControllerRegisterService/WatchTasks" ControllerRegisterService_UploadTaskResult_FullMethodName = "/controller_rpc.ControllerRegisterService/UploadTaskResult" )
Variables ¶
var ( TaskType_name = map[int32]string{ 0: "Capture", 1: "Ping", } TaskType_value = map[string]int32{ "Capture": 0, "Ping": 1, } )
Enum value maps for TaskType.
var ControllerRegisterService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "controller_rpc.ControllerRegisterService", HandlerType: (*ControllerRegisterServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterAgent", Handler: _ControllerRegisterService_RegisterAgent_Handler, }, { MethodName: "UploadTaskResult", Handler: _ControllerRegisterService_UploadTaskResult_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ReportEvents", Handler: _ControllerRegisterService_ReportEvents_Handler, ClientStreams: true, }, { StreamName: "WatchTasks", Handler: _ControllerRegisterService_WatchTasks_Handler, ServerStreams: true, }, }, Metadata: "controller.proto", }
ControllerRegisterService_ServiceDesc is the grpc.ServiceDesc for ControllerRegisterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_controller_proto protoreflect.FileDescriptor
Functions ¶
func RegisterControllerRegisterServiceServer ¶
func RegisterControllerRegisterServiceServer(s grpc.ServiceRegistrar, srv ControllerRegisterServiceServer)
Types ¶
type AgentInfo ¶
type AgentInfo struct { NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` SupportTaskTypes []TaskType `` /* 148-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AgentInfo) Descriptor
deprecated
func (*AgentInfo) GetNodeName ¶
func (*AgentInfo) GetSupportTaskTypes ¶
func (*AgentInfo) GetVersion ¶
func (*AgentInfo) ProtoMessage ¶
func (*AgentInfo) ProtoMessage()
func (*AgentInfo) ProtoReflect ¶
func (x *AgentInfo) ProtoReflect() protoreflect.Message
type CaptureInfo ¶
type CaptureInfo struct { Pod *PodInfo `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"` Node *NodeInfo `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"` Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"` CaptureType string `protobuf:"bytes,4,opt,name=capture_type,json=captureType,proto3" json:"capture_type,omitempty"` CaptureDurationSeconds int32 `` /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CaptureInfo) Descriptor
deprecated
func (*CaptureInfo) Descriptor() ([]byte, []int)
Deprecated: Use CaptureInfo.ProtoReflect.Descriptor instead.
func (*CaptureInfo) GetCaptureDurationSeconds ¶
func (x *CaptureInfo) GetCaptureDurationSeconds() int32
func (*CaptureInfo) GetCaptureType ¶
func (x *CaptureInfo) GetCaptureType() string
func (*CaptureInfo) GetFilter ¶
func (x *CaptureInfo) GetFilter() string
func (*CaptureInfo) GetNode ¶
func (x *CaptureInfo) GetNode() *NodeInfo
func (*CaptureInfo) GetPod ¶
func (x *CaptureInfo) GetPod() *PodInfo
func (*CaptureInfo) ProtoMessage ¶
func (*CaptureInfo) ProtoMessage()
func (*CaptureInfo) ProtoReflect ¶
func (x *CaptureInfo) ProtoReflect() protoreflect.Message
func (*CaptureInfo) Reset ¶
func (x *CaptureInfo) Reset()
func (*CaptureInfo) String ¶
func (x *CaptureInfo) String() string
type CaptureResult ¶
type CaptureResult struct { FileType string `protobuf:"bytes,1,opt,name=file_type,json=fileType,proto3" json:"file_type,omitempty"` Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*CaptureResult) Descriptor
deprecated
func (*CaptureResult) Descriptor() ([]byte, []int)
Deprecated: Use CaptureResult.ProtoReflect.Descriptor instead.
func (*CaptureResult) GetFileType ¶
func (x *CaptureResult) GetFileType() string
func (*CaptureResult) GetMessage ¶
func (x *CaptureResult) GetMessage() []byte
func (*CaptureResult) ProtoMessage ¶
func (*CaptureResult) ProtoMessage()
func (*CaptureResult) ProtoReflect ¶
func (x *CaptureResult) ProtoReflect() protoreflect.Message
func (*CaptureResult) Reset ¶
func (x *CaptureResult) Reset()
func (*CaptureResult) String ¶
func (x *CaptureResult) String() string
type ControllerInfo ¶
type ControllerInfo struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*ControllerInfo) Descriptor
deprecated
func (*ControllerInfo) Descriptor() ([]byte, []int)
Deprecated: Use ControllerInfo.ProtoReflect.Descriptor instead.
func (*ControllerInfo) GetVersion ¶
func (x *ControllerInfo) GetVersion() string
func (*ControllerInfo) ProtoMessage ¶
func (*ControllerInfo) ProtoMessage()
func (*ControllerInfo) ProtoReflect ¶
func (x *ControllerInfo) ProtoReflect() protoreflect.Message
func (*ControllerInfo) Reset ¶
func (x *ControllerInfo) Reset()
func (*ControllerInfo) String ¶
func (x *ControllerInfo) String() string
type ControllerRegisterServiceClient ¶
type ControllerRegisterServiceClient interface { // Agent Health Check RegisterAgent(ctx context.Context, in *AgentInfo, opts ...grpc.CallOption) (*ControllerInfo, error) ReportEvents(ctx context.Context, opts ...grpc.CallOption) (ControllerRegisterService_ReportEventsClient, error) WatchTasks(ctx context.Context, in *TaskFilter, opts ...grpc.CallOption) (ControllerRegisterService_WatchTasksClient, error) UploadTaskResult(ctx context.Context, in *TaskResult, opts ...grpc.CallOption) (*TaskResultReply, error) }
ControllerRegisterServiceClient is the client API for ControllerRegisterService 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 NewControllerRegisterServiceClient ¶
func NewControllerRegisterServiceClient(cc grpc.ClientConnInterface) ControllerRegisterServiceClient
type ControllerRegisterServiceServer ¶
type ControllerRegisterServiceServer interface { // Agent Health Check RegisterAgent(context.Context, *AgentInfo) (*ControllerInfo, error) ReportEvents(ControllerRegisterService_ReportEventsServer) error WatchTasks(*TaskFilter, ControllerRegisterService_WatchTasksServer) error UploadTaskResult(context.Context, *TaskResult) (*TaskResultReply, error) // contains filtered or unexported methods }
ControllerRegisterServiceServer is the server API for ControllerRegisterService service. All implementations must embed UnimplementedControllerRegisterServiceServer for forward compatibility
type ControllerRegisterService_ReportEventsClient ¶
type ControllerRegisterService_ReportEventsClient interface { Send(*Event) error CloseAndRecv() (*EventReply, error) grpc.ClientStream }
type ControllerRegisterService_ReportEventsServer ¶
type ControllerRegisterService_ReportEventsServer interface { SendAndClose(*EventReply) error Recv() (*Event, error) grpc.ServerStream }
type ControllerRegisterService_WatchTasksClient ¶
type ControllerRegisterService_WatchTasksClient interface { Recv() (*ServerTask, error) grpc.ClientStream }
type ControllerRegisterService_WatchTasksServer ¶
type ControllerRegisterService_WatchTasksServer interface { Send(*ServerTask) error grpc.ServerStream }
type Event ¶
type Event struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetMessage ¶
func (*Event) GetTimestamp ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventReply ¶
type EventReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*EventReply) Descriptor
deprecated
func (*EventReply) Descriptor() ([]byte, []int)
Deprecated: Use EventReply.ProtoReflect.Descriptor instead.
func (*EventReply) GetMessage ¶
func (x *EventReply) GetMessage() string
func (*EventReply) GetSuccess ¶
func (x *EventReply) GetSuccess() bool
func (*EventReply) ProtoMessage ¶
func (*EventReply) ProtoMessage()
func (*EventReply) ProtoReflect ¶
func (x *EventReply) ProtoReflect() protoreflect.Message
func (*EventReply) Reset ¶
func (x *EventReply) Reset()
func (*EventReply) String ¶
func (x *EventReply) String() string
type NodeInfo ¶
type NodeInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
type PingInfo ¶
type PingInfo struct { Pod *PodInfo `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"` Node *NodeInfo `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"` Destination string `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"` // contains filtered or unexported fields }
func (*PingInfo) Descriptor
deprecated
func (*PingInfo) GetDestination ¶
func (*PingInfo) ProtoMessage ¶
func (*PingInfo) ProtoMessage()
func (*PingInfo) ProtoReflect ¶
func (x *PingInfo) ProtoReflect() protoreflect.Message
type PingResult ¶
type PingResult struct { Max float32 `protobuf:"fixed32,1,opt,name=max,proto3" json:"max,omitempty"` Avg float32 `protobuf:"fixed32,2,opt,name=avg,proto3" json:"avg,omitempty"` Min float32 `protobuf:"fixed32,3,opt,name=min,proto3" json:"min,omitempty"` Message []byte `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*PingResult) Descriptor
deprecated
func (*PingResult) Descriptor() ([]byte, []int)
Deprecated: Use PingResult.ProtoReflect.Descriptor instead.
func (*PingResult) GetAvg ¶
func (x *PingResult) GetAvg() float32
func (*PingResult) GetMax ¶
func (x *PingResult) GetMax() float32
func (*PingResult) GetMessage ¶
func (x *PingResult) GetMessage() []byte
func (*PingResult) GetMin ¶
func (x *PingResult) GetMin() float32
func (*PingResult) ProtoMessage ¶
func (*PingResult) ProtoMessage()
func (*PingResult) ProtoReflect ¶
func (x *PingResult) ProtoReflect() protoreflect.Message
func (*PingResult) Reset ¶
func (x *PingResult) Reset()
func (*PingResult) String ¶
func (x *PingResult) String() string
type PodInfo ¶
type PodInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*PodInfo) Descriptor
deprecated
func (*PodInfo) GetNamespace ¶
func (*PodInfo) ProtoMessage ¶
func (*PodInfo) ProtoMessage()
func (*PodInfo) ProtoReflect ¶
func (x *PodInfo) ProtoReflect() protoreflect.Message
type ServerTask ¶
type ServerTask struct { Server *ControllerInfo `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Task *Task `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` // contains filtered or unexported fields }
func (*ServerTask) Descriptor
deprecated
func (*ServerTask) Descriptor() ([]byte, []int)
Deprecated: Use ServerTask.ProtoReflect.Descriptor instead.
func (*ServerTask) GetServer ¶
func (x *ServerTask) GetServer() *ControllerInfo
func (*ServerTask) GetTask ¶
func (x *ServerTask) GetTask() *Task
func (*ServerTask) ProtoMessage ¶
func (*ServerTask) ProtoMessage()
func (*ServerTask) ProtoReflect ¶
func (x *ServerTask) ProtoReflect() protoreflect.Message
func (*ServerTask) Reset ¶
func (x *ServerTask) Reset()
func (*ServerTask) String ¶
func (x *ServerTask) String() string
type Task ¶
type Task struct { Type TaskType `protobuf:"varint,1,opt,name=type,proto3,enum=controller_rpc.TaskType" json:"type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // Types that are assignable to TaskInfo: // // *Task_Capture // *Task_Ping TaskInfo isTask_TaskInfo `protobuf_oneof:"TaskInfo"` // contains filtered or unexported fields }
func (*Task) Descriptor
deprecated
func (*Task) GetCapture ¶
func (x *Task) GetCapture() *CaptureInfo
func (*Task) GetTaskInfo ¶
func (m *Task) GetTaskInfo() isTask_TaskInfo
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶
func (x *Task) ProtoReflect() protoreflect.Message
type TaskFilter ¶
type TaskFilter struct { NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` Type []TaskType `protobuf:"varint,2,rep,packed,name=type,proto3,enum=controller_rpc.TaskType" json:"type,omitempty"` // contains filtered or unexported fields }
func (*TaskFilter) Descriptor
deprecated
func (*TaskFilter) Descriptor() ([]byte, []int)
Deprecated: Use TaskFilter.ProtoReflect.Descriptor instead.
func (*TaskFilter) GetNodeName ¶
func (x *TaskFilter) GetNodeName() string
func (*TaskFilter) GetType ¶
func (x *TaskFilter) GetType() []TaskType
func (*TaskFilter) ProtoMessage ¶
func (*TaskFilter) ProtoMessage()
func (*TaskFilter) ProtoReflect ¶
func (x *TaskFilter) ProtoReflect() protoreflect.Message
func (*TaskFilter) Reset ¶
func (x *TaskFilter) Reset()
func (*TaskFilter) String ¶
func (x *TaskFilter) String() string
type TaskResult ¶
type TaskResult struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type TaskType `protobuf:"varint,2,opt,name=type,proto3,enum=controller_rpc.TaskType" json:"type,omitempty"` Success bool `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"` Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"` Task *CaptureInfo `protobuf:"bytes,5,opt,name=task,proto3" json:"task,omitempty"` // Types that are assignable to TaskResultInfo: // // *TaskResult_Capture // *TaskResult_Ping TaskResultInfo isTaskResult_TaskResultInfo `protobuf_oneof:"TaskResultInfo"` // contains filtered or unexported fields }
func (*TaskResult) Descriptor
deprecated
func (*TaskResult) Descriptor() ([]byte, []int)
Deprecated: Use TaskResult.ProtoReflect.Descriptor instead.
func (*TaskResult) GetCapture ¶
func (x *TaskResult) GetCapture() *CaptureResult
func (*TaskResult) GetId ¶
func (x *TaskResult) GetId() string
func (*TaskResult) GetMessage ¶
func (x *TaskResult) GetMessage() string
func (*TaskResult) GetPing ¶
func (x *TaskResult) GetPing() *PingResult
func (*TaskResult) GetSuccess ¶
func (x *TaskResult) GetSuccess() bool
func (*TaskResult) GetTask ¶
func (x *TaskResult) GetTask() *CaptureInfo
func (*TaskResult) GetTaskResultInfo ¶
func (m *TaskResult) GetTaskResultInfo() isTaskResult_TaskResultInfo
func (*TaskResult) GetType ¶
func (x *TaskResult) GetType() TaskType
func (*TaskResult) ProtoMessage ¶
func (*TaskResult) ProtoMessage()
func (*TaskResult) ProtoReflect ¶
func (x *TaskResult) ProtoReflect() protoreflect.Message
func (*TaskResult) Reset ¶
func (x *TaskResult) Reset()
func (*TaskResult) String ¶
func (x *TaskResult) String() string
type TaskResultReply ¶
type TaskResultReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*TaskResultReply) Descriptor
deprecated
func (*TaskResultReply) Descriptor() ([]byte, []int)
Deprecated: Use TaskResultReply.ProtoReflect.Descriptor instead.
func (*TaskResultReply) GetMessage ¶
func (x *TaskResultReply) GetMessage() string
func (*TaskResultReply) GetSuccess ¶
func (x *TaskResultReply) GetSuccess() bool
func (*TaskResultReply) ProtoMessage ¶
func (*TaskResultReply) ProtoMessage()
func (*TaskResultReply) ProtoReflect ¶
func (x *TaskResultReply) ProtoReflect() protoreflect.Message
func (*TaskResultReply) Reset ¶
func (x *TaskResultReply) Reset()
func (*TaskResultReply) String ¶
func (x *TaskResultReply) String() string
type TaskResult_Capture ¶
type TaskResult_Capture struct {
Capture *CaptureResult `protobuf:"bytes,6,opt,name=capture,proto3,oneof"`
}
type TaskResult_Ping ¶
type TaskResult_Ping struct {
Ping *PingResult `protobuf:"bytes,7,opt,name=ping,proto3,oneof"`
}
type TaskType ¶
type TaskType int32
func (TaskType) Descriptor ¶
func (TaskType) Descriptor() protoreflect.EnumDescriptor
func (TaskType) EnumDescriptor
deprecated
func (TaskType) Number ¶
func (x TaskType) Number() protoreflect.EnumNumber
func (TaskType) Type ¶
func (TaskType) Type() protoreflect.EnumType
type Task_Capture ¶
type Task_Capture struct {
Capture *CaptureInfo `protobuf:"bytes,3,opt,name=capture,proto3,oneof"`
}
type Task_Ping ¶
type Task_Ping struct {
Ping *PingInfo `protobuf:"bytes,4,opt,name=ping,proto3,oneof"`
}
type UnimplementedControllerRegisterServiceServer ¶
type UnimplementedControllerRegisterServiceServer struct { }
UnimplementedControllerRegisterServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedControllerRegisterServiceServer) RegisterAgent ¶
func (UnimplementedControllerRegisterServiceServer) RegisterAgent(context.Context, *AgentInfo) (*ControllerInfo, error)
func (UnimplementedControllerRegisterServiceServer) ReportEvents ¶
func (UnimplementedControllerRegisterServiceServer) UploadTaskResult ¶
func (UnimplementedControllerRegisterServiceServer) UploadTaskResult(context.Context, *TaskResult) (*TaskResultReply, error)
func (UnimplementedControllerRegisterServiceServer) WatchTasks ¶
type UnsafeControllerRegisterServiceServer ¶
type UnsafeControllerRegisterServiceServer interface {
// contains filtered or unexported methods
}
UnsafeControllerRegisterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControllerRegisterServiceServer will result in compilation errors.