manager

package
v0.0.0-...-de0472c Latest Latest
Warning

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

 Go to latest Published: Aug 11, 2022 License: MulanPSL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ScheduleState_name = map[int32]string{
		0: "ScheduleStateNotUse",
		1: "ScheduleStateSuccess",
		2: "ScheduleStateFailure",
	}
	ScheduleState_value = map[string]int32{
		"ScheduleStateNotUse":  0,
		"ScheduleStateSuccess": 1,
		"ScheduleStateFailure": 2,
	}
)

Enum value maps for ScheduleState.

View Source 
var (
	CommandState_name = map[int32]string{
		0: "CommandStateNotUse",
		1: "CommandStateSuccess",
		2: "CommandStateFailure",
	}
	CommandState_value = map[string]int32{
		"CommandStateNotUse":  0,
		"CommandStateSuccess": 1,
		"CommandStateFailure": 2,
	}
)

Enum value maps for CommandState.

View Source 
var (
	CommandUpOutputRequest_State_name = map[int32]string{
		0: "NotUse",
		1: "Running",
		2: "Success",
		3: "Failure",
	}
	CommandUpOutputRequest_State_value = map[string]int32{
		"NotUse":  0,
		"Running": 1,
		"Success": 2,
		"Failure": 3,
	}
)

Enum value maps for CommandUpOutputRequest_State.

View Source 
var (
	ScheduleSetTaskRequest_Mode_name = map[int32]string{
		0: "ModeNotUse",
		1: "ModeAll",
		2: "ModeRand",
	}
	ScheduleSetTaskRequest_Mode_value = map[string]int32{
		"ModeNotUse": 0,
		"ModeAll":    1,
		"ModeRand":   2,
	}
)

Enum value maps for ScheduleSetTaskRequest_Mode.

View Source 
var (
	CommandRunSyncRequest_Action_name = map[int32]string{
		0: "ActionNotUse",
		1: "ActionExecute",
		2: "ActionInput",
		3: "ActionExit",
	}
	CommandRunSyncRequest_Action_value = map[string]int32{
		"ActionNotUse":  0,
		"ActionExecute": 1,
		"ActionInput":   2,
		"ActionExit":    3,
	}
)

Enum value maps for CommandRunSyncRequest_Action.

View Source 
var File_manager_proto protoreflect.FileDescriptor
View Source 
var Manager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "eternal.protobuf.manager.Manager",
	HandlerType: (*ManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "WorkerJoin",
			Handler:    _Manager_WorkerJoin_Handler,
		},
		{
			MethodName: "WorkerQuit",
			Handler:    _Manager_WorkerQuit_Handler,
		},
		{
			MethodName: "WorkerList",
			Handler:    _Manager_WorkerList_Handler,
		},
		{
			MethodName: "WorkerUpStats",
			Handler:    _Manager_WorkerUpStats_Handler,
		},
		{
			MethodName: "WorkerGetStats",
			Handler:    _Manager_WorkerGetStats_Handler,
		},
		{
			MethodName: "ScheduleTaskList",
			Handler:    _Manager_ScheduleTaskList_Handler,
		},
		{
			MethodName: "ScheduleSetTask",
			Handler:    _Manager_ScheduleSetTask_Handler,
		},
		{
			MethodName: "ScheduleRemoveTask",
			Handler:    _Manager_ScheduleRemoveTask_Handler,
		},
		{
			MethodName: "ScheduleRunTask",
			Handler:    _Manager_ScheduleRunTask_Handler,
		},
		{
			MethodName: "ScheduleTaskHistoryList",
			Handler:    _Manager_ScheduleTaskHistoryList_Handler,
		},
		{
			MethodName: "ScheduleTaskHistoryDetail",
			Handler:    _Manager_ScheduleTaskHistoryDetail_Handler,
		},
		{
			MethodName: "CommandRunAsync",
			Handler:    _Manager_CommandRunAsync_Handler,
		},
		{
			MethodName: "CommandUpOutput",
			Handler:    _Manager_CommandUpOutput_Handler,
		},
		{
			MethodName: "CommandRunStats",
			Handler:    _Manager_CommandRunStats_Handler,
		},
		{
			MethodName: "CommandGetOutput",
			Handler:    _Manager_CommandGetOutput_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CommandRunSync",
			Handler:       _Manager_CommandRunSync_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "manager.proto",
}

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

Functions

func RegisterManagerServer 

func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)

Types

type ClusterLeaderRequest 

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

func (*ClusterLeaderRequest) Descriptor deprecated 

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

Deprecated: Use ClusterLeaderRequest.ProtoReflect.Descriptor instead.

func (*ClusterLeaderRequest) ProtoMessage 

func (*ClusterLeaderRequest) ProtoMessage()

func (*ClusterLeaderRequest) ProtoReflect 

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

func (*ClusterLeaderRequest) Reset 

func (x *ClusterLeaderRequest) Reset()

func (*ClusterLeaderRequest) String 

func (x *ClusterLeaderRequest) String() string

type ClusterLeaderResponse 

type ClusterLeaderResponse struct {
	Ip   string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`      // 主节点IP
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // 主节点端口
	// contains filtered or unexported fields
}

func (*ClusterLeaderResponse) Descriptor deprecated 

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

Deprecated: Use ClusterLeaderResponse.ProtoReflect.Descriptor instead.

func (*ClusterLeaderResponse) GetIp 

func (x *ClusterLeaderResponse) GetIp() string

func (*ClusterLeaderResponse) GetPort 

func (x *ClusterLeaderResponse) GetPort() int32

func (*ClusterLeaderResponse) ProtoMessage 

func (*ClusterLeaderResponse) ProtoMessage()

func (*ClusterLeaderResponse) ProtoReflect 

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

func (*ClusterLeaderResponse) Reset 

func (x *ClusterLeaderResponse) Reset()

func (*ClusterLeaderResponse) String 

func (x *ClusterLeaderResponse) String() string

type CommandGetOutputRequest 

type CommandGetOutputRequest struct {
	TaskId   string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"`     // 任务ID
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"` // 主机名称
	// contains filtered or unexported fields
}

func (*CommandGetOutputRequest) Descriptor deprecated 

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

Deprecated: Use CommandGetOutputRequest.ProtoReflect.Descriptor instead.

func (*CommandGetOutputRequest) GetHostname 

func (x *CommandGetOutputRequest) GetHostname() string

func (*CommandGetOutputRequest) GetTaskId 

func (x *CommandGetOutputRequest) GetTaskId() string

func (*CommandGetOutputRequest) ProtoMessage 

func (*CommandGetOutputRequest) ProtoMessage()

func (*CommandGetOutputRequest) ProtoReflect 

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

func (*CommandGetOutputRequest) Reset 

func (x *CommandGetOutputRequest) Reset()

func (*CommandGetOutputRequest) String 

func (x *CommandGetOutputRequest) String() string

type CommandGetOutputResponse 

type CommandGetOutputResponse struct {
	Output []byte `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"` // 输出内容
	// contains filtered or unexported fields
}

func (*CommandGetOutputResponse) Descriptor deprecated 

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

Deprecated: Use CommandGetOutputResponse.ProtoReflect.Descriptor instead.

func (*CommandGetOutputResponse) GetOutput 

func (x *CommandGetOutputResponse) GetOutput() []byte

func (*CommandGetOutputResponse) ProtoMessage 

func (*CommandGetOutputResponse) ProtoMessage()

func (*CommandGetOutputResponse) ProtoReflect 

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

func (*CommandGetOutputResponse) Reset 

func (x *CommandGetOutputResponse) Reset()

func (*CommandGetOutputResponse) String 

func (x *CommandGetOutputResponse) String() string

type CommandRunAsyncRequest 

type CommandRunAsyncRequest struct {
	HostnameList []string `protobuf:"bytes,1,rep,name=hostnameList,proto3" json:"hostnameList,omitempty"` // 执行命令的Worker列表
	Command      string   `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`           // 命令，可执行的完整的命令，应该包含执行需要的所有信息
	Timeout      int64    `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`          // 执行超时时间，单位秒
	Tags         []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`                 // 自定义标签
	// contains filtered or unexported fields
}

func (*CommandRunAsyncRequest) Descriptor deprecated 

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

Deprecated: Use CommandRunAsyncRequest.ProtoReflect.Descriptor instead.

func (*CommandRunAsyncRequest) GetCommand 

func (x *CommandRunAsyncRequest) GetCommand() string

func (*CommandRunAsyncRequest) GetHostnameList 

func (x *CommandRunAsyncRequest) GetHostnameList() []string

func (*CommandRunAsyncRequest) GetTags 

func (x *CommandRunAsyncRequest) GetTags() []string

func (*CommandRunAsyncRequest) GetTimeout 

func (x *CommandRunAsyncRequest) GetTimeout() int64

func (*CommandRunAsyncRequest) ProtoMessage 

func (*CommandRunAsyncRequest) ProtoMessage()

func (*CommandRunAsyncRequest) ProtoReflect 

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

func (*CommandRunAsyncRequest) Reset 

func (x *CommandRunAsyncRequest) Reset()

func (*CommandRunAsyncRequest) String 

func (x *CommandRunAsyncRequest) String() string

type CommandRunAsyncResponse 

type CommandRunAsyncResponse struct {
	TaskId    string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"`        // 任务ID
	StartTime int64  `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"` // 开始时间
	// contains filtered or unexported fields
}

func (*CommandRunAsyncResponse) Descriptor deprecated 

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

Deprecated: Use CommandRunAsyncResponse.ProtoReflect.Descriptor instead.

func (*CommandRunAsyncResponse) GetStartTime 

func (x *CommandRunAsyncResponse) GetStartTime() int64

func (*CommandRunAsyncResponse) GetTaskId 

func (x *CommandRunAsyncResponse) GetTaskId() string

