healthcheck

Documentation

Overview

* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

• Constants
• type EndpointChecker
  • func (c *EndpointChecker) HandleFailure(timeout bool)
  • func (c *EndpointChecker) HandleSuccess()
  • func (c *EndpointChecker) HandleTimeout()
  • func (c *EndpointChecker) OnCheck()
  • func (c *EndpointChecker) OnTimeout()
  • func (c *EndpointChecker) Start()
  • func (c *EndpointChecker) Stop()
• type HealthChecker
  • func CreateHealthCheck(cluster *model.ClusterConfig, cfg model.HealthCheckConfig) *HealthChecker
  • func (hc *HealthChecker) Start()
  • func (hc *HealthChecker) StartOne(endpoint *model.Endpoint)
  • func (hc *HealthChecker) Stop()
  • func (hc *HealthChecker) StopOne(endpoint *model.Endpoint)
• type TCPChecker
  • func (s *TCPChecker) CheckHealth() bool
  • func (s *TCPChecker) OnTimeout()

Constants

const (
	DefaultTimeout  = time.Second
	DefaultInterval = 3 * time.Second

	DefaultHealthyThreshold   uint32 = 5
	DefaultUnhealthyThreshold uint32 = 5
	DefaultFirstInterval             = 5 * time.Second
)

Types

type EndpointChecker

type EndpointChecker struct {
	HealthChecker *HealthChecker
	// contains filtered or unexported fields
}

EndpointChecker is a wrapper of types.HealthCheckSession for health check

func (*EndpointChecker) HandleFailure

func (c *EndpointChecker) HandleFailure(timeout bool)

func (*EndpointChecker) HandleSuccess

func (c *EndpointChecker) HandleSuccess()

func (*EndpointChecker) HandleTimeout

func (c *EndpointChecker) HandleTimeout()

func (*EndpointChecker) OnCheck

func (c *EndpointChecker) OnCheck()

func (*EndpointChecker) OnTimeout

func (c *EndpointChecker) OnTimeout()

func (*EndpointChecker) Start

func (c *EndpointChecker) Start()

func (*EndpointChecker) Stop

func (c *EndpointChecker) Stop()

type HealthChecker

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

func CreateHealthCheck

func CreateHealthCheck(cluster *model.ClusterConfig, cfg model.HealthCheckConfig) *HealthChecker

func (*HealthChecker) Start

func (hc *HealthChecker) Start()

func (*HealthChecker) StartOne

func (hc *HealthChecker) StartOne(endpoint *model.Endpoint)

func (*HealthChecker) Stop

func (hc *HealthChecker) Stop()

func (*HealthChecker) StopOne

func (hc *HealthChecker) StopOne(endpoint *model.Endpoint)

type TCPChecker

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

func (*TCPChecker) CheckHealth

func (s *TCPChecker) CheckHealth() bool

func (*TCPChecker) OnTimeout

func (s *TCPChecker) OnTimeout()