func New()

in pkg/clients/event/event.go [63:82]


func New(client kubernetes.Interface) (Interface, error) {
	broadcaster := record.NewBroadcaster()
	broadcaster.StartLogging(klog.V(4).Infof)
	broadcaster.StartRecordingToSink(&typedcorev1.EventSinkImpl{
		Interface: typedcorev1.New(client.CoreV1().RESTClient()).Events(namespace),
	})

	eventsScheme := runtime.NewScheme()
	if err := v1.AddToScheme(eventsScheme); err != nil {
		return nil, err
	}
	if err := netv1.AddToScheme(eventsScheme); err != nil {
		return nil, err
	}

	return &impl{
		recorder: broadcaster.NewRecorder(eventsScheme,
			corev1.EventSource{Component: component}),
	}, nil
}