guaproto

package
v1.6.22 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_gua_proto protoreflect.FileDescriptor
View Source 
var File_job_proto protoreflect.FileDescriptor
View Source 
var File_node_proto protoreflect.FileDescriptor
View Source 
var GuaNode_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "guaproto.GuaNode",
	HandlerType: (*GuaNodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RemoteCommand",
			Handler:    _GuaNode_RemoteCommand_Handler,
		},
		{
			MethodName: "RegisterCommand",
			Handler:    _GuaNode_RegisterCommand_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "node.proto",
}

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

View Source 
var Gua_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "guaproto.Gua",
	HandlerType: (*GuaServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NodeRegister",
			Handler:    _Gua_NodeRegister_Handler,
		},
		{
			MethodName: "JobReply",
			Handler:    _Gua_JobReply_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _Gua_Heartbeat_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gua.proto",
}

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

Functions

func RegisterGuaNodeServer 

func RegisterGuaNodeServer(s grpc.ServiceRegistrar, srv GuaNodeServer)

func RegisterGuaServer 

func RegisterGuaServer(s grpc.ServiceRegistrar, srv GuaServer)

Types

type Func 

type Func struct {
	Name            string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	GroupName       string `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	UseOtp          bool   `protobuf:"varint,3,opt,name=use_otp,json=useOtp,proto3" json:"use_otp,omitempty"`
	DisableGroupOtp bool   `protobuf:"varint,4,opt,name=disable_group_otp,json=disableGroupOtp,proto3" json:"disable_group_otp,omitempty"`
	OtpToken        string `protobuf:"bytes,5,opt,name=otp_token,json=otpToken,proto3" json:"otp_token,omitempty"`
	LuaBody         []byte `protobuf:"bytes,6,opt,name=LuaBody,proto3" json:"LuaBody,omitempty"`
	Active          bool   `protobuf:"varint,7,opt,name=active,proto3" json:"active,omitempty"`
	Memo            string `protobuf:"bytes,8,opt,name=memo,proto3" json:"memo,omitempty"`
	// contains filtered or unexported fields
}

func (*Func) Descriptor deprecated 

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

Deprecated: Use Func.ProtoReflect.Descriptor instead.

func (*Func) GetActive 

func (x *Func) GetActive() bool

func (*Func) GetDisableGroupOtp 

func (x *Func) GetDisableGroupOtp() bool

func (*Func) GetGroupName 

func (x *Func) GetGroupName() string

func (*Func) GetLuaBody 

func (x *Func) GetLuaBody() []byte

func (*Func) GetMemo 

func (x *Func) GetMemo() string

func (*Func) GetName 

func (x *Func) GetName() string

func (*Func) GetOtpToken 

func (x *Func) GetOtpToken() string

func (*Func) GetUseOtp 

func (x *Func) GetUseOtp() bool

func (*Func) ProtoMessage 

func (*Func) ProtoMessage()

func (*Func) ProtoReflect added in v1.4.13 

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

func (*Func) Reset 

func (x *Func) Reset()

func (*Func) String 

func (x *Func) String() string

type GuaClient 

type GuaClient interface {
	NodeRegister(ctx context.Context, in *NodeRegisterRequest, opts ...grpc.CallOption) (*NodeRegisterResponse, error)
	JobReply(ctx context.Context, in *JobReplyRequest, opts ...grpc.CallOption) (*JobReplyResponse, error)
	Heartbeat(ctx context.Context, in *Ping, opts ...grpc.CallOption) (*Pong, error)
}

GuaClient is the client API for Gua service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGuaClient 

func NewGuaClient(cc grpc.ClientConnInterface) GuaClient

type GuaNodeClient 

type GuaNodeClient interface {
	RemoteCommand(ctx context.Context, in *RemoteCommandRequest, opts ...grpc.CallOption) (*RemoteCommandResponse, error)
	RegisterCommand(ctx context.Context, in *RegisterCommandRequest, opts ...grpc.CallOption) (*RegisterCommandReponse, error)
}

GuaNodeClient is the client API for GuaNode service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGuaNodeClient 

func NewGuaNodeClient(cc grpc.ClientConnInterface) GuaNodeClient

type GuaNodeServer 

type GuaNodeServer interface {
	RemoteCommand(context.Context, *RemoteCommandRequest) (*RemoteCommandResponse, error)
	RegisterCommand(context.Context, *RegisterCommandRequest) (*RegisterCommandReponse, error)
}

GuaNodeServer is the server API for GuaNode service. All implementations should embed UnimplementedGuaNodeServer for forward compatibility

type GuaServer 

type GuaServer interface {
	NodeRegister(context.Context, *NodeRegisterRequest) (*NodeRegisterResponse, error)
	JobReply(context.Context, *JobReplyRequest) (*JobReplyResponse, error)
	Heartbeat(context.Context, *Ping) (*Pong, error)
}

GuaServer is the server API for Gua service. All implementations should embed UnimplementedGuaServer for forward compatibility

type Job 

type Job struct {
	Name            string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id              string `protobuf:"bytes,2,opt,name=Id,proto3" json:"Id,omitempty"`
	Exectime        int64  `protobuf:"varint,3,opt,name=exectime,proto3" json:"exectime,omitempty"`
	OtpToken        string `protobuf:"bytes,4,opt,name=otp_token,json=otpToken,proto3" json:"otp_token,omitempty"`
	Timeout         int64  `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	IntervalPattern string `protobuf:"bytes,6,opt,name=interval_pattern,json=intervalPattern,proto3" json:"interval_pattern,omitempty"`
	RequestUrl      string `protobuf:"bytes,7,opt,name=request_url,json=requestUrl,proto3" json:"request_url,omitempty"`
	ExecCmd         []byte `protobuf:"bytes,8,opt,name=exec_cmd,json=execCmd,proto3" json:"exec_cmd,omitempty"`
	GroupName       string `protobuf:"bytes,9,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	Active          bool   `protobuf:"varint,10,opt,name=active,proto3" json:"active,omitempty"`
	Memo            string `protobuf:"bytes,11,opt,name=memo,proto3" json:"memo,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetActive 

func (x *Job) GetActive() bool

func (*Job) GetExecCmd 

func (x *Job) GetExecCmd() []byte

func (*Job) GetExectime 

func (x *Job) GetExectime() int64

func (*Job) GetGroupName 

func (x *Job) GetGroupName() string

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetIntervalPattern 

func (x *Job) GetIntervalPattern() string

func (*Job) GetMemo 

func (x *Job) GetMemo() string

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetOtpToken 

func (x *Job) GetOtpToken() string

func (*Job) GetRequestUrl 

func (x *Job) GetRequestUrl() string

func (*Job) GetTimeout 

func (x *Job) GetTimeout() int64

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect added in v1.4.13 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobReplyRequest 

type JobReplyRequest struct {
	JobId              string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Success            string `protobuf:"bytes,2,opt,name=success,proto3" json:"success,omitempty"`
	Error              string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	OtpCode            string `protobuf:"bytes,4,opt,name=otp_code,json=otpCode,proto3" json:"otp_code,omitempty"`
	PlanTime           int64  `protobuf:"varint,5,opt,name=plan_time,json=planTime,proto3" json:"plan_time,omitempty"`
	ExecTime           int64  `protobuf:"varint,6,opt,name=exec_time,json=execTime,proto3" json:"exec_time,omitempty"`
	FinishTime         int64  `protobuf:"varint,7,opt,name=finish_time,json=finishTime,proto3" json:"finish_time,omitempty"`
	GetJobTime         int64  `protobuf:"varint,8,opt,name=get_job_time,json=getJobTime,proto3" json:"get_job_time,omitempty"`
	ExecJobMachineHost string `protobuf:"bytes,9,opt,name=exec_job_machine_host,json=execJobMachineHost,proto3" json:"exec_job_machine_host,omitempty"`
	ExecJobMachineMac  string `protobuf:"bytes,10,opt,name=exec_job_machine_mac,json=execJobMachineMac,proto3" json:"exec_job_machine_mac,omitempty"`
	ExecJobMachineIp   string `protobuf:"bytes,11,opt,name=exec_job_machine_ip,json=execJobMachineIp,proto3" json:"exec_job_machine_ip,omitempty"`
	GetJobMachineHost  string `protobuf:"bytes,12,opt,name=get_job_machine_host,json=getJobMachineHost,proto3" json:"get_job_machine_host,omitempty"`
	GetJobMachineMac   string `protobuf:"bytes,13,opt,name=get_job_machine_mac,json=getJobMachineMac,proto3" json:"get_job_machine_mac,omitempty"`
	GetJobMachineIp    string `protobuf:"bytes,14,opt,name=get_job_machine_ip,json=getJobMachineIp,proto3" json:"get_job_machine_ip,omitempty"`
	NodeId             string `protobuf:"bytes,15,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	GroupName          string `protobuf:"bytes,16,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*JobReplyRequest) Descriptor deprecated 

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

Deprecated: Use JobReplyRequest.ProtoReflect.Descriptor instead.

func (*JobReplyRequest) GetError 

func (x *JobReplyRequest) GetError() string

func (*JobReplyRequest) GetExecJobMachineHost 

func (x *JobReplyRequest) GetExecJobMachineHost() string

func (*JobReplyRequest) GetExecJobMachineIp 

func (x *JobReplyRequest) GetExecJobMachineIp() string

func (*JobReplyRequest) GetExecJobMachineMac 

func (x *JobReplyRequest) GetExecJobMachineMac() string

func (*JobReplyRequest) GetExecTime 

func (x *JobReplyRequest) GetExecTime() int64

func (*JobReplyRequest) GetFinishTime 

func (x *JobReplyRequest) GetFinishTime() int64

func (*JobReplyRequest) GetGetJobMachineHost 

func (x *JobReplyRequest) GetGetJobMachineHost() string

func (*JobReplyRequest) GetGetJobMachineIp 

func (x *JobReplyRequest) GetGetJobMachineIp() string

func (*JobReplyRequest) GetGetJobMachineMac 

func (x *JobReplyRequest) GetGetJobMachineMac() string

func (*JobReplyRequest) GetGetJobTime 

func (x *JobReplyRequest) GetGetJobTime() int64

func (*JobReplyRequest) GetGroupName 

func (x *JobReplyRequest) GetGroupName() string

func (*JobReplyRequest) GetJobId 

func (x *JobReplyRequest) GetJobId() string

func (*JobReplyRequest) GetNodeId 

func (x *JobReplyRequest) GetNodeId() string

func (*JobReplyRequest) GetOtpCode 

func (x *JobReplyRequest) GetOtpCode() string

func (*JobReplyRequest) GetPlanTime 

func (x *JobReplyRequest) GetPlanTime() int64

func (*JobReplyRequest) GetSuccess 

func (x *JobReplyRequest) GetSuccess() string

func (*JobReplyRequest) ProtoMessage 

func (*JobReplyRequest) ProtoMessage()

func (*JobReplyRequest) ProtoReflect added in v1.4.13 

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

func (*JobReplyRequest) Reset 

func (x *JobReplyRequest) Reset()

func (*JobReplyRequest) String 

func (x *JobReplyRequest) String() string

type JobReplyResponse 

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

func (*JobReplyResponse) Descriptor deprecated 

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

Deprecated: Use JobReplyResponse.ProtoReflect.Descriptor instead.

func (*JobReplyResponse) ProtoMessage 

func (*JobReplyResponse) ProtoMessage()

func (*JobReplyResponse) ProtoReflect added in v1.4.13 

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

func (*JobReplyResponse) Reset 

func (x *JobReplyResponse) Reset()

func (*JobReplyResponse) String 

func (x *JobReplyResponse) String() string

type NodeRegisterRequest 

type NodeRegisterRequest 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"`
	Mac           string `protobuf:"bytes,3,opt,name=mac,proto3" json:"mac,omitempty"`
	OtpToken      string `protobuf:"bytes,4,opt,name=otp_token,json=otpToken,proto3" json:"otp_token,omitempty"`
	BoradcastAddr string `protobuf:"bytes,5,opt,name=boradcast_addr,json=boradcastAddr,proto3" json:"boradcast_addr,omitempty"`
	Grpclisten    string `protobuf:"bytes,6,opt,name=grpclisten,proto3" json:"grpclisten,omitempty"`
	MachineCode   string `protobuf:"bytes,7,opt,name=machine_code,json=machineCode,proto3" json:"machine_code,omitempty"`
	GroupName     string `protobuf:"bytes,8,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	OtpCode       string `protobuf:"bytes,9,opt,name=otp_code,json=otpCode,proto3" json:"otp_code,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRegisterRequest) Descriptor deprecated 

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

Deprecated: Use NodeRegisterRequest.ProtoReflect.Descriptor instead.

func (*NodeRegisterRequest) GetBoradcastAddr 

func (x *NodeRegisterRequest) GetBoradcastAddr() string

func (*NodeRegisterRequest) GetGroupName 

func (x *NodeRegisterRequest) GetGroupName() string

func (*NodeRegisterRequest) GetGrpclisten 

func (x *NodeRegisterRequest) GetGrpclisten() string

func (*NodeRegisterRequest) GetHostname 

func (x *NodeRegisterRequest) GetHostname() string

func (*NodeRegisterRequest) GetIp 

func (x *NodeRegisterRequest) GetIp() string

func (*NodeRegisterRequest) GetMac 

func (x *NodeRegisterRequest) GetMac() string

func (*NodeRegisterRequest) GetMachineCode 

func (x *NodeRegisterRequest) GetMachineCode() string

func (*NodeRegisterRequest) GetOtpCode 

func (x *NodeRegisterRequest) GetOtpCode() string

func (*NodeRegisterRequest) GetOtpToken 

func (x *NodeRegisterRequest) GetOtpToken() string

func (*NodeRegisterRequest) ProtoMessage 

func (*NodeRegisterRequest) ProtoMessage()

func (*NodeRegisterRequest) ProtoReflect added in v1.4.13 

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

func (*NodeRegisterRequest) Reset 

func (x *NodeRegisterRequest) Reset()

func (*NodeRegisterRequest) String 

func (x *NodeRegisterRequest) String() string

type NodeRegisterResponse 

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

func (*NodeRegisterResponse) Descriptor deprecated 

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

Deprecated: Use NodeRegisterResponse.ProtoReflect.Descriptor instead.

func (*NodeRegisterResponse) GetNodeId 

func (x *NodeRegisterResponse) GetNodeId() string

func (*NodeRegisterResponse) ProtoMessage 

func (*NodeRegisterResponse) ProtoMessage()

func (*NodeRegisterResponse) ProtoReflect added in v1.4.13 

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

func (*NodeRegisterResponse) Reset 

func (x *NodeRegisterResponse) Reset()

func (*NodeRegisterResponse) String 

func (x *NodeRegisterResponse) String() string

type Ping 

type Ping struct {
	NodeId    string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	GroupName string `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	OtpCode   string `protobuf:"bytes,3,opt,name=otp_code,json=otpCode,proto3" json:"otp_code,omitempty"`
	// contains filtered or unexported fields
}

func (*Ping) Descriptor deprecated 

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

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) GetGroupName 

func (x *Ping) GetGroupName() string

func (*Ping) GetNodeId 

func (x *Ping) GetNodeId() string

func (*Ping) GetOtpCode 

func (x *Ping) GetOtpCode() string

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect added in v1.4.13 

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

func (*Ping) Reset 

func (x *Ping) Reset()

func (*Ping) String 

func (x *Ping) String() string

type Pong 

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

func (*Pong) Descriptor deprecated 

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

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect added in v1.4.13 

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

func (*Pong) Reset 

func (x *Pong) Reset()

func (*Pong) String 

func (x *Pong) String() string

type ReadyJob 

type ReadyJob struct {
	Name              string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id                string `protobuf:"bytes,2,opt,name=Id,proto3" json:"Id,omitempty"`
	OtpToken          string `protobuf:"bytes,3,opt,name=otp_token,json=otpToken,proto3" json:"otp_token,omitempty"`
	Timeout           int64  `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	RequestUrl        string `protobuf:"bytes,5,opt,name=request_url,json=requestUrl,proto3" json:"request_url,omitempty"`
	ExecCmd           []byte `protobuf:"bytes,6,opt,name=exec_cmd,json=execCmd,proto3" json:"exec_cmd,omitempty"`
	PlanTime          int64  `protobuf:"varint,7,opt,name=plan_time,json=planTime,proto3" json:"plan_time,omitempty"`
	GetJobTime        int64  `protobuf:"varint,8,opt,name=get_job_time,json=getJobTime,proto3" json:"get_job_time,omitempty"`
	GetJobMachineHost string `protobuf:"bytes,9,opt,name=get_job_machine_host,json=getJobMachineHost,proto3" json:"get_job_machine_host,omitempty"`
	GetJobMachineMac  string `protobuf:"bytes,10,opt,name=get_job_machine_mac,json=getJobMachineMac,proto3" json:"get_job_machine_mac,omitempty"`
	GetJobMachineIp   string `protobuf:"bytes,11,opt,name=get_job_machine_ip,json=getJobMachineIp,proto3" json:"get_job_machine_ip,omitempty"`
	GroupName         string `protobuf:"bytes,12,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadyJob) Descriptor deprecated 

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

Deprecated: Use ReadyJob.ProtoReflect.Descriptor instead.

func (*ReadyJob) GetExecCmd 

func (x *ReadyJob) GetExecCmd() []byte

func (*ReadyJob) GetGetJobMachineHost 

func (x *ReadyJob) GetGetJobMachineHost() string

func (*ReadyJob) GetGetJobMachineIp 

func (x *ReadyJob) GetGetJobMachineIp() string

func (*ReadyJob) GetGetJobMachineMac 

func (x *ReadyJob) GetGetJobMachineMac() string

func (*ReadyJob) GetGetJobTime 

func (x *ReadyJob) GetGetJobTime() int64

func (*ReadyJob) GetGroupName 

func (x *ReadyJob) GetGroupName() string

func (*ReadyJob) GetId 

func (x *ReadyJob) GetId() string

func (*ReadyJob) GetName 

func (x *ReadyJob) GetName() string

func (*ReadyJob) GetOtpToken 

func (x *ReadyJob) GetOtpToken() string

func (*ReadyJob) GetPlanTime 

func (x *ReadyJob) GetPlanTime() int64

func (*ReadyJob) GetRequestUrl 

func (x *ReadyJob) GetRequestUrl() string

func (*ReadyJob) GetTimeout 

func (x *ReadyJob) GetTimeout() int64

func (*ReadyJob) ProtoMessage 

func (*ReadyJob) ProtoMessage()

func (*ReadyJob) ProtoReflect added in v1.4.13 

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

func (*ReadyJob) Reset 

func (x *ReadyJob) Reset()

func (*ReadyJob) String 

func (x *ReadyJob) String() string

type RegisterCommandReponse 

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

func (*RegisterCommandReponse) Descriptor deprecated 

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

Deprecated: Use RegisterCommandReponse.ProtoReflect.Descriptor instead.

func (*RegisterCommandReponse) ProtoMessage 

func (*RegisterCommandReponse) ProtoMessage()

func (*RegisterCommandReponse) ProtoReflect added in v1.4.13 

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

func (*RegisterCommandReponse) Reset 

func (x *RegisterCommandReponse) Reset()

func (*RegisterCommandReponse) String 

func (x *RegisterCommandReponse) String() string

type RegisterCommandRequest 

type RegisterCommandRequest struct {
	JobId     string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	OtpToken  string `protobuf:"bytes,2,opt,name=otp_token,json=otpToken,proto3" json:"otp_token,omitempty"`
	OtpCode   string `protobuf:"bytes,3,opt,name=otp_code,json=otpCode,proto3" json:"otp_code,omitempty"`
	GroupName string `protobuf:"bytes,4,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterCommandRequest) Descriptor deprecated 

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

Deprecated: Use RegisterCommandRequest.ProtoReflect.Descriptor instead.

func (*RegisterCommandRequest) GetGroupName 

func (x *RegisterCommandRequest) GetGroupName() string

func (*RegisterCommandRequest) GetJobId 

func (x *RegisterCommandRequest) GetJobId() string

func (*RegisterCommandRequest) GetOtpCode 

func (x *RegisterCommandRequest) GetOtpCode() string

func (*RegisterCommandRequest) GetOtpToken 

func (x *RegisterCommandRequest) GetOtpToken() string

func (*RegisterCommandRequest) ProtoMessage 

func (*RegisterCommandRequest) ProtoMessage()

func (*RegisterCommandRequest) ProtoReflect added in v1.4.13 

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

func (*RegisterCommandRequest) Reset 

func (x *RegisterCommandRequest) Reset()

func (*RegisterCommandRequest) String 

func (x *RegisterCommandRequest) String() string

type RemoteCommandRequest 

type RemoteCommandRequest struct {
	ExecCmd            []byte `protobuf:"bytes,1,opt,name=exec_cmd,json=execCmd,proto3" json:"exec_cmd,omitempty"`
	JobId              string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Timeout            int64  `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	OtpCode            string `protobuf:"bytes,4,opt,name=otp_code,json=otpCode,proto3" json:"otp_code,omitempty"`
	PlanTime           int64  `protobuf:"varint,5,opt,name=plan_time,json=planTime,proto3" json:"plan_time,omitempty"`
	ExecTime           int64  `protobuf:"varint,6,opt,name=exec_time,json=execTime,proto3" json:"exec_time,omitempty"`
	ExecJobMachineHost string `protobuf:"bytes,7,opt,name=exec_job_machine_host,json=execJobMachineHost,proto3" json:"exec_job_machine_host,omitempty"`
	ExecJobMachineMac  string `protobuf:"bytes,8,opt,name=exec_job_machine_mac,json=execJobMachineMac,proto3" json:"exec_job_machine_mac,omitempty"`
	ExecJobMachineIp   string `protobuf:"bytes,9,opt,name=exec_job_machine_ip,json=execJobMachineIp,proto3" json:"exec_job_machine_ip,omitempty"`
	GetJobMachineHost  string `protobuf:"bytes,10,opt,name=get_job_machine_host,json=getJobMachineHost,proto3" json:"get_job_machine_host,omitempty"`
	GetJobMachineMac   string `protobuf:"bytes,11,opt,name=get_job_machine_mac,json=getJobMachineMac,proto3" json:"get_job_machine_mac,omitempty"`
	GetJobMachineIp    string `protobuf:"bytes,12,opt,name=get_job_machine_ip,json=getJobMachineIp,proto3" json:"get_job_machine_ip,omitempty"`
	GroupName          string `protobuf:"bytes,13,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteCommandRequest) Descriptor deprecated 

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

Deprecated: Use RemoteCommandRequest.ProtoReflect.Descriptor instead.

func (*RemoteCommandRequest) GetExecCmd 

func (x *RemoteCommandRequest) GetExecCmd() []byte

func (*RemoteCommandRequest) GetExecJobMachineHost 

func (x *RemoteCommandRequest) GetExecJobMachineHost() string

func (*RemoteCommandRequest) GetExecJobMachineIp 

func (x *RemoteCommandRequest) GetExecJobMachineIp() string

func (*RemoteCommandRequest) GetExecJobMachineMac 

func (x *RemoteCommandRequest) GetExecJobMachineMac() string

func (*RemoteCommandRequest) GetExecTime 

func (x *RemoteCommandRequest) GetExecTime() int64

func (*RemoteCommandRequest) GetGetJobMachineHost 

func (x *RemoteCommandRequest) GetGetJobMachineHost() string

func (*RemoteCommandRequest) GetGetJobMachineIp 

func (x *RemoteCommandRequest) GetGetJobMachineIp() string

func (*RemoteCommandRequest) GetGetJobMachineMac 

func (x *RemoteCommandRequest) GetGetJobMachineMac() string

func (*RemoteCommandRequest) GetGroupName 

func (x *RemoteCommandRequest) GetGroupName() string

func (*RemoteCommandRequest) GetJobId 

func (x *RemoteCommandRequest) GetJobId() string

func (*RemoteCommandRequest) GetOtpCode 

func (x *RemoteCommandRequest) GetOtpCode() string

func (*RemoteCommandRequest) GetPlanTime 

func (x *RemoteCommandRequest) GetPlanTime() int64

func (*RemoteCommandRequest) GetTimeout 

func (x *RemoteCommandRequest) GetTimeout() int64

func (*RemoteCommandRequest) ProtoMessage 

func (*RemoteCommandRequest) ProtoMessage()

func (*RemoteCommandRequest) ProtoReflect added in v1.4.13 

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

func (*RemoteCommandRequest) Reset 

func (x *RemoteCommandRequest) Reset()

func (*RemoteCommandRequest) String 

func (x *RemoteCommandRequest) String() string

type RemoteCommandResponse 

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

func (*RemoteCommandResponse) Descriptor deprecated 

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

Deprecated: Use RemoteCommandResponse.ProtoReflect.Descriptor instead.

func (*RemoteCommandResponse) ProtoMessage 

func (*RemoteCommandResponse) ProtoMessage()

func (*RemoteCommandResponse) ProtoReflect added in v1.4.13 

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

func (*RemoteCommandResponse) Reset 

func (x *RemoteCommandResponse) Reset()

func (*RemoteCommandResponse) String 

func (x *RemoteCommandResponse) String() string

type UnimplementedGuaNodeServer added in v1.4.13 

type UnimplementedGuaNodeServer struct {
}

UnimplementedGuaNodeServer should be embedded to have forward compatible implementations.

func (UnimplementedGuaNodeServer) RegisterCommand added in v1.4.13 

func (UnimplementedGuaNodeServer) RegisterCommand(context.Context, *RegisterCommandRequest) (*RegisterCommandReponse, error)

func (UnimplementedGuaNodeServer) RemoteCommand added in v1.4.13 

func (UnimplementedGuaNodeServer) RemoteCommand(context.Context, *RemoteCommandRequest) (*RemoteCommandResponse, error)

type UnimplementedGuaServer added in v1.4.13 

type UnimplementedGuaServer struct {
}

UnimplementedGuaServer should be embedded to have forward compatible implementations.

func (UnimplementedGuaServer) Heartbeat added in v1.4.13 

func (UnimplementedGuaServer) Heartbeat(context.Context, *Ping) (*Pong, error)

func (UnimplementedGuaServer) JobReply added in v1.4.13 

func (UnimplementedGuaServer) JobReply(context.Context, *JobReplyRequest) (*JobReplyResponse, error)

func (UnimplementedGuaServer) NodeRegister added in v1.4.13 

func (UnimplementedGuaServer) NodeRegister(context.Context, *NodeRegisterRequest) (*NodeRegisterResponse, error)

type UnsafeGuaNodeServer added in v1.4.13 

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

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

type UnsafeGuaServer added in v1.4.13 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.