kubernetes

type APIConfig struct {
	// How to authenticate to the K8s API server.  This can be one of `none`
	// (for no auth), `serviceAccount` (to use the standard service account
	// token provided to the agent pod), or `kubeConfig` to use credentials
	// from user-defined file
	AuthType     AuthType `mapstructure:"auth_type"`
	AuthFilePath string
}

type AuthType string

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

type Controller struct {
	Name       string
	Kind       string
	APIVersion string
}

type HostPortMap struct {
	HostPortInfo map[string]*K8sContainerInfo
	// contains filtered or unexported fields
}

type IpPortKey struct {
	Ip   string
	Port uint32
}

type K8sContainerInfo struct {
	ContainerId string
	Name        string
	HostPortMap map[int32]int32
	RefPodInfo  *K8sPodInfo
}

type K8sMetaDataCache struct {
	ContainerIdInfo map[string]*K8sContainerInfo

	IpContainerInfo map[string]map[uint32]*K8sContainerInfo

	IpServiceInfo map[string]map[uint32]*K8sServiceInfo

	HostPortInfo *HostPortMap
	// contains filtered or unexported fields
}

type K8sPodInfo struct {
	UID          string
	Ip           string
	PodName      string
	Ports        []int32
	HostPorts    []int32
	ContainerIds []string
	Labels       map[string]string
	// TODO: There may be multiple kinds of workload or services for the same pod
	WorkloadKind string
	WorkloadName string
	Namespace    string
	NodeName     string
	NodeAddress  string

	ServiceInfo *K8sServiceInfo
	// contains filtered or unexported fields
}

type K8sServiceInfo struct {
	Ip          string
	ServiceName string
	Namespace   string

	Selector map[string]string
	// TODO: How to delete the workload info when it is deleted?
	WorkloadKind string
	WorkloadName string
	// contains filtered or unexported fields
}

type MetaDataProviderConfig struct {
	Enable bool `mapstructure:"enable"`
	// print every K8s Metadata received from mp, used for debug
	EnableTrace bool `mapstructure:"enable_trace"`
	// Endpoint is where metadata-provider deloyed and provide service
	// e.g "http://localhost:9504"
	Endpoint string `mapstructure:"endpoint"`
}

type NodeInfo struct {
	Ip     string
	Name   string
	Labels map[string]string
}

type NodeMap struct {
	Info map[string]*NodeInfo
	// contains filtered or unexported fields
}

type Option func(cfg *config)

type ReplicaSetMap struct {
	// Key is ${namespace}/${name}
	Info map[string]Controller
	// contains filtered or unexported fields
}

type ServiceMap struct {
	// Service name could be duplicated in different namespace, so here
	// service name must not be the key of map. Therefore, a map with the
	// following structure is constructed.
	//
	// namespace1:
	//   servicename1: ServiceInfo{}
	//   servicename2: ServiceInfo{}
	// namespace2:
	//   servicename1: ServiceInfo{}
	ServiceMap map[string]map[string]*K8sServiceInfo
	// contains filtered or unexported fields
}

type SetPreprocessingMetaDataCache func(cache *K8sMetaDataCache, nodeMap *NodeMap, serviceMap *ServiceMap, rsMap *ReplicaSetMap)