pod_enrichment

Documentation

Index

• Constants
• Variables
• type PodEnrichmentReconciler
  • func (r *PodEnrichmentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PodEnrichmentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PodHandler
  • func NewPodHandler(client client.Client, pod *corev1.Pod) *PodHandler
  • func (p *PodHandler) GetNodeAddress(ctx context.Context) (string, error)
  • func (p *PodHandler) GetNodeName() string
  • func (p *PodHandler) Reconcile(ctx context.Context) (ctrl.Result, error)
  • func (p *PodHandler) Scheduled() bool
  • func (p *PodHandler) UpdateNodeAddrToPodMeta(ctx context.Context, nodeAddress string) error

Constants

const (
	PodEnrichmentLabelName  = "enrichment.zncdata.dev/enable"
	PodEnrichmentLabelValue = "true"
)

Variables

var (
	OrderedAddressTypes = []corev1.NodeAddressType{
		corev1.NodeHostName,
		corev1.NodeExternalDNS,
		corev1.NodeInternalDNS,
		corev1.NodeExternalIP,
		corev1.NodeInternalIP,
	}
)

Types

type PodEnrichmentReconciler

type PodEnrichmentReconciler struct {
	client.Client
	Schema *runtime.Scheme
}

func (*PodEnrichmentReconciler) Reconcile

func (r *PodEnrichmentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PodEnrichmentReconciler) SetupWithManager

func (r *PodEnrichmentReconciler) SetupWithManager(mgr ctrl.Manager) error

type PodHandler

type PodHandler struct {
	Client client.Client
	Pod    *corev1.Pod
}

func NewPodHandler

func NewPodHandler(client client.Client, pod *corev1.Pod) *PodHandler

func (*PodHandler) GetNodeAddress

func (p *PodHandler) GetNodeAddress(ctx context.Context) (string, error)

func (*PodHandler) GetNodeName

func (p *PodHandler) GetNodeName() string

func (*PodHandler) Reconcile

func (p *PodHandler) Reconcile(ctx context.Context) (ctrl.Result, error)

func (*PodHandler) Scheduled

func (p *PodHandler) Scheduled() bool

func (*PodHandler) UpdateNodeAddrToPodMeta

func (p *PodHandler) UpdateNodeAddrToPodMeta(ctx context.Context, nodeAddress string) error