api

type CommandProvider struct {
	Command []string
	Role    []string
	// contains filtered or unexported fields
}

type DCOSHelper interface {
	// open dbus connection
	InitializeDBUSConnection() error

	// close dbus connection
	CloseDBUSConnection() error

	// function to get Connection.GetUnitProperties(pname)
	// returns a maps of properties https://github.com/coreos/go-systemd/blob/master/dbus/methods.go#L176
	GetUnitProperties(string) (map[string]interface{}, error)

	// A wrapper to /opt/mesosphere/bin/detect_ip script
	// should return empty string if script fails.
	DetectIP() (string, error)

	// get system's hostname
	GetHostname() (string, error)

	// Detect node role: master/agent
	GetNodeRole() (string, error)

	// Get DC/OS systemd units on a system
	GetUnitNames() ([]string, error)

	// Get journal output
	GetJournalOutput(string) (string, error)

	// Get mesos node id, first argument is a function to determine a role.
	GetMesosNodeID() (string, error)

	// Get makes HTTP GET request, return read arrays of bytes
	Get(string, time.Duration) ([]byte, int, error)

	// Post makes HTTP GET request, return read arrays of bytes
	Post(string, time.Duration) ([]byte, int, error)

	// LookupMaster will lookup a masters in DC/OS cluster.
	// Initial lookup will be done by making HTTP GET request to exhibitor.If GET request fails, the next lookup
	// will failover to history service for one minute, it this fails or no nodes found, masters will be looked up
	// in history service for last hour.
	GetMasterNodes() ([]Node, error)
	//
	//// GetAgentsFromMaster will lookup agents in DC/OS cluster.
	GetAgentNodes() ([]Node, error)

	// Get timestamp
	GetTimestamp() time.Time
}

type DCOSTools struct {
	sync.Mutex

	ExhibitorURL string
	Role         string
	ForceTLS     bool
	NodeInfo     nodeutil.NodeInfo
	Transport    http.RoundTripper
	// contains filtered or unexported fields
}

type DiagnosticsJob struct {
	sync.Mutex

	Transport             http.RoundTripper `json:"-"`
	Running               bool              `json:"is_running"`
	Status                string            `json:"status"`
	Errors                []string          `json:"errors"`
	LastBundlePath        string            `json:"last_bundle_dir"`
	JobStarted            time.Time         `json:"job_started"`
	JobEnded              time.Time         `json:"job_ended"`
	JobDuration           time.Duration     `json:"job_duration"`
	JobProgressPercentage float32           `json:"job_progress_percentage"`
	// contains filtered or unexported fields
}

type Dt struct {
	Cfg               *config.Config
	DtDCOSTools       DCOSHelper
	DtDiagnosticsJob  *DiagnosticsJob
	RunPullerChan     chan bool
	RunPullerDoneChan chan bool
	SystemdUnits      *SystemdUnits
	MR                *MonitoringResponse
}

type FileProvider struct {
	Location string
	Role     []string
	// contains filtered or unexported fields
}

type HTTPProvider struct {
	Port     int
	URI      string
	FileName string
	Role     []string
}

type HTTPRequester interface {
	Init(*config.Config, DCOSHelper) error
	Do(*http.Request, time.Duration) (*http.Response, error)
	Transport() http.RoundTripper
}

type HealthResponseValues struct {
	UnitID     string `json:"id"`
	UnitHealth int    `json:"health"`
	UnitOutput string `json:"output"`
	UnitTitle  string `json:"description"`
	Help       string `json:"help"`
	PrettyName string `json:"name"`
}

type LogProviders struct {
	HTTPEndpoints []HTTPProvider
	LocalFiles    []FileProvider
	LocalCommands []CommandProvider
}

type MonitoringResponse struct {
	sync.RWMutex

	Units       map[string]Unit
	Nodes       map[string]Node
	UpdatedTime time.Time
}

type Node struct {
	Leader  bool
	Role    string
	IP      string
	Host    string
	Health  int
	Output  map[string]string
	Units   []Unit `json:",omitempty"`
	MesosID string
}

type NodeResponseFieldsStruct struct {
	HostIP     string `json:"host_ip"`
	NodeHealth int    `json:"health"`
	NodeRole   string `json:"role"`
}

type NodeResponseFieldsWithErrorStruct struct {
	HostIP     string `json:"host_ip"`
	NodeHealth int    `json:"health"`
	NodeRole   string `json:"role"`
	UnitOutput string `json:"output"`
	Help       string `json:"help"`
}

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

type NodesResponseJSONStruct struct {
	Array []*NodeResponseFieldsStruct `json:"nodes"`
}

type SystemdUnits struct {
	sync.Mutex
}

type Unit struct {
	UnitName   string
	Nodes      []Node `json:",omitempty"`
	Health     int
	Title      string
	Timestamp  time.Time
	PrettyName string
}

type UnitPropertiesResponse struct {
	ID             string `json:"Id"`
	LoadState      string
	ActiveState    string
	SubState       string
	Description    string
	ExecMainStatus int

	InactiveExitTimestampMonotonic  uint64
	ActiveEnterTimestampMonotonic   uint64
	ActiveExitTimestampMonotonic    uint64
	InactiveEnterTimestampMonotonic uint64
}

type UnitResponseFieldsStruct struct {
	UnitID     string `json:"id"`
	PrettyName string `json:"name"`
	UnitHealth int    `json:"health"`
	UnitTitle  string `json:"description"`
}

type UnitsHealthResponseJSONStruct struct {
	Array       []HealthResponseValues `json:"units"`
	System      sysMetrics             `json:"system"`
	Hostname    string                 `json:"hostname"`
	IPAddress   string                 `json:"ip"`
	DcosVersion string                 `json:"dcos_version"`
	Role        string                 `json:"node_role"`
	MesosID     string                 `json:"mesos_id"`
	TdtVersion  string                 `json:"3dt_version"`
}

type UnitsResponseJSONStruct struct {
	Array []UnitResponseFieldsStruct `json:"units"`
}