func (*CommandRunAsyncResponse) ProtoMessage 

func (*CommandRunAsyncResponse) ProtoMessage()

func (*CommandRunAsyncResponse) ProtoReflect 

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

func (*CommandRunAsyncResponse) Reset 

func (x *CommandRunAsyncResponse) Reset()

func (*CommandRunAsyncResponse) String 

func (x *CommandRunAsyncResponse) String() string

type CommandRunStatsRequest 

type CommandRunStatsRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"` // 任务ID
	// contains filtered or unexported fields
}

func (*CommandRunStatsRequest) Descriptor deprecated 

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

Deprecated: Use CommandRunStatsRequest.ProtoReflect.Descriptor instead.

func (*CommandRunStatsRequest) GetTaskId 

func (x *CommandRunStatsRequest) GetTaskId() string

func (*CommandRunStatsRequest) ProtoMessage 

func (*CommandRunStatsRequest) ProtoMessage()

func (*CommandRunStatsRequest) ProtoReflect 

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

func (*CommandRunStatsRequest) Reset 

func (x *CommandRunStatsRequest) Reset()

func (*CommandRunStatsRequest) String 

func (x *CommandRunStatsRequest) String() string

type CommandRunStatsResponse 

type CommandRunStatsResponse struct {
	State   CommandState                    `protobuf:"varint,1,opt,name=state,proto3,enum=eternal.protobuf.manager.CommandState" json:"state,omitempty"` // 任务状态
	EndTime int64                           `protobuf:"varint,2,opt,name=endTime,proto3" json:"endTime,omitempty"`                                        // 结束时间
	Workers []*CommandRunStatsResponse_Item `protobuf:"bytes,3,rep,name=workers,proto3" json:"workers,omitempty"`                                         // 状态列表
	// contains filtered or unexported fields
}

func (*CommandRunStatsResponse) Descriptor deprecated 

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

Deprecated: Use CommandRunStatsResponse.ProtoReflect.Descriptor instead.

func (*CommandRunStatsResponse) GetEndTime 

func (x *CommandRunStatsResponse) GetEndTime() int64

func (*CommandRunStatsResponse) GetState 

func (x *CommandRunStatsResponse) GetState() CommandState

func (*CommandRunStatsResponse) GetWorkers 

func (x *CommandRunStatsResponse) GetWorkers() []*CommandRunStatsResponse_Item

func (*CommandRunStatsResponse) ProtoMessage 

func (*CommandRunStatsResponse) ProtoMessage()

func (*CommandRunStatsResponse) ProtoReflect 

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

func (*CommandRunStatsResponse) Reset 

func (x *CommandRunStatsResponse) Reset()

func (*CommandRunStatsResponse) String 

func (x *CommandRunStatsResponse) String() string

type CommandRunStatsResponse_Item 

type CommandRunStatsResponse_Item struct {
	Hostname  string       `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`                                       // 主机名称
	State     CommandState `protobuf:"varint,2,opt,name=state,proto3,enum=eternal.protobuf.manager.CommandState" json:"state,omitempty"` // 状态
	StartTime int64        `protobuf:"varint,3,opt,name=startTime,proto3" json:"startTime,omitempty"`                                    // 开始时间
	EndTime   int64        `protobuf:"varint,4,opt,name=endTime,proto3" json:"endTime,omitempty"`                                        // 结束时间
	// contains filtered or unexported fields
}

func (*CommandRunStatsResponse_Item) Descriptor deprecated 

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

Deprecated: Use CommandRunStatsResponse_Item.ProtoReflect.Descriptor instead.

func (*CommandRunStatsResponse_Item) GetEndTime 

func (x *CommandRunStatsResponse_Item) GetEndTime() int64

func (*CommandRunStatsResponse_Item) GetHostname 

func (x *CommandRunStatsResponse_Item) GetHostname() string

func (*CommandRunStatsResponse_Item) GetStartTime 

func (x *CommandRunStatsResponse_Item) GetStartTime() int64

func (*CommandRunStatsResponse_Item) GetState 

func (x *CommandRunStatsResponse_Item) GetState() CommandState

func (*CommandRunStatsResponse_Item) ProtoMessage 

func (*CommandRunStatsResponse_Item) ProtoMessage()

func (*CommandRunStatsResponse_Item) ProtoReflect 

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

func (*CommandRunStatsResponse_Item) Reset 

func (x *CommandRunStatsResponse_Item) Reset()

func (*CommandRunStatsResponse_Item) String 

func (x *CommandRunStatsResponse_Item) String() string

type CommandRunSyncRequest 

type CommandRunSyncRequest struct {
	Action    CommandRunSyncRequest_Action `protobuf:"varint,1,opt,name=action,proto3,enum=eternal.protobuf.manager.CommandRunSyncRequest_Action" json:"action,omitempty"` // 执行的操作
	CommandId string                       `protobuf:"bytes,2,opt,name=commandId,proto3" json:"commandId,omitempty"`                                                       // 本次执行的命令的ID，用于唯一标识一个任务，可以为空，将由Worker自动生成一个ID并返回
	Data      []byte                       `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`                                                                 // 数据字节数组，根据动作决定处理方式
	// contains filtered or unexported fields
}

func (*CommandRunSyncRequest) Descriptor deprecated 

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

Deprecated: Use CommandRunSyncRequest.ProtoReflect.Descriptor instead.

func (*CommandRunSyncRequest) GetAction 

func (x *CommandRunSyncRequest) GetAction() CommandRunSyncRequest_Action

func (*CommandRunSyncRequest) GetCommandId 

func (x *CommandRunSyncRequest) GetCommandId() string

func (*CommandRunSyncRequest) GetData 

func (x *CommandRunSyncRequest) GetData() []byte

func (*CommandRunSyncRequest) ProtoMessage 

func (*CommandRunSyncRequest) ProtoMessage()

func (*CommandRunSyncRequest) ProtoReflect 

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

func (*CommandRunSyncRequest) Reset 

func (x *CommandRunSyncRequest) Reset()

func (*CommandRunSyncRequest) String 

func (x *CommandRunSyncRequest) String() string

type CommandRunSyncRequest_Action 

type CommandRunSyncRequest_Action int32
const (
	CommandRunSyncRequest_ActionNotUse  CommandRunSyncRequest_Action = 0 // 未使用的枚举值
	CommandRunSyncRequest_ActionExecute CommandRunSyncRequest_Action = 1 // 启动命令
	CommandRunSyncRequest_ActionInput   CommandRunSyncRequest_Action = 2 // 向命令追加输入
	CommandRunSyncRequest_ActionExit    CommandRunSyncRequest_Action = 3 // 结束命令
)

func (CommandRunSyncRequest_Action) Descriptor 

func (CommandRunSyncRequest_Action) Descriptor() protoreflect.EnumDescriptor

func (CommandRunSyncRequest_Action) Enum 

func (x CommandRunSyncRequest_Action) Enum() *CommandRunSyncRequest_Action

func (CommandRunSyncRequest_Action) EnumDescriptor deprecated 

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

Deprecated: Use CommandRunSyncRequest_Action.Descriptor instead.

func (CommandRunSyncRequest_Action) Number 

func (x CommandRunSyncRequest_Action) Number() protoreflect.EnumNumber

func (CommandRunSyncRequest_Action) String 

func (x CommandRunSyncRequest_Action) String() string

func (CommandRunSyncRequest_Action) Type 

func (CommandRunSyncRequest_Action) Type() protoreflect.EnumType

type CommandRunSyncResponse 

type CommandRunSyncResponse struct {
	CommandId string `protobuf:"bytes,1,opt,name=commandId,proto3" json:"commandId,omitempty"` // 执行的任务ID
	Output    []byte `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`       // 输出
	// contains filtered or unexported fields
}

func (*CommandRunSyncResponse) Descriptor deprecated 

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

Deprecated: Use CommandRunSyncResponse.ProtoReflect.Descriptor instead.

func (*CommandRunSyncResponse) GetCommandId 

func (x *CommandRunSyncResponse) GetCommandId() string

func (*CommandRunSyncResponse) GetOutput 

func (x *CommandRunSyncResponse) GetOutput() []byte

func (*CommandRunSyncResponse) ProtoMessage 

func (*CommandRunSyncResponse) ProtoMessage()

func (*CommandRunSyncResponse) ProtoReflect 

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

func (*CommandRunSyncResponse) Reset 

func (x *CommandRunSyncResponse) Reset()

func (*CommandRunSyncResponse) String 

func (x *CommandRunSyncResponse) String() string

type CommandState 

type CommandState int32
const (
	CommandState_CommandStateNotUse  CommandState = 0
	CommandState_CommandStateSuccess CommandState = 1
	CommandState_CommandStateFailure CommandState = 2
)

func (CommandState) Descriptor 

func (CommandState) Descriptor() protoreflect.EnumDescriptor

func (CommandState) Enum 

func (x CommandState) Enum() *CommandState

func (CommandState) EnumDescriptor deprecated 

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

Deprecated: Use CommandState.Descriptor instead.

func (CommandState) Number 

func (x CommandState) Number() protoreflect.EnumNumber

func (CommandState) String 

func (x CommandState) String() string

func (CommandState) Type 

func (CommandState) Type() protoreflect.EnumType

type CommandUpOutputRequest 

type CommandUpOutputRequest struct {
	CommandId string                       `protobuf:"bytes,1,opt,name=commandId,proto3" json:"commandId,omitempty"`                                                     // 执行的命令ID，与执行时传入的ID一致
	Num       int64                        `protobuf:"varint,2,opt,name=num,proto3" json:"num,omitempty"`                                                                // 消息序号
	State     CommandUpOutputRequest_State `protobuf:"varint,3,opt,name=state,proto3,enum=eternal.protobuf.manager.CommandUpOutputRequest_State" json:"state,omitempty"` // 任务状态
	EndTime   int64                        `protobuf:"varint,4,opt,name=endTime,proto3" json:"endTime,omitempty"`                                                        // 任务结束时间
	Output    []byte                       `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"`                                                           // 输出内容
	// contains filtered or unexported fields
}

