Documentation
¶
Index ¶
- func EvaluateAnnotationsForEnabledCapabilities(annotations map[string]string, options framework.Options)
- func FetchClusterLogForwarder(k8sClient client.Client, namespace, name string) (*obs.ClusterLogForwarder, error)
- func FetchConfigMaps(k8sClient client.Client, namespace string, names ...string) (configMaps []*corev1.ConfigMap, err error)
- func FetchSecrets(k8sClient client.Client, namespace string, names ...string) (secrets []*corev1.Secret, err error)
- func GenerateConfig(k8Client client.Client, clf obs.ClusterLogForwarder, ...) (config string, err error)
- func MapConfigMaps(k8Client client.Client, namespace string, inputs internalobs.Inputs, ...) (configMaps map[string]*corev1.ConfigMap, err error)
- func MapSecrets(k8Client client.Client, namespace string, inputs internalobs.Inputs, ...) (secretMap map[string]*corev1.Secret, err error)
- func ReconcileCollector(context internalcontext.ForwarderContext, pollInterval, timeout time.Duration) (err error)
- func RemoveStaleWorkload(k8Client client.Client, forwarder *obsv1.ClusterLogForwarder) error
- type ClusterLogForwarderReconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EvaluateAnnotationsForEnabledCapabilities ¶
func EvaluateAnnotationsForEnabledCapabilities(annotations map[string]string, options framework.Options)
EvaluateAnnotationsForEnabledCapabilities populates generator options with capabilities enabled by the ClusterLogForwarder
func FetchClusterLogForwarder ¶
func FetchClusterLogForwarder(k8sClient client.Client, namespace, name string) (*obs.ClusterLogForwarder, error)
FetchClusterLogForwarder returns a copy of the ClusterLogForwarder
func FetchConfigMaps ¶
func FetchConfigMaps(k8sClient client.Client, namespace string, names ...string) (configMaps []*corev1.ConfigMap, err error)
FetchConfigMaps from a list of names in a given namespace
func FetchSecrets ¶
func FetchSecrets(k8sClient client.Client, namespace string, names ...string) (secrets []*corev1.Secret, err error)
FetchSecrets from a list of names in a given namespace
func GenerateConfig ¶
func GenerateConfig(k8Client client.Client, clf obs.ClusterLogForwarder, resourceNames factory.ForwarderResourceNames, secrets internalobs.Secrets, op framework.Options) (config string, err error)
func MapConfigMaps ¶
func MapSecrets ¶
func ReconcileCollector ¶
func ReconcileCollector(context internalcontext.ForwarderContext, pollInterval, timeout time.Duration) (err error)
ReconcileCollector generates and deploys all resources required by the ClusterLogForwarder
func RemoveStaleWorkload ¶
func RemoveStaleWorkload(k8Client client.Client, forwarder *obsv1.ClusterLogForwarder) error
RemoveStaleWorkload removes existing workload if the ClusterLogForwarder was modified such that the deployment will change from a daemonSet to a deployment or vise versa
Types ¶
type ClusterLogForwarderReconciler ¶
type ClusterLogForwarderReconciler struct {
Scheme *runtime.Scheme
NewForwarderContext func() internalcontext.ForwarderContext
PollInterval time.Duration
TimeOut time.Duration
}
ClusterLogForwarderReconciler reconciles a ClusterLogForwarder object
func (*ClusterLogForwarderReconciler) SetupWithManager ¶
func (r *ClusterLogForwarderReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Source Files
Click to show internal directories.
Click to hide internal directories.