ci

type BackendSampler struct {
	TestConfiguration
	SampleRunner sampler.Runner
	// contains filtered or unexported fields
}

type Factory interface {
	New(TestConfiguration) (Sampler, error)
}

type Sampler interface {
	GetTargetServerName() string
	GetLoadBalancerType() string
	GetConnectionType() monitorapi.BackendConnectionType
	GetProtocol() string
	GetDisruptionBackendName() string
	GetLocator() monitorapi.Locator
	GetURL() (string, error)
	RunEndpointMonitoring(ctx context.Context, m monitorapi.RecorderWriter, eventRecorder events.EventRecorder) error
	StartEndpointMonitoring(ctx context.Context, m monitorapi.RecorderWriter, eventRecorder events.EventRecorder) error
	Stop()
}

type ServerNameType string

type TestConfiguration struct {
	TestDescriptor

	// Path is the request path that the backend sampler will exercise
	Path string

	// Timeout is the transport timeout, it is the maximum amount of time a
	// dial will wait for a connect to complete.
	// If Deadline is also set, it may fail earlier.
	// NOTE: we infer the client timeout and request deadline from this value,
	//  this is how the current backend sampler works.
	Timeout time.Duration

	// SampleInterval is the interval that the sampler will
	// wait before generating the next sample.
	// NOTE: the current backend sampler implementation defaults
	//  it to 1s.
	SampleInterval time.Duration

	// EnableShutdownResponseHeader indicates whether to include the shutdown
	// response header extractor, this should be true only when the
	// request(s) are being sent to the kube-apiserver.
	EnableShutdownResponseHeader bool

	// Source contains pod name if incluster monitor is used
	Source string
}

type TestDescriptor struct {
	// TargetServer is the server that is is being tested
	TargetServer ServerNameType

	// LoadBalancerType is the type of load balancer through which the
	// disruption test is hitting the target server.
	LoadBalancerType backend.LoadBalancerType

	// ConnectionType specifies whether the underlying TCP connection(s) used
	// by the requests should be new or reused.
	ConnectionType monitorapi.BackendConnectionType

	// Protocol specifies the protocol used by the test,
	// whether it is http/1x or http/2.0
	Protocol backend.ProtocolType
}