checker

Documentation

Index

• type HealthChecker
  • func NewHealthChecker(cClient consulutil.ConsulClient) HealthChecker
• type LabelReader
• type ReplicationControllerStore
• type ResourceClient

Types

type HealthChecker

type HealthChecker interface {
	WatchPodOnNode(
		nodename types.NodeName,
		podID types.PodID,
		quitCh <-chan struct{},
	) (chan health.Result, chan error)
	WatchService(
		ctx context.Context,
		serviceID string,
		resultCh chan<- map[types.NodeName]health.Result,
		errCh chan<- error,
		watchDelay time.Duration,
	)
	WatchHealth(
		resultCh chan []*health.Result,
		errCh chan<- error,
		quitCh <-chan struct{},
		jitterWindow time.Duration,
	)
	Service(serviceID string) (map[types.NodeName]health.Result, error)
}

func NewHealthChecker

func NewHealthChecker(cClient consulutil.ConsulClient) HealthChecker

type LabelReader

type LabelReader interface {
	GetMatches(klabels.Selector, labels.Type) ([]labels.Labeled, error)
}

type ReplicationControllerStore

type ReplicationControllerStore interface {
	Get(id rcfields.ID) (rcfields.RC, error)
}

type ResourceClient

type ResourceClient interface {
	GetRCIDsForPod(pod types.PodID) ([]rcfields.ID, error)
}