github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-10 13:42:02 +00:00
Code Issues Projects Releases Wiki Activity

fed: s/NewclusterController/NewClusterController

Browse Source
This commit is contained in:
Maru Newby
2017-02-24 21:21:03 -08:00
parent 30e010da3b
commit 522aeb7f36
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
federation/cmd/federation-controller-manager/app/controllermanager.go
View File

@@ -166,7 +166,7 @@ func StartControllers(s *options.CMServer, restClientCfg *restclient.Config) err
glog.Fatalf("Could not find resources from API Server: %v", err) glog.Fatalf("Could not find resources from API Server: %v", err)
} }
go clustercontroller.NewclusterController(ccClientset, s.ClusterMonitorPeriod.Duration).Run() go clustercontroller.NewClusterController(ccClientset, s.ClusterMonitorPeriod.Duration).Run()
if controllerEnabled(s.Controllers, serverResources, servicecontroller.ControllerName, servicecontroller.RequiredResources, true) { if controllerEnabled(s.Controllers, serverResources, servicecontroller.ControllerName, servicecontroller.RequiredResources, true) {
dns, err := dnsprovider.InitDnsProvider(s.DnsProvider, s.DnsConfigFile) dns, err := dnsprovider.InitDnsProvider(s.DnsProvider, s.DnsConfigFile)

4
federation/pkg/federation-controller/cluster/clustercontroller.go
View File

@@ -53,8 +53,8 @@ type ClusterController struct {
clusterStore clustercache.StoreToClusterLister clusterStore clustercache.StoreToClusterLister
} }
// NewclusterController returns a new cluster controller // NewClusterController returns a new cluster controller
func NewclusterController(federationClient federationclientset.Interface, clusterMonitorPeriod time.Duration) *ClusterController { func NewClusterController(federationClient federationclientset.Interface, clusterMonitorPeriod time.Duration) *ClusterController {
cc := &ClusterController{ cc := &ClusterController{
knownClusterSet: make(sets.String), knownClusterSet: make(sets.String),
federationClient: federationClient, federationClient: federationClient,

2
federation/pkg/federation-controller/cluster/clustercontroller_test.go
View File

@@ -132,7 +132,7 @@ func TestUpdateClusterStatusOK(t *testing.T) {
} }
} }
manager := NewclusterController(federationClientSet, 5) manager := NewClusterController(federationClientSet, 5)
err = manager.UpdateClusterStatus() err = manager.UpdateClusterStatus()
if err != nil { if err != nil {
t.Errorf("Failed to Update Cluster Status: %v", err) t.Errorf("Failed to Update Cluster Status: %v", err)