Versions in this module Expand all Collapse all v1 v1.16.4 Nov 29, 2024 v0 v0.16.4 Nov 29, 2024 Changes in this version + const DefaultBufSize + const DefaultDockerHost + const MinInterval + const UserAgent + var ErrOSServiceStatusCritical = errors.New(errOSServiceStatusCritical) + func ParseHost(host string) (string, string, string, error) + type AliasNotifier interface + AddAliasCheck func(structs.CheckID, structs.ServiceID, chan<- struct{}) error + Checks func(*acl.EnterpriseMeta) map[structs.CheckID]*structs.HealthCheck + RemoveAliasCheck func(structs.CheckID, structs.ServiceID) + type CheckAlias struct + CheckID structs.CheckID + Node string + Notify AliasNotifier + RPC RPC + RPCReq structs.NodeSpecificRequest + ServiceID structs.ServiceID + func (c *CheckAlias) Start() + func (c *CheckAlias) Stop() + type CheckDocker struct + CheckID structs.CheckID + Client *DockerClient + DockerContainerID string + Interval time.Duration + Logger hclog.Logger + Script string + ScriptArgs []string + ServiceID structs.ServiceID + Shell string + StatusHandler *StatusHandler + func (c *CheckDocker) Start() + func (c *CheckDocker) Stop() + type CheckGRPC struct + CheckID structs.CheckID + GRPC string + Interval time.Duration + Logger hclog.Logger + ProxyGRPC string + ServiceID structs.ServiceID + StatusHandler *StatusHandler + TLSClientConfig *tls.Config + Timeout time.Duration + func (c *CheckGRPC) CheckType() structs.CheckType + func (c *CheckGRPC) Start() + func (c *CheckGRPC) Stop() + type CheckH2PING struct + CheckID structs.CheckID + H2PING string + Interval time.Duration + Logger hclog.Logger + ServiceID structs.ServiceID + StatusHandler *StatusHandler + TLSClientConfig *tls.Config + Timeout time.Duration + func (c *CheckH2PING) Start() + func (c *CheckH2PING) Stop() + type CheckHTTP struct + Body string + CheckID structs.CheckID + DisableRedirects bool + HTTP string + Header map[string][]string + Interval time.Duration + Logger hclog.Logger + Method string + OutputMaxSize int + ProxyHTTP string + ServiceID structs.ServiceID + StatusHandler *StatusHandler + TLSClientConfig *tls.Config + Timeout time.Duration + func (c *CheckHTTP) CheckType() structs.CheckType + func (c *CheckHTTP) Start() + func (c *CheckHTTP) Stop() + type CheckIfServiceIDExists func(*structs.ServiceID) bool + type CheckMonitor struct + CheckID structs.CheckID + Interval time.Duration + Logger hclog.Logger + Notify CheckNotifier + OutputMaxSize int + Script string + ScriptArgs []string + ServiceID structs.ServiceID + StatusHandler *StatusHandler + Timeout time.Duration + func (c *CheckMonitor) Start() + func (c *CheckMonitor) Stop() + type CheckNotifier interface + ServiceExists func(serviceID structs.ServiceID) bool + UpdateCheck func(checkID structs.CheckID, status, output string) + type CheckOSService struct + CheckID structs.CheckID + Client *OSServiceClient + Interval time.Duration + Logger hclog.Logger + OSService string + ServiceID structs.ServiceID + StatusHandler *StatusHandler + Timeout time.Duration + func (c *CheckOSService) CheckType() structs.CheckType + func (c *CheckOSService) Start() + func (c *CheckOSService) Stop() + type CheckTCP struct + CheckID structs.CheckID + Interval time.Duration + Logger hclog.Logger + ServiceID structs.ServiceID + StatusHandler *StatusHandler + TCP string + TLSClientConfig *tls.Config + Timeout time.Duration + func (c *CheckTCP) Start() + func (c *CheckTCP) Stop() + type CheckTTL struct + CheckID structs.CheckID + Logger hclog.Logger + Notify CheckNotifier + OutputMaxSize int + ServiceID structs.ServiceID + TTL time.Duration + func (c *CheckTTL) SetStatus(status, output string) string + func (c *CheckTTL) Start() + func (c *CheckTTL) Stop() + type CheckUDP struct + CheckID structs.CheckID + Interval time.Duration + Logger hclog.Logger + Message string + ServiceID structs.ServiceID + StatusHandler *StatusHandler + Timeout time.Duration + UDP string + func (c *CheckUDP) Start() + func (c *CheckUDP) Stop() + type DockerClient struct + func NewDockerClient(host string, maxbuf int64) (*DockerClient, error) + func (c *DockerClient) Close() error + func (c *DockerClient) CreateExec(containerID string, cmd []string) (string, error) + func (c *DockerClient) Host() string + func (c *DockerClient) InspectExec(containerID, execID string) (int, error) + func (c *DockerClient) StartExec(containerID, execID string) (*circbuf.Buffer, error) + type GrpcHealthProbe struct + func NewGrpcHealthProbe(target string, timeout time.Duration, tlsConfig *tls.Config) *GrpcHealthProbe + func (probe *GrpcHealthProbe) Check(target string) error + type OSServiceClient struct + func NewOSServiceClient() (*OSServiceClient, error) + func (client *OSServiceClient) Check(serviceName string) (err error) + func (client *OSServiceClient) Check(serviceName string) error + type RPC interface + RPC func(ctx context.Context, method string, args interface{}, reply interface{}) error + type StatusHandler struct + func NewStatusHandler(inner CheckNotifier, logger hclog.Logger, ...) *StatusHandler