goflowkube

Documentation

Index

• Constants
• type ConfigMap
• type GFKReconciler
  • func NewReconciler(cl reconcilers.ClientHelper, ns, prevNS string) GFKReconciler
  • func (r *GFKReconciler) InitStaticResources(ctx context.Context) error
  • func (r *GFKReconciler) PrepareNamespaceChange(ctx context.Context) error
  • func (r *GFKReconciler) Reconcile(ctx context.Context, desiredGoflowKube *goflowKubeSpec, desiredLoki *lokiSpec) error
• type LokiConfigMap

Constants

const PodConfigurationDigest = "flows.netobserv.io/goflow-kube-config"

PodConfigurationDigest is an annotation name to facilitate pod restart after any external configuration change

Types

type ConfigMap

type ConfigMap struct {
	Listen      string        `json:"listen,omitempty"`
	Loki        LokiConfigMap `json:"loki,omitempty"`
	PrintInput  bool          `json:"printInput"`
	PrintOutput bool          `json:"printOutput"`
}

type GFKReconciler

type GFKReconciler struct {
	reconcilers.ClientHelper
	// contains filtered or unexported fields
}

GFKReconciler reconciles the current goflow-kube state with the desired configuration

func NewReconciler

func NewReconciler(cl reconcilers.ClientHelper, ns, prevNS string) GFKReconciler

func (*GFKReconciler) InitStaticResources

func (r *GFKReconciler) InitStaticResources(ctx context.Context) error

InitStaticResources inits some "static" / one-shot resources, usually not subject to reconciliation

func (*GFKReconciler) PrepareNamespaceChange

func (r *GFKReconciler) PrepareNamespaceChange(ctx context.Context) error

PrepareNamespaceChange cleans up old namespace and restore the relevant "static" resources

func (*GFKReconciler) Reconcile

func (r *GFKReconciler) Reconcile(ctx context.Context, desiredGoflowKube *goflowKubeSpec, desiredLoki *lokiSpec) error

Reconcile is the reconciler entry point to reconcile the current goflow-kube state with the desired configuration

type LokiConfigMap

type LokiConfigMap struct {
	URL          string            `json:"url,omitempty"`
	BatchWait    metav1.Duration   `json:"batchWait,omitempty"`
	BatchSize    int64             `json:"batchSize,omitempty"`
	Timeout      metav1.Duration   `json:"timeout,omitempty"`
	MinBackoff   metav1.Duration   `json:"minBackoff,omitempty"`
	MaxBackoff   metav1.Duration   `json:"maxBackoff,omitempty"`
	MaxRetries   int32             `json:"maxRetries,omitempty"`
	Labels       []string          `json:"labels,omitempty"`
	StaticLabels map[string]string `json:"staticLabels,omitempty"`
}