func (*CommandUpOutputRequest) Descriptor deprecated 

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

Deprecated: Use CommandUpOutputRequest.ProtoReflect.Descriptor instead.

func (*CommandUpOutputRequest) GetCommandId 

func (x *CommandUpOutputRequest) GetCommandId() string

func (*CommandUpOutputRequest) GetEndTime 

func (x *CommandUpOutputRequest) GetEndTime() int64

func (*CommandUpOutputRequest) GetNum 

func (x *CommandUpOutputRequest) GetNum() int64

func (*CommandUpOutputRequest) GetOutput 

func (x *CommandUpOutputRequest) GetOutput() []byte

func (*CommandUpOutputRequest) GetState 

func (x *CommandUpOutputRequest) GetState() CommandUpOutputRequest_State

func (*CommandUpOutputRequest) ProtoMessage 

func (*CommandUpOutputRequest) ProtoMessage()

func (*CommandUpOutputRequest) ProtoReflect 

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

func (*CommandUpOutputRequest) Reset 

func (x *CommandUpOutputRequest) Reset()

func (*CommandUpOutputRequest) String 

func (x *CommandUpOutputRequest) String() string

type CommandUpOutputRequest_State 

type CommandUpOutputRequest_State int32
const (
	CommandUpOutputRequest_NotUse  CommandUpOutputRequest_State = 0
	CommandUpOutputRequest_Running CommandUpOutputRequest_State = 1 // 执行中状态，本次消息为内容上报，output字段有效
	CommandUpOutputRequest_Success CommandUpOutputRequest_State = 2 // 成功状态，任务退出状态为0，endTime字段有效，output字段有效
	CommandUpOutputRequest_Failure CommandUpOutputRequest_State = 3 // 失败状态，任务退出状态不为0，endTime字段有效，output字段有效
)

func (CommandUpOutputRequest_State) Descriptor 

func (CommandUpOutputRequest_State) Descriptor() protoreflect.EnumDescriptor

func (CommandUpOutputRequest_State) Enum 

func (x CommandUpOutputRequest_State) Enum() *CommandUpOutputRequest_State

func (CommandUpOutputRequest_State) EnumDescriptor deprecated 

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

Deprecated: Use CommandUpOutputRequest_State.Descriptor instead.

func (CommandUpOutputRequest_State) Number 

func (x CommandUpOutputRequest_State) Number() protoreflect.EnumNumber

func (CommandUpOutputRequest_State) String 

func (x CommandUpOutputRequest_State) String() string

func (CommandUpOutputRequest_State) Type 

func (CommandUpOutputRequest_State) Type() protoreflect.EnumType

type CommandUpOutputResponse 

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

func (*CommandUpOutputResponse) Descriptor deprecated 

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

Deprecated: Use CommandUpOutputResponse.ProtoReflect.Descriptor instead.

func (*CommandUpOutputResponse) ProtoMessage 

func (*CommandUpOutputResponse) ProtoMessage()

func (*CommandUpOutputResponse) ProtoReflect 

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

func (*CommandUpOutputResponse) Reset 

func (x *CommandUpOutputResponse) Reset()

func (*CommandUpOutputResponse) String 

func (x *CommandUpOutputResponse) String() string

type ManagerClient 

type ManagerClient interface {
	// WorkerJoin 注册Worker
	WorkerJoin(ctx context.Context, in *WorkerJoinRequest, opts ...grpc.CallOption) (*WorkerJoinResponse, error)
	// WorkerQuit Worker在关闭时向Manager通知取消注册
	WorkerQuit(ctx context.Context, in *WorkerQuitRequest, opts ...grpc.CallOption) (*WorkerQuitResponse, error)
	// WorkerList 获取所有已注册的Worker列表
	WorkerList(ctx context.Context, in *WorkerListRequest, opts ...grpc.CallOption) (*WorkerListResponse, error)
	// WorkerUpStats Worker上报资源使用统计
	// 该方法由Worker主动调起上报自身的状态数据
	WorkerUpStats(ctx context.Context, in *WorkerUpStatsRequest, opts ...grpc.CallOption) (*WorkerUpStatsResponse, error)
	// WorkerGetStats 获取Worker的资源统计数据
	WorkerGetStats(ctx context.Context, in *WorkerGetStatsRequest, opts ...grpc.CallOption) (*WorkerGetStatsResponse, error)
	// ScheduleTaskList 获取调度任务列表
	ScheduleTaskList(ctx context.Context, in *ScheduleTaskListRequest, opts ...grpc.CallOption) (*ScheduleTaskListResponse, error)
	// ScheduleSetTask 设置一个调度任务
	// 在该任务ID已存在时将会更新任务，否则新增
	ScheduleSetTask(ctx context.Context, in *ScheduleSetTaskRequest, opts ...grpc.CallOption) (*ScheduleSetTaskResponse, error)
	// ScheduleRemoveTask 移除一个调度任务
	ScheduleRemoveTask(ctx context.Context, in *ScheduleRemoveTaskRequest, opts ...grpc.CallOption) (*ScheduleRemoveTaskResponse, error)
	// ScheduleRunTask 主动执行一个调度任务
	ScheduleRunTask(ctx context.Context, in *ScheduleRunTaskRequest, opts ...grpc.CallOption) (*ScheduleRunTaskResponse, error)
	// 获取任务历史日志
	// Manager仅保存有限次数的任务历史
	// 保存历史记录数量有配置参数决定
	ScheduleTaskHistoryList(ctx context.Context, in *ScheduleTaskHistoryListRequest, opts ...grpc.CallOption) (*ScheduleTaskHistoryListResponse, error)
	// 获取任务历史的详细
	ScheduleTaskHistoryDetail(ctx context.Context, in *ScheduleTaskHistoryDetailRequest, opts ...grpc.CallOption) (*ScheduleTaskHistoryDetailResponse, error)
	// CommandRunSync 执行同步任务
	CommandRunSync(ctx context.Context, opts ...grpc.CallOption) (Manager_CommandRunSyncClient, error)
	// CommandRunAsync 执行异步命令
	CommandRunAsync(ctx context.Context, in *CommandRunAsyncRequest, opts ...grpc.CallOption) (*CommandRunAsyncResponse, error)
	// CommandUpOutput 上传任务输出
	// 该方法由Worker主动调起上传异步任务的日志数据
	CommandUpOutput(ctx context.Context, in *CommandUpOutputRequest, opts ...grpc.CallOption) (*CommandUpOutputResponse, error)
	// CommandRunStats 获取任务的状态
	CommandRunStats(ctx context.Context, in *CommandRunStatsRequest, opts ...grpc.CallOption) (*CommandRunStatsResponse, error)
	// CommandGetOutput 获取任务中主机的输出
	CommandGetOutput(ctx context.Context, in *CommandGetOutputRequest, opts ...grpc.CallOption) (*CommandGetOutputResponse, error)
}

ManagerClient is the client API for Manager 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 NewManagerClient 

func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient

type ManagerServer 

type ManagerServer interface {
	// WorkerJoin 注册Worker
	WorkerJoin(context.Context, *WorkerJoinRequest) (*WorkerJoinResponse, error)
	// WorkerQuit Worker在关闭时向Manager通知取消注册
	WorkerQuit(context.Context, *WorkerQuitRequest) (*WorkerQuitResponse, error)
	// WorkerList 获取所有已注册的Worker列表
	WorkerList(context.Context, *WorkerListRequest) (*WorkerListResponse, error)
	// WorkerUpStats Worker上报资源使用统计
	// 该方法由Worker主动调起上报自身的状态数据
	WorkerUpStats(context.Context, *WorkerUpStatsRequest) (*WorkerUpStatsResponse, error)
	// WorkerGetStats 获取Worker的资源统计数据
	WorkerGetStats(context.Context, *WorkerGetStatsRequest) (*WorkerGetStatsResponse, error)
	// ScheduleTaskList 获取调度任务列表
	ScheduleTaskList(context.Context, *ScheduleTaskListRequest) (*ScheduleTaskListResponse, error)
	// ScheduleSetTask 设置一个调度任务
	// 在该任务ID已存在时将会更新任务，否则新增
	ScheduleSetTask(context.Context, *ScheduleSetTaskRequest) (*ScheduleSetTaskResponse, error)
	// ScheduleRemoveTask 移除一个调度任务
	ScheduleRemoveTask(context.Context, *ScheduleRemoveTaskRequest) (*ScheduleRemoveTaskResponse, error)
	// ScheduleRunTask 主动执行一个调度任务
	ScheduleRunTask(context.Context, *ScheduleRunTaskRequest) (*ScheduleRunTaskResponse, error)
	// 获取任务历史日志
	// Manager仅保存有限次数的任务历史
	// 保存历史记录数量有配置参数决定
	ScheduleTaskHistoryList(context.Context, *ScheduleTaskHistoryListRequest) (*ScheduleTaskHistoryListResponse, error)
	// 获取任务历史的详细
	ScheduleTaskHistoryDetail(context.Context, *ScheduleTaskHistoryDetailRequest) (*ScheduleTaskHistoryDetailResponse, error)
	// CommandRunSync 执行同步任务
	CommandRunSync(Manager_CommandRunSyncServer) error
	// CommandRunAsync 执行异步命令
	CommandRunAsync(context.Context, *CommandRunAsyncRequest) (*CommandRunAsyncResponse, error)
	// CommandUpOutput 上传任务输出
	// 该方法由Worker主动调起上传异步任务的日志数据
	CommandUpOutput(context.Context, *CommandUpOutputRequest) (*CommandUpOutputResponse, error)
	// CommandRunStats 获取任务的状态
	CommandRunStats(context.Context, *CommandRunStatsRequest) (*CommandRunStatsResponse, error)
	// CommandGetOutput 获取任务中主机的输出
	CommandGetOutput(context.Context, *CommandGetOutputRequest) (*CommandGetOutputResponse, error)
	// contains filtered or unexported methods
}

