healthd

package
v0.0.0-...-8675af2 Latest Latest
Warning

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

Go to latest
Published: Sep 25, 2017 License: MIT Imports: 13 Imported by: 14

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