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
}