mirror of
https://github.com/rancher/types.git
synced 2025-07-12 04:47:59 +00:00
Merge pull request #611 from ibuildthecloud/master
Change handler return type to runtime.Object
This commit is contained in:
commit
1ec57e5eaa
@ -36,7 +36,7 @@ type DaemonSetList struct {
|
||||
Items []v1beta2.DaemonSet
|
||||
}
|
||||
|
||||
type DaemonSetHandlerFunc func(key string, obj *v1beta2.DaemonSet) (*v1beta2.DaemonSet, error)
|
||||
type DaemonSetHandlerFunc func(key string, obj *v1beta2.DaemonSet) (runtime.Object, error)
|
||||
|
||||
type DaemonSetLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1beta2.DaemonSet, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type DaemonSetLifecycle interface {
|
||||
Create(obj *v1beta2.DaemonSet) (*v1beta2.DaemonSet, error)
|
||||
Remove(obj *v1beta2.DaemonSet) (*v1beta2.DaemonSet, error)
|
||||
Updated(obj *v1beta2.DaemonSet) (*v1beta2.DaemonSet, error)
|
||||
Create(obj *v1beta2.DaemonSet) (runtime.Object, error)
|
||||
Remove(obj *v1beta2.DaemonSet) (runtime.Object, error)
|
||||
Updated(obj *v1beta2.DaemonSet) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type daemonSetLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *daemonSetLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object,
|
||||
func NewDaemonSetLifecycleAdapter(name string, clusterScoped bool, client DaemonSetInterface, l DaemonSetLifecycle) DaemonSetHandlerFunc {
|
||||
adapter := &daemonSetLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1beta2.DaemonSet) (*v1beta2.DaemonSet, error) {
|
||||
return func(key string, obj *v1beta2.DaemonSet) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1beta2.DaemonSet); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type DeploymentList struct {
|
||||
Items []v1beta2.Deployment
|
||||
}
|
||||
|
||||
type DeploymentHandlerFunc func(key string, obj *v1beta2.Deployment) (*v1beta2.Deployment, error)
|
||||
type DeploymentHandlerFunc func(key string, obj *v1beta2.Deployment) (runtime.Object, error)
|
||||
|
||||
type DeploymentLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1beta2.Deployment, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type DeploymentLifecycle interface {
|
||||
Create(obj *v1beta2.Deployment) (*v1beta2.Deployment, error)
|
||||
Remove(obj *v1beta2.Deployment) (*v1beta2.Deployment, error)
|
||||
Updated(obj *v1beta2.Deployment) (*v1beta2.Deployment, error)
|
||||
Create(obj *v1beta2.Deployment) (runtime.Object, error)
|
||||
Remove(obj *v1beta2.Deployment) (runtime.Object, error)
|
||||
Updated(obj *v1beta2.Deployment) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type deploymentLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *deploymentLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object
|
||||
func NewDeploymentLifecycleAdapter(name string, clusterScoped bool, client DeploymentInterface, l DeploymentLifecycle) DeploymentHandlerFunc {
|
||||
adapter := &deploymentLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1beta2.Deployment) (*v1beta2.Deployment, error) {
|
||||
return func(key string, obj *v1beta2.Deployment) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1beta2.Deployment); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type ReplicaSetList struct {
|
||||
Items []v1beta2.ReplicaSet
|
||||
}
|
||||
|
||||
type ReplicaSetHandlerFunc func(key string, obj *v1beta2.ReplicaSet) (*v1beta2.ReplicaSet, error)
|
||||
type ReplicaSetHandlerFunc func(key string, obj *v1beta2.ReplicaSet) (runtime.Object, error)
|
||||
|
||||
type ReplicaSetLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1beta2.ReplicaSet, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type ReplicaSetLifecycle interface {
|
||||
Create(obj *v1beta2.ReplicaSet) (*v1beta2.ReplicaSet, error)
|
||||
Remove(obj *v1beta2.ReplicaSet) (*v1beta2.ReplicaSet, error)
|
||||
Updated(obj *v1beta2.ReplicaSet) (*v1beta2.ReplicaSet, error)
|
||||
Create(obj *v1beta2.ReplicaSet) (runtime.Object, error)
|
||||
Remove(obj *v1beta2.ReplicaSet) (runtime.Object, error)
|
||||
Updated(obj *v1beta2.ReplicaSet) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type replicaSetLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *replicaSetLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object
|
||||
func NewReplicaSetLifecycleAdapter(name string, clusterScoped bool, client ReplicaSetInterface, l ReplicaSetLifecycle) ReplicaSetHandlerFunc {
|
||||
adapter := &replicaSetLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1beta2.ReplicaSet) (*v1beta2.ReplicaSet, error) {
|
||||
return func(key string, obj *v1beta2.ReplicaSet) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1beta2.ReplicaSet); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type StatefulSetList struct {
|
||||
Items []v1beta2.StatefulSet
|
||||
}
|
||||
|
||||
type StatefulSetHandlerFunc func(key string, obj *v1beta2.StatefulSet) (*v1beta2.StatefulSet, error)
|
||||
type StatefulSetHandlerFunc func(key string, obj *v1beta2.StatefulSet) (runtime.Object, error)
|
||||
|
||||
type StatefulSetLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1beta2.StatefulSet, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type StatefulSetLifecycle interface {
|
||||
Create(obj *v1beta2.StatefulSet) (*v1beta2.StatefulSet, error)
|
||||
Remove(obj *v1beta2.StatefulSet) (*v1beta2.StatefulSet, error)
|
||||
Updated(obj *v1beta2.StatefulSet) (*v1beta2.StatefulSet, error)
|
||||
Create(obj *v1beta2.StatefulSet) (runtime.Object, error)
|
||||
Remove(obj *v1beta2.StatefulSet) (runtime.Object, error)
|
||||
Updated(obj *v1beta2.StatefulSet) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type statefulSetLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *statefulSetLifecycleAdapter) Updated(obj runtime.Object) (runtime.Objec
|
||||
func NewStatefulSetLifecycleAdapter(name string, clusterScoped bool, client StatefulSetInterface, l StatefulSetLifecycle) StatefulSetHandlerFunc {
|
||||
adapter := &statefulSetLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1beta2.StatefulSet) (*v1beta2.StatefulSet, error) {
|
||||
return func(key string, obj *v1beta2.StatefulSet) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1beta2.StatefulSet); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type JobList struct {
|
||||
Items []v1.Job
|
||||
}
|
||||
|
||||
type JobHandlerFunc func(key string, obj *v1.Job) (*v1.Job, error)
|
||||
type JobHandlerFunc func(key string, obj *v1.Job) (runtime.Object, error)
|
||||
|
||||
type JobLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.Job, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type JobLifecycle interface {
|
||||
Create(obj *v1.Job) (*v1.Job, error)
|
||||
Remove(obj *v1.Job) (*v1.Job, error)
|
||||
Updated(obj *v1.Job) (*v1.Job, error)
|
||||
Create(obj *v1.Job) (runtime.Object, error)
|
||||
Remove(obj *v1.Job) (runtime.Object, error)
|
||||
Updated(obj *v1.Job) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type jobLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *jobLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, error
|
||||
func NewJobLifecycleAdapter(name string, clusterScoped bool, client JobInterface, l JobLifecycle) JobHandlerFunc {
|
||||
adapter := &jobLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.Job) (*v1.Job, error) {
|
||||
return func(key string, obj *v1.Job) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.Job); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type CronJobList struct {
|
||||
Items []v1beta1.CronJob
|
||||
}
|
||||
|
||||
type CronJobHandlerFunc func(key string, obj *v1beta1.CronJob) (*v1beta1.CronJob, error)
|
||||
type CronJobHandlerFunc func(key string, obj *v1beta1.CronJob) (runtime.Object, error)
|
||||
|
||||
type CronJobLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1beta1.CronJob, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type CronJobLifecycle interface {
|
||||
Create(obj *v1beta1.CronJob) (*v1beta1.CronJob, error)
|
||||
Remove(obj *v1beta1.CronJob) (*v1beta1.CronJob, error)
|
||||
Updated(obj *v1beta1.CronJob) (*v1beta1.CronJob, error)
|
||||
Create(obj *v1beta1.CronJob) (runtime.Object, error)
|
||||
Remove(obj *v1beta1.CronJob) (runtime.Object, error)
|
||||
Updated(obj *v1beta1.CronJob) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type cronJobLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *cronJobLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, e
|
||||
func NewCronJobLifecycleAdapter(name string, clusterScoped bool, client CronJobInterface, l CronJobLifecycle) CronJobHandlerFunc {
|
||||
adapter := &cronJobLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1beta1.CronJob) (*v1beta1.CronJob, error) {
|
||||
return func(key string, obj *v1beta1.CronJob) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1beta1.CronJob); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ComponentStatusList struct {
|
||||
Items []v1.ComponentStatus
|
||||
}
|
||||
|
||||
type ComponentStatusHandlerFunc func(key string, obj *v1.ComponentStatus) (*v1.ComponentStatus, error)
|
||||
type ComponentStatusHandlerFunc func(key string, obj *v1.ComponentStatus) (runtime.Object, error)
|
||||
|
||||
type ComponentStatusLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.ComponentStatus, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type ComponentStatusLifecycle interface {
|
||||
Create(obj *v1.ComponentStatus) (*v1.ComponentStatus, error)
|
||||
Remove(obj *v1.ComponentStatus) (*v1.ComponentStatus, error)
|
||||
Updated(obj *v1.ComponentStatus) (*v1.ComponentStatus, error)
|
||||
Create(obj *v1.ComponentStatus) (runtime.Object, error)
|
||||
Remove(obj *v1.ComponentStatus) (runtime.Object, error)
|
||||
Updated(obj *v1.ComponentStatus) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type componentStatusLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *componentStatusLifecycleAdapter) Updated(obj runtime.Object) (runtime.O
|
||||
func NewComponentStatusLifecycleAdapter(name string, clusterScoped bool, client ComponentStatusInterface, l ComponentStatusLifecycle) ComponentStatusHandlerFunc {
|
||||
adapter := &componentStatusLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.ComponentStatus) (*v1.ComponentStatus, error) {
|
||||
return func(key string, obj *v1.ComponentStatus) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.ComponentStatus); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type ConfigMapList struct {
|
||||
Items []v1.ConfigMap
|
||||
}
|
||||
|
||||
type ConfigMapHandlerFunc func(key string, obj *v1.ConfigMap) (*v1.ConfigMap, error)
|
||||
type ConfigMapHandlerFunc func(key string, obj *v1.ConfigMap) (runtime.Object, error)
|
||||
|
||||
type ConfigMapLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.ConfigMap, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type ConfigMapLifecycle interface {
|
||||
Create(obj *v1.ConfigMap) (*v1.ConfigMap, error)
|
||||
Remove(obj *v1.ConfigMap) (*v1.ConfigMap, error)
|
||||
Updated(obj *v1.ConfigMap) (*v1.ConfigMap, error)
|
||||
Create(obj *v1.ConfigMap) (runtime.Object, error)
|
||||
Remove(obj *v1.ConfigMap) (runtime.Object, error)
|
||||
Updated(obj *v1.ConfigMap) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type configMapLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *configMapLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object,
|
||||
func NewConfigMapLifecycleAdapter(name string, clusterScoped bool, client ConfigMapInterface, l ConfigMapLifecycle) ConfigMapHandlerFunc {
|
||||
adapter := &configMapLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.ConfigMap) (*v1.ConfigMap, error) {
|
||||
return func(key string, obj *v1.ConfigMap) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.ConfigMap); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type EndpointsList struct {
|
||||
Items []v1.Endpoints
|
||||
}
|
||||
|
||||
type EndpointsHandlerFunc func(key string, obj *v1.Endpoints) (*v1.Endpoints, error)
|
||||
type EndpointsHandlerFunc func(key string, obj *v1.Endpoints) (runtime.Object, error)
|
||||
|
||||
type EndpointsLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.Endpoints, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type EndpointsLifecycle interface {
|
||||
Create(obj *v1.Endpoints) (*v1.Endpoints, error)
|
||||
Remove(obj *v1.Endpoints) (*v1.Endpoints, error)
|
||||
Updated(obj *v1.Endpoints) (*v1.Endpoints, error)
|
||||
Create(obj *v1.Endpoints) (runtime.Object, error)
|
||||
Remove(obj *v1.Endpoints) (runtime.Object, error)
|
||||
Updated(obj *v1.Endpoints) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type endpointsLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *endpointsLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object,
|
||||
func NewEndpointsLifecycleAdapter(name string, clusterScoped bool, client EndpointsInterface, l EndpointsLifecycle) EndpointsHandlerFunc {
|
||||
adapter := &endpointsLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.Endpoints) (*v1.Endpoints, error) {
|
||||
return func(key string, obj *v1.Endpoints) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.Endpoints); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type EventList struct {
|
||||
Items []v1.Event
|
||||
}
|
||||
|
||||
type EventHandlerFunc func(key string, obj *v1.Event) (*v1.Event, error)
|
||||
type EventHandlerFunc func(key string, obj *v1.Event) (runtime.Object, error)
|
||||
|
||||
type EventLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.Event, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type EventLifecycle interface {
|
||||
Create(obj *v1.Event) (*v1.Event, error)
|
||||
Remove(obj *v1.Event) (*v1.Event, error)
|
||||
Updated(obj *v1.Event) (*v1.Event, error)
|
||||
Create(obj *v1.Event) (runtime.Object, error)
|
||||
Remove(obj *v1.Event) (runtime.Object, error)
|
||||
Updated(obj *v1.Event) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type eventLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *eventLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, err
|
||||
func NewEventLifecycleAdapter(name string, clusterScoped bool, client EventInterface, l EventLifecycle) EventHandlerFunc {
|
||||
adapter := &eventLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.Event) (*v1.Event, error) {
|
||||
return func(key string, obj *v1.Event) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.Event); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type NamespaceList struct {
|
||||
Items []v1.Namespace
|
||||
}
|
||||
|
||||
type NamespaceHandlerFunc func(key string, obj *v1.Namespace) (*v1.Namespace, error)
|
||||
type NamespaceHandlerFunc func(key string, obj *v1.Namespace) (runtime.Object, error)
|
||||
|
||||
type NamespaceLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.Namespace, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type NamespaceLifecycle interface {
|
||||
Create(obj *v1.Namespace) (*v1.Namespace, error)
|
||||
Remove(obj *v1.Namespace) (*v1.Namespace, error)
|
||||
Updated(obj *v1.Namespace) (*v1.Namespace, error)
|
||||
Create(obj *v1.Namespace) (runtime.Object, error)
|
||||
Remove(obj *v1.Namespace) (runtime.Object, error)
|
||||
Updated(obj *v1.Namespace) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type namespaceLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *namespaceLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object,
|
||||
func NewNamespaceLifecycleAdapter(name string, clusterScoped bool, client NamespaceInterface, l NamespaceLifecycle) NamespaceHandlerFunc {
|
||||
adapter := &namespaceLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.Namespace) (*v1.Namespace, error) {
|
||||
return func(key string, obj *v1.Namespace) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.Namespace); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type NodeList struct {
|
||||
Items []v1.Node
|
||||
}
|
||||
|
||||
type NodeHandlerFunc func(key string, obj *v1.Node) (*v1.Node, error)
|
||||
type NodeHandlerFunc func(key string, obj *v1.Node) (runtime.Object, error)
|
||||
|
||||
type NodeLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.Node, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type NodeLifecycle interface {
|
||||
Create(obj *v1.Node) (*v1.Node, error)
|
||||
Remove(obj *v1.Node) (*v1.Node, error)
|
||||
Updated(obj *v1.Node) (*v1.Node, error)
|
||||
Create(obj *v1.Node) (runtime.Object, error)
|
||||
Remove(obj *v1.Node) (runtime.Object, error)
|
||||
Updated(obj *v1.Node) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type nodeLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *nodeLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, erro
|
||||
func NewNodeLifecycleAdapter(name string, clusterScoped bool, client NodeInterface, l NodeLifecycle) NodeHandlerFunc {
|
||||
adapter := &nodeLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.Node) (*v1.Node, error) {
|
||||
return func(key string, obj *v1.Node) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.Node); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type PersistentVolumeClaimList struct {
|
||||
Items []v1.PersistentVolumeClaim
|
||||
}
|
||||
|
||||
type PersistentVolumeClaimHandlerFunc func(key string, obj *v1.PersistentVolumeClaim) (*v1.PersistentVolumeClaim, error)
|
||||
type PersistentVolumeClaimHandlerFunc func(key string, obj *v1.PersistentVolumeClaim) (runtime.Object, error)
|
||||
|
||||
type PersistentVolumeClaimLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.PersistentVolumeClaim, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type PersistentVolumeClaimLifecycle interface {
|
||||
Create(obj *v1.PersistentVolumeClaim) (*v1.PersistentVolumeClaim, error)
|
||||
Remove(obj *v1.PersistentVolumeClaim) (*v1.PersistentVolumeClaim, error)
|
||||
Updated(obj *v1.PersistentVolumeClaim) (*v1.PersistentVolumeClaim, error)
|
||||
Create(obj *v1.PersistentVolumeClaim) (runtime.Object, error)
|
||||
Remove(obj *v1.PersistentVolumeClaim) (runtime.Object, error)
|
||||
Updated(obj *v1.PersistentVolumeClaim) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type persistentVolumeClaimLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *persistentVolumeClaimLifecycleAdapter) Updated(obj runtime.Object) (run
|
||||
func NewPersistentVolumeClaimLifecycleAdapter(name string, clusterScoped bool, client PersistentVolumeClaimInterface, l PersistentVolumeClaimLifecycle) PersistentVolumeClaimHandlerFunc {
|
||||
adapter := &persistentVolumeClaimLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.PersistentVolumeClaim) (*v1.PersistentVolumeClaim, error) {
|
||||
return func(key string, obj *v1.PersistentVolumeClaim) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.PersistentVolumeClaim); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type PodList struct {
|
||||
Items []v1.Pod
|
||||
}
|
||||
|
||||
type PodHandlerFunc func(key string, obj *v1.Pod) (*v1.Pod, error)
|
||||
type PodHandlerFunc func(key string, obj *v1.Pod) (runtime.Object, error)
|
||||
|
||||
type PodLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.Pod, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type PodLifecycle interface {
|
||||
Create(obj *v1.Pod) (*v1.Pod, error)
|
||||
Remove(obj *v1.Pod) (*v1.Pod, error)
|
||||
Updated(obj *v1.Pod) (*v1.Pod, error)
|
||||
Create(obj *v1.Pod) (runtime.Object, error)
|
||||
Remove(obj *v1.Pod) (runtime.Object, error)
|
||||
Updated(obj *v1.Pod) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type podLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *podLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, error
|
||||
func NewPodLifecycleAdapter(name string, clusterScoped bool, client PodInterface, l PodLifecycle) PodHandlerFunc {
|
||||
adapter := &podLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.Pod) (*v1.Pod, error) {
|
||||
return func(key string, obj *v1.Pod) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.Pod); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type ReplicationControllerList struct {
|
||||
Items []v1.ReplicationController
|
||||
}
|
||||
|
||||
type ReplicationControllerHandlerFunc func(key string, obj *v1.ReplicationController) (*v1.ReplicationController, error)
|
||||
type ReplicationControllerHandlerFunc func(key string, obj *v1.ReplicationController) (runtime.Object, error)
|
||||
|
||||
type ReplicationControllerLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.ReplicationController, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type ReplicationControllerLifecycle interface {
|
||||
Create(obj *v1.ReplicationController) (*v1.ReplicationController, error)
|
||||
Remove(obj *v1.ReplicationController) (*v1.ReplicationController, error)
|
||||
Updated(obj *v1.ReplicationController) (*v1.ReplicationController, error)
|
||||
Create(obj *v1.ReplicationController) (runtime.Object, error)
|
||||
Remove(obj *v1.ReplicationController) (runtime.Object, error)
|
||||
Updated(obj *v1.ReplicationController) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type replicationControllerLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *replicationControllerLifecycleAdapter) Updated(obj runtime.Object) (run
|
||||
func NewReplicationControllerLifecycleAdapter(name string, clusterScoped bool, client ReplicationControllerInterface, l ReplicationControllerLifecycle) ReplicationControllerHandlerFunc {
|
||||
adapter := &replicationControllerLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.ReplicationController) (*v1.ReplicationController, error) {
|
||||
return func(key string, obj *v1.ReplicationController) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.ReplicationController); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type ResourceQuotaList struct {
|
||||
Items []v1.ResourceQuota
|
||||
}
|
||||
|
||||
type ResourceQuotaHandlerFunc func(key string, obj *v1.ResourceQuota) (*v1.ResourceQuota, error)
|
||||
type ResourceQuotaHandlerFunc func(key string, obj *v1.ResourceQuota) (runtime.Object, error)
|
||||
|
||||
type ResourceQuotaLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.ResourceQuota, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type ResourceQuotaLifecycle interface {
|
||||
Create(obj *v1.ResourceQuota) (*v1.ResourceQuota, error)
|
||||
Remove(obj *v1.ResourceQuota) (*v1.ResourceQuota, error)
|
||||
Updated(obj *v1.ResourceQuota) (*v1.ResourceQuota, error)
|
||||
Create(obj *v1.ResourceQuota) (runtime.Object, error)
|
||||
Remove(obj *v1.ResourceQuota) (runtime.Object, error)
|
||||
Updated(obj *v1.ResourceQuota) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type resourceQuotaLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *resourceQuotaLifecycleAdapter) Updated(obj runtime.Object) (runtime.Obj
|
||||
func NewResourceQuotaLifecycleAdapter(name string, clusterScoped bool, client ResourceQuotaInterface, l ResourceQuotaLifecycle) ResourceQuotaHandlerFunc {
|
||||
adapter := &resourceQuotaLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.ResourceQuota) (*v1.ResourceQuota, error) {
|
||||
return func(key string, obj *v1.ResourceQuota) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.ResourceQuota); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type SecretList struct {
|
||||
Items []v1.Secret
|
||||
}
|
||||
|
||||
type SecretHandlerFunc func(key string, obj *v1.Secret) (*v1.Secret, error)
|
||||
type SecretHandlerFunc func(key string, obj *v1.Secret) (runtime.Object, error)
|
||||
|
||||
type SecretLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.Secret, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type SecretLifecycle interface {
|
||||
Create(obj *v1.Secret) (*v1.Secret, error)
|
||||
Remove(obj *v1.Secret) (*v1.Secret, error)
|
||||
Updated(obj *v1.Secret) (*v1.Secret, error)
|
||||
Create(obj *v1.Secret) (runtime.Object, error)
|
||||
Remove(obj *v1.Secret) (runtime.Object, error)
|
||||
Updated(obj *v1.Secret) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type secretLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *secretLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, er
|
||||
func NewSecretLifecycleAdapter(name string, clusterScoped bool, client SecretInterface, l SecretLifecycle) SecretHandlerFunc {
|
||||
adapter := &secretLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.Secret) (*v1.Secret, error) {
|
||||
return func(key string, obj *v1.Secret) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.Secret); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type ServiceAccountList struct {
|
||||
Items []v1.ServiceAccount
|
||||
}
|
||||
|
||||
type ServiceAccountHandlerFunc func(key string, obj *v1.ServiceAccount) (*v1.ServiceAccount, error)
|
||||
type ServiceAccountHandlerFunc func(key string, obj *v1.ServiceAccount) (runtime.Object, error)
|
||||
|
||||
type ServiceAccountLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.ServiceAccount, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type ServiceAccountLifecycle interface {
|
||||
Create(obj *v1.ServiceAccount) (*v1.ServiceAccount, error)
|
||||
Remove(obj *v1.ServiceAccount) (*v1.ServiceAccount, error)
|
||||
Updated(obj *v1.ServiceAccount) (*v1.ServiceAccount, error)
|
||||
Create(obj *v1.ServiceAccount) (runtime.Object, error)
|
||||
Remove(obj *v1.ServiceAccount) (runtime.Object, error)
|
||||
Updated(obj *v1.ServiceAccount) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type serviceAccountLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *serviceAccountLifecycleAdapter) Updated(obj runtime.Object) (runtime.Ob
|
||||
func NewServiceAccountLifecycleAdapter(name string, clusterScoped bool, client ServiceAccountInterface, l ServiceAccountLifecycle) ServiceAccountHandlerFunc {
|
||||
adapter := &serviceAccountLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.ServiceAccount) (*v1.ServiceAccount, error) {
|
||||
return func(key string, obj *v1.ServiceAccount) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.ServiceAccount); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type ServiceList struct {
|
||||
Items []v1.Service
|
||||
}
|
||||
|
||||
type ServiceHandlerFunc func(key string, obj *v1.Service) (*v1.Service, error)
|
||||
type ServiceHandlerFunc func(key string, obj *v1.Service) (runtime.Object, error)
|
||||
|
||||
type ServiceLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1.Service, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type ServiceLifecycle interface {
|
||||
Create(obj *v1.Service) (*v1.Service, error)
|
||||
Remove(obj *v1.Service) (*v1.Service, error)
|
||||
Updated(obj *v1.Service) (*v1.Service, error)
|
||||
Create(obj *v1.Service) (runtime.Object, error)
|
||||
Remove(obj *v1.Service) (runtime.Object, error)
|
||||
Updated(obj *v1.Service) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type serviceLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *serviceLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, e
|
||||
func NewServiceLifecycleAdapter(name string, clusterScoped bool, client ServiceInterface, l ServiceLifecycle) ServiceHandlerFunc {
|
||||
adapter := &serviceLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1.Service) (*v1.Service, error) {
|
||||
return func(key string, obj *v1.Service) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1.Service); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -36,7 +36,7 @@ type IngressList struct {
|
||||
Items []v1beta1.Ingress
|
||||
}
|
||||
|
||||
type IngressHandlerFunc func(key string, obj *v1beta1.Ingress) (*v1beta1.Ingress, error)
|
||||
type IngressHandlerFunc func(key string, obj *v1beta1.Ingress) (runtime.Object, error)
|
||||
|
||||
type IngressLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1beta1.Ingress, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type IngressLifecycle interface {
|
||||
Create(obj *v1beta1.Ingress) (*v1beta1.Ingress, error)
|
||||
Remove(obj *v1beta1.Ingress) (*v1beta1.Ingress, error)
|
||||
Updated(obj *v1beta1.Ingress) (*v1beta1.Ingress, error)
|
||||
Create(obj *v1beta1.Ingress) (runtime.Object, error)
|
||||
Remove(obj *v1beta1.Ingress) (runtime.Object, error)
|
||||
Updated(obj *v1beta1.Ingress) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type ingressLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *ingressLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, e
|
||||
func NewIngressLifecycleAdapter(name string, clusterScoped bool, client IngressInterface, l IngressLifecycle) IngressHandlerFunc {
|
||||
adapter := &ingressLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1beta1.Ingress) (*v1beta1.Ingress, error) {
|
||||
return func(key string, obj *v1beta1.Ingress) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1beta1.Ingress); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type PodSecurityPolicyList struct {
|
||||
Items []v1beta1.PodSecurityPolicy
|
||||
}
|
||||
|
||||
type PodSecurityPolicyHandlerFunc func(key string, obj *v1beta1.PodSecurityPolicy) (*v1beta1.PodSecurityPolicy, error)
|
||||
type PodSecurityPolicyHandlerFunc func(key string, obj *v1beta1.PodSecurityPolicy) (runtime.Object, error)
|
||||
|
||||
type PodSecurityPolicyLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*v1beta1.PodSecurityPolicy, err error)
|
||||
|
@ -7,9 +7,9 @@ import (
|
||||
)
|
||||
|
||||
type PodSecurityPolicyLifecycle interface {
|
||||
Create(obj *v1beta1.PodSecurityPolicy) (*v1beta1.PodSecurityPolicy, error)
|
||||
Remove(obj *v1beta1.PodSecurityPolicy) (*v1beta1.PodSecurityPolicy, error)
|
||||
Updated(obj *v1beta1.PodSecurityPolicy) (*v1beta1.PodSecurityPolicy, error)
|
||||
Create(obj *v1beta1.PodSecurityPolicy) (runtime.Object, error)
|
||||
Remove(obj *v1beta1.PodSecurityPolicy) (runtime.Object, error)
|
||||
Updated(obj *v1beta1.PodSecurityPolicy) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type podSecurityPolicyLifecycleAdapter struct {
|
||||
@ -43,9 +43,9 @@ func (w *podSecurityPolicyLifecycleAdapter) Updated(obj runtime.Object) (runtime
|
||||
func NewPodSecurityPolicyLifecycleAdapter(name string, clusterScoped bool, client PodSecurityPolicyInterface, l PodSecurityPolicyLifecycle) PodSecurityPolicyHandlerFunc {
|
||||
adapter := &podSecurityPolicyLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *v1beta1.PodSecurityPolicy) (*v1beta1.PodSecurityPolicy, error) {
|
||||
return func(key string, obj *v1beta1.PodSecurityPolicy) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*v1beta1.PodSecurityPolicy); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type AuthConfigList struct {
|
||||
Items []AuthConfig
|
||||
}
|
||||
|
||||
type AuthConfigHandlerFunc func(key string, obj *AuthConfig) (*AuthConfig, error)
|
||||
type AuthConfigHandlerFunc func(key string, obj *AuthConfig) (runtime.Object, error)
|
||||
|
||||
type AuthConfigLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*AuthConfig, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type AuthConfigLifecycle interface {
|
||||
Create(obj *AuthConfig) (*AuthConfig, error)
|
||||
Remove(obj *AuthConfig) (*AuthConfig, error)
|
||||
Updated(obj *AuthConfig) (*AuthConfig, error)
|
||||
Create(obj *AuthConfig) (runtime.Object, error)
|
||||
Remove(obj *AuthConfig) (runtime.Object, error)
|
||||
Updated(obj *AuthConfig) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type authConfigLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *authConfigLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object
|
||||
func NewAuthConfigLifecycleAdapter(name string, clusterScoped bool, client AuthConfigInterface, l AuthConfigLifecycle) AuthConfigHandlerFunc {
|
||||
adapter := &authConfigLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *AuthConfig) (*AuthConfig, error) {
|
||||
return func(key string, obj *AuthConfig) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*AuthConfig); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type CatalogList struct {
|
||||
Items []Catalog
|
||||
}
|
||||
|
||||
type CatalogHandlerFunc func(key string, obj *Catalog) (*Catalog, error)
|
||||
type CatalogHandlerFunc func(key string, obj *Catalog) (runtime.Object, error)
|
||||
|
||||
type CatalogLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*Catalog, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type CatalogLifecycle interface {
|
||||
Create(obj *Catalog) (*Catalog, error)
|
||||
Remove(obj *Catalog) (*Catalog, error)
|
||||
Updated(obj *Catalog) (*Catalog, error)
|
||||
Create(obj *Catalog) (runtime.Object, error)
|
||||
Remove(obj *Catalog) (runtime.Object, error)
|
||||
Updated(obj *Catalog) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type catalogLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *catalogLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, e
|
||||
func NewCatalogLifecycleAdapter(name string, clusterScoped bool, client CatalogInterface, l CatalogLifecycle) CatalogHandlerFunc {
|
||||
adapter := &catalogLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *Catalog) (*Catalog, error) {
|
||||
return func(key string, obj *Catalog) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*Catalog); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ClusterAlertList struct {
|
||||
Items []ClusterAlert
|
||||
}
|
||||
|
||||
type ClusterAlertHandlerFunc func(key string, obj *ClusterAlert) (*ClusterAlert, error)
|
||||
type ClusterAlertHandlerFunc func(key string, obj *ClusterAlert) (runtime.Object, error)
|
||||
|
||||
type ClusterAlertLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ClusterAlert, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ClusterAlertLifecycle interface {
|
||||
Create(obj *ClusterAlert) (*ClusterAlert, error)
|
||||
Remove(obj *ClusterAlert) (*ClusterAlert, error)
|
||||
Updated(obj *ClusterAlert) (*ClusterAlert, error)
|
||||
Create(obj *ClusterAlert) (runtime.Object, error)
|
||||
Remove(obj *ClusterAlert) (runtime.Object, error)
|
||||
Updated(obj *ClusterAlert) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type clusterAlertLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *clusterAlertLifecycleAdapter) Updated(obj runtime.Object) (runtime.Obje
|
||||
func NewClusterAlertLifecycleAdapter(name string, clusterScoped bool, client ClusterAlertInterface, l ClusterAlertLifecycle) ClusterAlertHandlerFunc {
|
||||
adapter := &clusterAlertLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ClusterAlert) (*ClusterAlert, error) {
|
||||
return func(key string, obj *ClusterAlert) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ClusterAlert); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ClusterCatalogList struct {
|
||||
Items []ClusterCatalog
|
||||
}
|
||||
|
||||
type ClusterCatalogHandlerFunc func(key string, obj *ClusterCatalog) (*ClusterCatalog, error)
|
||||
type ClusterCatalogHandlerFunc func(key string, obj *ClusterCatalog) (runtime.Object, error)
|
||||
|
||||
type ClusterCatalogLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ClusterCatalog, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ClusterCatalogLifecycle interface {
|
||||
Create(obj *ClusterCatalog) (*ClusterCatalog, error)
|
||||
Remove(obj *ClusterCatalog) (*ClusterCatalog, error)
|
||||
Updated(obj *ClusterCatalog) (*ClusterCatalog, error)
|
||||
Create(obj *ClusterCatalog) (runtime.Object, error)
|
||||
Remove(obj *ClusterCatalog) (runtime.Object, error)
|
||||
Updated(obj *ClusterCatalog) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type clusterCatalogLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *clusterCatalogLifecycleAdapter) Updated(obj runtime.Object) (runtime.Ob
|
||||
func NewClusterCatalogLifecycleAdapter(name string, clusterScoped bool, client ClusterCatalogInterface, l ClusterCatalogLifecycle) ClusterCatalogHandlerFunc {
|
||||
adapter := &clusterCatalogLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ClusterCatalog) (*ClusterCatalog, error) {
|
||||
return func(key string, obj *ClusterCatalog) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ClusterCatalog); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type ClusterList struct {
|
||||
Items []Cluster
|
||||
}
|
||||
|
||||
type ClusterHandlerFunc func(key string, obj *Cluster) (*Cluster, error)
|
||||
type ClusterHandlerFunc func(key string, obj *Cluster) (runtime.Object, error)
|
||||
|
||||
type ClusterLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*Cluster, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ClusterLifecycle interface {
|
||||
Create(obj *Cluster) (*Cluster, error)
|
||||
Remove(obj *Cluster) (*Cluster, error)
|
||||
Updated(obj *Cluster) (*Cluster, error)
|
||||
Create(obj *Cluster) (runtime.Object, error)
|
||||
Remove(obj *Cluster) (runtime.Object, error)
|
||||
Updated(obj *Cluster) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type clusterLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *clusterLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, e
|
||||
func NewClusterLifecycleAdapter(name string, clusterScoped bool, client ClusterInterface, l ClusterLifecycle) ClusterHandlerFunc {
|
||||
adapter := &clusterLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *Cluster) (*Cluster, error) {
|
||||
return func(key string, obj *Cluster) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*Cluster); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ClusterLoggingList struct {
|
||||
Items []ClusterLogging
|
||||
}
|
||||
|
||||
type ClusterLoggingHandlerFunc func(key string, obj *ClusterLogging) (*ClusterLogging, error)
|
||||
type ClusterLoggingHandlerFunc func(key string, obj *ClusterLogging) (runtime.Object, error)
|
||||
|
||||
type ClusterLoggingLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ClusterLogging, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ClusterLoggingLifecycle interface {
|
||||
Create(obj *ClusterLogging) (*ClusterLogging, error)
|
||||
Remove(obj *ClusterLogging) (*ClusterLogging, error)
|
||||
Updated(obj *ClusterLogging) (*ClusterLogging, error)
|
||||
Create(obj *ClusterLogging) (runtime.Object, error)
|
||||
Remove(obj *ClusterLogging) (runtime.Object, error)
|
||||
Updated(obj *ClusterLogging) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type clusterLoggingLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *clusterLoggingLifecycleAdapter) Updated(obj runtime.Object) (runtime.Ob
|
||||
func NewClusterLoggingLifecycleAdapter(name string, clusterScoped bool, client ClusterLoggingInterface, l ClusterLoggingLifecycle) ClusterLoggingHandlerFunc {
|
||||
adapter := &clusterLoggingLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ClusterLogging) (*ClusterLogging, error) {
|
||||
return func(key string, obj *ClusterLogging) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ClusterLogging); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ClusterRegistrationTokenList struct {
|
||||
Items []ClusterRegistrationToken
|
||||
}
|
||||
|
||||
type ClusterRegistrationTokenHandlerFunc func(key string, obj *ClusterRegistrationToken) (*ClusterRegistrationToken, error)
|
||||
type ClusterRegistrationTokenHandlerFunc func(key string, obj *ClusterRegistrationToken) (runtime.Object, error)
|
||||
|
||||
type ClusterRegistrationTokenLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ClusterRegistrationToken, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ClusterRegistrationTokenLifecycle interface {
|
||||
Create(obj *ClusterRegistrationToken) (*ClusterRegistrationToken, error)
|
||||
Remove(obj *ClusterRegistrationToken) (*ClusterRegistrationToken, error)
|
||||
Updated(obj *ClusterRegistrationToken) (*ClusterRegistrationToken, error)
|
||||
Create(obj *ClusterRegistrationToken) (runtime.Object, error)
|
||||
Remove(obj *ClusterRegistrationToken) (runtime.Object, error)
|
||||
Updated(obj *ClusterRegistrationToken) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type clusterRegistrationTokenLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *clusterRegistrationTokenLifecycleAdapter) Updated(obj runtime.Object) (
|
||||
func NewClusterRegistrationTokenLifecycleAdapter(name string, clusterScoped bool, client ClusterRegistrationTokenInterface, l ClusterRegistrationTokenLifecycle) ClusterRegistrationTokenHandlerFunc {
|
||||
adapter := &clusterRegistrationTokenLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ClusterRegistrationToken) (*ClusterRegistrationToken, error) {
|
||||
return func(key string, obj *ClusterRegistrationToken) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ClusterRegistrationToken); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ClusterRoleTemplateBindingList struct {
|
||||
Items []ClusterRoleTemplateBinding
|
||||
}
|
||||
|
||||
type ClusterRoleTemplateBindingHandlerFunc func(key string, obj *ClusterRoleTemplateBinding) (*ClusterRoleTemplateBinding, error)
|
||||
type ClusterRoleTemplateBindingHandlerFunc func(key string, obj *ClusterRoleTemplateBinding) (runtime.Object, error)
|
||||
|
||||
type ClusterRoleTemplateBindingLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ClusterRoleTemplateBinding, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ClusterRoleTemplateBindingLifecycle interface {
|
||||
Create(obj *ClusterRoleTemplateBinding) (*ClusterRoleTemplateBinding, error)
|
||||
Remove(obj *ClusterRoleTemplateBinding) (*ClusterRoleTemplateBinding, error)
|
||||
Updated(obj *ClusterRoleTemplateBinding) (*ClusterRoleTemplateBinding, error)
|
||||
Create(obj *ClusterRoleTemplateBinding) (runtime.Object, error)
|
||||
Remove(obj *ClusterRoleTemplateBinding) (runtime.Object, error)
|
||||
Updated(obj *ClusterRoleTemplateBinding) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type clusterRoleTemplateBindingLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *clusterRoleTemplateBindingLifecycleAdapter) Updated(obj runtime.Object)
|
||||
func NewClusterRoleTemplateBindingLifecycleAdapter(name string, clusterScoped bool, client ClusterRoleTemplateBindingInterface, l ClusterRoleTemplateBindingLifecycle) ClusterRoleTemplateBindingHandlerFunc {
|
||||
adapter := &clusterRoleTemplateBindingLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ClusterRoleTemplateBinding) (*ClusterRoleTemplateBinding, error) {
|
||||
return func(key string, obj *ClusterRoleTemplateBinding) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ClusterRoleTemplateBinding); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type ComposeConfigList struct {
|
||||
Items []ComposeConfig
|
||||
}
|
||||
|
||||
type ComposeConfigHandlerFunc func(key string, obj *ComposeConfig) (*ComposeConfig, error)
|
||||
type ComposeConfigHandlerFunc func(key string, obj *ComposeConfig) (runtime.Object, error)
|
||||
|
||||
type ComposeConfigLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ComposeConfig, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ComposeConfigLifecycle interface {
|
||||
Create(obj *ComposeConfig) (*ComposeConfig, error)
|
||||
Remove(obj *ComposeConfig) (*ComposeConfig, error)
|
||||
Updated(obj *ComposeConfig) (*ComposeConfig, error)
|
||||
Create(obj *ComposeConfig) (runtime.Object, error)
|
||||
Remove(obj *ComposeConfig) (runtime.Object, error)
|
||||
Updated(obj *ComposeConfig) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type composeConfigLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *composeConfigLifecycleAdapter) Updated(obj runtime.Object) (runtime.Obj
|
||||
func NewComposeConfigLifecycleAdapter(name string, clusterScoped bool, client ComposeConfigInterface, l ComposeConfigLifecycle) ComposeConfigHandlerFunc {
|
||||
adapter := &composeConfigLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ComposeConfig) (*ComposeConfig, error) {
|
||||
return func(key string, obj *ComposeConfig) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ComposeConfig); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type DynamicSchemaList struct {
|
||||
Items []DynamicSchema
|
||||
}
|
||||
|
||||
type DynamicSchemaHandlerFunc func(key string, obj *DynamicSchema) (*DynamicSchema, error)
|
||||
type DynamicSchemaHandlerFunc func(key string, obj *DynamicSchema) (runtime.Object, error)
|
||||
|
||||
type DynamicSchemaLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*DynamicSchema, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type DynamicSchemaLifecycle interface {
|
||||
Create(obj *DynamicSchema) (*DynamicSchema, error)
|
||||
Remove(obj *DynamicSchema) (*DynamicSchema, error)
|
||||
Updated(obj *DynamicSchema) (*DynamicSchema, error)
|
||||
Create(obj *DynamicSchema) (runtime.Object, error)
|
||||
Remove(obj *DynamicSchema) (runtime.Object, error)
|
||||
Updated(obj *DynamicSchema) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type dynamicSchemaLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *dynamicSchemaLifecycleAdapter) Updated(obj runtime.Object) (runtime.Obj
|
||||
func NewDynamicSchemaLifecycleAdapter(name string, clusterScoped bool, client DynamicSchemaInterface, l DynamicSchemaLifecycle) DynamicSchemaHandlerFunc {
|
||||
adapter := &dynamicSchemaLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *DynamicSchema) (*DynamicSchema, error) {
|
||||
return func(key string, obj *DynamicSchema) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*DynamicSchema); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type GlobalRoleBindingList struct {
|
||||
Items []GlobalRoleBinding
|
||||
}
|
||||
|
||||
type GlobalRoleBindingHandlerFunc func(key string, obj *GlobalRoleBinding) (*GlobalRoleBinding, error)
|
||||
type GlobalRoleBindingHandlerFunc func(key string, obj *GlobalRoleBinding) (runtime.Object, error)
|
||||
|
||||
type GlobalRoleBindingLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*GlobalRoleBinding, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type GlobalRoleBindingLifecycle interface {
|
||||
Create(obj *GlobalRoleBinding) (*GlobalRoleBinding, error)
|
||||
Remove(obj *GlobalRoleBinding) (*GlobalRoleBinding, error)
|
||||
Updated(obj *GlobalRoleBinding) (*GlobalRoleBinding, error)
|
||||
Create(obj *GlobalRoleBinding) (runtime.Object, error)
|
||||
Remove(obj *GlobalRoleBinding) (runtime.Object, error)
|
||||
Updated(obj *GlobalRoleBinding) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type globalRoleBindingLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *globalRoleBindingLifecycleAdapter) Updated(obj runtime.Object) (runtime
|
||||
func NewGlobalRoleBindingLifecycleAdapter(name string, clusterScoped bool, client GlobalRoleBindingInterface, l GlobalRoleBindingLifecycle) GlobalRoleBindingHandlerFunc {
|
||||
adapter := &globalRoleBindingLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *GlobalRoleBinding) (*GlobalRoleBinding, error) {
|
||||
return func(key string, obj *GlobalRoleBinding) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*GlobalRoleBinding); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type GlobalRoleList struct {
|
||||
Items []GlobalRole
|
||||
}
|
||||
|
||||
type GlobalRoleHandlerFunc func(key string, obj *GlobalRole) (*GlobalRole, error)
|
||||
type GlobalRoleHandlerFunc func(key string, obj *GlobalRole) (runtime.Object, error)
|
||||
|
||||
type GlobalRoleLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*GlobalRole, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type GlobalRoleLifecycle interface {
|
||||
Create(obj *GlobalRole) (*GlobalRole, error)
|
||||
Remove(obj *GlobalRole) (*GlobalRole, error)
|
||||
Updated(obj *GlobalRole) (*GlobalRole, error)
|
||||
Create(obj *GlobalRole) (runtime.Object, error)
|
||||
Remove(obj *GlobalRole) (runtime.Object, error)
|
||||
Updated(obj *GlobalRole) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type globalRoleLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *globalRoleLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object
|
||||
func NewGlobalRoleLifecycleAdapter(name string, clusterScoped bool, client GlobalRoleInterface, l GlobalRoleLifecycle) GlobalRoleHandlerFunc {
|
||||
adapter := &globalRoleLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *GlobalRole) (*GlobalRole, error) {
|
||||
return func(key string, obj *GlobalRole) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*GlobalRole); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type GroupList struct {
|
||||
Items []Group
|
||||
}
|
||||
|
||||
type GroupHandlerFunc func(key string, obj *Group) (*Group, error)
|
||||
type GroupHandlerFunc func(key string, obj *Group) (runtime.Object, error)
|
||||
|
||||
type GroupLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*Group, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type GroupLifecycle interface {
|
||||
Create(obj *Group) (*Group, error)
|
||||
Remove(obj *Group) (*Group, error)
|
||||
Updated(obj *Group) (*Group, error)
|
||||
Create(obj *Group) (runtime.Object, error)
|
||||
Remove(obj *Group) (runtime.Object, error)
|
||||
Updated(obj *Group) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type groupLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *groupLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, err
|
||||
func NewGroupLifecycleAdapter(name string, clusterScoped bool, client GroupInterface, l GroupLifecycle) GroupHandlerFunc {
|
||||
adapter := &groupLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *Group) (*Group, error) {
|
||||
return func(key string, obj *Group) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*Group); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type GroupMemberList struct {
|
||||
Items []GroupMember
|
||||
}
|
||||
|
||||
type GroupMemberHandlerFunc func(key string, obj *GroupMember) (*GroupMember, error)
|
||||
type GroupMemberHandlerFunc func(key string, obj *GroupMember) (runtime.Object, error)
|
||||
|
||||
type GroupMemberLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*GroupMember, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type GroupMemberLifecycle interface {
|
||||
Create(obj *GroupMember) (*GroupMember, error)
|
||||
Remove(obj *GroupMember) (*GroupMember, error)
|
||||
Updated(obj *GroupMember) (*GroupMember, error)
|
||||
Create(obj *GroupMember) (runtime.Object, error)
|
||||
Remove(obj *GroupMember) (runtime.Object, error)
|
||||
Updated(obj *GroupMember) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type groupMemberLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *groupMemberLifecycleAdapter) Updated(obj runtime.Object) (runtime.Objec
|
||||
func NewGroupMemberLifecycleAdapter(name string, clusterScoped bool, client GroupMemberInterface, l GroupMemberLifecycle) GroupMemberHandlerFunc {
|
||||
adapter := &groupMemberLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *GroupMember) (*GroupMember, error) {
|
||||
return func(key string, obj *GroupMember) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*GroupMember); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type LdapConfigList struct {
|
||||
Items []LdapConfig
|
||||
}
|
||||
|
||||
type LdapConfigHandlerFunc func(key string, obj *LdapConfig) (*LdapConfig, error)
|
||||
type LdapConfigHandlerFunc func(key string, obj *LdapConfig) (runtime.Object, error)
|
||||
|
||||
type LdapConfigLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*LdapConfig, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type LdapConfigLifecycle interface {
|
||||
Create(obj *LdapConfig) (*LdapConfig, error)
|
||||
Remove(obj *LdapConfig) (*LdapConfig, error)
|
||||
Updated(obj *LdapConfig) (*LdapConfig, error)
|
||||
Create(obj *LdapConfig) (runtime.Object, error)
|
||||
Remove(obj *LdapConfig) (runtime.Object, error)
|
||||
Updated(obj *LdapConfig) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type ldapConfigLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *ldapConfigLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object
|
||||
func NewLdapConfigLifecycleAdapter(name string, clusterScoped bool, client LdapConfigInterface, l LdapConfigLifecycle) LdapConfigHandlerFunc {
|
||||
adapter := &ldapConfigLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *LdapConfig) (*LdapConfig, error) {
|
||||
return func(key string, obj *LdapConfig) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*LdapConfig); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type ListenConfigList struct {
|
||||
Items []ListenConfig
|
||||
}
|
||||
|
||||
type ListenConfigHandlerFunc func(key string, obj *ListenConfig) (*ListenConfig, error)
|
||||
type ListenConfigHandlerFunc func(key string, obj *ListenConfig) (runtime.Object, error)
|
||||
|
||||
type ListenConfigLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ListenConfig, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ListenConfigLifecycle interface {
|
||||
Create(obj *ListenConfig) (*ListenConfig, error)
|
||||
Remove(obj *ListenConfig) (*ListenConfig, error)
|
||||
Updated(obj *ListenConfig) (*ListenConfig, error)
|
||||
Create(obj *ListenConfig) (runtime.Object, error)
|
||||
Remove(obj *ListenConfig) (runtime.Object, error)
|
||||
Updated(obj *ListenConfig) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type listenConfigLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *listenConfigLifecycleAdapter) Updated(obj runtime.Object) (runtime.Obje
|
||||
func NewListenConfigLifecycleAdapter(name string, clusterScoped bool, client ListenConfigInterface, l ListenConfigLifecycle) ListenConfigHandlerFunc {
|
||||
adapter := &listenConfigLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ListenConfig) (*ListenConfig, error) {
|
||||
return func(key string, obj *ListenConfig) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ListenConfig); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type NodeList struct {
|
||||
Items []Node
|
||||
}
|
||||
|
||||
type NodeHandlerFunc func(key string, obj *Node) (*Node, error)
|
||||
type NodeHandlerFunc func(key string, obj *Node) (runtime.Object, error)
|
||||
|
||||
type NodeLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*Node, err error)
|
||||
|
@ -34,7 +34,7 @@ type NodeDriverList struct {
|
||||
Items []NodeDriver
|
||||
}
|
||||
|
||||
type NodeDriverHandlerFunc func(key string, obj *NodeDriver) (*NodeDriver, error)
|
||||
type NodeDriverHandlerFunc func(key string, obj *NodeDriver) (runtime.Object, error)
|
||||
|
||||
type NodeDriverLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*NodeDriver, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type NodeDriverLifecycle interface {
|
||||
Create(obj *NodeDriver) (*NodeDriver, error)
|
||||
Remove(obj *NodeDriver) (*NodeDriver, error)
|
||||
Updated(obj *NodeDriver) (*NodeDriver, error)
|
||||
Create(obj *NodeDriver) (runtime.Object, error)
|
||||
Remove(obj *NodeDriver) (runtime.Object, error)
|
||||
Updated(obj *NodeDriver) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type nodeDriverLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *nodeDriverLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object
|
||||
func NewNodeDriverLifecycleAdapter(name string, clusterScoped bool, client NodeDriverInterface, l NodeDriverLifecycle) NodeDriverHandlerFunc {
|
||||
adapter := &nodeDriverLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *NodeDriver) (*NodeDriver, error) {
|
||||
return func(key string, obj *NodeDriver) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*NodeDriver); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type NodeLifecycle interface {
|
||||
Create(obj *Node) (*Node, error)
|
||||
Remove(obj *Node) (*Node, error)
|
||||
Updated(obj *Node) (*Node, error)
|
||||
Create(obj *Node) (runtime.Object, error)
|
||||
Remove(obj *Node) (runtime.Object, error)
|
||||
Updated(obj *Node) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type nodeLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *nodeLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, erro
|
||||
func NewNodeLifecycleAdapter(name string, clusterScoped bool, client NodeInterface, l NodeLifecycle) NodeHandlerFunc {
|
||||
adapter := &nodeLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *Node) (*Node, error) {
|
||||
return func(key string, obj *Node) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*Node); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type NodePoolList struct {
|
||||
Items []NodePool
|
||||
}
|
||||
|
||||
type NodePoolHandlerFunc func(key string, obj *NodePool) (*NodePool, error)
|
||||
type NodePoolHandlerFunc func(key string, obj *NodePool) (runtime.Object, error)
|
||||
|
||||
type NodePoolLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*NodePool, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type NodePoolLifecycle interface {
|
||||
Create(obj *NodePool) (*NodePool, error)
|
||||
Remove(obj *NodePool) (*NodePool, error)
|
||||
Updated(obj *NodePool) (*NodePool, error)
|
||||
Create(obj *NodePool) (runtime.Object, error)
|
||||
Remove(obj *NodePool) (runtime.Object, error)
|
||||
Updated(obj *NodePool) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type nodePoolLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *nodePoolLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object,
|
||||
func NewNodePoolLifecycleAdapter(name string, clusterScoped bool, client NodePoolInterface, l NodePoolLifecycle) NodePoolHandlerFunc {
|
||||
adapter := &nodePoolLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *NodePool) (*NodePool, error) {
|
||||
return func(key string, obj *NodePool) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*NodePool); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type NodeTemplateList struct {
|
||||
Items []NodeTemplate
|
||||
}
|
||||
|
||||
type NodeTemplateHandlerFunc func(key string, obj *NodeTemplate) (*NodeTemplate, error)
|
||||
type NodeTemplateHandlerFunc func(key string, obj *NodeTemplate) (runtime.Object, error)
|
||||
|
||||
type NodeTemplateLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*NodeTemplate, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type NodeTemplateLifecycle interface {
|
||||
Create(obj *NodeTemplate) (*NodeTemplate, error)
|
||||
Remove(obj *NodeTemplate) (*NodeTemplate, error)
|
||||
Updated(obj *NodeTemplate) (*NodeTemplate, error)
|
||||
Create(obj *NodeTemplate) (runtime.Object, error)
|
||||
Remove(obj *NodeTemplate) (runtime.Object, error)
|
||||
Updated(obj *NodeTemplate) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type nodeTemplateLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *nodeTemplateLifecycleAdapter) Updated(obj runtime.Object) (runtime.Obje
|
||||
func NewNodeTemplateLifecycleAdapter(name string, clusterScoped bool, client NodeTemplateInterface, l NodeTemplateLifecycle) NodeTemplateHandlerFunc {
|
||||
adapter := &nodeTemplateLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *NodeTemplate) (*NodeTemplate, error) {
|
||||
return func(key string, obj *NodeTemplate) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*NodeTemplate); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type NotifierList struct {
|
||||
Items []Notifier
|
||||
}
|
||||
|
||||
type NotifierHandlerFunc func(key string, obj *Notifier) (*Notifier, error)
|
||||
type NotifierHandlerFunc func(key string, obj *Notifier) (runtime.Object, error)
|
||||
|
||||
type NotifierLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*Notifier, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type NotifierLifecycle interface {
|
||||
Create(obj *Notifier) (*Notifier, error)
|
||||
Remove(obj *Notifier) (*Notifier, error)
|
||||
Updated(obj *Notifier) (*Notifier, error)
|
||||
Create(obj *Notifier) (runtime.Object, error)
|
||||
Remove(obj *Notifier) (runtime.Object, error)
|
||||
Updated(obj *Notifier) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type notifierLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *notifierLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object,
|
||||
func NewNotifierLifecycleAdapter(name string, clusterScoped bool, client NotifierInterface, l NotifierLifecycle) NotifierHandlerFunc {
|
||||
adapter := ¬ifierLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *Notifier) (*Notifier, error) {
|
||||
return func(key string, obj *Notifier) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*Notifier); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type PodSecurityPolicyTemplateList struct {
|
||||
Items []PodSecurityPolicyTemplate
|
||||
}
|
||||
|
||||
type PodSecurityPolicyTemplateHandlerFunc func(key string, obj *PodSecurityPolicyTemplate) (*PodSecurityPolicyTemplate, error)
|
||||
type PodSecurityPolicyTemplateHandlerFunc func(key string, obj *PodSecurityPolicyTemplate) (runtime.Object, error)
|
||||
|
||||
type PodSecurityPolicyTemplateLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*PodSecurityPolicyTemplate, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type PodSecurityPolicyTemplateLifecycle interface {
|
||||
Create(obj *PodSecurityPolicyTemplate) (*PodSecurityPolicyTemplate, error)
|
||||
Remove(obj *PodSecurityPolicyTemplate) (*PodSecurityPolicyTemplate, error)
|
||||
Updated(obj *PodSecurityPolicyTemplate) (*PodSecurityPolicyTemplate, error)
|
||||
Create(obj *PodSecurityPolicyTemplate) (runtime.Object, error)
|
||||
Remove(obj *PodSecurityPolicyTemplate) (runtime.Object, error)
|
||||
Updated(obj *PodSecurityPolicyTemplate) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type podSecurityPolicyTemplateLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *podSecurityPolicyTemplateLifecycleAdapter) Updated(obj runtime.Object)
|
||||
func NewPodSecurityPolicyTemplateLifecycleAdapter(name string, clusterScoped bool, client PodSecurityPolicyTemplateInterface, l PodSecurityPolicyTemplateLifecycle) PodSecurityPolicyTemplateHandlerFunc {
|
||||
adapter := &podSecurityPolicyTemplateLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *PodSecurityPolicyTemplate) (*PodSecurityPolicyTemplate, error) {
|
||||
return func(key string, obj *PodSecurityPolicyTemplate) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*PodSecurityPolicyTemplate); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type PodSecurityPolicyTemplateProjectBindingList struct {
|
||||
Items []PodSecurityPolicyTemplateProjectBinding
|
||||
}
|
||||
|
||||
type PodSecurityPolicyTemplateProjectBindingHandlerFunc func(key string, obj *PodSecurityPolicyTemplateProjectBinding) (*PodSecurityPolicyTemplateProjectBinding, error)
|
||||
type PodSecurityPolicyTemplateProjectBindingHandlerFunc func(key string, obj *PodSecurityPolicyTemplateProjectBinding) (runtime.Object, error)
|
||||
|
||||
type PodSecurityPolicyTemplateProjectBindingLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*PodSecurityPolicyTemplateProjectBinding, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type PodSecurityPolicyTemplateProjectBindingLifecycle interface {
|
||||
Create(obj *PodSecurityPolicyTemplateProjectBinding) (*PodSecurityPolicyTemplateProjectBinding, error)
|
||||
Remove(obj *PodSecurityPolicyTemplateProjectBinding) (*PodSecurityPolicyTemplateProjectBinding, error)
|
||||
Updated(obj *PodSecurityPolicyTemplateProjectBinding) (*PodSecurityPolicyTemplateProjectBinding, error)
|
||||
Create(obj *PodSecurityPolicyTemplateProjectBinding) (runtime.Object, error)
|
||||
Remove(obj *PodSecurityPolicyTemplateProjectBinding) (runtime.Object, error)
|
||||
Updated(obj *PodSecurityPolicyTemplateProjectBinding) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type podSecurityPolicyTemplateProjectBindingLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *podSecurityPolicyTemplateProjectBindingLifecycleAdapter) Updated(obj ru
|
||||
func NewPodSecurityPolicyTemplateProjectBindingLifecycleAdapter(name string, clusterScoped bool, client PodSecurityPolicyTemplateProjectBindingInterface, l PodSecurityPolicyTemplateProjectBindingLifecycle) PodSecurityPolicyTemplateProjectBindingHandlerFunc {
|
||||
adapter := &podSecurityPolicyTemplateProjectBindingLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *PodSecurityPolicyTemplateProjectBinding) (*PodSecurityPolicyTemplateProjectBinding, error) {
|
||||
return func(key string, obj *PodSecurityPolicyTemplateProjectBinding) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*PodSecurityPolicyTemplateProjectBinding); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type PreferenceList struct {
|
||||
Items []Preference
|
||||
}
|
||||
|
||||
type PreferenceHandlerFunc func(key string, obj *Preference) (*Preference, error)
|
||||
type PreferenceHandlerFunc func(key string, obj *Preference) (runtime.Object, error)
|
||||
|
||||
type PreferenceLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*Preference, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type PreferenceLifecycle interface {
|
||||
Create(obj *Preference) (*Preference, error)
|
||||
Remove(obj *Preference) (*Preference, error)
|
||||
Updated(obj *Preference) (*Preference, error)
|
||||
Create(obj *Preference) (runtime.Object, error)
|
||||
Remove(obj *Preference) (runtime.Object, error)
|
||||
Updated(obj *Preference) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type preferenceLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *preferenceLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object
|
||||
func NewPreferenceLifecycleAdapter(name string, clusterScoped bool, client PreferenceInterface, l PreferenceLifecycle) PreferenceHandlerFunc {
|
||||
adapter := &preferenceLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *Preference) (*Preference, error) {
|
||||
return func(key string, obj *Preference) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*Preference); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -34,7 +34,7 @@ type PrincipalList struct {
|
||||
Items []Principal
|
||||
}
|
||||
|
||||
type PrincipalHandlerFunc func(key string, obj *Principal) (*Principal, error)
|
||||
type PrincipalHandlerFunc func(key string, obj *Principal) (runtime.Object, error)
|
||||
|
||||
type PrincipalLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*Principal, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type PrincipalLifecycle interface {
|
||||
Create(obj *Principal) (*Principal, error)
|
||||
Remove(obj *Principal) (*Principal, error)
|
||||
Updated(obj *Principal) (*Principal, error)
|
||||
Create(obj *Principal) (runtime.Object, error)
|
||||
Remove(obj *Principal) (runtime.Object, error)
|
||||
Updated(obj *Principal) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type principalLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *principalLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object,
|
||||
func NewPrincipalLifecycleAdapter(name string, clusterScoped bool, client PrincipalInterface, l PrincipalLifecycle) PrincipalHandlerFunc {
|
||||
adapter := &principalLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *Principal) (*Principal, error) {
|
||||
return func(key string, obj *Principal) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*Principal); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ProjectAlertList struct {
|
||||
Items []ProjectAlert
|
||||
}
|
||||
|
||||
type ProjectAlertHandlerFunc func(key string, obj *ProjectAlert) (*ProjectAlert, error)
|
||||
type ProjectAlertHandlerFunc func(key string, obj *ProjectAlert) (runtime.Object, error)
|
||||
|
||||
type ProjectAlertLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ProjectAlert, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ProjectAlertLifecycle interface {
|
||||
Create(obj *ProjectAlert) (*ProjectAlert, error)
|
||||
Remove(obj *ProjectAlert) (*ProjectAlert, error)
|
||||
Updated(obj *ProjectAlert) (*ProjectAlert, error)
|
||||
Create(obj *ProjectAlert) (runtime.Object, error)
|
||||
Remove(obj *ProjectAlert) (runtime.Object, error)
|
||||
Updated(obj *ProjectAlert) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type projectAlertLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *projectAlertLifecycleAdapter) Updated(obj runtime.Object) (runtime.Obje
|
||||
func NewProjectAlertLifecycleAdapter(name string, clusterScoped bool, client ProjectAlertInterface, l ProjectAlertLifecycle) ProjectAlertHandlerFunc {
|
||||
adapter := &projectAlertLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ProjectAlert) (*ProjectAlert, error) {
|
||||
return func(key string, obj *ProjectAlert) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ProjectAlert); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ProjectCatalogList struct {
|
||||
Items []ProjectCatalog
|
||||
}
|
||||
|
||||
type ProjectCatalogHandlerFunc func(key string, obj *ProjectCatalog) (*ProjectCatalog, error)
|
||||
type ProjectCatalogHandlerFunc func(key string, obj *ProjectCatalog) (runtime.Object, error)
|
||||
|
||||
type ProjectCatalogLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ProjectCatalog, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ProjectCatalogLifecycle interface {
|
||||
Create(obj *ProjectCatalog) (*ProjectCatalog, error)
|
||||
Remove(obj *ProjectCatalog) (*ProjectCatalog, error)
|
||||
Updated(obj *ProjectCatalog) (*ProjectCatalog, error)
|
||||
Create(obj *ProjectCatalog) (runtime.Object, error)
|
||||
Remove(obj *ProjectCatalog) (runtime.Object, error)
|
||||
Updated(obj *ProjectCatalog) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type projectCatalogLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *projectCatalogLifecycleAdapter) Updated(obj runtime.Object) (runtime.Ob
|
||||
func NewProjectCatalogLifecycleAdapter(name string, clusterScoped bool, client ProjectCatalogInterface, l ProjectCatalogLifecycle) ProjectCatalogHandlerFunc {
|
||||
adapter := &projectCatalogLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ProjectCatalog) (*ProjectCatalog, error) {
|
||||
return func(key string, obj *ProjectCatalog) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ProjectCatalog); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ProjectList struct {
|
||||
Items []Project
|
||||
}
|
||||
|
||||
type ProjectHandlerFunc func(key string, obj *Project) (*Project, error)
|
||||
type ProjectHandlerFunc func(key string, obj *Project) (runtime.Object, error)
|
||||
|
||||
type ProjectLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*Project, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ProjectLifecycle interface {
|
||||
Create(obj *Project) (*Project, error)
|
||||
Remove(obj *Project) (*Project, error)
|
||||
Updated(obj *Project) (*Project, error)
|
||||
Create(obj *Project) (runtime.Object, error)
|
||||
Remove(obj *Project) (runtime.Object, error)
|
||||
Updated(obj *Project) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type projectLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *projectLifecycleAdapter) Updated(obj runtime.Object) (runtime.Object, e
|
||||
func NewProjectLifecycleAdapter(name string, clusterScoped bool, client ProjectInterface, l ProjectLifecycle) ProjectHandlerFunc {
|
||||
adapter := &projectLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *Project) (*Project, error) {
|
||||
return func(key string, obj *Project) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*Project); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
@ -35,7 +35,7 @@ type ProjectLoggingList struct {
|
||||
Items []ProjectLogging
|
||||
}
|
||||
|
||||
type ProjectLoggingHandlerFunc func(key string, obj *ProjectLogging) (*ProjectLogging, error)
|
||||
type ProjectLoggingHandlerFunc func(key string, obj *ProjectLogging) (runtime.Object, error)
|
||||
|
||||
type ProjectLoggingLister interface {
|
||||
List(namespace string, selector labels.Selector) (ret []*ProjectLogging, err error)
|
||||
|
@ -6,9 +6,9 @@ import (
|
||||
)
|
||||
|
||||
type ProjectLoggingLifecycle interface {
|
||||
Create(obj *ProjectLogging) (*ProjectLogging, error)
|
||||
Remove(obj *ProjectLogging) (*ProjectLogging, error)
|
||||
Updated(obj *ProjectLogging) (*ProjectLogging, error)
|
||||
Create(obj *ProjectLogging) (runtime.Object, error)
|
||||
Remove(obj *ProjectLogging) (runtime.Object, error)
|
||||
Updated(obj *ProjectLogging) (runtime.Object, error)
|
||||
}
|
||||
|
||||
type projectLoggingLifecycleAdapter struct {
|
||||
@ -42,9 +42,9 @@ func (w *projectLoggingLifecycleAdapter) Updated(obj runtime.Object) (runtime.Ob
|
||||
func NewProjectLoggingLifecycleAdapter(name string, clusterScoped bool, client ProjectLoggingInterface, l ProjectLoggingLifecycle) ProjectLoggingHandlerFunc {
|
||||
adapter := &projectLoggingLifecycleAdapter{lifecycle: l}
|
||||
syncFn := lifecycle.NewObjectLifecycleAdapter(name, clusterScoped, adapter, client.ObjectClient())
|
||||
return func(key string, obj *ProjectLogging) (*ProjectLogging, error) {
|
||||
return func(key string, obj *ProjectLogging) (runtime.Object, error) {
|
||||
newObj, err := syncFn(key, obj)
|
||||
if o, ok := newObj.(*ProjectLogging); ok {
|
||||
if o, ok := newObj.(runtime.Object); ok {
|
||||
return o, err
|
||||
}
|
||||
return nil, err
|
||||
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue
Block a user