healthd

package
v0.0.0-...-f1632ac Latest Latest
Warning

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

Go to latest
Published: Feb 5, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApiResponseAggregations

type ApiResponseAggregations struct {
	Aggregations []*health.IntervalAggregation `json:"aggregations"`
	// contains filtered or unexported fields
}

type ApiResponseAggregationsOverall

type ApiResponseAggregationsOverall struct {
	Overall *health.IntervalAggregation `json:"overall"`
	// contains filtered or unexported fields
}

type ApiResponseHosts

type ApiResponseHosts struct {
	Hosts []*HostStatus `json:"hosts"`
	// contains filtered or unexported fields
}

type ApiResponseJobs

type ApiResponseJobs struct {
	Jobs []*Job `json:"jobs"`
	// contains filtered or unexported fields
}

type By

type By func(j1, j2 *Job) bool

By is the type of a "less" function that defines the ordering of its Planet arguments.

func (By) Sort

func (by By) Sort(jobs []*Job)

Sort is a method on the function type, By, that sorts the argument slice according to the function.

type ByInterval

type ByInterval []*health.IntervalAggregation

func (ByInterval) Len

func (a ByInterval) Len() int

func (ByInterval) Less

func (a ByInterval) Less(i, j int) bool

func (ByInterval) Swap

func (a ByInterval) Swap(i, j int)

type HealthD

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

func StartNewHealthD

func StartNewHealthD(monitoredHostPorts []string, serverHostPort string, stream *health.Stream) *HealthD

func (*HealthD) Stop

func (hd *HealthD) Stop()

type HostStatus

type HostStatus struct {
	HostPort                string        `json:"host_port"`
	LastCheckTime           time.Time     `json:"last_check_time"`
	LastInstanceId          string        `json:"last_instance_id"`
	LastIntervalDuration    time.Duration `json:"last_interval_duration"`
	LastErr                 string        `json:"last_err"`
	LastNanos               int64         `json:"last_nanos"`
	LastCode                int           `json:"last_code"` // http status code of last response
	FirstSuccessfulResponse time.Time     `json:"first_successful_response"`
	LastSuccessfulResponse  time.Time     `json:"last_successful_response"`
}

type HostStatusByHostPort

type HostStatusByHostPort []*HostStatus

func (HostStatusByHostPort) Len

func (a HostStatusByHostPort) Len() int

func (HostStatusByHostPort) Less

func (a HostStatusByHostPort) Less(i, j int) bool

func (HostStatusByHostPort) Swap

func (a HostStatusByHostPort) Swap(i, j int)

type Job

type Job struct {
	Name                 string  `json:"name"`
	Count                int64   `json:"count"`
	CountSuccess         int64   `json:"count_success"`
	CountValidationError int64   `json:"count_validation_error"`
	CountPanic           int64   `json:"count_panic"`
	CountError           int64   `json:"count_error"`
	CountJunk            int64   `json:"count_junk"`
	NanosSum             int64   `json:"nanos_sum"`
	NanosSumSquares      float64 `json:"nanos_sum_squares"`
	NanosMin             int64   `json:"nanos_min"`
	NanosMax             int64   `json:"nanos_max"`
	NanosAvg             float64 `json:"nanos_avg"`
	NanosStdDev          float64 `json:"nanos_std_dev"`
}

Job represents a health.JobAggregation, but designed for JSON-ization without all the nested counters/timers

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL