types

Documentation

Index

• type CLCRunnerStats
• type CLCRunnersStats
• type ConfigResponse
• type LeaderIPCallback
• type NodeStatus
• type StateNodeResponse
• type StateResponse
• type Stats
• type StatusResponse

Types

type CLCRunnerStats

type CLCRunnerStats struct {
	AverageExecutionTime int  `json:"AverageExecutionTime"`
	MetricSamples        int  `json:"MetricSamples"`
	IsClusterCheck       bool `json:"IsClusterCheck"`
	LastExecFailed       bool `json:"LastExecFailed"`
}

CLCRunnerStats is used to unmarshall the stats of each CLC Runner

type CLCRunnersStats

type CLCRunnersStats map[string]CLCRunnerStats

CLCRunnersStats is used to unmarshall the CLC Runners stats payload

type ConfigResponse

type ConfigResponse struct {
	LastChange int64                `json:"last_change"`
	Configs    []integration.Config `json:"configs"`
}

ConfigResponse holds the DCA response for a config query

type LeaderIPCallback

type LeaderIPCallback func() (string, error)

LeaderIPCallback describes the leader-election method we need and allows to inject a custom one for tests

type NodeStatus

type NodeStatus struct {
	LastChange int64 `json:"last_change"`
}

NodeStatus holds the status report from the node-agent

type StateNodeResponse

type StateNodeResponse struct {
	Name    string               `json:"name"`
	Configs []integration.Config `json:"configs"`
}

StateNodeResponse is a chunk of StateResponse

type StateResponse

type StateResponse struct {
	NotRunning string               `json:"not_running"` // Reason why not running, empty if leading
	Warmup     bool                 `json:"warmup"`
	Nodes      []StateNodeResponse  `json:"nodes"`
	Dangling   []integration.Config `json:"dangling"`
}

StateResponse holds the DCA response for a dispatching state query

type Stats

type Stats struct {
	// Following
	Follower bool
	LeaderIP string

	// Leading
	Leader          bool
	Active          bool
	NodeCount       int
	ActiveConfigs   int
	DanglingConfigs int
	TotalConfigs    int
}

Stats holds statistics for the agent status command

type StatusResponse

type StatusResponse struct {
	IsUpToDate bool `json:"isuptodate"`
}

StatusResponse holds the DCA response for a status report