Ajay Tripathy 4 лет назад
Родитель
Сommit
ada6ffed45
2 измененных файлов с 15 добавлено и 0 удалено
  1. 9 0
      pkg/clustercache/clustercache.go
  2. 6 0
      pkg/clustercache/clusterimporter.go

+ 9 - 0
pkg/clustercache/clustercache.go

@@ -67,6 +67,9 @@ type ClusterCache interface {
 	// GetAllPodDisruptionBudgets returns all cached pod disruption budgets
 	// GetAllPodDisruptionBudgets returns all cached pod disruption budgets
 	GetAllPodDisruptionBudgets() []*v1beta1.PodDisruptionBudget
 	GetAllPodDisruptionBudgets() []*v1beta1.PodDisruptionBudget
 
 
+	// GetAllReplicationControllers returns all cached replication controllers
+	GetAllReplicationControllers() []*v1.ReplicationController
+
 	// SetConfigMapUpdateFunc sets the configmap update function
 	// SetConfigMapUpdateFunc sets the configmap update function
 	SetConfigMapUpdateFunc(func(interface{}))
 	SetConfigMapUpdateFunc(func(interface{}))
 }
 }
@@ -315,6 +318,12 @@ func (kcc *KubernetesClusterCache) GetAllPodDisruptionBudgets() []*v1beta1.PodDi
 	return pdbs
 	return pdbs
 }
 }
 
 
+func (kcc *KubernetesClusterCache) GetAllReplicationControllers() []*v1.ReplicationController {
+	var rcs []*v1.ReplicationController
+	//TODO: Implement
+	return rcs
+}
+
 func (kcc *KubernetesClusterCache) SetConfigMapUpdateFunc(f func(interface{})) {
 func (kcc *KubernetesClusterCache) SetConfigMapUpdateFunc(f func(interface{})) {
 	kcc.kubecostConfigMapWatch.SetUpdateHandler(f)
 	kcc.kubecostConfigMapWatch.SetUpdateHandler(f)
 }
 }

+ 6 - 0
pkg/clustercache/clusterimporter.go

@@ -301,6 +301,12 @@ func (ci *ClusterImporter) GetAllPodDisruptionBudgets() []*v1beta1.PodDisruption
 	return cloneList
 	return cloneList
 }
 }
 
 
+func (ci *ClusterImporter) GetAllReplicationControllers() []*v1.ReplicationController {
+	var rcs []*v1.ReplicationController
+	//TODO: Implement
+	return rcs
+}
+
 // SetConfigMapUpdateFunc sets the configmap update function
 // SetConfigMapUpdateFunc sets the configmap update function
 func (ci *ClusterImporter) SetConfigMapUpdateFunc(_ func(interface{})) {
 func (ci *ClusterImporter) SetConfigMapUpdateFunc(_ func(interface{})) {
 	// TODO: (bolt) This function is still a bit strange to me for the ClusterCache interface.
 	// TODO: (bolt) This function is still a bit strange to me for the ClusterCache interface.