rancher/types
1
0
Fork 0
mirror of https://github.com/rancher/types.git synced 2025-08-31 21:00:16 +00:00
Code Issues Releases Wiki Activity

Update generated code

Browse Source
This commit is contained in:
Darren Shepherd
2018-01-15 22:16:06 -07:00
parent 5d96eb4d2e
commit 3f2de9094b
61 changed files with 355 additions and 355 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
apis/project.cattle.io/v3/zz_generated_basic_auth_controller.go
View File

@@ -45,7 +45,7 @@ type BasicAuthLister interface {
type BasicAuthController interface {
Informer() cache.SharedIndexInformer
Lister() BasicAuthLister
AddHandler(handler BasicAuthHandlerFunc)
AddHandler(name string, handler BasicAuthHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type BasicAuthInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() BasicAuthController
AddSyncHandler(sync BasicAuthHandlerFunc)
AddHandler(name string, sync BasicAuthHandlerFunc)
AddLifecycle(name string, lifecycle BasicAuthLifecycle)
}
@@ -108,8 +108,8 @@ func (c *basicAuthController) Lister() BasicAuthLister {
}
}
func (c *basicAuthController) AddHandler(handler BasicAuthHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *basicAuthController) AddHandler(name string, handler BasicAuthHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *basicAuthClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, lis
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *basicAuthClient) AddSyncHandler(sync BasicAuthHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *basicAuthClient) AddHandler(name string, sync BasicAuthHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *basicAuthClient) AddLifecycle(name string, lifecycle BasicAuthLifecycle) {
sync := NewBasicAuthLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_certificate_controller.go
View File

@@ -45,7 +45,7 @@ type CertificateLister interface {
type CertificateController interface {
Informer() cache.SharedIndexInformer
Lister() CertificateLister
AddHandler(handler CertificateHandlerFunc)
AddHandler(name string, handler CertificateHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type CertificateInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() CertificateController
AddSyncHandler(sync CertificateHandlerFunc)
AddHandler(name string, sync CertificateHandlerFunc)
AddLifecycle(name string, lifecycle CertificateLifecycle)
}
@@ -108,8 +108,8 @@ func (c *certificateController) Lister() CertificateLister {
}
}
func (c *certificateController) AddHandler(handler CertificateHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *certificateController) AddHandler(name string, handler CertificateHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *certificateClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, l
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *certificateClient) AddSyncHandler(sync CertificateHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *certificateClient) AddHandler(name string, sync CertificateHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *certificateClient) AddLifecycle(name string, lifecycle CertificateLifecycle) {
sync := NewCertificateLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_docker_credential_controller.go
View File

@@ -45,7 +45,7 @@ type DockerCredentialLister interface {
type DockerCredentialController interface {
Informer() cache.SharedIndexInformer
Lister() DockerCredentialLister
AddHandler(handler DockerCredentialHandlerFunc)
AddHandler(name string, handler DockerCredentialHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type DockerCredentialInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() DockerCredentialController
AddSyncHandler(sync DockerCredentialHandlerFunc)
AddHandler(name string, sync DockerCredentialHandlerFunc)
AddLifecycle(name string, lifecycle DockerCredentialLifecycle)
}
@@ -108,8 +108,8 @@ func (c *dockerCredentialController) Lister() DockerCredentialLister {
}
}
func (c *dockerCredentialController) AddHandler(handler DockerCredentialHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *dockerCredentialController) AddHandler(name string, handler DockerCredentialHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *dockerCredentialClient) DeleteCollection(deleteOpts *metav1.DeleteOptio
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *dockerCredentialClient) AddSyncHandler(sync DockerCredentialHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *dockerCredentialClient) AddHandler(name string, sync DockerCredentialHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *dockerCredentialClient) AddLifecycle(name string, lifecycle DockerCredentialLifecycle) {
sync := NewDockerCredentialLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_namespaced_basic_auth_controller.go
View File

@@ -45,7 +45,7 @@ type NamespacedBasicAuthLister interface {
type NamespacedBasicAuthController interface {
Informer() cache.SharedIndexInformer
Lister() NamespacedBasicAuthLister
AddHandler(handler NamespacedBasicAuthHandlerFunc)
AddHandler(name string, handler NamespacedBasicAuthHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type NamespacedBasicAuthInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() NamespacedBasicAuthController
AddSyncHandler(sync NamespacedBasicAuthHandlerFunc)
AddHandler(name string, sync NamespacedBasicAuthHandlerFunc)
AddLifecycle(name string, lifecycle NamespacedBasicAuthLifecycle)
}
@@ -108,8 +108,8 @@ func (c *namespacedBasicAuthController) Lister() NamespacedBasicAuthLister {
}
}
func (c *namespacedBasicAuthController) AddHandler(handler NamespacedBasicAuthHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *namespacedBasicAuthController) AddHandler(name string, handler NamespacedBasicAuthHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *namespacedBasicAuthClient) DeleteCollection(deleteOpts *metav1.DeleteOp
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *namespacedBasicAuthClient) AddSyncHandler(sync NamespacedBasicAuthHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *namespacedBasicAuthClient) AddHandler(name string, sync NamespacedBasicAuthHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *namespacedBasicAuthClient) AddLifecycle(name string, lifecycle NamespacedBasicAuthLifecycle) {
sync := NewNamespacedBasicAuthLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_namespaced_certificate_controller.go
View File

@@ -45,7 +45,7 @@ type NamespacedCertificateLister interface {
type NamespacedCertificateController interface {
Informer() cache.SharedIndexInformer
Lister() NamespacedCertificateLister
AddHandler(handler NamespacedCertificateHandlerFunc)
AddHandler(name string, handler NamespacedCertificateHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type NamespacedCertificateInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() NamespacedCertificateController
AddSyncHandler(sync NamespacedCertificateHandlerFunc)
AddHandler(name string, sync NamespacedCertificateHandlerFunc)
AddLifecycle(name string, lifecycle NamespacedCertificateLifecycle)
}
@@ -108,8 +108,8 @@ func (c *namespacedCertificateController) Lister() NamespacedCertificateLister {
}
}
func (c *namespacedCertificateController) AddHandler(handler NamespacedCertificateHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *namespacedCertificateController) AddHandler(name string, handler NamespacedCertificateHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *namespacedCertificateClient) DeleteCollection(deleteOpts *metav1.Delete
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *namespacedCertificateClient) AddSyncHandler(sync NamespacedCertificateHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *namespacedCertificateClient) AddHandler(name string, sync NamespacedCertificateHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *namespacedCertificateClient) AddLifecycle(name string, lifecycle NamespacedCertificateLifecycle) {
sync := NewNamespacedCertificateLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_namespaced_docker_credential_controller.go
View File

@@ -45,7 +45,7 @@ type NamespacedDockerCredentialLister interface {
type NamespacedDockerCredentialController interface {
Informer() cache.SharedIndexInformer
Lister() NamespacedDockerCredentialLister
AddHandler(handler NamespacedDockerCredentialHandlerFunc)
AddHandler(name string, handler NamespacedDockerCredentialHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type NamespacedDockerCredentialInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() NamespacedDockerCredentialController
AddSyncHandler(sync NamespacedDockerCredentialHandlerFunc)
AddHandler(name string, sync NamespacedDockerCredentialHandlerFunc)
AddLifecycle(name string, lifecycle NamespacedDockerCredentialLifecycle)
}
@@ -108,8 +108,8 @@ func (c *namespacedDockerCredentialController) Lister() NamespacedDockerCredenti
}
}
func (c *namespacedDockerCredentialController) AddHandler(handler NamespacedDockerCredentialHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *namespacedDockerCredentialController) AddHandler(name string, handler NamespacedDockerCredentialHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *namespacedDockerCredentialClient) DeleteCollection(deleteOpts *metav1.D
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *namespacedDockerCredentialClient) AddSyncHandler(sync NamespacedDockerCredentialHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *namespacedDockerCredentialClient) AddHandler(name string, sync NamespacedDockerCredentialHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *namespacedDockerCredentialClient) AddLifecycle(name string, lifecycle NamespacedDockerCredentialLifecycle) {
sync := NewNamespacedDockerCredentialLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_namespaced_service_account_token_controller.go
View File

@@ -45,7 +45,7 @@ type NamespacedServiceAccountTokenLister interface {
type NamespacedServiceAccountTokenController interface {
Informer() cache.SharedIndexInformer
Lister() NamespacedServiceAccountTokenLister
AddHandler(handler NamespacedServiceAccountTokenHandlerFunc)
AddHandler(name string, handler NamespacedServiceAccountTokenHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type NamespacedServiceAccountTokenInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() NamespacedServiceAccountTokenController
AddSyncHandler(sync NamespacedServiceAccountTokenHandlerFunc)
AddHandler(name string, sync NamespacedServiceAccountTokenHandlerFunc)
AddLifecycle(name string, lifecycle NamespacedServiceAccountTokenLifecycle)
}
@@ -108,8 +108,8 @@ func (c *namespacedServiceAccountTokenController) Lister() NamespacedServiceAcco
}
}
func (c *namespacedServiceAccountTokenController) AddHandler(handler NamespacedServiceAccountTokenHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *namespacedServiceAccountTokenController) AddHandler(name string, handler NamespacedServiceAccountTokenHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *namespacedServiceAccountTokenClient) DeleteCollection(deleteOpts *metav
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *namespacedServiceAccountTokenClient) AddSyncHandler(sync NamespacedServiceAccountTokenHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *namespacedServiceAccountTokenClient) AddHandler(name string, sync NamespacedServiceAccountTokenHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *namespacedServiceAccountTokenClient) AddLifecycle(name string, lifecycle NamespacedServiceAccountTokenLifecycle) {
sync := NewNamespacedServiceAccountTokenLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_namespaced_ssh_auth_controller.go
View File

@@ -45,7 +45,7 @@ type NamespacedSSHAuthLister interface {
type NamespacedSSHAuthController interface {
Informer() cache.SharedIndexInformer
Lister() NamespacedSSHAuthLister
AddHandler(handler NamespacedSSHAuthHandlerFunc)
AddHandler(name string, handler NamespacedSSHAuthHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type NamespacedSSHAuthInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() NamespacedSSHAuthController
AddSyncHandler(sync NamespacedSSHAuthHandlerFunc)
AddHandler(name string, sync NamespacedSSHAuthHandlerFunc)
AddLifecycle(name string, lifecycle NamespacedSSHAuthLifecycle)
}
@@ -108,8 +108,8 @@ func (c *namespacedSshAuthController) Lister() NamespacedSSHAuthLister {
}
}
func (c *namespacedSshAuthController) AddHandler(handler NamespacedSSHAuthHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *namespacedSshAuthController) AddHandler(name string, handler NamespacedSSHAuthHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *namespacedSshAuthClient) DeleteCollection(deleteOpts *metav1.DeleteOpti
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *namespacedSshAuthClient) AddSyncHandler(sync NamespacedSSHAuthHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *namespacedSshAuthClient) AddHandler(name string, sync NamespacedSSHAuthHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *namespacedSshAuthClient) AddLifecycle(name string, lifecycle NamespacedSSHAuthLifecycle) {
sync := NewNamespacedSSHAuthLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_service_account_token_controller.go
View File

@@ -45,7 +45,7 @@ type ServiceAccountTokenLister interface {
type ServiceAccountTokenController interface {
Informer() cache.SharedIndexInformer
Lister() ServiceAccountTokenLister
AddHandler(handler ServiceAccountTokenHandlerFunc)
AddHandler(name string, handler ServiceAccountTokenHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type ServiceAccountTokenInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() ServiceAccountTokenController
AddSyncHandler(sync ServiceAccountTokenHandlerFunc)
AddHandler(name string, sync ServiceAccountTokenHandlerFunc)
AddLifecycle(name string, lifecycle ServiceAccountTokenLifecycle)
}
@@ -108,8 +108,8 @@ func (c *serviceAccountTokenController) Lister() ServiceAccountTokenLister {
}
}
func (c *serviceAccountTokenController) AddHandler(handler ServiceAccountTokenHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *serviceAccountTokenController) AddHandler(name string, handler ServiceAccountTokenHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *serviceAccountTokenClient) DeleteCollection(deleteOpts *metav1.DeleteOp
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *serviceAccountTokenClient) AddSyncHandler(sync ServiceAccountTokenHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *serviceAccountTokenClient) AddHandler(name string, sync ServiceAccountTokenHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *serviceAccountTokenClient) AddLifecycle(name string, lifecycle ServiceAccountTokenLifecycle) {
sync := NewServiceAccountTokenLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_ssh_auth_controller.go
View File

@@ -45,7 +45,7 @@ type SSHAuthLister interface {
type SSHAuthController interface {
Informer() cache.SharedIndexInformer
Lister() SSHAuthLister
AddHandler(handler SSHAuthHandlerFunc)
AddHandler(name string, handler SSHAuthHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type SSHAuthInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() SSHAuthController
AddSyncHandler(sync SSHAuthHandlerFunc)
AddHandler(name string, sync SSHAuthHandlerFunc)
AddLifecycle(name string, lifecycle SSHAuthLifecycle)
}
@@ -108,8 +108,8 @@ func (c *sshAuthController) Lister() SSHAuthLister {
}
}
func (c *sshAuthController) AddHandler(handler SSHAuthHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *sshAuthController) AddHandler(name string, handler SSHAuthHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *sshAuthClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, listO
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *sshAuthClient) AddSyncHandler(sync SSHAuthHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *sshAuthClient) AddHandler(name string, sync SSHAuthHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *sshAuthClient) AddLifecycle(name string, lifecycle SSHAuthLifecycle) {
sync := NewSSHAuthLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}

14
apis/project.cattle.io/v3/zz_generated_workload_controller.go
View File

@@ -45,7 +45,7 @@ type WorkloadLister interface {
type WorkloadController interface {
Informer() cache.SharedIndexInformer
Lister() WorkloadLister
AddHandler(handler WorkloadHandlerFunc)
AddHandler(name string, handler WorkloadHandlerFunc)
Enqueue(namespace, name string)
Sync(ctx context.Context) error
Start(ctx context.Context, threadiness int) error
@@ -63,7 +63,7 @@ type WorkloadInterface interface {
Watch(opts metav1.ListOptions) (watch.Interface, error)
DeleteCollection(deleteOpts *metav1.DeleteOptions, listOpts metav1.ListOptions) error
Controller() WorkloadController
AddSyncHandler(sync WorkloadHandlerFunc)
AddHandler(name string, sync WorkloadHandlerFunc)
AddLifecycle(name string, lifecycle WorkloadLifecycle)
}
@@ -108,8 +108,8 @@ func (c *workloadController) Lister() WorkloadLister {
}
}
func (c *workloadController) AddHandler(handler WorkloadHandlerFunc) {
c.GenericController.AddHandler(func(key string) error {
func (c *workloadController) AddHandler(name string, handler WorkloadHandlerFunc) {
c.GenericController.AddHandler(name, func(key string) error {
obj, exists, err := c.Informer().GetStore().GetByKey(key)
if err != nil {
return err
@@ -212,11 +212,11 @@ func (s *workloadClient) DeleteCollection(deleteOpts *metav1.DeleteOptions, list
return s.objectClient.DeleteCollection(deleteOpts, listOpts)
}
func (s *workloadClient) AddSyncHandler(sync WorkloadHandlerFunc) {
s.Controller().AddHandler(sync)
func (s *workloadClient) AddHandler(name string, sync WorkloadHandlerFunc) {
s.Controller().AddHandler(name, sync)
}
func (s *workloadClient) AddLifecycle(name string, lifecycle WorkloadLifecycle) {
sync := NewWorkloadLifecycleAdapter(name, s, lifecycle)
s.AddSyncHandler(sync)
s.AddHandler(name, sync)
}