agent

type Collector struct {
	Id            int    /**< primary key(sequence) */
	StatName      string /**< Metric */
	Status        string
	StatEnable    bool /**< Enabled */
	Build         int  /**< Build version */
	StatStdoutLog bool /**< Standard output flag */
	StatInterval  int  /**< Interval(sec) */
	StatTimeout   int  /**< Timeout(sec) */
	NextTimestamp time.Time
	StatMode      string /**< Stataus mode */

	Jobs []*Job /**< First job */
}

type CommandInfo struct {
	CmdLine string
	OutPath string
	Timeout int

	Executed bool
	Pid      int
	ExitCode int
	Status   string
	OutBuf   string
}

type Config struct {
	Module        int       // Module id(S:Scheduler, C:Collector, W:Worker)
	ElapseTime    int       // Elapsed time(sec)
	StartTime     time.Time // Start time(UTC)
	Mode          ProcMode  // Status(INIT, WAIT, RUN, ...)
	ManagedPid    int       // Scheduler process id
	LocaleFlag    int       // Localization flag(0:English, 1:Japanese)
	DaemonFlag    int       // Daemon flag
	Host          string    // Hostname(Convert to lowercase , except the domain part)
	ServiceName   string    // HA service name
	Pwd           string    // Current directory
	Home          string    // Home directory
	ParameterFile string    // Parameter file
	ProgramName   string    // Program name
	ProgramPath   string    // Program path

	OutDir        string // Metric collection directory
	WorkDir       string // Work directory
	WorkCommonDir string // Common work directory
	ArchiveDir    string // Archive directory
	BackupDir     string // Backup directory
	ScriptDir     string // Script directory
	BinDir        string // Binary directory
	LogDir        string // Application log directory

	SslDir       string // SSL manage directory
	CacertFile   string // CA cert file
	ClcertFile   string // Client cert file
	ClkeyFile    string // Bind file of client cert and key
	SvParamFile  string // Server parameter file
	SvcertFile   string // Server cert file
	SvkeyFile    string // Server key file
	SvcacertFile string // Inter CA cert file
	LicenseFile  string // License file

	SoapRetry int // WEB service retry count

	ExitFlag string // Exit flag file
	PidFile  string // PID file
	PidPath  string // PID absolute path

	// CollectorPids map[int]int     // Collector pids
	SslConfig *soap.SSLConfig // struct  GPFSSLConfig_t  *sslConfig; // SSL manager
	// logConfig     *LogConfig  // struct  GPFLogConfig_t  *logConfig; // Log manager
	Schedule *Schedule // struct  GPFSchedule_t   *schedule;  // Scheduler
}

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

type Datastore struct {
	StartTime time.Time
	Host      string
	StatName  string
	DateDir   string
	TimeDir   string
	OutDir    string
}

type DatastoreKey struct {
	Host     string `json:"host"`
	StatName string `json:"stat_name"`
}

type DatastoreSet struct {
	DsKey   DatastoreKey `json:"keys"`
	ZipFile string
}

type DateFormat int

type DiskStatus struct {
	All  uint64 `json:"all"`
	Used uint64 `json:"used"`
	Free uint64 `json:"free"`
}

type Job struct {
	Id int /**< Primary key(sequence) */
	// Pid    int    /**< Worker process id */
	// Status int    /**< Process status */
	Cmd   string /**< Execute command */
	Ofile string /**< Output file */
	Cycle int    /**< Interval(sec) */
	Step  int    /**< Execute count */
}

type License struct {
	Hostname string
	Expired  string
	Code     string
}

type ParamMode int

type ParamType int

type ProcMode int

type ReportTask struct {
	Schedule ReportTaskTime
	Jobs     []ReportTaskJob
}

type ReportTaskJob struct {
	Id     int
	Out    string
	Cmd    string
	Start  time.Time
	End    time.Time
	Pid    int
	Rc     int
	Error  string
	Status string
}

type ReportTaskTime struct {
	Start time.Time
	End   time.Time
}

type Schedule struct {
	DiskCapacity int /**< Disk free threshold(%) */
	SaveHour     int /**< Metric data retention(H) */
	RecoveryHour int /**< Metric data retransmission(H) */
	MaxErrorLog  int /**< Max rows of error output */

	Pid    int /**< Scheduler process id */
	Status int /**< Process status */

	LogLevel     int  /**< Log level */
	DebugConsole bool /**< Console log enabled */
	LogSize      int  /**< Log size */
	LogRotation  int  /**< Number of log rotation */
	LogLocalize  bool /**< Flag of Japanese log */

	HanodeEnable bool   /**< HA node check flag */
	HanodeCmd    string /**< HA node check script */

	PostEnable bool   /**< Post command enabled */
	PostCmd    string /**< Post command */

	RemhostEnable bool   /**< Remote transfer enabled */
	UrlCM         string /**< Web service URL (Configuration manager) */
	UrlPM         string /**< Web service URL (Performance manager) */
	SoapTimeout   int    /**< Web service timeout */
	SiteKey       string /**< Site key */

	WebServiceEnable bool   // Web service enable
	WebServiceUrl    string // Web service url

	ProxyEnable bool   /**< HTTP proxy enabled */
	ProxyHost   string /**< Proxy host */
	ProxyPort   int    /**< Proxy port */

	LastUpdate  time.Time /**< Last update of parameter file */
	ParseFailed bool      /**< Set true if parser failed */

	License    *License
	Collectors map[string]*Collector // Collector pids
}

type Task struct {
	Collector   *Collector
	Datastore   *Datastore
	Pid         int      /**< Collector process id */
	Status      ProcMode /**< Process status */
	StatTimeout int

	StartTime time.Time /**< Start time(UTC) */
	EndTime   time.Time /**< End time(UTC) */

	// DateDir   string /**< Date directory */
	// TimeDir   string /**< Time directory */
	Odir      string /**< Output directory */
	ScriptDir string /**< Script directory */
	TaskJobs  []*TaskJob
}

type TaskJob struct {
	Job       *Job
	Seq       int
	Timeout   int
	MaxRow    int
	Odir      string
	ScriptDir string
	CmdLine   string

	LoopCount   int
	CommandInfo *CommandInfo
	Status      ProcMode
	StartTime   time.Time
	EndTime     time.Time
}

type WebService struct {
	ServiceUrl string
	ArchiveDir string
	Cfg        *Config
}