test

Documentation

Index

• func HappyHealthChecker(nodes []types.NodeName) checker.HealthChecker
• func NewSingleService(service string, health map[types.NodeName]health.Result) checker.HealthChecker
• func NewSingleServiceShadow(service string, health map[types.NodeName]health.Result) checker.ShadowTrafficHealthChecker
• type AlwaysHappyHealthChecker
  • func (h AlwaysHappyHealthChecker) Service(serviceID string) (map[types.NodeName]health.Result, error)
  • func (h AlwaysHappyHealthChecker) WatchHealth(_ chan []*health.Result, errCh chan<- error, quitCh <-chan struct{}, ...)
  • func (h AlwaysHappyHealthChecker) WatchPodOnNode(nodeName types.NodeName, podID types.PodID, quitCh <-chan struct{}) (chan health.Result, chan error)
  • func (h AlwaysHappyHealthChecker) WatchService(ctx context.Context, serviceID string, ...)

Functions

func HappyHealthChecker

func HappyHealthChecker(nodes []types.NodeName) checker.HealthChecker

creates an implementation of checker.HealthChecker that always reports satisfied health checks for testing purposes

func NewSingleService

func NewSingleService(service string, health map[types.NodeName]health.Result) checker.HealthChecker

NewSingleService reports a fixed health result for a single service only

func NewSingleServiceShadow

func NewSingleServiceShadow(service string, health map[types.NodeName]health.Result) checker.ShadowTrafficHealthChecker

Types

type AlwaysHappyHealthChecker

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

func (AlwaysHappyHealthChecker) Service

func (h AlwaysHappyHealthChecker) Service(serviceID string) (map[types.NodeName]health.Result, error)

func (AlwaysHappyHealthChecker) WatchHealth

func (h AlwaysHappyHealthChecker) WatchHealth(
	_ chan []*health.Result,
	errCh chan<- error,
	quitCh <-chan struct{},
	jitterWindow time.Duration,
)

func (AlwaysHappyHealthChecker) WatchPodOnNode

func (h AlwaysHappyHealthChecker) WatchPodOnNode(
	nodeName types.NodeName,
	podID types.PodID,
	quitCh <-chan struct{},
) (chan health.Result, chan error)

func (AlwaysHappyHealthChecker) WatchService

func (h AlwaysHappyHealthChecker) WatchService(
	ctx context.Context,
	serviceID string,
	resultCh chan<- map[types.NodeName]health.Result,
	errCh chan<- error,
	watchDelay time.Duration,
)