Merge pull request #21325 from caesarxuchao/coding-conventions

Auto commit by PR queue bot
This commit is contained in:
k8s-merge-robot 2016-02-16 13:00:13 -08:00
commit 8081956be3
30 changed files with 105 additions and 105 deletions

View File

@ -40,7 +40,7 @@ import (
"k8s.io/kubernetes/pkg/client/chaosclient" "k8s.io/kubernetes/pkg/client/chaosclient"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
client "k8s.io/kubernetes/pkg/client/unversioned" client "k8s.io/kubernetes/pkg/client/unversioned"
clientauth "k8s.io/kubernetes/pkg/client/unversioned/auth" clientauth "k8s.io/kubernetes/pkg/client/unversioned/auth"
"k8s.io/kubernetes/pkg/client/unversioned/clientcmd" "k8s.io/kubernetes/pkg/client/unversioned/clientcmd"
@ -586,7 +586,7 @@ func RunKubelet(kcfg *KubeletConfig) error {
eventBroadcaster.StartLogging(glog.V(3).Infof) eventBroadcaster.StartLogging(glog.V(3).Infof)
if kcfg.EventClient != nil { if kcfg.EventClient != nil {
glog.V(4).Infof("Sending events to api server.") glog.V(4).Infof("Sending events to api server.")
eventBroadcaster.StartRecordingToSink(&unversioned_core.EventSinkImpl{kcfg.EventClient.Events("")}) eventBroadcaster.StartRecordingToSink(&unversionedcore.EventSinkImpl{kcfg.EventClient.Events("")})
} else { } else {
glog.Warning("No api server defined - no events will be sent to API server.") glog.Warning("No api server defined - no events will be sent to API server.")
} }

View File

@ -59,9 +59,9 @@ func (g *genClientset) Imports(c *generator.Context) (imports []string) {
group := normalization.Group(gv.Group) group := normalization.Group(gv.Group)
version := normalization.Version(gv.Version) version := normalization.Version(gv.Version)
typedClientPath := filepath.Join(g.typedClientPath, group, version) typedClientPath := filepath.Join(g.typedClientPath, group, version)
imports = append(imports, fmt.Sprintf("%s_%s \"%s\"", group, version, typedClientPath)) imports = append(imports, fmt.Sprintf("%s%s \"%s\"", version, group, typedClientPath))
fakeTypedClientPath := filepath.Join(typedClientPath, "fake") fakeTypedClientPath := filepath.Join(typedClientPath, "fake")
imports = append(imports, fmt.Sprintf("%s_%s_fake \"%s\"", group, version, fakeTypedClientPath)) imports = append(imports, fmt.Sprintf("fake%s%s \"%s\"", version, group, fakeTypedClientPath))
} }
return return
} }
@ -79,7 +79,7 @@ func (g *genClientset) GenerateType(c *generator.Context, t *types.Type, w io.Wr
for _, gv := range g.groupVersions { for _, gv := range g.groupVersions {
group := normalization.Group(gv.Group) group := normalization.Group(gv.Group)
version := normalization.Version(gv.Version) version := normalization.Version(gv.Version)
allGroups = append(allGroups, arg{namer.IC(group), group + "_" + version}) allGroups = append(allGroups, arg{namer.IC(group), version + group})
} }
for _, g := range allGroups { for _, g := range allGroups {
@ -92,6 +92,6 @@ func (g *genClientset) GenerateType(c *generator.Context, t *types.Type, w io.Wr
var clientsetInterfaceImplTemplate = ` var clientsetInterfaceImplTemplate = `
// $.Group$ retrieves the $.Group$Client // $.Group$ retrieves the $.Group$Client
func (c *Clientset) $.Group$() $.PackageName$.$.Group$Interface { func (c *Clientset) $.Group$() $.PackageName$.$.Group$Interface {
return &$.PackageName$_fake.Fake$.Group${&c.Fake} return &fake$.PackageName$.Fake$.Group${&c.Fake}
} }
` `

View File

@ -59,7 +59,7 @@ func (g *genClientset) Imports(c *generator.Context) (imports []string) {
group := normalization.Group(gv.Group) group := normalization.Group(gv.Group)
version := normalization.Version(gv.Version) version := normalization.Version(gv.Version)
typedClientPath := filepath.Join(g.typedClientPath, group, version) typedClientPath := filepath.Join(g.typedClientPath, group, version)
imports = append(imports, fmt.Sprintf("%s_%s \"%s\"", group, version, typedClientPath)) imports = append(imports, fmt.Sprintf("%s%s \"%s\"", version, group, typedClientPath))
imports = append(imports, "github.com/golang/glog") imports = append(imports, "github.com/golang/glog")
} }
return return
@ -80,7 +80,7 @@ func (g *genClientset) GenerateType(c *generator.Context, t *types.Type, w io.Wr
for _, gv := range g.groupVersions { for _, gv := range g.groupVersions {
group := normalization.Group(gv.Group) group := normalization.Group(gv.Group)
version := normalization.Version(gv.Version) version := normalization.Version(gv.Version)
allGroups = append(allGroups, arg{namer.IC(group), group + "_" + version}) allGroups = append(allGroups, arg{namer.IC(group), version + group})
} }
m := map[string]interface{}{ m := map[string]interface{}{

View File

@ -18,24 +18,24 @@ package test_internalclientset
import ( import (
"github.com/golang/glog" "github.com/golang/glog"
testgroup_unversioned "k8s.io/kubernetes/cmd/libs/go2idl/client-gen/testoutput/testgroup/unversioned" unversionedtestgroup "k8s.io/kubernetes/cmd/libs/go2idl/client-gen/testoutput/testgroup/unversioned"
unversioned "k8s.io/kubernetes/pkg/client/unversioned" unversioned "k8s.io/kubernetes/pkg/client/unversioned"
) )
type Interface interface { type Interface interface {
Discovery() unversioned.DiscoveryInterface Discovery() unversioned.DiscoveryInterface
Testgroup() testgroup_unversioned.TestgroupInterface Testgroup() unversionedtestgroup.TestgroupInterface
} }
// Clientset contains the clients for groups. Each group has exactly one // Clientset contains the clients for groups. Each group has exactly one
// version included in a Clientset. // version included in a Clientset.
type Clientset struct { type Clientset struct {
*unversioned.DiscoveryClient *unversioned.DiscoveryClient
*testgroup_unversioned.TestgroupClient *unversionedtestgroup.TestgroupClient
} }
// Testgroup retrieves the TestgroupClient // Testgroup retrieves the TestgroupClient
func (c *Clientset) Testgroup() testgroup_unversioned.TestgroupInterface { func (c *Clientset) Testgroup() unversionedtestgroup.TestgroupInterface {
return c.TestgroupClient return c.TestgroupClient
} }
@ -48,7 +48,7 @@ func (c *Clientset) Discovery() unversioned.DiscoveryInterface {
func NewForConfig(c *unversioned.Config) (*Clientset, error) { func NewForConfig(c *unversioned.Config) (*Clientset, error) {
var clientset Clientset var clientset Clientset
var err error var err error
clientset.TestgroupClient, err = testgroup_unversioned.NewForConfig(c) clientset.TestgroupClient, err = unversionedtestgroup.NewForConfig(c)
if err != nil { if err != nil {
return &clientset, err return &clientset, err
} }
@ -64,7 +64,7 @@ func NewForConfig(c *unversioned.Config) (*Clientset, error) {
// panics if there is an error in the config. // panics if there is an error in the config.
func NewForConfigOrDie(c *unversioned.Config) *Clientset { func NewForConfigOrDie(c *unversioned.Config) *Clientset {
var clientset Clientset var clientset Clientset
clientset.TestgroupClient = testgroup_unversioned.NewForConfigOrDie(c) clientset.TestgroupClient = unversionedtestgroup.NewForConfigOrDie(c)
clientset.DiscoveryClient = unversioned.NewDiscoveryClientForConfigOrDie(c) clientset.DiscoveryClient = unversioned.NewDiscoveryClientForConfigOrDie(c)
return &clientset return &clientset
@ -73,7 +73,7 @@ func NewForConfigOrDie(c *unversioned.Config) *Clientset {
// New creates a new Clientset for the given RESTClient. // New creates a new Clientset for the given RESTClient.
func New(c *unversioned.RESTClient) *Clientset { func New(c *unversioned.RESTClient) *Clientset {
var clientset Clientset var clientset Clientset
clientset.TestgroupClient = testgroup_unversioned.New(c) clientset.TestgroupClient = unversionedtestgroup.New(c)
clientset.DiscoveryClient = unversioned.NewDiscoveryClient(c) clientset.DiscoveryClient = unversioned.NewDiscoveryClient(c)
return &clientset return &clientset

View File

@ -19,7 +19,7 @@ package executor
import ( import (
"k8s.io/kubernetes/contrib/mesos/pkg/node" "k8s.io/kubernetes/contrib/mesos/pkg/node"
"k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api"
core_unversioned "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
) )
type kubeAPI interface { type kubeAPI interface {
@ -33,7 +33,7 @@ type nodeAPI interface {
// clientAPIWrapper implements kubeAPI and node API, which serve to isolate external dependencies // clientAPIWrapper implements kubeAPI and node API, which serve to isolate external dependencies
// such that they're easier to mock in unit test. // such that they're easier to mock in unit test.
type clientAPIWrapper struct { type clientAPIWrapper struct {
client core_unversioned.CoreInterface client unversionedcore.CoreInterface
} }
func (cw *clientAPIWrapper) killPod(ns, name string) error { func (cw *clientAPIWrapper) killPod(ns, name string) error {

View File

@ -23,7 +23,7 @@ import (
"strings" "strings"
"time" "time"
core_unversioned "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
log "github.com/golang/glog" log "github.com/golang/glog"
mesos "github.com/mesos/mesos-go/mesosproto" mesos "github.com/mesos/mesos-go/mesosproto"
@ -42,7 +42,7 @@ const (
// Create creates a new node api object with the given hostname, // Create creates a new node api object with the given hostname,
// slave attribute labels and annotations // slave attribute labels and annotations
func Create( func Create(
client core_unversioned.NodesGetter, client unversionedcore.NodesGetter,
hostName string, hostName string,
slaveAttrLabels, slaveAttrLabels,
annotations map[string]string, annotations map[string]string,
@ -88,7 +88,7 @@ func Create(
// The updated node merges the given slave attribute labels // The updated node merges the given slave attribute labels
// and annotations with the found api object. // and annotations with the found api object.
func Update( func Update(
client core_unversioned.NodesGetter, client unversionedcore.NodesGetter,
hostname string, hostname string,
slaveAttrLabels, slaveAttrLabels,
annotations map[string]string, annotations map[string]string,
@ -123,7 +123,7 @@ func Update(
// CreateOrUpdate creates a node api object or updates an existing one // CreateOrUpdate creates a node api object or updates an existing one
func CreateOrUpdate( func CreateOrUpdate(
client core_unversioned.NodesGetter, client unversionedcore.NodesGetter,
hostname string, hostname string,
slaveAttrLabels, slaveAttrLabels,
annotations map[string]string, annotations map[string]string,

View File

@ -73,7 +73,7 @@ import (
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
client "k8s.io/kubernetes/pkg/client/unversioned" client "k8s.io/kubernetes/pkg/client/unversioned"
"k8s.io/kubernetes/pkg/client/unversioned/clientcmd" "k8s.io/kubernetes/pkg/client/unversioned/clientcmd"
cloud "k8s.io/kubernetes/pkg/cloudprovider/providers/mesos" cloud "k8s.io/kubernetes/pkg/cloudprovider/providers/mesos"
@ -795,7 +795,7 @@ func (s *SchedulerServer) bootstrap(hks hyperkube.Interface, sc *schedcfg.Config
broadcaster := record.NewBroadcaster() broadcaster := record.NewBroadcaster()
recorder := broadcaster.NewRecorder(api.EventSource{Component: api.DefaultSchedulerName}) recorder := broadcaster.NewRecorder(api.EventSource{Component: api.DefaultSchedulerName})
broadcaster.StartLogging(log.Infof) broadcaster.StartLogging(log.Infof)
broadcaster.StartRecordingToSink(&unversioned_core.EventSinkImpl{eventsClient.Events("")}) broadcaster.StartRecordingToSink(&unversionedcore.EventSinkImpl{eventsClient.Events("")})
lw := cache.NewListWatchFromClient(s.client.CoreClient, "pods", api.NamespaceAll, fields.Everything()) lw := cache.NewListWatchFromClient(s.client.CoreClient, "pods", api.NamespaceAll, fields.Everything())

View File

@ -18,32 +18,32 @@ package internalclientset
import ( import (
"github.com/golang/glog" "github.com/golang/glog"
core_unversioned "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
extensions_unversioned "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned" unversionedextensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned"
unversioned "k8s.io/kubernetes/pkg/client/unversioned" unversioned "k8s.io/kubernetes/pkg/client/unversioned"
) )
type Interface interface { type Interface interface {
Discovery() unversioned.DiscoveryInterface Discovery() unversioned.DiscoveryInterface
Core() core_unversioned.CoreInterface Core() unversionedcore.CoreInterface
Extensions() extensions_unversioned.ExtensionsInterface Extensions() unversionedextensions.ExtensionsInterface
} }
// Clientset contains the clients for groups. Each group has exactly one // Clientset contains the clients for groups. Each group has exactly one
// version included in a Clientset. // version included in a Clientset.
type Clientset struct { type Clientset struct {
*unversioned.DiscoveryClient *unversioned.DiscoveryClient
*core_unversioned.CoreClient *unversionedcore.CoreClient
*extensions_unversioned.ExtensionsClient *unversionedextensions.ExtensionsClient
} }
// Core retrieves the CoreClient // Core retrieves the CoreClient
func (c *Clientset) Core() core_unversioned.CoreInterface { func (c *Clientset) Core() unversionedcore.CoreInterface {
return c.CoreClient return c.CoreClient
} }
// Extensions retrieves the ExtensionsClient // Extensions retrieves the ExtensionsClient
func (c *Clientset) Extensions() extensions_unversioned.ExtensionsInterface { func (c *Clientset) Extensions() unversionedextensions.ExtensionsInterface {
return c.ExtensionsClient return c.ExtensionsClient
} }
@ -56,11 +56,11 @@ func (c *Clientset) Discovery() unversioned.DiscoveryInterface {
func NewForConfig(c *unversioned.Config) (*Clientset, error) { func NewForConfig(c *unversioned.Config) (*Clientset, error) {
var clientset Clientset var clientset Clientset
var err error var err error
clientset.CoreClient, err = core_unversioned.NewForConfig(c) clientset.CoreClient, err = unversionedcore.NewForConfig(c)
if err != nil { if err != nil {
return &clientset, err return &clientset, err
} }
clientset.ExtensionsClient, err = extensions_unversioned.NewForConfig(c) clientset.ExtensionsClient, err = unversionedextensions.NewForConfig(c)
if err != nil { if err != nil {
return &clientset, err return &clientset, err
} }
@ -76,8 +76,8 @@ func NewForConfig(c *unversioned.Config) (*Clientset, error) {
// panics if there is an error in the config. // panics if there is an error in the config.
func NewForConfigOrDie(c *unversioned.Config) *Clientset { func NewForConfigOrDie(c *unversioned.Config) *Clientset {
var clientset Clientset var clientset Clientset
clientset.CoreClient = core_unversioned.NewForConfigOrDie(c) clientset.CoreClient = unversionedcore.NewForConfigOrDie(c)
clientset.ExtensionsClient = extensions_unversioned.NewForConfigOrDie(c) clientset.ExtensionsClient = unversionedextensions.NewForConfigOrDie(c)
clientset.DiscoveryClient = unversioned.NewDiscoveryClientForConfigOrDie(c) clientset.DiscoveryClient = unversioned.NewDiscoveryClientForConfigOrDie(c)
return &clientset return &clientset
@ -86,8 +86,8 @@ func NewForConfigOrDie(c *unversioned.Config) *Clientset {
// New creates a new Clientset for the given RESTClient. // New creates a new Clientset for the given RESTClient.
func New(c *unversioned.RESTClient) *Clientset { func New(c *unversioned.RESTClient) *Clientset {
var clientset Clientset var clientset Clientset
clientset.CoreClient = core_unversioned.New(c) clientset.CoreClient = unversionedcore.New(c)
clientset.ExtensionsClient = extensions_unversioned.New(c) clientset.ExtensionsClient = unversionedextensions.New(c)
clientset.DiscoveryClient = unversioned.NewDiscoveryClient(c) clientset.DiscoveryClient = unversioned.NewDiscoveryClient(c)
return &clientset return &clientset

View File

@ -17,8 +17,8 @@ limitations under the License.
package internalclientset package internalclientset
import ( import (
core_unversioned "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
extensions_unversioned "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned" unversionedextensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned"
"k8s.io/kubernetes/pkg/client/unversioned" "k8s.io/kubernetes/pkg/client/unversioned"
) )
@ -28,14 +28,14 @@ import (
func FromUnversionedClient(c *unversioned.Client) *Clientset { func FromUnversionedClient(c *unversioned.Client) *Clientset {
var clientset Clientset var clientset Clientset
if c != nil { if c != nil {
clientset.CoreClient = core_unversioned.New(c.RESTClient) clientset.CoreClient = unversionedcore.New(c.RESTClient)
} else { } else {
clientset.CoreClient = core_unversioned.New(nil) clientset.CoreClient = unversionedcore.New(nil)
} }
if c != nil && c.ExtensionsClient != nil { if c != nil && c.ExtensionsClient != nil {
clientset.ExtensionsClient = extensions_unversioned.New(c.ExtensionsClient.RESTClient) clientset.ExtensionsClient = unversionedextensions.New(c.ExtensionsClient.RESTClient)
} else { } else {
clientset.ExtensionsClient = extensions_unversioned.New(nil) clientset.ExtensionsClient = unversionedextensions.New(nil)
} }
return &clientset return &clientset

View File

@ -18,32 +18,32 @@ package release_1_2
import ( import (
"github.com/golang/glog" "github.com/golang/glog"
core_v1 "k8s.io/kubernetes/pkg/client/typed/generated/core/v1" v1core "k8s.io/kubernetes/pkg/client/typed/generated/core/v1"
extensions_v1beta1 "k8s.io/kubernetes/pkg/client/typed/generated/extensions/v1beta1" v1beta1extensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/v1beta1"
unversioned "k8s.io/kubernetes/pkg/client/unversioned" unversioned "k8s.io/kubernetes/pkg/client/unversioned"
) )
type Interface interface { type Interface interface {
Discovery() unversioned.DiscoveryInterface Discovery() unversioned.DiscoveryInterface
Core() core_v1.CoreInterface Core() v1core.CoreInterface
Extensions() extensions_v1beta1.ExtensionsInterface Extensions() v1beta1extensions.ExtensionsInterface
} }
// Clientset contains the clients for groups. Each group has exactly one // Clientset contains the clients for groups. Each group has exactly one
// version included in a Clientset. // version included in a Clientset.
type Clientset struct { type Clientset struct {
*unversioned.DiscoveryClient *unversioned.DiscoveryClient
*core_v1.CoreClient *v1core.CoreClient
*extensions_v1beta1.ExtensionsClient *v1beta1extensions.ExtensionsClient
} }
// Core retrieves the CoreClient // Core retrieves the CoreClient
func (c *Clientset) Core() core_v1.CoreInterface { func (c *Clientset) Core() v1core.CoreInterface {
return c.CoreClient return c.CoreClient
} }
// Extensions retrieves the ExtensionsClient // Extensions retrieves the ExtensionsClient
func (c *Clientset) Extensions() extensions_v1beta1.ExtensionsInterface { func (c *Clientset) Extensions() v1beta1extensions.ExtensionsInterface {
return c.ExtensionsClient return c.ExtensionsClient
} }
@ -56,11 +56,11 @@ func (c *Clientset) Discovery() unversioned.DiscoveryInterface {
func NewForConfig(c *unversioned.Config) (*Clientset, error) { func NewForConfig(c *unversioned.Config) (*Clientset, error) {
var clientset Clientset var clientset Clientset
var err error var err error
clientset.CoreClient, err = core_v1.NewForConfig(c) clientset.CoreClient, err = v1core.NewForConfig(c)
if err != nil { if err != nil {
return &clientset, err return &clientset, err
} }
clientset.ExtensionsClient, err = extensions_v1beta1.NewForConfig(c) clientset.ExtensionsClient, err = v1beta1extensions.NewForConfig(c)
if err != nil { if err != nil {
return &clientset, err return &clientset, err
} }
@ -76,8 +76,8 @@ func NewForConfig(c *unversioned.Config) (*Clientset, error) {
// panics if there is an error in the config. // panics if there is an error in the config.
func NewForConfigOrDie(c *unversioned.Config) *Clientset { func NewForConfigOrDie(c *unversioned.Config) *Clientset {
var clientset Clientset var clientset Clientset
clientset.CoreClient = core_v1.NewForConfigOrDie(c) clientset.CoreClient = v1core.NewForConfigOrDie(c)
clientset.ExtensionsClient = extensions_v1beta1.NewForConfigOrDie(c) clientset.ExtensionsClient = v1beta1extensions.NewForConfigOrDie(c)
clientset.DiscoveryClient = unversioned.NewDiscoveryClientForConfigOrDie(c) clientset.DiscoveryClient = unversioned.NewDiscoveryClientForConfigOrDie(c)
return &clientset return &clientset
@ -86,8 +86,8 @@ func NewForConfigOrDie(c *unversioned.Config) *Clientset {
// New creates a new Clientset for the given RESTClient. // New creates a new Clientset for the given RESTClient.
func New(c *unversioned.RESTClient) *Clientset { func New(c *unversioned.RESTClient) *Clientset {
var clientset Clientset var clientset Clientset
clientset.CoreClient = core_v1.New(c) clientset.CoreClient = v1core.New(c)
clientset.ExtensionsClient = extensions_v1beta1.New(c) clientset.ExtensionsClient = v1beta1extensions.New(c)
clientset.DiscoveryClient = unversioned.NewDiscoveryClient(c) clientset.DiscoveryClient = unversioned.NewDiscoveryClient(c)
return &clientset return &clientset

View File

@ -17,8 +17,8 @@ limitations under the License.
package release_1_2 package release_1_2
import ( import (
core_v1 "k8s.io/kubernetes/pkg/client/typed/generated/core/v1" v1core "k8s.io/kubernetes/pkg/client/typed/generated/core/v1"
extensions_v1beta1 "k8s.io/kubernetes/pkg/client/typed/generated/extensions/v1beta1" v1beta1extensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/v1beta1"
"k8s.io/kubernetes/pkg/client/unversioned" "k8s.io/kubernetes/pkg/client/unversioned"
) )
@ -28,14 +28,14 @@ import (
func FromUnversionedClient(c *unversioned.Client) *Clientset { func FromUnversionedClient(c *unversioned.Client) *Clientset {
var clientset Clientset var clientset Clientset
if c != nil { if c != nil {
clientset.CoreClient = core_v1.New(c.RESTClient) clientset.CoreClient = v1core.New(c.RESTClient)
} else { } else {
clientset.CoreClient = core_v1.New(nil) clientset.CoreClient = v1core.New(nil)
} }
if c != nil && c.ExtensionsClient != nil { if c != nil && c.ExtensionsClient != nil {
clientset.ExtensionsClient = extensions_v1beta1.New(c.ExtensionsClient.RESTClient) clientset.ExtensionsClient = v1beta1extensions.New(c.ExtensionsClient.RESTClient)
} else { } else {
clientset.ExtensionsClient = extensions_v1beta1.New(nil) clientset.ExtensionsClient = v1beta1extensions.New(nil)
} }
return &clientset return &clientset

View File

@ -17,18 +17,18 @@ limitations under the License.
package fake package fake
import ( import (
core_unversioned "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
core_unversioned_fake "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned/fake" fakeunversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned/fake"
extensions_unversioned "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned" unversionedextensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned"
extensions_unversioned_fake "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned/fake" fakeunversionedextensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned/fake"
) )
// Core retrieves the CoreClient // Core retrieves the CoreClient
func (c *Clientset) Core() core_unversioned.CoreInterface { func (c *Clientset) Core() unversionedcore.CoreInterface {
return &core_unversioned_fake.FakeCore{&c.Fake} return &fakeunversionedcore.FakeCore{&c.Fake}
} }
// Extensions retrieves the ExtensionsClient // Extensions retrieves the ExtensionsClient
func (c *Clientset) Extensions() extensions_unversioned.ExtensionsInterface { func (c *Clientset) Extensions() unversionedextensions.ExtensionsInterface {
return &extensions_unversioned_fake.FakeExtensions{&c.Fake} return &fakeunversionedextensions.FakeExtensions{&c.Fake}
} }

View File

@ -30,8 +30,8 @@ import (
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
unversioned_extensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned" unversionedextensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned"
"k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller"
"k8s.io/kubernetes/pkg/controller/framework" "k8s.io/kubernetes/pkg/controller/framework"
"k8s.io/kubernetes/pkg/labels" "k8s.io/kubernetes/pkg/labels"
@ -99,7 +99,7 @@ func NewDaemonSetsController(kubeClient clientset.Interface, resyncPeriod contro
eventBroadcaster := record.NewBroadcaster() eventBroadcaster := record.NewBroadcaster()
eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartLogging(glog.Infof)
// TODO: remove the wrapper when every clients have moved to use the clientset. // TODO: remove the wrapper when every clients have moved to use the clientset.
eventBroadcaster.StartRecordingToSink(&unversioned_core.EventSinkImpl{kubeClient.Core().Events("")}) eventBroadcaster.StartRecordingToSink(&unversionedcore.EventSinkImpl{kubeClient.Core().Events("")})
dsc := &DaemonSetsController{ dsc := &DaemonSetsController{
kubeClient: kubeClient, kubeClient: kubeClient,
@ -467,7 +467,7 @@ func (dsc *DaemonSetsController) manage(ds *extensions.DaemonSet) {
deleteWait.Wait() deleteWait.Wait()
} }
func storeDaemonSetStatus(dsClient unversioned_extensions.DaemonSetInterface, ds *extensions.DaemonSet, desiredNumberScheduled, currentNumberScheduled, numberMisscheduled int) error { func storeDaemonSetStatus(dsClient unversionedextensions.DaemonSetInterface, ds *extensions.DaemonSet, desiredNumberScheduled, currentNumberScheduled, numberMisscheduled int) error {
if ds.Status.DesiredNumberScheduled == desiredNumberScheduled && ds.Status.CurrentNumberScheduled == currentNumberScheduled && ds.Status.NumberMisscheduled == numberMisscheduled { if ds.Status.DesiredNumberScheduled == desiredNumberScheduled && ds.Status.CurrentNumberScheduled == currentNumberScheduled && ds.Status.NumberMisscheduled == numberMisscheduled {
return nil return nil
} }

View File

@ -30,7 +30,7 @@ import (
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
"k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller"
"k8s.io/kubernetes/pkg/controller/framework" "k8s.io/kubernetes/pkg/controller/framework"
"k8s.io/kubernetes/pkg/kubectl" "k8s.io/kubernetes/pkg/kubectl"
@ -101,7 +101,7 @@ func NewDeploymentController(client clientset.Interface, resyncPeriod controller
eventBroadcaster := record.NewBroadcaster() eventBroadcaster := record.NewBroadcaster()
eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartLogging(glog.Infof)
// TODO: remove the wrapper when every clients have moved to use the clientset. // TODO: remove the wrapper when every clients have moved to use the clientset.
eventBroadcaster.StartRecordingToSink(&unversioned_core.EventSinkImpl{client.Core().Events("")}) eventBroadcaster.StartRecordingToSink(&unversionedcore.EventSinkImpl{client.Core().Events("")})
dc := &DeploymentController{ dc := &DeploymentController{
client: client, client: client,

View File

@ -29,7 +29,7 @@ import (
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
"k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller"
"k8s.io/kubernetes/pkg/controller/framework" "k8s.io/kubernetes/pkg/controller/framework"
replicationcontroller "k8s.io/kubernetes/pkg/controller/replication" replicationcontroller "k8s.io/kubernetes/pkg/controller/replication"
@ -74,7 +74,7 @@ func NewJobController(kubeClient clientset.Interface, resyncPeriod controller.Re
eventBroadcaster := record.NewBroadcaster() eventBroadcaster := record.NewBroadcaster()
eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartLogging(glog.Infof)
// TODO: remove the wrapper when every clients have moved to use the clientset. // TODO: remove the wrapper when every clients have moved to use the clientset.
eventBroadcaster.StartRecordingToSink(&unversioned_core.EventSinkImpl{kubeClient.Core().Events("")}) eventBroadcaster.StartRecordingToSink(&unversionedcore.EventSinkImpl{kubeClient.Core().Events("")})
jm := &JobController{ jm := &JobController{
kubeClient: kubeClient, kubeClient: kubeClient,

View File

@ -23,7 +23,7 @@ import (
"k8s.io/kubernetes/pkg/api/errors" "k8s.io/kubernetes/pkg/api/errors"
"k8s.io/kubernetes/pkg/api/unversioned" "k8s.io/kubernetes/pkg/api/unversioned"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
extensions_unversioned "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned" unversionedextensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned"
"k8s.io/kubernetes/pkg/util/sets" "k8s.io/kubernetes/pkg/util/sets"
"github.com/golang/glog" "github.com/golang/glog"
@ -333,27 +333,27 @@ func deletePersistentVolumeClaims(kubeClient clientset.Interface, ns string) err
return kubeClient.Core().PersistentVolumeClaims(ns).DeleteCollection(nil, api.ListOptions{}) return kubeClient.Core().PersistentVolumeClaims(ns).DeleteCollection(nil, api.ListOptions{})
} }
func deleteHorizontalPodAutoscalers(expClient extensions_unversioned.ExtensionsInterface, ns string) error { func deleteHorizontalPodAutoscalers(expClient unversionedextensions.ExtensionsInterface, ns string) error {
return expClient.HorizontalPodAutoscalers(ns).DeleteCollection(nil, api.ListOptions{}) return expClient.HorizontalPodAutoscalers(ns).DeleteCollection(nil, api.ListOptions{})
} }
func deleteDaemonSets(expClient extensions_unversioned.ExtensionsInterface, ns string) error { func deleteDaemonSets(expClient unversionedextensions.ExtensionsInterface, ns string) error {
return expClient.DaemonSets(ns).DeleteCollection(nil, api.ListOptions{}) return expClient.DaemonSets(ns).DeleteCollection(nil, api.ListOptions{})
} }
func deleteJobs(expClient extensions_unversioned.ExtensionsInterface, ns string) error { func deleteJobs(expClient unversionedextensions.ExtensionsInterface, ns string) error {
return expClient.Jobs(ns).DeleteCollection(nil, api.ListOptions{}) return expClient.Jobs(ns).DeleteCollection(nil, api.ListOptions{})
} }
func deleteDeployments(expClient extensions_unversioned.ExtensionsInterface, ns string) error { func deleteDeployments(expClient unversionedextensions.ExtensionsInterface, ns string) error {
return expClient.Deployments(ns).DeleteCollection(nil, api.ListOptions{}) return expClient.Deployments(ns).DeleteCollection(nil, api.ListOptions{})
} }
func deleteReplicaSets(expClient extensions_unversioned.ExtensionsInterface, ns string) error { func deleteReplicaSets(expClient unversionedextensions.ExtensionsInterface, ns string) error {
return expClient.ReplicaSets(ns).DeleteCollection(nil, api.ListOptions{}) return expClient.ReplicaSets(ns).DeleteCollection(nil, api.ListOptions{})
} }
func deleteIngress(expClient extensions_unversioned.ExtensionsInterface, ns string) error { func deleteIngress(expClient unversionedextensions.ExtensionsInterface, ns string) error {
return expClient.Ingresses(ns).DeleteCollection(nil, api.ListOptions{}) return expClient.Ingresses(ns).DeleteCollection(nil, api.ListOptions{})
} }

View File

@ -30,7 +30,7 @@ import (
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
client "k8s.io/kubernetes/pkg/client/unversioned" client "k8s.io/kubernetes/pkg/client/unversioned"
"k8s.io/kubernetes/pkg/cloudprovider" "k8s.io/kubernetes/pkg/cloudprovider"
"k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller"
@ -139,7 +139,7 @@ func NewNodeController(
eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartLogging(glog.Infof)
if kubeClient != nil { if kubeClient != nil {
glog.Infof("Sending events to api server.") glog.Infof("Sending events to api server.")
eventBroadcaster.StartRecordingToSink(&unversioned_core.EventSinkImpl{kubeClient.Core().Events("")}) eventBroadcaster.StartRecordingToSink(&unversionedcore.EventSinkImpl{kubeClient.Core().Events("")})
} else { } else {
glog.Infof("No api server defined - no events will be sent to API server.") glog.Infof("No api server defined - no events will be sent to API server.")
} }

View File

@ -29,7 +29,7 @@ import (
"k8s.io/kubernetes/pkg/apis/extensions" "k8s.io/kubernetes/pkg/apis/extensions"
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
"k8s.io/kubernetes/pkg/client/testing/fake" "k8s.io/kubernetes/pkg/client/testing/fake"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
"k8s.io/kubernetes/pkg/util" "k8s.io/kubernetes/pkg/util"
"k8s.io/kubernetes/pkg/watch" "k8s.io/kubernetes/pkg/watch"
) )
@ -63,15 +63,15 @@ type FakeNodeHandler struct {
} }
type FakeLegacyHandler struct { type FakeLegacyHandler struct {
unversioned_core.CoreInterface unversionedcore.CoreInterface
n *FakeNodeHandler n *FakeNodeHandler
} }
func (c *FakeNodeHandler) Core() unversioned_core.CoreInterface { func (c *FakeNodeHandler) Core() unversionedcore.CoreInterface {
return &FakeLegacyHandler{c.Clientset.Core(), c} return &FakeLegacyHandler{c.Clientset.Core(), c}
} }
func (m *FakeLegacyHandler) Nodes() unversioned_core.NodeInterface { func (m *FakeLegacyHandler) Nodes() unversionedcore.NodeInterface {
return m.n return m.n
} }

View File

@ -28,8 +28,8 @@ import (
"k8s.io/kubernetes/pkg/api/unversioned" "k8s.io/kubernetes/pkg/api/unversioned"
"k8s.io/kubernetes/pkg/apis/extensions" "k8s.io/kubernetes/pkg/apis/extensions"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
unversioned_extensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned" unversionedextensions "k8s.io/kubernetes/pkg/client/typed/generated/extensions/unversioned"
"k8s.io/kubernetes/pkg/controller/podautoscaler/metrics" "k8s.io/kubernetes/pkg/controller/podautoscaler/metrics"
"k8s.io/kubernetes/pkg/util/wait" "k8s.io/kubernetes/pkg/util/wait"
) )
@ -44,8 +44,8 @@ const (
) )
type HorizontalController struct { type HorizontalController struct {
scaleNamespacer unversioned_extensions.ScalesGetter scaleNamespacer unversionedextensions.ScalesGetter
hpaNamespacer unversioned_extensions.HorizontalPodAutoscalersGetter hpaNamespacer unversionedextensions.HorizontalPodAutoscalersGetter
metricsClient metrics.MetricsClient metricsClient metrics.MetricsClient
eventRecorder record.EventRecorder eventRecorder record.EventRecorder
@ -54,7 +54,7 @@ type HorizontalController struct {
var downscaleForbiddenWindow = 5 * time.Minute var downscaleForbiddenWindow = 5 * time.Minute
var upscaleForbiddenWindow = 3 * time.Minute var upscaleForbiddenWindow = 3 * time.Minute
func NewHorizontalController(evtNamespacer unversioned_core.EventsGetter, scaleNamespacer unversioned_extensions.ScalesGetter, hpaNamespacer unversioned_extensions.HorizontalPodAutoscalersGetter, metricsClient metrics.MetricsClient) *HorizontalController { func NewHorizontalController(evtNamespacer unversionedcore.EventsGetter, scaleNamespacer unversionedextensions.ScalesGetter, hpaNamespacer unversionedextensions.HorizontalPodAutoscalersGetter, metricsClient metrics.MetricsClient) *HorizontalController {
broadcaster := record.NewBroadcaster() broadcaster := record.NewBroadcaster()
broadcaster.StartRecordingToSink(evtNamespacer.Events("")) broadcaster.StartRecordingToSink(evtNamespacer.Events(""))
recorder := broadcaster.NewRecorder(api.EventSource{Component: "horizontal-pod-autoscaler"}) recorder := broadcaster.NewRecorder(api.EventSource{Component: "horizontal-pod-autoscaler"})

View File

@ -31,7 +31,7 @@ import (
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
"k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller"
"k8s.io/kubernetes/pkg/controller/framework" "k8s.io/kubernetes/pkg/controller/framework"
"k8s.io/kubernetes/pkg/runtime" "k8s.io/kubernetes/pkg/runtime"
@ -94,7 +94,7 @@ type ReplicaSetController struct {
func NewReplicaSetController(kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc, burstReplicas int) *ReplicaSetController { func NewReplicaSetController(kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc, burstReplicas int) *ReplicaSetController {
eventBroadcaster := record.NewBroadcaster() eventBroadcaster := record.NewBroadcaster()
eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartLogging(glog.Infof)
eventBroadcaster.StartRecordingToSink(&unversioned_core.EventSinkImpl{kubeClient.Core().Events("")}) eventBroadcaster.StartRecordingToSink(&unversionedcore.EventSinkImpl{kubeClient.Core().Events("")})
rsc := &ReplicaSetController{ rsc := &ReplicaSetController{
kubeClient: kubeClient, kubeClient: kubeClient,

View File

@ -29,7 +29,7 @@ import (
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
"k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller"
"k8s.io/kubernetes/pkg/controller/framework" "k8s.io/kubernetes/pkg/controller/framework"
"k8s.io/kubernetes/pkg/labels" "k8s.io/kubernetes/pkg/labels"
@ -95,7 +95,7 @@ type ReplicationManager struct {
func NewReplicationManager(kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc, burstReplicas int) *ReplicationManager { func NewReplicationManager(kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc, burstReplicas int) *ReplicationManager {
eventBroadcaster := record.NewBroadcaster() eventBroadcaster := record.NewBroadcaster()
eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartLogging(glog.Infof)
eventBroadcaster.StartRecordingToSink(&unversioned_core.EventSinkImpl{kubeClient.Core().Events("")}) eventBroadcaster.StartRecordingToSink(&unversionedcore.EventSinkImpl{kubeClient.Core().Events("")})
rm := &ReplicationManager{ rm := &ReplicationManager{
kubeClient: kubeClient, kubeClient: kubeClient,

View File

@ -21,11 +21,11 @@ package replication
import ( import (
"github.com/golang/glog" "github.com/golang/glog"
"k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
) )
// updateReplicaCount attempts to update the Status.Replicas of the given controller, with a single GET/PUT retry. // updateReplicaCount attempts to update the Status.Replicas of the given controller, with a single GET/PUT retry.
func updateReplicaCount(rcClient unversioned_core.ReplicationControllerInterface, controller api.ReplicationController, numReplicas int) (updateErr error) { func updateReplicaCount(rcClient unversionedcore.ReplicationControllerInterface, controller api.ReplicationController, numReplicas int) (updateErr error) {
// This is the steady state. It happens when the rc doesn't have any expectations, since // This is the steady state. It happens when the rc doesn't have any expectations, since
// we do a periodic relist every 30s. If the generations differ but the replicas are // we do a periodic relist every 30s. If the generations differ but the replicas are
// the same, a caller might've resized to the same replica count. // the same, a caller might've resized to the same replica count.

View File

@ -29,7 +29,7 @@ import (
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
"k8s.io/kubernetes/pkg/client/record" "k8s.io/kubernetes/pkg/client/record"
unversioned_core "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned" unversionedcore "k8s.io/kubernetes/pkg/client/typed/generated/core/unversioned"
"k8s.io/kubernetes/pkg/cloudprovider" "k8s.io/kubernetes/pkg/cloudprovider"
"k8s.io/kubernetes/pkg/fields" "k8s.io/kubernetes/pkg/fields"
"k8s.io/kubernetes/pkg/types" "k8s.io/kubernetes/pkg/types"
@ -82,7 +82,7 @@ type ServiceController struct {
// (like load balancers) in sync with the registry. // (like load balancers) in sync with the registry.
func New(cloud cloudprovider.Interface, kubeClient clientset.Interface, clusterName string) *ServiceController { func New(cloud cloudprovider.Interface, kubeClient clientset.Interface, clusterName string) *ServiceController {
broadcaster := record.NewBroadcaster() broadcaster := record.NewBroadcaster()
broadcaster.StartRecordingToSink(&unversioned_core.EventSinkImpl{kubeClient.Core().Events("")}) broadcaster.StartRecordingToSink(&unversionedcore.EventSinkImpl{kubeClient.Core().Events("")})
recorder := broadcaster.NewRecorder(api.EventSource{Component: "service-controller"}) recorder := broadcaster.NewRecorder(api.EventSource{Component: "service-controller"})
return &ServiceController{ return &ServiceController{