kube

type APIClientsetProvider func(config k8sconfig.APIConfig) (kubernetes.Interface, error)

type Association struct {
	Name    string
	Sources []AssociationSource
}

type AssociationSource struct {
	From string
	Name string
}

type Associations struct {
	Associations []Association
}

type Client interface {
	GetPod(PodIdentifier) (*Pod, bool)
	GetNamespace(string) (*Namespace, bool)
	GetNode(string) (*Node, bool)
	GetDeployment(string) (*Deployment, bool)
	GetStatefulSet(string) (*StatefulSet, bool)
	GetDaemonSet(string) (*DaemonSet, bool)
	GetJob(string) (*Job, bool)
	Start() error
	Stop()
}

type ClientProvider func(component.TelemetrySettings, k8sconfig.APIConfig, ExtractionRules, Filters, []Association, Excludes, APIClientsetProvider, InformersFactoryList, bool, time.Duration) (Client, error)

type Container struct {
	Name              string
	ImageName         string
	ImageTag          string
	ServiceInstanceID string
	ServiceVersion    string

	// Statuses is a map of container k8s.container.restart_count attribute to ContainerStatus struct.
	Statuses map[int]ContainerStatus
}

type ContainerStatus struct {
	ContainerID     string
	ImageRepoDigest string
}

type CronJob struct {
	Name       string
	UID        string
	Attributes map[string]string
}

type DaemonSet struct {
	Name       string
	UID        string
	Attributes map[string]string
}

type Deployment struct {
	Name       string
	UID        string
	Attributes map[string]string
}

type ExcludePods struct {
	Name *regexp.Regexp
}

type Excludes struct {
	Pods []ExcludePods
}

type ExtractionRules struct {
	CronJobName               bool
	CronJobUID                bool
	DeploymentName            bool
	DeploymentUID             bool
	DaemonSetUID              bool
	DaemonSetName             bool
	JobUID                    bool
	JobName                   bool
	Namespace                 bool
	PodName                   bool
	PodUID                    bool
	PodHostName               bool
	PodIP                     bool
	ReplicaSetID              bool
	ReplicaSetName            bool
	StatefulSetUID            bool
	StatefulSetName           bool
	Node                      bool
	NodeUID                   bool
	StartTime                 bool
	ContainerName             bool
	ContainerID               bool
	ContainerImageName        bool
	ContainerImageRepoDigests bool
	ContainerImageTag         bool
	ClusterUID                bool
	ServiceNamespace          bool
	ServiceName               bool
	ServiceVersion            bool
	ServiceInstanceID         bool

	Annotations []FieldExtractionRule
	Labels      []FieldExtractionRule
}

type FakeController struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type FakeInformer struct {
	*FakeController
	// contains filtered or unexported fields
}

type FakeNamespaceInformer struct {
	*FakeController
}

type FakeReplicaSetInformer struct {
	*FakeController
}

type FieldExtractionRule struct {
	// Name is used to as the Span tag name.
	Name string
	// Key is used to lookup k8s pod fields.
	Key string
	// KeyRegex is a regular expression(full length match) used to extract a Key that matches the regex.
	KeyRegex             *regexp.Regexp
	HasKeyRegexReference bool
	// Regex is a regular expression used to extract a sub-part of a field value.
	// Full value is extracted when no regexp is provided.
	Regex *regexp.Regexp
	// From determines the kubernetes object the field should be retrieved from.
	// Currently only three values are supported,
	//  - pod
	//  - namespace
	//  - node
	//  - deployment
	//  - statefulset
	//  - daemonset
	//  - job
	From string
}

type FieldFilter struct {
	// Key matches the field name.
	Key string
	// Value matches the field value.
	Value string
	// Op determines the matching operation.
	// Currently only two operations are supported,
	//  - Equals
	//  - NotEquals
	Op selection.Operator
}

type Filters struct {
	Node      string
	Namespace string
	Fields    []FieldFilter
	Labels    []LabelFilter
}

type InformerProvider func(
	client kubernetes.Interface,
	namespace string,
	labelSelector labels.Selector,
	fieldSelector fields.Selector,
) cache.SharedInformer

type InformerProviderNamespace func(
	client kubernetes.Interface,
) cache.SharedInformer

type InformerProviderNode func(
	client kubernetes.Interface,
) cache.SharedInformer

type InformerProviderWorkload func(
	client kubernetes.Interface,
	namespace string,
) cache.SharedInformer

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

type Job struct {
	Name       string
	UID        string
	Attributes map[string]string
	CronJob    CronJob
}

type LabelFilter struct {
	// Key matches the label name.
	Key string
	// Value matches the label value.
	Value string
	// Op determines the matching operation.
	// The following operations are supported,
	//	- Exists
	// 	- DoesNotExist
	//	- Equals
	//	- DoubleEquals
	//	- NotEquals
	//	- GreaterThan
	//	- LessThan
	Op selection.Operator
}

type Namespace struct {
	Name         string
	NamespaceUID string
	Attributes   map[string]string
	StartTime    metav1.Time
	DeletedAt    time.Time
}

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

type NoOpInformer struct {
	*NoOpController
}

type Node struct {
	Name       string
	NodeUID    string
	Attributes map[string]string
}

type Pod struct {
	Name           string
	Address        string
	PodUID         string
	Attributes     map[string]string
	StartTime      *metav1.Time
	Ignore         bool
	Namespace      string
	NodeName       string
	DeploymentUID  string
	StatefulSetUID string
	DaemonSetUID   string
	JobUID         string
	HostNetwork    bool

	// Containers specifies all containers in this pod.
	Containers PodContainers

	DeletedAt time.Time
}

type PodContainers struct {
	// ByID specifies all containers in a pod by container ID.
	ByID map[string]*Container
	// ByName specifies all containers in a pod by container name (k8s.container.name).
	ByName map[string]*Container
}

type PodIdentifier [PodIdentifierMaxLength]PodIdentifierAttribute

type PodIdentifierAttribute struct {
	Source AssociationSource
	Value  string
}

type ReplicaSet struct {
	Name       string
	Namespace  string
	UID        string
	Deployment Deployment
}

type StatefulSet struct {
	Name       string
	UID        string
	Attributes map[string]string
}

type WatchClient struct {

	// A map containing Pod related data, used to associate them with resources.
	// Key can be either an IP address or Pod UID
	Pods         map[PodIdentifier]*Pod
	Rules        ExtractionRules
	Filters      Filters
	Associations []Association
	Exclude      Excludes

	// A map containing Namespace related data, used to associate them with resources.
	// Key is namespace name
	Namespaces map[string]*Namespace

	// A map containing Node related data, used to associate them with resources.
	// Key is node name
	Nodes map[string]*Node

	// A map containing Deployment related data, used to associate them with resources.
	// Key is deployment uid
	Deployments map[string]*Deployment

	// A map containing StatefulSet related data, used to associate them with resources.
	// Key is statefulset uid
	StatefulSets map[string]*StatefulSet

	// A map containing DaemonSet related data, used to associate them with resources.
	// Key is daemonset uid
	DaemonSets map[string]*DaemonSet

	// A map containing job related data, used to associate them with resources.
	// Key is job uid
	Jobs map[string]*Job

	// A map containing ReplicaSets related data, used to associate them with resources.
	// Key is replicaset uid
	ReplicaSets map[string]*ReplicaSet
	// contains filtered or unexported fields
}