hosttailer

Documentation

Index

• func SetupWithBuilder(builder *builder.Builder)
• type HostTailer
  • func New(client client.Client, log logr.Logger, opts reconciler.ReconcilerOpts, ...) *HostTailer
  • func (h *HostTailer) Container(name string, volumeMount corev1.VolumeMount, command []string, ...) corev1.Container
  • func (h *HostTailer) Containers(tailers []tailer.Tailer, volumePaths []string) []corev1.Container
  • func (h *HostTailer) DaemonSet(containers []corev1.Container, volumes []corev1.Volume) *appsv1.DaemonSet
  • func (h *HostTailer) GatherPathStrings(tailers []tailer.Tailer) []string
  • func (h *HostTailer) MergeTailers() []tailer.Tailer
  • func (h *HostTailer) Name(suffix string) string
  • func (h *HostTailer) Reconcile(object runtime.Object) (*reconcile.Result, error)
  • func (h *HostTailer) RegisterWatches(*builder.Builder)
  • func (h *HostTailer) Run() (runtime.Object, reconciler.DesiredState, error)
  • func (h *HostTailer) Volumes(volumePaths []string) []corev1.Volume

Functions

func SetupWithBuilder

func SetupWithBuilder(builder *builder.Builder)

SetupWithBuilder .

Types

type HostTailer

type HostTailer struct {
	*reconciler.GenericResourceReconciler

	CommonSelectorLabels map[string]string `json:"selectorLabels,omitempty"`
	// contains filtered or unexported fields
}

HostTailer .

func New

func New(client client.Client, log logr.Logger, opts reconciler.ReconcilerOpts, customResource v1alpha1.HostTailer) *HostTailer

New constructor

func (*HostTailer) Container

func (h *HostTailer) Container(name string, volumeMount corev1.VolumeMount, command []string, overrides *types.ContainerBase, imageSpec *tailer.ImageSpec) corev1.Container

Container returns the assembled container for the current tailer

func (*HostTailer) Containers

func (h *HostTailer) Containers(tailers []tailer.Tailer, volumePaths []string) []corev1.Container

Containers assembles the required containers

func (*HostTailer) DaemonSet

func (h *HostTailer) DaemonSet(containers []corev1.Container, volumes []corev1.Volume) *appsv1.DaemonSet

DaemonSet produces k8s daemonset struct from the given parameters

func (*HostTailer) GatherPathStrings

func (h *HostTailer) GatherPathStrings(tailers []tailer.Tailer) []string

GatherPathStrings returns the path strings

func (*HostTailer) MergeTailers

func (h *HostTailer) MergeTailers() []tailer.Tailer

MergeTailers collects all the tailers through the different tailer types and cast them to Tailer interface array

func (*HostTailer) Name

func (h *HostTailer) Name(suffix string) string

Name returns generated name string

func (*HostTailer) Reconcile

func (h *HostTailer) Reconcile(object runtime.Object) (*reconcile.Result, error)

func (*HostTailer) RegisterWatches

func (h *HostTailer) RegisterWatches(*builder.Builder)

RegisterWatches completes the implementation of ComponentReconciler

func (*HostTailer) Run

func (h *HostTailer) Run() (runtime.Object, reconciler.DesiredState, error)

Run is the implementation of type Resource interface, generates Deamonset for fileTailers

func (*HostTailer) Volumes

func (h *HostTailer) Volumes(volumePaths []string) []corev1.Volume

Volumes makes corev1.Volumes from the given paths