Documentation
¶
Overview ¶
Package cluster provides abstraction from kubernetes API.
Package cluster [TODO:description]
Package cluster provides abstraction from kubernetes API.
Package cluster provides abstraction from kubernetes API. util.go contains type utility functions for the cluster package.
Index ¶
- func CreateClientSet(kubeconfigPath string) *kubernetes.Clientset
- func ProcessContainer(pod *corev1.Pod, bunDB *bun.DB, timestamp time.Time)
- func ProcessNode(event Event, bunDB *bun.DB)
- func ProcessPersistentVolume(event Event, bunDB *bun.DB)
- func ProcessPersistentVolumeClaim(event Event, bunDB *bun.DB)
- func ProcessPod(event Event, bunDB *bun.DB)
- func ProcessService(event Event, bunDB *bun.DB)
- func ProcessWorkqueue(bunDB *bun.DB, workqueue workqueue.RateLimitingInterface)
- func RegisterEventHandlers(resourceTypes []string, informerFactory informers.SharedInformerFactory, ...)
- func SetupEventHandlerFuncs(workqueue workqueue.RateLimitingInterface) cache.ResourceEventHandlerFuncs
- type Allocatable
- type Capacity
- type Event
- type EventType
- type NodeConditions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateClientSet ¶
func CreateClientSet(kubeconfigPath string) *kubernetes.Clientset
CreateClientSet to interact with kubernetes api server.
func ProcessContainer ¶
Process all contenders from one Pod.
func ProcessNode ¶
func ProcessPersistentVolume ¶
ProcessPersistentVolume Handling event of PersistentVolumeClaim and insert the PV into the database with all available information.
func ProcessPersistentVolumeClaim ¶
ProcessPersistentVolumeClaim Handling event of PersistentVolumeClaim and insert the PVC into the database with all available information.
func ProcessPod ¶
func ProcessService ¶
func ProcessWorkqueue ¶
func ProcessWorkqueue(bunDB *bun.DB, workqueue workqueue.RateLimitingInterface)
ProcessWorkqueue is the logic for one workqueue handler.
func RegisterEventHandlers ¶
func RegisterEventHandlers(resourceTypes []string, informerFactory informers.SharedInformerFactory, funcs cache.ResourceEventHandlerFuncs, )
RegisterEventHandlers for configured resource types in case they are implemented.
func SetupEventHandlerFuncs ¶
func SetupEventHandlerFuncs(workqueue workqueue.RateLimitingInterface) cache.ResourceEventHandlerFuncs
SetupEventHandlerFuncs setups and returns a new event handler funcs.
Source Files