@@ -33,7 +33,6 @@ func NewPublisher(ctx context.Context, client kube.Client, systemNamespace strin
3333
3434// onNack publishes a NACK event as a k8s event.
3535func (p * Publisher ) onNack (event NackEvent ) {
36-
3736 nackID := ComputeNackID (event .Gateway .Namespace + "/" + event .Gateway .Name , event .TypeUrl )
3837
3938 k8sEvent := & corev1.Event {
@@ -64,11 +63,11 @@ func (p *Publisher) onNack(event NackEvent) {
6463 p .ctx , k8sEvent , metav1.CreateOptions {},
6564 )
6665 if err != nil && ! errors .IsAlreadyExists (err ) {
67- log .Error ("Failed to publish NACK event for Gateway" , "gateway" , event .Gateway , "error" , err )
66+ log .Error ("failed to publish NACK event for Gateway" , "gateway" , event .Gateway , "error" , err )
6867 return
6968 }
7069
71- log .Debug ("Published NACK event for Gateway" , "gateway" , event .Gateway , "nackID" , nackID , "typeURL" , event .TypeUrl )
70+ log .Debug ("published NACK event for Gateway" , "gateway" , event .Gateway , "nackID" , nackID , "typeURL" , event .TypeUrl )
7271}
7372
7473// onAck publishes an ACK event as a k8s event.
@@ -104,9 +103,9 @@ func (p *Publisher) onAck(event AckEvent) {
104103 p .ctx , k8sEvent , metav1.CreateOptions {},
105104 )
106105 if err != nil && ! errors .IsAlreadyExists (err ) {
107- log .Error ("Failed to publish ACK event for Gateway" , "gateway" , event .Gateway , "error" , err )
106+ log .Error ("failed to publish ACK event for Gateway" , "gateway" , event .Gateway , "error" , err )
108107 return
109108 }
110109
111- log .Debug ("Published ACK event for Gateway" , "gateway" , event .Gateway , "typeURL" , event .TypeUrl )
110+ log .Debug ("published ACK event for Gateway" , "gateway" , event .Gateway , "typeURL" , event .TypeUrl )
112111}
0 commit comments