Documentation ¶
Overview ¶
Package thunder is a generated protocol buffer package.
It is generated from these files:
thunder-config.proto
It has these top-level messages:
ConfigT
Package thunder is a generated protocol buffer package.
It is generated from these files:
thunder.proto
It has these top-level messages:
ResponseGeneric RequestHeartbeat RequestPhproxydHeartbeat RequestAddJobs ResponseJobIds RequestUpdateStatus RequestLogFinish ResponseRunInfo
Index ¶
- Constants
- Variables
- type ConfigT
- func (m *ConfigT) GetCycleMs() int64
- func (m *ConfigT) GetDefault() *ConfigTDefaultT
- func (m *ConfigT) GetDelay() uint32
- func (m *ConfigT) GetExitWithParent() bool
- func (m *ConfigT) GetFullTimetableReloadIntervalMs() int64
- func (m *ConfigT) GetIsDevel() bool
- func (m *ConfigT) GetLauncher() *ConfigTLauncherT
- func (m *ConfigT) GetMysql() *ConfigTMysqlT
- func (*ConfigT) ProtoMessage()
- func (m *ConfigT) Reset()
- func (m *ConfigT) String() string
- type ConfigTDefaultT
- func (m *ConfigTDefaultT) GetMaxMemory() int64
- func (m *ConfigTDefaultT) GetMinIdleCpu() float64
- func (m *ConfigTDefaultT) GetMinMemory() int64
- func (m *ConfigTDefaultT) GetMinMemoryRatio() float64
- func (m *ConfigTDefaultT) GetParasiteMemory() int64
- func (m *ConfigTDefaultT) GetRusage() float64
- func (*ConfigTDefaultT) ProtoMessage()
- func (m *ConfigTDefaultT) Reset()
- func (m *ConfigTDefaultT) String() string
- type ConfigTLauncherT
- func (m *ConfigTLauncherT) GetBaseDir() string
- func (m *ConfigTLauncherT) GetDeveloperDir() string
- func (m *ConfigTLauncherT) GetHostSuffix() string
- func (m *ConfigTLauncherT) GetRqhLogFile() string
- func (*ConfigTLauncherT) ProtoMessage()
- func (m *ConfigTLauncherT) Reset()
- func (m *ConfigTLauncherT) String() string
- type ConfigTMysqlT
- type Errno
- type GpbrpcInterface
- type GpbrpcType
- func (GpbrpcType) Dispatch(rctx gpbrpc.RequestT, abstract_service interface{}) gpbrpc.ResultT
- func (GpbrpcType) ErrorGeneric(args ...interface{}) gpbrpc.ResultT
- func (GpbrpcType) GetPackageName() string
- func (GpbrpcType) GetRequestIdToNameMap() map[uint32]string
- func (GpbrpcType) GetRequestMsg(request_msgid uint32) proto.Message
- func (GpbrpcType) GetRequestMsgid(msg proto.Message) uint32
- func (GpbrpcType) GetRequestNameToIdMap() map[string]uint32
- func (GpbrpcType) GetResponseIdToNameMap() map[uint32]string
- func (GpbrpcType) GetResponseMsg(response_msgid uint32) proto.Message
- func (GpbrpcType) GetResponseMsgid(msg proto.Message) uint32
- func (GpbrpcType) GetResponseNameToIdMap() map[string]uint32
- func (GpbrpcType) OK(args ...interface{}) gpbrpc.ResultT
- type RequestAddJobs
- type RequestAddJobsJobT
- func (m *RequestAddJobsJobT) GetClassName() string
- func (m *RequestAddJobsJobT) GetGenerationId() int64
- func (m *RequestAddJobsJobT) GetJobData() string
- func (m *RequestAddJobsJobT) GetLocation() string
- func (m *RequestAddJobsJobT) GetMethod() string
- func (m *RequestAddJobsJobT) GetNextLaunchTs() int64
- func (m *RequestAddJobsJobT) GetRepeat() *RequestAddJobsJobTRepeatT
- func (m *RequestAddJobsJobT) GetSettingsId() uint64
- func (*RequestAddJobsJobT) ProtoMessage()
- func (m *RequestAddJobsJobT) Reset()
- func (m *RequestAddJobsJobT) String() string
- type RequestAddJobsJobTRepeatT
- type RequestHeartbeat
- func (m *RequestHeartbeat) GetCpu() *RequestHeartbeatCpuT
- func (m *RequestHeartbeat) GetCpuCores() uint32
- func (m *RequestHeartbeat) GetCpuParrotsPerCore() uint32
- func (m *RequestHeartbeat) GetHostgroup() string
- func (m *RequestHeartbeat) GetHostname() string
- func (m *RequestHeartbeat) GetMemory() *RequestHeartbeatMemoryT
- func (*RequestHeartbeat) ProtoMessage()
- func (m *RequestHeartbeat) Reset()
- func (m *RequestHeartbeat) String() string
- type RequestHeartbeatCpuT
- func (m *RequestHeartbeatCpuT) GetIdle() float32
- func (m *RequestHeartbeatCpuT) GetIowait() float32
- func (m *RequestHeartbeatCpuT) GetNice() float32
- func (m *RequestHeartbeatCpuT) GetParasite() float32
- func (m *RequestHeartbeatCpuT) GetSteal() float32
- func (m *RequestHeartbeatCpuT) GetSys() float32
- func (m *RequestHeartbeatCpuT) GetUser() float32
- func (*RequestHeartbeatCpuT) ProtoMessage()
- func (m *RequestHeartbeatCpuT) Reset()
- func (m *RequestHeartbeatCpuT) String() string
- type RequestHeartbeatMemoryT
- func (m *RequestHeartbeatMemoryT) GetBuffers() int64
- func (m *RequestHeartbeatMemoryT) GetCached() int64
- func (m *RequestHeartbeatMemoryT) GetFree() int64
- func (m *RequestHeartbeatMemoryT) GetParasite() int64
- func (m *RequestHeartbeatMemoryT) GetSwapTotal() int64
- func (m *RequestHeartbeatMemoryT) GetSwapUsed() int64
- func (m *RequestHeartbeatMemoryT) GetTotal() int64
- func (*RequestHeartbeatMemoryT) ProtoMessage()
- func (m *RequestHeartbeatMemoryT) Reset()
- func (m *RequestHeartbeatMemoryT) String() string
- type RequestLogFinish
- func (m *RequestLogFinish) GetHostname() string
- func (m *RequestLogFinish) GetPrevStatus() string
- func (m *RequestLogFinish) GetRunId() uint64
- func (m *RequestLogFinish) GetSuccess() bool
- func (*RequestLogFinish) ProtoMessage()
- func (m *RequestLogFinish) Reset()
- func (m *RequestLogFinish) String() string
- type RequestMsgid
- type RequestPhproxydHeartbeat
- type RequestUpdateStatus
- func (m *RequestUpdateStatus) GetHostname() string
- func (m *RequestUpdateStatus) GetPrevStatus() string
- func (m *RequestUpdateStatus) GetRunId() uint64
- func (m *RequestUpdateStatus) GetStatus() string
- func (*RequestUpdateStatus) ProtoMessage()
- func (m *RequestUpdateStatus) Reset()
- func (m *RequestUpdateStatus) String() string
- type ResponseGeneric
- type ResponseJobIds
- type ResponseMsgid
- type ResponseRunInfo
Constants ¶
View Source
const Default_ConfigTDefaultT_MaxMemory int64 = 52428800
View Source
const Default_ConfigTDefaultT_MinIdleCpu float64 = -0.15
View Source
const Default_ConfigTDefaultT_MinMemory int64 = 1073741824
View Source
const Default_ConfigTDefaultT_MinMemoryRatio float64 = 0.01
View Source
const Default_ConfigTDefaultT_ParasiteMemory int64 = 838860800
View Source
const Default_ConfigTDefaultT_Rusage float64 = 0.02
View Source
const Default_ConfigT_CycleMs int64 = 1000
View Source
const Default_ConfigT_Delay uint32 = 0
View Source
const Default_ConfigT_ExitWithParent bool = false
View Source
const Default_ConfigT_FullTimetableReloadIntervalMs int64 = 1000
Variables ¶
View Source
var Errno_name = map[int32]string{
1: "ERRNO_GENERIC",
}
View Source
var Errno_value = map[string]int32{
"ERRNO_GENERIC": 1,
}
View Source
var RequestMsgid_gpbrpc_name = map[uint32]string{
1: "request_add_jobs",
2: "request_update_status",
3: "request_log_finish",
}
View Source
var RequestMsgid_gpbrpc_value = map[string]uint32{
"request_add_jobs": 1,
"request_update_status": 2,
"request_log_finish": 3,
}
View Source
var RequestMsgid_name = map[int32]string{
1: "REQUEST_ADD_JOBS",
2: "REQUEST_UPDATE_STATUS",
3: "REQUEST_LOG_FINISH",
}
View Source
var RequestMsgid_value = map[string]int32{
"REQUEST_ADD_JOBS": 1,
"REQUEST_UPDATE_STATUS": 2,
"REQUEST_LOG_FINISH": 3,
}
View Source
var ResponseMsgid_gpbrpc_name = map[uint32]string{
1: "response_generic",
2: "response_job_ids",
3: "response_run_info",
}
View Source
var ResponseMsgid_gpbrpc_value = map[string]uint32{
"response_generic": 1,
"response_job_ids": 2,
"response_run_info": 3,
}
View Source
var ResponseMsgid_name = map[int32]string{
1: "RESPONSE_GENERIC",
2: "RESPONSE_JOB_IDS",
3: "RESPONSE_RUN_INFO",
}
View Source
var ResponseMsgid_value = map[string]int32{
"RESPONSE_GENERIC": 1,
"RESPONSE_JOB_IDS": 2,
"RESPONSE_RUN_INFO": 3,
}
Functions ¶
This section is empty.
Types ¶
type ConfigT ¶
type ConfigT struct { Mysql *ConfigTMysqlT `protobuf:"bytes,1,req,name=mysql" json:"mysql,omitempty"` ExitWithParent *bool `protobuf:"varint,2,opt,name=exit_with_parent,def=0" json:"exit_with_parent,omitempty"` Delay *uint32 `protobuf:"varint,3,opt,name=delay,def=0" json:"delay,omitempty"` Default *ConfigTDefaultT `protobuf:"bytes,4,req,name=default" json:"default,omitempty"` CycleMs *int64 `protobuf:"varint,5,opt,name=cycle_ms,def=1000" json:"cycle_ms,omitempty"` FullTimetableReloadIntervalMs *int64 `protobuf:"varint,6,opt,name=full_timetable_reload_interval_ms,def=1000" json:"full_timetable_reload_interval_ms,omitempty"` Launcher *ConfigTLauncherT `protobuf:"bytes,7,req,name=launcher" json:"launcher,omitempty"` IsDevel *bool `protobuf:"varint,8,req,name=is_devel" json:"is_devel,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ConfigT) GetCycleMs ¶
func (*ConfigT) GetDefault ¶
func (m *ConfigT) GetDefault() *ConfigTDefaultT
func (*ConfigT) GetExitWithParent ¶
func (*ConfigT) GetFullTimetableReloadIntervalMs ¶
func (*ConfigT) GetIsDevel ¶
func (*ConfigT) GetLauncher ¶
func (m *ConfigT) GetLauncher() *ConfigTLauncherT
func (*ConfigT) GetMysql ¶
func (m *ConfigT) GetMysql() *ConfigTMysqlT
func (*ConfigT) ProtoMessage ¶
func (*ConfigT) ProtoMessage()
type ConfigTDefaultT ¶
type ConfigTDefaultT struct { // average parasite memory on devel and production servers if we were to guess ParasiteMemory *int64 `protobuf:"varint,1,opt,name=parasite_memory,def=838860800" json:"parasite_memory,omitempty"` // minimum requirements for hosts to be considered alive MinMemory *int64 `protobuf:"varint,2,opt,name=min_memory,def=1073741824" json:"min_memory,omitempty"` MinMemoryRatio *float64 `protobuf:"fixed64,3,opt,name=min_memory_ratio,def=0.01" json:"min_memory_ratio,omitempty"` MinIdleCpu *float64 `protobuf:"fixed64,4,opt,name=min_idle_cpu,def=-0.15" json:"min_idle_cpu,omitempty"` // average script memory usage in bytes MaxMemory *int64 `protobuf:"varint,5,opt,name=max_memory,def=52428800" json:"max_memory,omitempty"` Rusage *float64 `protobuf:"fixed64,6,opt,name=rusage,def=0.02" json:"rusage,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ConfigTDefaultT) GetMaxMemory ¶
func (m *ConfigTDefaultT) GetMaxMemory() int64
func (*ConfigTDefaultT) GetMinIdleCpu ¶
func (m *ConfigTDefaultT) GetMinIdleCpu() float64
func (*ConfigTDefaultT) GetMinMemory ¶
func (m *ConfigTDefaultT) GetMinMemory() int64
func (*ConfigTDefaultT) GetMinMemoryRatio ¶
func (m *ConfigTDefaultT) GetMinMemoryRatio() float64
func (*ConfigTDefaultT) GetParasiteMemory ¶
func (m *ConfigTDefaultT) GetParasiteMemory() int64
func (*ConfigTDefaultT) GetRusage ¶
func (m *ConfigTDefaultT) GetRusage() float64
func (*ConfigTDefaultT) ProtoMessage ¶
func (*ConfigTDefaultT) ProtoMessage()
func (*ConfigTDefaultT) Reset ¶
func (m *ConfigTDefaultT) Reset()
func (*ConfigTDefaultT) String ¶
func (m *ConfigTDefaultT) String() string
type ConfigTLauncherT ¶
type ConfigTLauncherT struct { HostSuffix *string `protobuf:"bytes,1,req,name=host_suffix" json:"host_suffix,omitempty"` BaseDir *string `protobuf:"bytes,2,req,name=base_dir" json:"base_dir,omitempty"` DeveloperDir *string `protobuf:"bytes,3,opt,name=developer_dir" json:"developer_dir,omitempty"` RqhLogFile *string `protobuf:"bytes,4,req,name=rqh_log_file" json:"rqh_log_file,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ConfigTLauncherT) GetBaseDir ¶
func (m *ConfigTLauncherT) GetBaseDir() string
func (*ConfigTLauncherT) GetDeveloperDir ¶
func (m *ConfigTLauncherT) GetDeveloperDir() string
func (*ConfigTLauncherT) GetHostSuffix ¶
func (m *ConfigTLauncherT) GetHostSuffix() string
func (*ConfigTLauncherT) GetRqhLogFile ¶
func (m *ConfigTLauncherT) GetRqhLogFile() string
func (*ConfigTLauncherT) ProtoMessage ¶
func (*ConfigTLauncherT) ProtoMessage()
func (*ConfigTLauncherT) Reset ¶
func (m *ConfigTLauncherT) Reset()
func (*ConfigTLauncherT) String ¶
func (m *ConfigTLauncherT) String() string
type ConfigTMysqlT ¶
type ConfigTMysqlT struct { Dsn *string `protobuf:"bytes,1,req,name=dsn" json:"dsn,omitempty"` MaxConnections *uint32 `protobuf:"varint,2,req,name=max_connections" json:"max_connections,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ConfigTMysqlT) GetDsn ¶
func (m *ConfigTMysqlT) GetDsn() string
func (*ConfigTMysqlT) GetMaxConnections ¶
func (m *ConfigTMysqlT) GetMaxConnections() uint32
func (*ConfigTMysqlT) ProtoMessage ¶
func (*ConfigTMysqlT) ProtoMessage()
func (*ConfigTMysqlT) Reset ¶
func (m *ConfigTMysqlT) Reset()
func (*ConfigTMysqlT) String ¶
func (m *ConfigTMysqlT) String() string
type GpbrpcInterface ¶
type GpbrpcInterface interface { RequestAddJobs(rctx gpbrpc.RequestT, request *RequestAddJobs) gpbrpc.ResultT RequestUpdateStatus(rctx gpbrpc.RequestT, request *RequestUpdateStatus) gpbrpc.ResultT RequestLogFinish(rctx gpbrpc.RequestT, request *RequestLogFinish) gpbrpc.ResultT }
type GpbrpcType ¶
type GpbrpcType struct { }
var Gpbrpc GpbrpcType
func (GpbrpcType) Dispatch ¶
func (GpbrpcType) Dispatch(rctx gpbrpc.RequestT, abstract_service interface{}) gpbrpc.ResultT
func (GpbrpcType) ErrorGeneric ¶
func (GpbrpcType) ErrorGeneric(args ...interface{}) gpbrpc.ResultT
func (GpbrpcType) GetPackageName ¶
func (GpbrpcType) GetPackageName() string
func (GpbrpcType) GetRequestIdToNameMap ¶
func (GpbrpcType) GetRequestIdToNameMap() map[uint32]string
func (GpbrpcType) GetRequestMsg ¶
func (GpbrpcType) GetRequestMsg(request_msgid uint32) proto.Message
func (GpbrpcType) GetRequestMsgid ¶
func (GpbrpcType) GetRequestMsgid(msg proto.Message) uint32
func (GpbrpcType) GetRequestNameToIdMap ¶
func (GpbrpcType) GetRequestNameToIdMap() map[string]uint32
func (GpbrpcType) GetResponseIdToNameMap ¶
func (GpbrpcType) GetResponseIdToNameMap() map[uint32]string
func (GpbrpcType) GetResponseMsg ¶
func (GpbrpcType) GetResponseMsg(response_msgid uint32) proto.Message
func (GpbrpcType) GetResponseMsgid ¶
func (GpbrpcType) GetResponseMsgid(msg proto.Message) uint32
func (GpbrpcType) GetResponseNameToIdMap ¶
func (GpbrpcType) GetResponseNameToIdMap() map[string]uint32
func (GpbrpcType) OK ¶
func (GpbrpcType) OK(args ...interface{}) gpbrpc.ResultT
type RequestAddJobs ¶
type RequestAddJobs struct { Jobs []*RequestAddJobsJobT `protobuf:"bytes,1,rep,name=jobs" json:"jobs,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RequestAddJobs) GetJobs ¶
func (m *RequestAddJobs) GetJobs() []*RequestAddJobsJobT
func (*RequestAddJobs) ProtoMessage ¶
func (*RequestAddJobs) ProtoMessage()
func (*RequestAddJobs) Reset ¶
func (m *RequestAddJobs) Reset()
func (*RequestAddJobs) String ¶
func (m *RequestAddJobs) String() string
type RequestAddJobsJobT ¶
type RequestAddJobsJobT struct { GenerationId *int64 `protobuf:"varint,1,opt,name=generation_id" json:"generation_id,omitempty"` ClassName *string `protobuf:"bytes,2,req,name=class_name" json:"class_name,omitempty"` JobData *string `protobuf:"bytes,3,req,name=job_data" json:"job_data,omitempty"` Method *string `protobuf:"bytes,4,opt,name=method" json:"method,omitempty"` Location *string `protobuf:"bytes,5,opt,name=location" json:"location,omitempty"` NextLaunchTs *int64 `protobuf:"varint,6,opt,name=next_launch_ts" json:"next_launch_ts,omitempty"` Repeat *RequestAddJobsJobTRepeatT `protobuf:"bytes,7,opt,name=repeat" json:"repeat,omitempty"` SettingsId *uint64 `protobuf:"varint,8,opt,name=settings_id" json:"settings_id,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RequestAddJobsJobT) GetClassName ¶
func (m *RequestAddJobsJobT) GetClassName() string
func (*RequestAddJobsJobT) GetGenerationId ¶
func (m *RequestAddJobsJobT) GetGenerationId() int64
func (*RequestAddJobsJobT) GetJobData ¶
func (m *RequestAddJobsJobT) GetJobData() string
func (*RequestAddJobsJobT) GetLocation ¶
func (m *RequestAddJobsJobT) GetLocation() string
func (*RequestAddJobsJobT) GetMethod ¶
func (m *RequestAddJobsJobT) GetMethod() string
func (*RequestAddJobsJobT) GetNextLaunchTs ¶
func (m *RequestAddJobsJobT) GetNextLaunchTs() int64
func (*RequestAddJobsJobT) GetRepeat ¶
func (m *RequestAddJobsJobT) GetRepeat() *RequestAddJobsJobTRepeatT
func (*RequestAddJobsJobT) GetSettingsId ¶
func (m *RequestAddJobsJobT) GetSettingsId() uint64
func (*RequestAddJobsJobT) ProtoMessage ¶
func (*RequestAddJobsJobT) ProtoMessage()
func (*RequestAddJobsJobT) Reset ¶
func (m *RequestAddJobsJobT) Reset()
func (*RequestAddJobsJobT) String ¶
func (m *RequestAddJobsJobT) String() string
type RequestAddJobsJobTRepeatT ¶
type RequestAddJobsJobTRepeatT struct { Value *int32 `protobuf:"varint,1,opt,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RequestAddJobsJobTRepeatT) GetValue ¶
func (m *RequestAddJobsJobTRepeatT) GetValue() int32
func (*RequestAddJobsJobTRepeatT) ProtoMessage ¶
func (*RequestAddJobsJobTRepeatT) ProtoMessage()
func (*RequestAddJobsJobTRepeatT) Reset ¶
func (m *RequestAddJobsJobTRepeatT) Reset()
func (*RequestAddJobsJobTRepeatT) String ¶
func (m *RequestAddJobsJobTRepeatT) String() string
type RequestHeartbeat ¶
type RequestHeartbeat struct { Hostname *string `protobuf:"bytes,1,req,name=hostname" json:"hostname,omitempty"` Hostgroup *string `protobuf:"bytes,2,req,name=hostgroup" json:"hostgroup,omitempty"` CpuParrotsPerCore *uint32 `protobuf:"varint,3,opt,name=cpu_parrots_per_core" json:"cpu_parrots_per_core,omitempty"` CpuCores *uint32 `protobuf:"varint,4,req,name=cpu_cores" json:"cpu_cores,omitempty"` Cpu *RequestHeartbeatCpuT `protobuf:"bytes,5,opt,name=cpu" json:"cpu,omitempty"` Memory *RequestHeartbeatMemoryT `protobuf:"bytes,6,opt,name=memory" json:"memory,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RequestHeartbeat) GetCpu ¶
func (m *RequestHeartbeat) GetCpu() *RequestHeartbeatCpuT
func (*RequestHeartbeat) GetCpuCores ¶
func (m *RequestHeartbeat) GetCpuCores() uint32
func (*RequestHeartbeat) GetCpuParrotsPerCore ¶
func (m *RequestHeartbeat) GetCpuParrotsPerCore() uint32
func (*RequestHeartbeat) GetHostgroup ¶
func (m *RequestHeartbeat) GetHostgroup() string
func (*RequestHeartbeat) GetHostname ¶
func (m *RequestHeartbeat) GetHostname() string
func (*RequestHeartbeat) GetMemory ¶
func (m *RequestHeartbeat) GetMemory() *RequestHeartbeatMemoryT
func (*RequestHeartbeat) ProtoMessage ¶
func (*RequestHeartbeat) ProtoMessage()
func (*RequestHeartbeat) Reset ¶
func (m *RequestHeartbeat) Reset()
func (*RequestHeartbeat) String ¶
func (m *RequestHeartbeat) String() string
type RequestHeartbeatCpuT ¶
type RequestHeartbeatCpuT struct { User *float32 `protobuf:"fixed32,1,req,name=user" json:"user,omitempty"` Sys *float32 `protobuf:"fixed32,2,req,name=sys" json:"sys,omitempty"` Nice *float32 `protobuf:"fixed32,3,req,name=nice" json:"nice,omitempty"` Iowait *float32 `protobuf:"fixed32,4,req,name=iowait" json:"iowait,omitempty"` Steal *float32 `protobuf:"fixed32,5,req,name=steal" json:"steal,omitempty"` Idle *float32 `protobuf:"fixed32,6,req,name=idle" json:"idle,omitempty"` Parasite *float32 `protobuf:"fixed32,7,req,name=parasite" json:"parasite,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RequestHeartbeatCpuT) GetIdle ¶
func (m *RequestHeartbeatCpuT) GetIdle() float32
func (*RequestHeartbeatCpuT) GetIowait ¶
func (m *RequestHeartbeatCpuT) GetIowait() float32
func (*RequestHeartbeatCpuT) GetNice ¶
func (m *RequestHeartbeatCpuT) GetNice() float32
func (*RequestHeartbeatCpuT) GetParasite ¶
func (m *RequestHeartbeatCpuT) GetParasite() float32
func (*RequestHeartbeatCpuT) GetSteal ¶
func (m *RequestHeartbeatCpuT) GetSteal() float32
func (*RequestHeartbeatCpuT) GetSys ¶
func (m *RequestHeartbeatCpuT) GetSys() float32
func (*RequestHeartbeatCpuT) GetUser ¶
func (m *RequestHeartbeatCpuT) GetUser() float32
func (*RequestHeartbeatCpuT) ProtoMessage ¶
func (*RequestHeartbeatCpuT) ProtoMessage()
func (*RequestHeartbeatCpuT) Reset ¶
func (m *RequestHeartbeatCpuT) Reset()
func (*RequestHeartbeatCpuT) String ¶
func (m *RequestHeartbeatCpuT) String() string
type RequestHeartbeatMemoryT ¶
type RequestHeartbeatMemoryT struct { Total *int64 `protobuf:"varint,1,req,name=total" json:"total,omitempty"` Free *int64 `protobuf:"varint,2,req,name=free" json:"free,omitempty"` Cached *int64 `protobuf:"varint,3,req,name=cached" json:"cached,omitempty"` Buffers *int64 `protobuf:"varint,4,req,name=buffers" json:"buffers,omitempty"` Parasite *int64 `protobuf:"varint,5,req,name=parasite" json:"parasite,omitempty"` SwapTotal *int64 `protobuf:"varint,6,req,name=swap_total" json:"swap_total,omitempty"` SwapUsed *int64 `protobuf:"varint,7,req,name=swap_used" json:"swap_used,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RequestHeartbeatMemoryT) GetBuffers ¶
func (m *RequestHeartbeatMemoryT) GetBuffers() int64
func (*RequestHeartbeatMemoryT) GetCached ¶
func (m *RequestHeartbeatMemoryT) GetCached() int64
func (*RequestHeartbeatMemoryT) GetFree ¶
func (m *RequestHeartbeatMemoryT) GetFree() int64
func (*RequestHeartbeatMemoryT) GetParasite ¶
func (m *RequestHeartbeatMemoryT) GetParasite() int64
func (*RequestHeartbeatMemoryT) GetSwapTotal ¶
func (m *RequestHeartbeatMemoryT) GetSwapTotal() int64
func (*RequestHeartbeatMemoryT) GetSwapUsed ¶
func (m *RequestHeartbeatMemoryT) GetSwapUsed() int64
func (*RequestHeartbeatMemoryT) GetTotal ¶
func (m *RequestHeartbeatMemoryT) GetTotal() int64
func (*RequestHeartbeatMemoryT) ProtoMessage ¶
func (*RequestHeartbeatMemoryT) ProtoMessage()
func (*RequestHeartbeatMemoryT) Reset ¶
func (m *RequestHeartbeatMemoryT) Reset()
func (*RequestHeartbeatMemoryT) String ¶
func (m *RequestHeartbeatMemoryT) String() string
type RequestLogFinish ¶
type RequestLogFinish struct { Hostname *string `protobuf:"bytes,1,req,name=hostname" json:"hostname,omitempty"` RunId *uint64 `protobuf:"varint,2,req,name=run_id" json:"run_id,omitempty"` PrevStatus *string `protobuf:"bytes,3,req,name=prev_status" json:"prev_status,omitempty"` Success *bool `protobuf:"varint,4,req,name=success" json:"success,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RequestLogFinish) GetHostname ¶
func (m *RequestLogFinish) GetHostname() string
func (*RequestLogFinish) GetPrevStatus ¶
func (m *RequestLogFinish) GetPrevStatus() string
func (*RequestLogFinish) GetRunId ¶
func (m *RequestLogFinish) GetRunId() uint64
func (*RequestLogFinish) GetSuccess ¶
func (m *RequestLogFinish) GetSuccess() bool
func (*RequestLogFinish) ProtoMessage ¶
func (*RequestLogFinish) ProtoMessage()
func (*RequestLogFinish) Reset ¶
func (m *RequestLogFinish) Reset()
func (*RequestLogFinish) String ¶
func (m *RequestLogFinish) String() string
type RequestMsgid ¶
type RequestMsgid int32
const ( RequestMsgid_REQUEST_ADD_JOBS RequestMsgid = 1 RequestMsgid_REQUEST_UPDATE_STATUS RequestMsgid = 2 RequestMsgid_REQUEST_LOG_FINISH RequestMsgid = 3 )
func (RequestMsgid) Enum ¶
func (x RequestMsgid) Enum() *RequestMsgid
func (RequestMsgid) String ¶
func (x RequestMsgid) String() string
func (*RequestMsgid) UnmarshalJSON ¶
func (x *RequestMsgid) UnmarshalJSON(data []byte) error
type RequestPhproxydHeartbeat ¶
type RequestPhproxydHeartbeat struct { Hostname *string `protobuf:"bytes,1,req,name=hostname" json:"hostname,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RequestPhproxydHeartbeat) GetHostname ¶
func (m *RequestPhproxydHeartbeat) GetHostname() string
func (*RequestPhproxydHeartbeat) ProtoMessage ¶
func (*RequestPhproxydHeartbeat) ProtoMessage()
func (*RequestPhproxydHeartbeat) Reset ¶
func (m *RequestPhproxydHeartbeat) Reset()
func (*RequestPhproxydHeartbeat) String ¶
func (m *RequestPhproxydHeartbeat) String() string
type RequestUpdateStatus ¶
type RequestUpdateStatus struct { Hostname *string `protobuf:"bytes,1,req,name=hostname" json:"hostname,omitempty"` RunId *uint64 `protobuf:"varint,2,req,name=run_id" json:"run_id,omitempty"` PrevStatus *string `protobuf:"bytes,3,req,name=prev_status" json:"prev_status,omitempty"` Status *string `protobuf:"bytes,4,req,name=status" json:"status,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RequestUpdateStatus) GetHostname ¶
func (m *RequestUpdateStatus) GetHostname() string
func (*RequestUpdateStatus) GetPrevStatus ¶
func (m *RequestUpdateStatus) GetPrevStatus() string
func (*RequestUpdateStatus) GetRunId ¶
func (m *RequestUpdateStatus) GetRunId() uint64
func (*RequestUpdateStatus) GetStatus ¶
func (m *RequestUpdateStatus) GetStatus() string
func (*RequestUpdateStatus) ProtoMessage ¶
func (*RequestUpdateStatus) ProtoMessage()
func (*RequestUpdateStatus) Reset ¶
func (m *RequestUpdateStatus) Reset()
func (*RequestUpdateStatus) String ¶
func (m *RequestUpdateStatus) String() string
type ResponseGeneric ¶
type ResponseGeneric struct { ErrorCode *int32 `protobuf:"zigzag32,1,req,name=error_code" json:"error_code,omitempty"` ErrorText *string `protobuf:"bytes,2,opt,name=error_text" json:"error_text,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ResponseGeneric) GetErrorCode ¶
func (m *ResponseGeneric) GetErrorCode() int32
func (*ResponseGeneric) GetErrorText ¶
func (m *ResponseGeneric) GetErrorText() string
func (*ResponseGeneric) ProtoMessage ¶
func (*ResponseGeneric) ProtoMessage()
func (*ResponseGeneric) Reset ¶
func (m *ResponseGeneric) Reset()
func (*ResponseGeneric) String ¶
func (m *ResponseGeneric) String() string
type ResponseJobIds ¶
type ResponseJobIds struct { JobId []uint64 `protobuf:"varint,1,rep,name=job_id" json:"job_id,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ResponseJobIds) GetJobId ¶
func (m *ResponseJobIds) GetJobId() []uint64
func (*ResponseJobIds) ProtoMessage ¶
func (*ResponseJobIds) ProtoMessage()
func (*ResponseJobIds) Reset ¶
func (m *ResponseJobIds) Reset()
func (*ResponseJobIds) String ¶
func (m *ResponseJobIds) String() string
type ResponseMsgid ¶
type ResponseMsgid int32
const ( ResponseMsgid_RESPONSE_GENERIC ResponseMsgid = 1 ResponseMsgid_RESPONSE_JOB_IDS ResponseMsgid = 2 ResponseMsgid_RESPONSE_RUN_INFO ResponseMsgid = 3 )
func (ResponseMsgid) Enum ¶
func (x ResponseMsgid) Enum() *ResponseMsgid
func (ResponseMsgid) String ¶
func (x ResponseMsgid) String() string
func (*ResponseMsgid) UnmarshalJSON ¶
func (x *ResponseMsgid) UnmarshalJSON(data []byte) error
type ResponseRunInfo ¶
type ResponseRunInfo struct { Info *string `protobuf:"bytes,1,req,name=info" json:"info,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ResponseRunInfo) GetInfo ¶
func (m *ResponseRunInfo) GetInfo() string
func (*ResponseRunInfo) ProtoMessage ¶
func (*ResponseRunInfo) ProtoMessage()
func (*ResponseRunInfo) Reset ¶
func (m *ResponseRunInfo) Reset()
func (*ResponseRunInfo) String ¶
func (m *ResponseRunInfo) String() string
Click to show internal directories.
Click to hide internal directories.