Documentation
¶
Index ¶
- Constants
- Variables
- func PvcHandlePodDeletion(podDetails *groups_v1.PodDetails)
- func Start(conf *Config)
- func UpdatePodVolumeClaims(pod api_v1.Pod, podDetails groups_v1.PodDetails, eventTime meta_v1.Time) groups_v1.PodDetails
- type Config
- type Controller
- type Event
- type Payload
- type PayloadWrapper
- type Resource
Constants ¶
const ( Create = "create" Delete = "delete" Update = "update" )
These are the event types supported for controllers
Variables ¶
var Kubeclient *kubernetes.Clientset
Kubeclient is kubernetes Clientset
Functions ¶
func PvcHandlePodDeletion ¶
func PvcHandlePodDeletion(podDetails *groups_v1.PodDetails)
PvcHandlePodDeletion action to be taken when pod is deleted. Unbound all bounded pvcs.
func Start ¶
func Start(conf *Config)
Start runs the controller goroutine. nolint: gocyclo, interfacer
func UpdatePodVolumeClaims ¶
func UpdatePodVolumeClaims(pod api_v1.Pod, podDetails groups_v1.PodDetails, eventTime meta_v1.Time) groups_v1.PodDetails
UpdatePodVolumeClaims activePodVolumeClaims: current active(bounded) podVolumeClaims for the pod. old podVolumeClaims: Claims(map) for the pod before this update. compares old podVolumeClaims and activePodVolumeClaims. This function hadles 3 cases. Case Unbound pvc:
Present as 'bounded' in old podVolumeClaims. Not present in activePodVolumeClaims.
Case New PVC:
Not present in old podVolumeClaims. Present in activePodVolumeClaims.
Case Bound an unbounded pvc:
Present as 'unbounded' in old podVolumeClaims. Present in activePodVolumeClaims.
Types ¶
type Config ¶
type Config struct {
KubeConfig *rest.Config
Resource Resource `json:"resource"`
RingBuffer *buffering.RingBuffer
Groupcrdclient *groups_v1.GroupClient
Subscriberclient *subscriber_v1.SubscriberClient
Kubeclient *kubernetes.Clientset
}
Config contains config objects
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller holds Kubernetes controller components
func (*Controller) HasSynced ¶
func (c *Controller) HasSynced() bool
HasSynced is required for the cache.Controller interface.
func (*Controller) LastSyncResourceVersion ¶
func (c *Controller) LastSyncResourceVersion() string
LastSyncResourceVersion is required for the cache.Controller interface.
func (*Controller) Run ¶
func (c *Controller) Run(stopCh <-chan struct{})
Run initiates the controller
type Event ¶
type Event struct {
// contains filtered or unexported fields
}
Event indicate the informerEvent
type Payload ¶
type Payload struct {
Key string `json:"key"`
EventType string `json:"eventType"`
ResourceType string `json:"resourceType"`
CloudType string `json:"cloudType"`
Data string `json:"data"`
CaptureTime meta_v1.Time
}
Payload holds payload information
type PayloadWrapper ¶
type PayloadWrapper struct {
OrgID string `json:"orgId"`
Cluster string `json:"cluster"`
Data []*interface{} `json:"data"`
}
PayloadWrapper holds additional information about payload
type Resource ¶
type Resource struct {
Pod bool `json:"po"`
Node bool `json:"node"`
PersistentVolume bool `json:"pv"`
PersistentVolumeClaim bool `json:"pvc"`
Service bool `json:"service"`
ReplicaSet bool `json:"replicaset"`
StatefulSet bool `json:"statefulset"`
Deployment bool `json:"deployment"`
Job bool `json:"job"`
DaemonSet bool `json:"daemonset"`
Namespace bool `json:"namespace"`
Group bool `json:"groups.vmware.purser.com"`
Subscriber bool `json:"subscribers.vmware.purser.com"`
}
Resource contains resource configuration
Source Files
Directories