rpc

type AddressFamily int32

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
}

type CacheEntry struct {
	IP   string    `protobuf:"bytes,1,opt,name=IP,proto3" json:"IP,omitempty"`
	Type ValueType `protobuf:"varint,2,opt,name=type,proto3,enum=controller_rpc.ValueType" json:"type,omitempty"`
	// Types that are assignable to Meta:
	//
	//	*CacheEntry_Pod
	//	*CacheEntry_Node
	Meta isCacheEntry_Meta `protobuf_oneof:"meta"`
	// contains filtered or unexported fields
}

type CacheEntry_Node struct {
	Node *NodeMeta `protobuf:"bytes,4,opt,name=node,proto3,oneof"`
}

type CacheEntry_Pod struct {
	Pod *PodMeta `protobuf:"bytes,3,opt,name=pod,proto3,oneof"`
}

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
}

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
}

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

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)
}

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
}

type ControllerRegisterService_ReportEventsClient interface {
	Send(*Event) error
	CloseAndRecv() (*EventReply, error)
	grpc.ClientStream
}

type ControllerRegisterService_ReportEventsServer interface {
	SendAndClose(*EventReply) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type ControllerRegisterService_WatchTasksClient interface {
	Recv() (*ServerTask, error)
	grpc.ClientStream
}

type ControllerRegisterService_WatchTasksServer interface {
	Send(*ServerTask) error
	grpc.ServerStream
}

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
}

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
}

type IPCacheServiceClient interface {
	ListCache(ctx context.Context, in *ListCacheRequest, opts ...grpc.CallOption) (*ListCacheResponse, error)
	WatchCache(ctx context.Context, in *WatchCacheRequest, opts ...grpc.CallOption) (IPCacheService_WatchCacheClient, error)
}

type IPCacheServiceServer interface {
	ListCache(context.Context, *ListCacheRequest) (*ListCacheResponse, error)
	WatchCache(*WatchCacheRequest, IPCacheService_WatchCacheServer) error
	// contains filtered or unexported methods
}

type IPCacheService_WatchCacheClient interface {
	Recv() (*WatchCacheResponse, error)
	grpc.ClientStream
}

type IPCacheService_WatchCacheServer interface {
	Send(*WatchCacheResponse) error
	grpc.ServerStream
}

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

type ListCacheResponse struct {
	Period   string        `protobuf:"bytes,1,opt,name=period,proto3" json:"period,omitempty"`
	Revision uint64        `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	Entries  []*CacheEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

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

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

type OpCode int32

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
}

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
}

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"`
	HostNetwork bool   `protobuf:"varint,3,opt,name=hostNetwork,proto3" json:"hostNetwork,omitempty"`
	// contains filtered or unexported fields
}

type PodMeta struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

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
}

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
}

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
}

type TaskResult_Capture struct {
	Capture *CaptureResult `protobuf:"bytes,6,opt,name=capture,proto3,oneof"`
}

type TaskResult_Ping struct {
	Ping *PingResult `protobuf:"bytes,7,opt,name=ping,proto3,oneof"`
}

type TaskType int32

type Task_Capture struct {
	Capture *CaptureInfo `protobuf:"bytes,3,opt,name=capture,proto3,oneof"`
}

type Task_Ping struct {
	Ping *PingInfo `protobuf:"bytes,4,opt,name=ping,proto3,oneof"`
}

type UnimplementedControllerRegisterServiceServer struct {
}

type UnimplementedIPCacheServiceServer struct {
}

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

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

type ValueType int32

type WatchCacheRequest struct {
	Period   string `protobuf:"bytes,1,opt,name=period,proto3" json:"period,omitempty"`
	Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

type WatchCacheResponse struct {
	Revision uint64      `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	Opcode   OpCode      `protobuf:"varint,2,opt,name=opcode,proto3,enum=controller_rpc.OpCode" json:"opcode,omitempty"`
	Entry    *CacheEntry `protobuf:"bytes,3,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}