github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-31 07:20:13 +00:00
Code Issues Projects Releases Wiki Activity

Don't call one of pointless conversions

Browse Source
This commit is contained in:
gmarek 2017-08-09 13:59:37 +02:00
parent c75d3028dd
commit e742c31f97
1 changed files with 3 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
federation/pkg/federation-controller/util/eventsink/eventsink.go
View File

@ -72,12 +72,7 @@ func init() {
} }
func (fes *FederatedEventSink) Create(event *v1.Event) (*v1.Event, error) { func (fes *FederatedEventSink) Create(event *v1.Event) (*v1.Event, error) {
kubeEvent := &v1.Event{} ret, err := fes.clientset.Core().Events(event.Namespace).Create(event)
if err := scheme.Convert(event, kubeEvent, nil); err != nil {
return nil, err
}
ret, err := fes.clientset.Core().Events(kubeEvent.Namespace).Create(kubeEvent)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -90,12 +85,7 @@ func (fes *FederatedEventSink) Create(event *v1.Event) (*v1.Event, error) {
} }
func (fes *FederatedEventSink) Update(event *v1.Event) (*v1.Event, error) { func (fes *FederatedEventSink) Update(event *v1.Event) (*v1.Event, error) {
kubeEvent := &v1.Event{} ret, err := fes.clientset.Core().Events(event.Namespace).Update(event)
if err := scheme.Convert(event, kubeEvent, nil); err != nil {
return nil, err
}
ret, err := fes.clientset.Core().Events(kubeEvent.Namespace).Update(kubeEvent)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -108,12 +98,7 @@ func (fes *FederatedEventSink) Update(event *v1.Event) (*v1.Event, error) {
} }
func (fes *FederatedEventSink) Patch(event *v1.Event, data []byte) (*v1.Event, error) { func (fes *FederatedEventSink) Patch(event *v1.Event, data []byte) (*v1.Event, error) {
kubeEvent := &v1.Event{} ret, err := fes.clientset.Core().Events(event.Namespace).Patch(event.Name, types.StrategicMergePatchType, data)
if err := scheme.Convert(event, kubeEvent, nil); err != nil {
return nil, err
}
ret, err := fes.clientset.Core().Events(kubeEvent.Namespace).Patch(kubeEvent.Name, types.StrategicMergePatchType, data)
if err != nil { if err != nil {
return nil, err return nil, err
} }