ManagerServer is the server API for Manager service. All implementations must embed UnimplementedManagerServer for forward compatibility

type Manager_CommandRunSyncClient 

type Manager_CommandRunSyncClient interface {
	Send(*CommandRunSyncRequest) error
	Recv() (*CommandRunSyncResponse, error)
	grpc.ClientStream
}

type Manager_CommandRunSyncServer 

type Manager_CommandRunSyncServer interface {
	Send(*CommandRunSyncResponse) error
	Recv() (*CommandRunSyncRequest, error)
	grpc.ServerStream
}

type ScheduleRemoveTaskRequest 

type ScheduleRemoveTaskRequest struct {
	ScheduleTaskId string `protobuf:"bytes,1,opt,name=scheduleTaskId,proto3" json:"scheduleTaskId,omitempty"` // 调度任务配置ID
	// contains filtered or unexported fields
}

func (*ScheduleRemoveTaskRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleRemoveTaskRequest.ProtoReflect.Descriptor instead.

func (*ScheduleRemoveTaskRequest) GetScheduleTaskId 

func (x *ScheduleRemoveTaskRequest) GetScheduleTaskId() string

func (*ScheduleRemoveTaskRequest) ProtoMessage 

func (*ScheduleRemoveTaskRequest) ProtoMessage()

func (*ScheduleRemoveTaskRequest) ProtoReflect 

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

func (*ScheduleRemoveTaskRequest) Reset 

func (x *ScheduleRemoveTaskRequest) Reset()

func (*ScheduleRemoveTaskRequest) String 

func (x *ScheduleRemoveTaskRequest) String() string

type ScheduleRemoveTaskResponse 

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

func (*ScheduleRemoveTaskResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleRemoveTaskResponse.ProtoReflect.Descriptor instead.

func (*ScheduleRemoveTaskResponse) ProtoMessage 

func (*ScheduleRemoveTaskResponse) ProtoMessage()

func (*ScheduleRemoveTaskResponse) ProtoReflect 

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

func (*ScheduleRemoveTaskResponse) Reset 

func (x *ScheduleRemoveTaskResponse) Reset()

func (*ScheduleRemoveTaskResponse) String 

func (x *ScheduleRemoveTaskResponse) String() string

type ScheduleRunTaskRequest 

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

func (*ScheduleRunTaskRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleRunTaskRequest.ProtoReflect.Descriptor instead.

func (*ScheduleRunTaskRequest) ProtoMessage 

func (*ScheduleRunTaskRequest) ProtoMessage()

func (*ScheduleRunTaskRequest) ProtoReflect 

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

func (*ScheduleRunTaskRequest) Reset 

func (x *ScheduleRunTaskRequest) Reset()

func (*ScheduleRunTaskRequest) String 

func (x *ScheduleRunTaskRequest) String() string

type ScheduleRunTaskResponse 

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

func (*ScheduleRunTaskResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleRunTaskResponse.ProtoReflect.Descriptor instead.

func (*ScheduleRunTaskResponse) ProtoMessage 

func (*ScheduleRunTaskResponse) ProtoMessage()

func (*ScheduleRunTaskResponse) ProtoReflect 

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

func (*ScheduleRunTaskResponse) Reset 

func (x *ScheduleRunTaskResponse) Reset()

func (*ScheduleRunTaskResponse) String 

func (x *ScheduleRunTaskResponse) String() string

type ScheduleSetTaskRequest 

type ScheduleSetTaskRequest struct {
	ScheduleId   string                      `protobuf:"bytes,1,opt,name=scheduleId,proto3" json:"scheduleId,omitempty"`                                                // 调度任务ID，该参数不为空时将更新已存在的调度任务，如果该参数指定的id不存在，将返回一个错误
	Enable       bool                        `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"`                                                       // 是否启用该任务
	Schedule     string                      `protobuf:"bytes,3,opt,name=schedule,proto3" json:"schedule,omitempty"`                                                    // 调度器配置，具体可用配置格式参考: https://pkg.go.dev/github.com/robfig/cron
	HostnameList []string                    `protobuf:"bytes,4,rep,name=hostnameList,proto3" json:"hostnameList,omitempty"`                                            // 运行任务的目标主机列表
	Command      string                      `protobuf:"bytes,5,opt,name=command,proto3" json:"command,omitempty"`                                                      // 命令，可执行的完整的命令，应该包含执行需要的所有信息
	Remark       string                      `protobuf:"bytes,6,opt,name=remark,proto3" json:"remark,omitempty"`                                                        // 任务的备注信息
	Tags         []string                    `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`                                                            // 自定义标签列表
	Mode         ScheduleSetTaskRequest_Mode `protobuf:"varint,8,opt,name=mode,proto3,enum=eternal.protobuf.manager.ScheduleSetTaskRequest_Mode" json:"mode,omitempty"` // 任务下发模式
	// contains filtered or unexported fields
}

func (*ScheduleSetTaskRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleSetTaskRequest.ProtoReflect.Descriptor instead.

func (*ScheduleSetTaskRequest) GetCommand 

func (x *ScheduleSetTaskRequest) GetCommand() string

func (*ScheduleSetTaskRequest) GetEnable 

func (x *ScheduleSetTaskRequest) GetEnable() bool

func (*ScheduleSetTaskRequest) GetHostnameList 

func (x *ScheduleSetTaskRequest) GetHostnameList() []string

func (*ScheduleSetTaskRequest) GetMode 

func (x *ScheduleSetTaskRequest) GetMode() ScheduleSetTaskRequest_Mode

func (*ScheduleSetTaskRequest) GetRemark 

func (x *ScheduleSetTaskRequest) GetRemark() string

func (*ScheduleSetTaskRequest) GetSchedule 

func (x *ScheduleSetTaskRequest) GetSchedule() string

func (*ScheduleSetTaskRequest) GetScheduleId 

func (x *ScheduleSetTaskRequest) GetScheduleId() string

func (*ScheduleSetTaskRequest) GetTags 

func (x *ScheduleSetTaskRequest) GetTags() []string

func (*ScheduleSetTaskRequest) ProtoMessage 

func (*ScheduleSetTaskRequest) ProtoMessage()

func (*ScheduleSetTaskRequest) ProtoReflect 

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

func (*ScheduleSetTaskRequest) Reset 

func (x *ScheduleSetTaskRequest) Reset()

func (*ScheduleSetTaskRequest) String 

func (x *ScheduleSetTaskRequest) String() string

type ScheduleSetTaskRequest_Mode 

type ScheduleSetTaskRequest_Mode int32
const (
	ScheduleSetTaskRequest_ModeNotUse ScheduleSetTaskRequest_Mode = 0
	ScheduleSetTaskRequest_ModeAll    ScheduleSetTaskRequest_Mode = 1 // 所有指定的HostList全部执行
	ScheduleSetTaskRequest_ModeRand   ScheduleSetTaskRequest_Mode = 2 // 在指定的HostList中随机选择一个执行，该模式将自动启用负载均衡
)

func (ScheduleSetTaskRequest_Mode) Descriptor 

func (ScheduleSetTaskRequest_Mode) Descriptor() protoreflect.EnumDescriptor

func (ScheduleSetTaskRequest_Mode) Enum 

func (x ScheduleSetTaskRequest_Mode) Enum() *ScheduleSetTaskRequest_Mode

func (ScheduleSetTaskRequest_Mode) EnumDescriptor deprecated 

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

Deprecated: Use ScheduleSetTaskRequest_Mode.Descriptor instead.

func (ScheduleSetTaskRequest_Mode) Number 

func (x ScheduleSetTaskRequest_Mode) Number() protoreflect.EnumNumber

func (ScheduleSetTaskRequest_Mode) String 

func (x ScheduleSetTaskRequest_Mode) String() string

func (ScheduleSetTaskRequest_Mode) Type 

func (ScheduleSetTaskRequest_Mode) Type() protoreflect.EnumType

type ScheduleSetTaskResponse 

type ScheduleSetTaskResponse struct {
	ScheduleTaskId string `protobuf:"bytes,1,opt,name=scheduleTaskId,proto3" json:"scheduleTaskId,omitempty"` // 新增或编辑的调度任务ID
	// contains filtered or unexported fields
}

func (*ScheduleSetTaskResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleSetTaskResponse.ProtoReflect.Descriptor instead.

func (*ScheduleSetTaskResponse) GetScheduleTaskId 

func (x *ScheduleSetTaskResponse) GetScheduleTaskId() string

func (*ScheduleSetTaskResponse) ProtoMessage 

func (*ScheduleSetTaskResponse) ProtoMessage()

func (*ScheduleSetTaskResponse) ProtoReflect 

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

func (*ScheduleSetTaskResponse) Reset 

func (x *ScheduleSetTaskResponse) Reset()

func (*ScheduleSetTaskResponse) String 

func (x *ScheduleSetTaskResponse) String() string

type ScheduleState 

type ScheduleState int32
const (
	ScheduleState_ScheduleStateNotUse  ScheduleState = 0
	ScheduleState_ScheduleStateSuccess ScheduleState = 1 // 成功
	ScheduleState_ScheduleStateFailure ScheduleState = 2 // 失败
)

func (ScheduleState) Descriptor 

func (ScheduleState) Descriptor() protoreflect.EnumDescriptor

func (ScheduleState) Enum 

func (x ScheduleState) Enum() *ScheduleState

func (ScheduleState) EnumDescriptor deprecated 

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

Deprecated: Use ScheduleState.Descriptor instead.

func (ScheduleState) Number 

func (x ScheduleState) Number() protoreflect.EnumNumber

func (ScheduleState) String 

func (x ScheduleState) String() string

func (ScheduleState) Type 

func (ScheduleState) Type() protoreflect.EnumType

type ScheduleTaskHistoryDetailRequest 

type ScheduleTaskHistoryDetailRequest struct {
	ScheduleTaskId string `protobuf:"bytes,1,opt,name=scheduleTaskId,proto3" json:"scheduleTaskId,omitempty"` // 调度任务ID
	StartTime      int64  `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`          // 开始时间
	// contains filtered or unexported fields
}

func (*ScheduleTaskHistoryDetailRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskHistoryDetailRequest.ProtoReflect.Descriptor instead.

func (*ScheduleTaskHistoryDetailRequest) GetScheduleTaskId 

func (x *ScheduleTaskHistoryDetailRequest) GetScheduleTaskId() string

func (*ScheduleTaskHistoryDetailRequest) GetStartTime 

func (x *ScheduleTaskHistoryDetailRequest) GetStartTime() int64

func (*ScheduleTaskHistoryDetailRequest) ProtoMessage 

func (*ScheduleTaskHistoryDetailRequest) ProtoMessage()

func (*ScheduleTaskHistoryDetailRequest) ProtoReflect 

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

func (*ScheduleTaskHistoryDetailRequest) Reset 

func (x *ScheduleTaskHistoryDetailRequest) Reset()

func (*ScheduleTaskHistoryDetailRequest) String 

func (x *ScheduleTaskHistoryDetailRequest) String() string

type ScheduleTaskHistoryDetailResponse 

type ScheduleTaskHistoryDetailResponse struct {
	Data []*ScheduleTaskHistoryDetailResponse_HistoryDetail `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleTaskHistoryDetailResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskHistoryDetailResponse.ProtoReflect.Descriptor instead.

func (*ScheduleTaskHistoryDetailResponse) GetData 

func (x *ScheduleTaskHistoryDetailResponse) GetData() []*ScheduleTaskHistoryDetailResponse_HistoryDetail

func (*ScheduleTaskHistoryDetailResponse) ProtoMessage 

func (*ScheduleTaskHistoryDetailResponse) ProtoMessage()

func (*ScheduleTaskHistoryDetailResponse) ProtoReflect 

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

func (*ScheduleTaskHistoryDetailResponse) Reset 

func (x *ScheduleTaskHistoryDetailResponse) Reset()

func (*ScheduleTaskHistoryDetailResponse) String 

func (x *ScheduleTaskHistoryDetailResponse) String() string

type ScheduleTaskHistoryDetailResponse_HistoryDetail 

type ScheduleTaskHistoryDetailResponse_HistoryDetail struct {
	Hostname  string        `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`                                        // 执行该任务的主机名
	State     ScheduleState `protobuf:"varint,2,opt,name=state,proto3,enum=eternal.protobuf.manager.ScheduleState" json:"state,omitempty"` // 执行状态
	StartTime int64         `protobuf:"varint,3,opt,name=startTime,proto3" json:"startTime,omitempty"`                                     // 开始执行时间
	EndTime   int64         `protobuf:"varint,4,opt,name=endTime,proto3" json:"endTime,omitempty"`                                         // 执行结束时间
	Output    []byte        `protobuf:"bytes,5,opt,name=output,proto3" json:"output,omitempty"`                                            // 输出内容
	// contains filtered or unexported fields
}

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskHistoryDetailResponse_HistoryDetail.ProtoReflect.Descriptor instead.

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) GetEndTime 

func (x *ScheduleTaskHistoryDetailResponse_HistoryDetail) GetEndTime() int64

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) GetHostname 

func (x *ScheduleTaskHistoryDetailResponse_HistoryDetail) GetHostname() string

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) GetOutput 

func (x *ScheduleTaskHistoryDetailResponse_HistoryDetail) GetOutput() []byte

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) GetStartTime 

func (x *ScheduleTaskHistoryDetailResponse_HistoryDetail) GetStartTime() int64

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) GetState 

func (x *ScheduleTaskHistoryDetailResponse_HistoryDetail) GetState() ScheduleState

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) ProtoMessage 

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) ProtoMessage()

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) ProtoReflect 

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

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) Reset 

func (x *ScheduleTaskHistoryDetailResponse_HistoryDetail) Reset()

func (*ScheduleTaskHistoryDetailResponse_HistoryDetail) String 

func (x *ScheduleTaskHistoryDetailResponse_HistoryDetail) String() string

type ScheduleTaskHistoryListRequest 

type ScheduleTaskHistoryListRequest struct {
	ScheduleTaskId string `protobuf:"bytes,1,opt,name=scheduleTaskId,proto3" json:"scheduleTaskId,omitempty"` // 调度任务ID
	// contains filtered or unexported fields
}

func (*ScheduleTaskHistoryListRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskHistoryListRequest.ProtoReflect.Descriptor instead.

func (*ScheduleTaskHistoryListRequest) GetScheduleTaskId 

func (x *ScheduleTaskHistoryListRequest) GetScheduleTaskId() string

func (*ScheduleTaskHistoryListRequest) ProtoMessage 

func (*ScheduleTaskHistoryListRequest) ProtoMessage()

func (*ScheduleTaskHistoryListRequest) ProtoReflect 

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

func (*ScheduleTaskHistoryListRequest) Reset 

func (x *ScheduleTaskHistoryListRequest) Reset()

func (*ScheduleTaskHistoryListRequest) String 

func (x *ScheduleTaskHistoryListRequest) String() string

type ScheduleTaskHistoryListResponse 

type ScheduleTaskHistoryListResponse struct {
	Data []*ScheduleTaskHistoryListResponse_History `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleTaskHistoryListResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskHistoryListResponse.ProtoReflect.Descriptor instead.

func (*ScheduleTaskHistoryListResponse) GetData 

func (x *ScheduleTaskHistoryListResponse) GetData() []*ScheduleTaskHistoryListResponse_History

func (*ScheduleTaskHistoryListResponse) ProtoMessage 

func (*ScheduleTaskHistoryListResponse) ProtoMessage()

func (*ScheduleTaskHistoryListResponse) ProtoReflect 

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

func (*ScheduleTaskHistoryListResponse) Reset 

func (x *ScheduleTaskHistoryListResponse) Reset()

func (*ScheduleTaskHistoryListResponse) String 

func (x *ScheduleTaskHistoryListResponse) String() string

type ScheduleTaskHistoryListResponse_History 

type ScheduleTaskHistoryListResponse_History struct {
	StartTime int64         `protobuf:"varint,1,opt,name=startTime,proto3" json:"startTime,omitempty"`                                     // 开始执行的时间
	EndTime   int64         `protobuf:"varint,2,opt,name=endTime,proto3" json:"endTime,omitempty"`                                         // 执行结束时间
	State     ScheduleState `protobuf:"varint,3,opt,name=state,proto3,enum=eternal.protobuf.manager.ScheduleState" json:"state,omitempty"` // 状态
	// contains filtered or unexported fields
}

func (*ScheduleTaskHistoryListResponse_History) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskHistoryListResponse_History.ProtoReflect.Descriptor instead.

func (*ScheduleTaskHistoryListResponse_History) GetEndTime 

func (x *ScheduleTaskHistoryListResponse_History) GetEndTime() int64

func (*ScheduleTaskHistoryListResponse_History) GetStartTime 

func (x *ScheduleTaskHistoryListResponse_History) GetStartTime() int64

func (*ScheduleTaskHistoryListResponse_History) GetState 

func (x *ScheduleTaskHistoryListResponse_History) GetState() ScheduleState

func (*ScheduleTaskHistoryListResponse_History) ProtoMessage 

func (*ScheduleTaskHistoryListResponse_History) ProtoMessage()

func (*ScheduleTaskHistoryListResponse_History) ProtoReflect 

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

func (*ScheduleTaskHistoryListResponse_History) Reset 

func (x *ScheduleTaskHistoryListResponse_History) Reset()

func (*ScheduleTaskHistoryListResponse_History) String 

func (x *ScheduleTaskHistoryListResponse_History) String() string

type ScheduleTaskListRequest 

type ScheduleTaskListRequest struct {
	Tags []string `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"` // 搜索的自定义标签
	// contains filtered or unexported fields
}

func (*ScheduleTaskListRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskListRequest.ProtoReflect.Descriptor instead.

func (*ScheduleTaskListRequest) GetTags 

func (x *ScheduleTaskListRequest) GetTags() []string

func (*ScheduleTaskListRequest) ProtoMessage 

func (*ScheduleTaskListRequest) ProtoMessage()

func (*ScheduleTaskListRequest) ProtoReflect 

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

func (*ScheduleTaskListRequest) Reset 

func (x *ScheduleTaskListRequest) Reset()

func (*ScheduleTaskListRequest) String 

func (x *ScheduleTaskListRequest) String() string

type ScheduleTaskListResponse 

type ScheduleTaskListResponse struct {
	ScheduleList []*ScheduleTaskListResponse_Schedule `protobuf:"bytes,1,rep,name=scheduleList,proto3" json:"scheduleList,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleTaskListResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskListResponse.ProtoReflect.Descriptor instead.

func (*ScheduleTaskListResponse) GetScheduleList 

func (x *ScheduleTaskListResponse) GetScheduleList() []*ScheduleTaskListResponse_Schedule

func (*ScheduleTaskListResponse) ProtoMessage 

func (*ScheduleTaskListResponse) ProtoMessage()

func (*ScheduleTaskListResponse) ProtoReflect 

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

func (*ScheduleTaskListResponse) Reset 

func (x *ScheduleTaskListResponse) Reset()

func (*ScheduleTaskListResponse) String 

func (x *ScheduleTaskListResponse) String() string

type ScheduleTaskListResponse_Schedule 

type ScheduleTaskListResponse_Schedule struct {
	Id           string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                                            // 任务id
	Schedule     string        `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`                                                // 设置的调度器
	Command      string        `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`                                                  // 命令，可执行的完整的命令
	HostnameList []string      `protobuf:"bytes,4,rep,name=hostnameList,proto3" json:"hostnameList,omitempty"`                                        // 设置的主机列表
	Remark       string        `protobuf:"bytes,5,opt,name=remark,proto3" json:"remark,omitempty"`                                                    // 备注信息
	Last         int64         `protobuf:"varint,6,opt,name=last,proto3" json:"last,omitempty"`                                                       // 最后一次运行时间
	Next         int64         `protobuf:"varint,7,opt,name=next,proto3" json:"next,omitempty"`                                                       // 下一次运行时间
	LastState    ScheduleState `protobuf:"varint,8,opt,name=lastState,proto3,enum=eternal.protobuf.manager.ScheduleState" json:"lastState,omitempty"` // 最后一次运行状态
	Tags         []string      `protobuf:"bytes,9,rep,name=tags,proto3" json:"tags,omitempty"`                                                        // 自定义标签列表
	Enable       bool          `protobuf:"varint,10,opt,name=enable,proto3" json:"enable,omitempty"`                                                  // 是否启用
	CreateTime   int64         `protobuf:"varint,11,opt,name=createTime,proto3" json:"createTime,omitempty"`                                          // 创建时间，任务的初次创建时间
	UpdateTime   int64         `protobuf:"varint,12,opt,name=updateTime,proto3" json:"updateTime,omitempty"`                                          // 更新时间，该时间为重新设置任务的时间，任务状态变更等自动更新统计的操作不会更新此时间
	// contains filtered or unexported fields
}

func (*ScheduleTaskListResponse_Schedule) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskListResponse_Schedule.ProtoReflect.Descriptor instead.

func (*ScheduleTaskListResponse_Schedule) GetCommand 

func (x *ScheduleTaskListResponse_Schedule) GetCommand() string

func (*ScheduleTaskListResponse_Schedule) GetCreateTime 

func (x *ScheduleTaskListResponse_Schedule) GetCreateTime() int64

func (*ScheduleTaskListResponse_Schedule) GetEnable 

func (x *ScheduleTaskListResponse_Schedule) GetEnable() bool

func (*ScheduleTaskListResponse_Schedule) GetHostnameList 

func (x *ScheduleTaskListResponse_Schedule) GetHostnameList() []string

func (*ScheduleTaskListResponse_Schedule) GetId 

func (x *ScheduleTaskListResponse_Schedule) GetId() string

func (*ScheduleTaskListResponse_Schedule) GetLast 

func (x *ScheduleTaskListResponse_Schedule) GetLast() int64

func (*ScheduleTaskListResponse_Schedule) GetLastState 

func (x *ScheduleTaskListResponse_Schedule) GetLastState() ScheduleState

func (*ScheduleTaskListResponse_Schedule) GetNext 

func (x *ScheduleTaskListResponse_Schedule) GetNext() int64

func (*ScheduleTaskListResponse_Schedule) GetRemark 

func (x *ScheduleTaskListResponse_Schedule) GetRemark() string

func (*ScheduleTaskListResponse_Schedule) GetSchedule 

func (x *ScheduleTaskListResponse_Schedule) GetSchedule() string

func (*ScheduleTaskListResponse_Schedule) GetTags 

func (x *ScheduleTaskListResponse_Schedule) GetTags() []string

func (*ScheduleTaskListResponse_Schedule) GetUpdateTime 

func (x *ScheduleTaskListResponse_Schedule) GetUpdateTime() int64

func (*ScheduleTaskListResponse_Schedule) ProtoMessage 

func (*ScheduleTaskListResponse_Schedule) ProtoMessage()

func (*ScheduleTaskListResponse_Schedule) ProtoReflect 

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

func (*ScheduleTaskListResponse_Schedule) Reset 

func (x *ScheduleTaskListResponse_Schedule) Reset()

func (*ScheduleTaskListResponse_Schedule) String 

func (x *ScheduleTaskListResponse_Schedule) String() string

type UnimplementedManagerServer 

type UnimplementedManagerServer struct {
}

UnimplementedManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedManagerServer) CommandGetOutput 

func (UnimplementedManagerServer) CommandGetOutput(context.Context, *CommandGetOutputRequest) (*CommandGetOutputResponse, error)

func (UnimplementedManagerServer) CommandRunAsync 

func (UnimplementedManagerServer) CommandRunAsync(context.Context, *CommandRunAsyncRequest) (*CommandRunAsyncResponse, error)

func (UnimplementedManagerServer) CommandRunStats 

func (UnimplementedManagerServer) CommandRunStats(context.Context, *CommandRunStatsRequest) (*CommandRunStatsResponse, error)

func (UnimplementedManagerServer) CommandRunSync 

func (UnimplementedManagerServer) CommandRunSync(Manager_CommandRunSyncServer) error

func (UnimplementedManagerServer) CommandUpOutput 

func (UnimplementedManagerServer) CommandUpOutput(context.Context, *CommandUpOutputRequest) (*CommandUpOutputResponse, error)

func (UnimplementedManagerServer) ScheduleRemoveTask 

func (UnimplementedManagerServer) ScheduleRemoveTask(context.Context, *ScheduleRemoveTaskRequest) (*ScheduleRemoveTaskResponse, error)

func (UnimplementedManagerServer) ScheduleRunTask 

func (UnimplementedManagerServer) ScheduleRunTask(context.Context, *ScheduleRunTaskRequest) (*ScheduleRunTaskResponse, error)

func (UnimplementedManagerServer) ScheduleSetTask 

func (UnimplementedManagerServer) ScheduleSetTask(context.Context, *ScheduleSetTaskRequest) (*ScheduleSetTaskResponse, error)

func (UnimplementedManagerServer) ScheduleTaskHistoryDetail 

func (UnimplementedManagerServer) ScheduleTaskHistoryDetail(context.Context, *ScheduleTaskHistoryDetailRequest) (*ScheduleTaskHistoryDetailResponse, error)

func (UnimplementedManagerServer) ScheduleTaskHistoryList 

func (UnimplementedManagerServer) ScheduleTaskHistoryList(context.Context, *ScheduleTaskHistoryListRequest) (*ScheduleTaskHistoryListResponse, error)

func (UnimplementedManagerServer) ScheduleTaskList 

func (UnimplementedManagerServer) ScheduleTaskList(context.Context, *ScheduleTaskListRequest) (*ScheduleTaskListResponse, error)

func (UnimplementedManagerServer) WorkerGetStats 

func (UnimplementedManagerServer) WorkerGetStats(context.Context, *WorkerGetStatsRequest) (*WorkerGetStatsResponse, error)

func (UnimplementedManagerServer) WorkerJoin 

func (UnimplementedManagerServer) WorkerJoin(context.Context, *WorkerJoinRequest) (*WorkerJoinResponse, error)

func (UnimplementedManagerServer) WorkerList 

func (UnimplementedManagerServer) WorkerList(context.Context, *WorkerListRequest) (*WorkerListResponse, error)

func (UnimplementedManagerServer) WorkerQuit 

func (UnimplementedManagerServer) WorkerQuit(context.Context, *WorkerQuitRequest) (*WorkerQuitResponse, error)

func (UnimplementedManagerServer) WorkerUpStats 

func (UnimplementedManagerServer) WorkerUpStats(context.Context, *WorkerUpStatsRequest) (*WorkerUpStatsResponse, error)

type UnsafeManagerServer 

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

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

type WorkerGetStatsRequest 

type WorkerGetStatsRequest struct {
	Hostname []string `protobuf:"bytes,1,rep,name=hostname,proto3" json:"hostname,omitempty"` // 主机名
	// contains filtered or unexported fields
}

func (*WorkerGetStatsRequest) Descriptor deprecated 

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

Deprecated: Use WorkerGetStatsRequest.ProtoReflect.Descriptor instead.

func (*WorkerGetStatsRequest) GetHostname 

func (x *WorkerGetStatsRequest) GetHostname() []string

func (*WorkerGetStatsRequest) ProtoMessage 

func (*WorkerGetStatsRequest) ProtoMessage()

func (*WorkerGetStatsRequest) ProtoReflect 

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

func (*WorkerGetStatsRequest) Reset 

func (x *WorkerGetStatsRequest) Reset()

func (*WorkerGetStatsRequest) String 

func (x *WorkerGetStatsRequest) String() string

type WorkerGetStatsResponse 

type WorkerGetStatsResponse struct {
	Data []*WorkerGetStatsResponse_Stat `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerGetStatsResponse) Descriptor deprecated 

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

Deprecated: Use WorkerGetStatsResponse.ProtoReflect.Descriptor instead.

func (*WorkerGetStatsResponse) GetData 

func (x *WorkerGetStatsResponse) GetData() []*WorkerGetStatsResponse_Stat

func (*WorkerGetStatsResponse) ProtoMessage 

func (*WorkerGetStatsResponse) ProtoMessage()

func (*WorkerGetStatsResponse) ProtoReflect 

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

func (*WorkerGetStatsResponse) Reset 

func (x *WorkerGetStatsResponse) Reset()

func (*WorkerGetStatsResponse) String 

func (x *WorkerGetStatsResponse) String() string

type WorkerGetStatsResponse_Net 

type WorkerGetStatsResponse_Net struct {
	Up   int64 `protobuf:"varint,1,opt,name=up,proto3" json:"up,omitempty"`     // 网络上行速率，单位字节
	Down int64 `protobuf:"varint,2,opt,name=down,proto3" json:"down,omitempty"` // 网络下行速率，单位字节
	// contains filtered or unexported fields
}

网络数据结构

func (*WorkerGetStatsResponse_Net) Descriptor deprecated 

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

Deprecated: Use WorkerGetStatsResponse_Net.ProtoReflect.Descriptor instead.

func (*WorkerGetStatsResponse_Net) GetDown 

func (x *WorkerGetStatsResponse_Net) GetDown() int64

func (*WorkerGetStatsResponse_Net) GetUp 

func (x *WorkerGetStatsResponse_Net) GetUp() int64

func (*WorkerGetStatsResponse_Net) ProtoMessage 

func (*WorkerGetStatsResponse_Net) ProtoMessage()

func (*WorkerGetStatsResponse_Net) ProtoReflect 

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

func (*WorkerGetStatsResponse_Net) Reset 

func (x *WorkerGetStatsResponse_Net) Reset()

func (*WorkerGetStatsResponse_Net) String 

func (x *WorkerGetStatsResponse_Net) String() string

type WorkerGetStatsResponse_Stat 

type WorkerGetStatsResponse_Stat struct {
	Hostname string                         `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` // hostname
	System   *WorkerGetStatsResponse_System `protobuf:"bytes,2,opt,name=system,proto3" json:"system,omitempty"`     // 系统信息
	Net      *WorkerGetStatsResponse_Net    `protobuf:"bytes,3,opt,name=net,proto3" json:"net,omitempty"`           // 网络信息
	// contains filtered or unexported fields
}

func (*WorkerGetStatsResponse_Stat) Descriptor deprecated 

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

Deprecated: Use WorkerGetStatsResponse_Stat.ProtoReflect.Descriptor instead.

func (*WorkerGetStatsResponse_Stat) GetHostname 

func (x *WorkerGetStatsResponse_Stat) GetHostname() string

func (*WorkerGetStatsResponse_Stat) GetNet 

func (x *WorkerGetStatsResponse_Stat) GetNet() *WorkerGetStatsResponse_Net

func (*WorkerGetStatsResponse_Stat) GetSystem 

func (x *WorkerGetStatsResponse_Stat) GetSystem() *WorkerGetStatsResponse_System

func (*WorkerGetStatsResponse_Stat) ProtoMessage 

func (*WorkerGetStatsResponse_Stat) ProtoMessage()

func (*WorkerGetStatsResponse_Stat) ProtoReflect 

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

func (*WorkerGetStatsResponse_Stat) Reset 

func (x *WorkerGetStatsResponse_Stat) Reset()

func (*WorkerGetStatsResponse_Stat) String 

func (x *WorkerGetStatsResponse_Stat) String() string

type WorkerGetStatsResponse_System 

type WorkerGetStatsResponse_System struct {
	CpuNum        int64 `protobuf:"varint,1,opt,name=cpuNum,proto3" json:"cpuNum,omitempty"`               // CPU数量
	CpuLoad       int64 `protobuf:"varint,2,opt,name=cpuLoad,proto3" json:"cpuLoad,omitempty"`             // CPU负载百分比
	MemTotal      int64 `protobuf:"varint,3,opt,name=memTotal,proto3" json:"memTotal,omitempty"`           // 内存总大小，单位byte
	MemUsed       int64 `protobuf:"varint,4,opt,name=memUsed,proto3" json:"memUsed,omitempty"`             // 内存已使用，单位byte
	MemFree       int64 `protobuf:"varint,5,opt,name=memFree,proto3" json:"memFree,omitempty"`             // 内存可用，单位byte
	DiskTotal     int64 `protobuf:"varint,6,opt,name=diskTotal,proto3" json:"diskTotal,omitempty"`         // 磁盘总量，单位byte
	DiskUsed      int64 `protobuf:"varint,7,opt,name=diskUsed,proto3" json:"diskUsed,omitempty"`           // 磁盘使用量，单位byte
	DiskFree      int64 `protobuf:"varint,8,opt,name=diskFree,proto3" json:"diskFree,omitempty"`           // 磁盘空闲量，单位byte
	DiskWriteRate int64 `protobuf:"varint,9,opt,name=diskWriteRate,proto3" json:"diskWriteRate,omitempty"` // 磁盘写入率，百分比
	DiskReadRate  int64 `protobuf:"varint,10,opt,name=diskReadRate,proto3" json:"diskReadRate,omitempty"`  // 磁盘读取率，百分比
	// contains filtered or unexported fields
}

系统数据结构

func (*WorkerGetStatsResponse_System) Descriptor deprecated 

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

Deprecated: Use WorkerGetStatsResponse_System.ProtoReflect.Descriptor instead.

func (*WorkerGetStatsResponse_System) GetCpuLoad 

func (x *WorkerGetStatsResponse_System) GetCpuLoad() int64

func (*WorkerGetStatsResponse_System) GetCpuNum 

func (x *WorkerGetStatsResponse_System) GetCpuNum() int64

func (*WorkerGetStatsResponse_System) GetDiskFree 

func (x *WorkerGetStatsResponse_System) GetDiskFree() int64

func (*WorkerGetStatsResponse_System) GetDiskReadRate 

func (x *WorkerGetStatsResponse_System) GetDiskReadRate() int64

func (*WorkerGetStatsResponse_System) GetDiskTotal 

func (x *WorkerGetStatsResponse_System) GetDiskTotal() int64

func (*WorkerGetStatsResponse_System) GetDiskUsed 

func (x *WorkerGetStatsResponse_System) GetDiskUsed() int64

func (*WorkerGetStatsResponse_System) GetDiskWriteRate 

func (x *WorkerGetStatsResponse_System) GetDiskWriteRate() int64

func (*WorkerGetStatsResponse_System) GetMemFree 

func (x *WorkerGetStatsResponse_System) GetMemFree() int64

func (*WorkerGetStatsResponse_System) GetMemTotal 

func (x *WorkerGetStatsResponse_System) GetMemTotal() int64

func (*WorkerGetStatsResponse_System) GetMemUsed 

func (x *WorkerGetStatsResponse_System) GetMemUsed() int64

func (*WorkerGetStatsResponse_System) ProtoMessage 

func (*WorkerGetStatsResponse_System) ProtoMessage()

func (*WorkerGetStatsResponse_System) ProtoReflect 

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

func (*WorkerGetStatsResponse_System) Reset 

func (x *WorkerGetStatsResponse_System) Reset()

func (*WorkerGetStatsResponse_System) String 

func (x *WorkerGetStatsResponse_System) String() string

type WorkerJoinRequest 

type WorkerJoinRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` // Worker的主机名，全局唯一
	Ip       string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`             // IP
	Port     int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`        // 端口
	// contains filtered or unexported fields
}

func (*WorkerJoinRequest) Descriptor deprecated 

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

Deprecated: Use WorkerJoinRequest.ProtoReflect.Descriptor instead.

func (*WorkerJoinRequest) GetHostname 

func (x *WorkerJoinRequest) GetHostname() string

func (*WorkerJoinRequest) GetIp 

func (x *WorkerJoinRequest) GetIp() string

func (*WorkerJoinRequest) GetPort 

func (x *WorkerJoinRequest) GetPort() int32

func (*WorkerJoinRequest) ProtoMessage 

func (*WorkerJoinRequest) ProtoMessage()

func (*WorkerJoinRequest) ProtoReflect 

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

func (*WorkerJoinRequest) Reset 

func (x *WorkerJoinRequest) Reset()

func (*WorkerJoinRequest) String 

func (x *WorkerJoinRequest) String() string

type WorkerJoinResponse 

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

func (*WorkerJoinResponse) Descriptor deprecated 

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

Deprecated: Use WorkerJoinResponse.ProtoReflect.Descriptor instead.

func (*WorkerJoinResponse) ProtoMessage 

func (*WorkerJoinResponse) ProtoMessage()

func (*WorkerJoinResponse) ProtoReflect 

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

func (*WorkerJoinResponse) Reset 

func (x *WorkerJoinResponse) Reset()

func (*WorkerJoinResponse) String 

func (x *WorkerJoinResponse) String() string

type WorkerListRequest 

type WorkerListRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` // 筛选主机名
	Ip       string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`             // 筛选IP
	// contains filtered or unexported fields
}

func (*WorkerListRequest) Descriptor deprecated 

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

Deprecated: Use WorkerListRequest.ProtoReflect.Descriptor instead.

func (*WorkerListRequest) GetHostname 

func (x *WorkerListRequest) GetHostname() string

func (*WorkerListRequest) GetIp 

func (x *WorkerListRequest) GetIp() string

func (*WorkerListRequest) ProtoMessage 

func (*WorkerListRequest) ProtoMessage()

func (*WorkerListRequest) ProtoReflect 

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

func (*WorkerListRequest) Reset 

func (x *WorkerListRequest) Reset()

func (*WorkerListRequest) String 

func (x *WorkerListRequest) String() string

type WorkerListResponse 

type WorkerListResponse struct {
	WorkerList []*WorkerListResponse_Worker `protobuf:"bytes,1,rep,name=workerList,proto3" json:"workerList,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerListResponse) Descriptor deprecated 

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

Deprecated: Use WorkerListResponse.ProtoReflect.Descriptor instead.

func (*WorkerListResponse) GetWorkerList 

func (x *WorkerListResponse) GetWorkerList() []*WorkerListResponse_Worker

func (*WorkerListResponse) ProtoMessage 

func (*WorkerListResponse) ProtoMessage()

func (*WorkerListResponse) ProtoReflect 

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

func (*WorkerListResponse) Reset 

func (x *WorkerListResponse) Reset()

func (*WorkerListResponse) String 

func (x *WorkerListResponse) String() string

type WorkerListResponse_Worker 

type WorkerListResponse_Worker struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` // 主机名
	Ip       string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`             // ip
	State    int32  `protobuf:"varint,3,opt,name=state,proto3" json:"state,omitempty"`      // 状态
	// contains filtered or unexported fields
}

func (*WorkerListResponse_Worker) Descriptor deprecated 

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

Deprecated: Use WorkerListResponse_Worker.ProtoReflect.Descriptor instead.

func (*WorkerListResponse_Worker) GetHostname 

func (x *WorkerListResponse_Worker) GetHostname() string

func (*WorkerListResponse_Worker) GetIp 

func (x *WorkerListResponse_Worker) GetIp() string

func (*WorkerListResponse_Worker) GetState 

func (x *WorkerListResponse_Worker) GetState() int32

func (*WorkerListResponse_Worker) ProtoMessage 

func (*WorkerListResponse_Worker) ProtoMessage()

func (*WorkerListResponse_Worker) ProtoReflect 

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

func (*WorkerListResponse_Worker) Reset 

func (x *WorkerListResponse_Worker) Reset()

func (*WorkerListResponse_Worker) String 

func (x *WorkerListResponse_Worker) String() string

type WorkerQuitRequest 

type WorkerQuitRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` // Worker的主机名
	// contains filtered or unexported fields
}

func (*WorkerQuitRequest) Descriptor deprecated 

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

Deprecated: Use WorkerQuitRequest.ProtoReflect.Descriptor instead.

func (*WorkerQuitRequest) GetHostname 

func (x *WorkerQuitRequest) GetHostname() string

func (*WorkerQuitRequest) ProtoMessage 

func (*WorkerQuitRequest) ProtoMessage()

func (*WorkerQuitRequest) ProtoReflect 

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

func (*WorkerQuitRequest) Reset 

func (x *WorkerQuitRequest) Reset()

func (*WorkerQuitRequest) String 

func (x *WorkerQuitRequest) String() string

type WorkerQuitResponse 

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

func (*WorkerQuitResponse) Descriptor deprecated 

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

Deprecated: Use WorkerQuitResponse.ProtoReflect.Descriptor instead.

func (*WorkerQuitResponse) ProtoMessage 

func (*WorkerQuitResponse) ProtoMessage()

func (*WorkerQuitResponse) ProtoReflect 

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

func (*WorkerQuitResponse) Reset 

func (x *WorkerQuitResponse) Reset()

func (*WorkerQuitResponse) String 

func (x *WorkerQuitResponse) String() string

type WorkerUpStatsRequest 

type WorkerUpStatsRequest struct {
	Hostname string                       `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` // hostname
	System   *WorkerUpStatsRequest_System `protobuf:"bytes,2,opt,name=system,proto3" json:"system,omitempty"`     // 系统信息
	Net      *WorkerUpStatsRequest_Net    `protobuf:"bytes,3,opt,name=net,proto3" json:"net,omitempty"`           // 网络信息
	// contains filtered or unexported fields
}

func (*WorkerUpStatsRequest) Descriptor deprecated 

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

Deprecated: Use WorkerUpStatsRequest.ProtoReflect.Descriptor instead.

func (*WorkerUpStatsRequest) GetHostname 

func (x *WorkerUpStatsRequest) GetHostname() string

func (*WorkerUpStatsRequest) GetNet 

func (x *WorkerUpStatsRequest) GetNet() *WorkerUpStatsRequest_Net

func (*WorkerUpStatsRequest) GetSystem 

func (x *WorkerUpStatsRequest) GetSystem() *WorkerUpStatsRequest_System

func (*WorkerUpStatsRequest) ProtoMessage 

func (*WorkerUpStatsRequest) ProtoMessage()

func (*WorkerUpStatsRequest) ProtoReflect 

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

func (*WorkerUpStatsRequest) Reset 

func (x *WorkerUpStatsRequest) Reset()

func (*WorkerUpStatsRequest) String 

func (x *WorkerUpStatsRequest) String() string

type WorkerUpStatsRequest_Net 

type WorkerUpStatsRequest_Net struct {
	Up   int64 `protobuf:"varint,1,opt,name=up,proto3" json:"up,omitempty"`     // 网络上行速率，单位byte
	Down int64 `protobuf:"varint,2,opt,name=down,proto3" json:"down,omitempty"` // 网络下行速率，单位byte
	// contains filtered or unexported fields
}

网络数据结构

func (*WorkerUpStatsRequest_Net) Descriptor deprecated 

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

Deprecated: Use WorkerUpStatsRequest_Net.ProtoReflect.Descriptor instead.

func (*WorkerUpStatsRequest_Net) GetDown 

func (x *WorkerUpStatsRequest_Net) GetDown() int64

func (*WorkerUpStatsRequest_Net) GetUp 

func (x *WorkerUpStatsRequest_Net) GetUp() int64

func (*WorkerUpStatsRequest_Net) ProtoMessage 

func (*WorkerUpStatsRequest_Net) ProtoMessage()

func (*WorkerUpStatsRequest_Net) ProtoReflect 

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

func (*WorkerUpStatsRequest_Net) Reset 

func (x *WorkerUpStatsRequest_Net) Reset()

func (*WorkerUpStatsRequest_Net) String 

func (x *WorkerUpStatsRequest_Net) String() string

type WorkerUpStatsRequest_System 

type WorkerUpStatsRequest_System struct {
	CpuNum        int64 `protobuf:"varint,1,opt,name=cpuNum,proto3" json:"cpuNum,omitempty"`               // CPU数量
	CpuLoad       int64 `protobuf:"varint,2,opt,name=cpuLoad,proto3" json:"cpuLoad,omitempty"`             // CPU负载百分比
	MemTotal      int64 `protobuf:"varint,3,opt,name=memTotal,proto3" json:"memTotal,omitempty"`           // 内存总大小，单位byte
	MemUsed       int64 `protobuf:"varint,4,opt,name=memUsed,proto3" json:"memUsed,omitempty"`             // 内存已使用，单位byte
	MemFree       int64 `protobuf:"varint,5,opt,name=memFree,proto3" json:"memFree,omitempty"`             // 内存可用，单位byte
	DiskTotal     int64 `protobuf:"varint,6,opt,name=diskTotal,proto3" json:"diskTotal,omitempty"`         // 磁盘总量，单位byte
	DiskUsed      int64 `protobuf:"varint,7,opt,name=diskUsed,proto3" json:"diskUsed,omitempty"`           // 磁盘使用量，单位byte
	DiskFree      int64 `protobuf:"varint,8,opt,name=diskFree,proto3" json:"diskFree,omitempty"`           // 磁盘空闲量，单位byte
	DiskWriteRate int64 `protobuf:"varint,9,opt,name=diskWriteRate,proto3" json:"diskWriteRate,omitempty"` // 磁盘写入率，百分比
	DiskReadRate  int64 `protobuf:"varint,10,opt,name=diskReadRate,proto3" json:"diskReadRate,omitempty"`  // 磁盘读取率，百分比
	// contains filtered or unexported fields
}

系统数据结构

func (*WorkerUpStatsRequest_System) Descriptor deprecated 

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

Deprecated: Use WorkerUpStatsRequest_System.ProtoReflect.Descriptor instead.

func (*WorkerUpStatsRequest_System) GetCpuLoad 

func (x *WorkerUpStatsRequest_System) GetCpuLoad() int64

func (*WorkerUpStatsRequest_System) GetCpuNum 

func (x *WorkerUpStatsRequest_System) GetCpuNum() int64

func (*WorkerUpStatsRequest_System) GetDiskFree 

func (x *WorkerUpStatsRequest_System) GetDiskFree() int64

func (*WorkerUpStatsRequest_System) GetDiskReadRate 

func (x *WorkerUpStatsRequest_System) GetDiskReadRate() int64

func (*WorkerUpStatsRequest_System) GetDiskTotal 

func (x *WorkerUpStatsRequest_System) GetDiskTotal() int64

func (*WorkerUpStatsRequest_System) GetDiskUsed 

func (x *WorkerUpStatsRequest_System) GetDiskUsed() int64

func (*WorkerUpStatsRequest_System) GetDiskWriteRate 

func (x *WorkerUpStatsRequest_System) GetDiskWriteRate() int64

func (*WorkerUpStatsRequest_System) GetMemFree 

func (x *WorkerUpStatsRequest_System) GetMemFree() int64

func (*WorkerUpStatsRequest_System) GetMemTotal 

func (x *WorkerUpStatsRequest_System) GetMemTotal() int64

func (*WorkerUpStatsRequest_System) GetMemUsed 

func (x *WorkerUpStatsRequest_System) GetMemUsed() int64

func (*WorkerUpStatsRequest_System) ProtoMessage 

func (*WorkerUpStatsRequest_System) ProtoMessage()

func (*WorkerUpStatsRequest_System) ProtoReflect 

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

func (*WorkerUpStatsRequest_System) Reset 

func (x *WorkerUpStatsRequest_System) Reset()

func (*WorkerUpStatsRequest_System) String 

func (x *WorkerUpStatsRequest_System) String() string

type WorkerUpStatsResponse 

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

func (*WorkerUpStatsResponse) Descriptor deprecated 

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

Deprecated: Use WorkerUpStatsResponse.ProtoReflect.Descriptor instead.

func (*WorkerUpStatsResponse) ProtoMessage 

func (*WorkerUpStatsResponse) ProtoMessage()

func (*WorkerUpStatsResponse) ProtoReflect 

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

func (*WorkerUpStatsResponse) Reset 

func (x *WorkerUpStatsResponse) Reset()

func (*WorkerUpStatsResponse) String 

func (x *WorkerUpStatsResponse) String() string

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.