Delve issue #1368

Gopkg.toml

[prune]
  unused-packages = true
  go-tests = true
  non-go = true

[[constraint]]
  name = "k8s.io/client-go"
  branch = "release-7.0"

[[constraint]]
  name = "k8s.io/api"
  branch = "release-1.10"

[[constraint]]
  name = "k8s.io/apimachinery"
  branch = "release-1.10"

issue.go

package main

import (
	"github.com/golang/glog"

	corev1 "k8s.io/api/core/v1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/kubernetes/scheme"
	clientcorev1 "k8s.io/client-go/kubernetes/typed/core/v1"
	"k8s.io/client-go/tools/record"

	//_ "k8s.io/client-go/kubernetes/fake"
)

// NewRecorder creates an event Recorder.
func NewRecorder(component string, client kubernetes.Interface) record.EventRecorder {
	eventSink := &clientcorev1.EventSinkImpl{
		client.CoreV1().Events(corev1.NamespaceAll),
	}

	eventBroadcaster := record.NewBroadcaster()
	eventBroadcaster.StartLogging(glog.V(3).Infof)
	eventBroadcaster.StartRecordingToSink(eventSink)

	return eventBroadcaster.NewRecorder(
		scheme.Scheme,
		corev1.EventSource{Component: component},
	)
}

issue_test.go

package main

import (
	"context"
	"fmt"
	"testing"
	"time"

	corev1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes/fake"
)

const defaultTestsTimeout = 2 * time.Second

func TestEvent(t *testing.T) {
	const (
		ns   = "test"
		name = "dummy"
	)

	obj := &corev1.Pod{
		ObjectMeta: metav1.ObjectMeta{
			Namespace: ns,
			Name:      name,
			SelfLink:  fmt.Sprintf("/api/v1/namespaces/%s/pods/%s", ns, name),
		},
	}

	cli := fake.NewSimpleClientset()
	r := NewRecorder("testing", cli)

	ctx, cancel := context.WithTimeout(context.Background(), defaultTestsTimeout)
	defer cancel()

	w, err := cli.EventsV1beta1().Events(ns).Watch(metav1.ListOptions{})
	if err != nil {
		t.Fatalf("Error obtaining watch interface: %s", err)
	}
	defer w.Stop()

	eventReceived := w.ResultChan()

	r.Eventf(obj, corev1.EventTypeNormal, "SomeReason", "Dummy event")

	select {
	case <-ctx.Done():
		t.Error("Timed out waiting for event")
	case <-eventReceived:
	}
}