INNER CODE UNIT · Go

NewBroadcaster

metacontroller/metacontroller · pkg/events/events.go:20

func NewBroadcaster(config *rest.Config, options record.CorrelatorOptions) (record.EventBroadcaster, error) {
	broadcaster := record.NewBroadcasterWithCorrelatorOptions(options)

	clientSet, err := kubernetes.NewForConfig(config)
	if err != nil {
		return nil, err
	}
	broadcaster.StartRecordingToSink(&typedcorev1.EventSinkImpl{Interface: clientSet.CoreV1().Events(metav1.NamespaceAll)})
	return broadcaster, nil
}

View source record →