useranalytics

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

type AnalyticsControllerConfig struct {
	Destinations            map[string]Destination
	KubeClient              kclientset.Interface
	OSClient                osclient.Interface
	MaximumQueueLength      int
	MetricsPollingFrequency int
	ClusterName             string
	UserKeyStrategy         string
	UserKeyAnnotation       string
	Typer                   runtime.ObjectTyper
}

type Destination interface {
	Send(ev *analyticsEvent) error
}

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

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

type MetricsConfig struct {
	BindAddr       string `json:"bindAddr" yaml:"bindAddr"`
	CollectRuntime bool   `json:"collectRuntime" yaml:"collectRuntime"`
	CollectWoopra  bool   `json:"collectWoopra" yaml:"collectWoopra"`
	CollectQueue   bool   `json:"collectQueue" yaml:"collectQueue"`
}

type MetricsServer struct {
	Config       MetricsConfig
	WoopraClient *WoopraDestination
	Controller   *AnalyticsController
}

type MockHttpEndpoint struct {
	Port            int
	RequestsHandled int
	LastRequestURI  string
	URLPrefix       string
	// maximum number of milliseconds to handle a request.
	// 0 for no latency
	MaxLatency int
	// percent chance of returning HTTP error, 0 - 100
	FlakeRate int
	DupeCheck bool
	// contains the unique hash of an event and the number of times it is posted to the endpoint
	Analytics map[string]int
}

type SimpleHttpClient interface {
	Get(endpoint string) (resp *http.Response, err error)
	Post(endpoint string, bodyType string, body io.Reader) (resp *http.Response, err error)
}

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

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

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

type WoopraDestination struct {
	Method   string
	Endpoint string
	Domain   string
	Client   SimpleHttpClient
}