kubenameresolver

Documentation

Overview

Package kubenameresolver provides an operator that enriches events by looking up the pod name and namespace and enriches it with its ip information. It is currently used by the following gadgets: - trace network

Index

• Constants
• type KubeNameResolver
  • func (k *KubeNameResolver) CanOperateOn(gadget gadgets.GadgetDesc) bool
  • func (k *KubeNameResolver) Close() error
  • func (k *KubeNameResolver) Dependencies() []string
  • func (k *KubeNameResolver) Description() string
  • func (k *KubeNameResolver) GlobalParamDescs() params.ParamDescs
  • func (k *KubeNameResolver) Init(params *params.Params) error
  • func (k *KubeNameResolver) Instantiate(gadgetCtx operators.GadgetContext, gadgetInstance any, params *params.Params) (operators.OperatorInstance, error)
  • func (k *KubeNameResolver) Name() string
  • func (k *KubeNameResolver) ParamDescs() params.ParamDescs
• type KubeNameResolverInstance
  • func (m *KubeNameResolverInstance) EnrichEvent(ev any) error
  • func (m *KubeNameResolverInstance) Name() string
  • func (m *KubeNameResolverInstance) PostGadgetRun() error
  • func (m *KubeNameResolverInstance) PreGadgetRun() error
• type KubeNameResolverInterface

Constants

const (
	OperatorName = "KubeNameResolver"
)

Types

type KubeNameResolver

type KubeNameResolver struct{}

func (*KubeNameResolver) CanOperateOn

func (k *KubeNameResolver) CanOperateOn(gadget gadgets.GadgetDesc) bool

func (*KubeNameResolver) Close

func (k *KubeNameResolver) Close() error

func (*KubeNameResolver) Dependencies

func (k *KubeNameResolver) Dependencies() []string

func (*KubeNameResolver) Description

func (k *KubeNameResolver) Description() string

func (*KubeNameResolver) GlobalParamDescs

func (k *KubeNameResolver) GlobalParamDescs() params.ParamDescs

func (*KubeNameResolver) Init

func (k *KubeNameResolver) Init(params *params.Params) error

func (*KubeNameResolver) Instantiate

func (k *KubeNameResolver) Instantiate(gadgetCtx operators.GadgetContext, gadgetInstance any, params *params.Params) (operators.OperatorInstance, error)

func (*KubeNameResolver) Name

func (k *KubeNameResolver) Name() string

func (*KubeNameResolver) ParamDescs

func (k *KubeNameResolver) ParamDescs() params.ParamDescs

type KubeNameResolverInstance

type KubeNameResolverInstance struct {
	// contains filtered or unexported fields
}

func (*KubeNameResolverInstance) EnrichEvent

func (m *KubeNameResolverInstance) EnrichEvent(ev any) error

func (*KubeNameResolverInstance) Name

func (m *KubeNameResolverInstance) Name() string

func (*KubeNameResolverInstance) PostGadgetRun

func (m *KubeNameResolverInstance) PostGadgetRun() error

func (*KubeNameResolverInstance) PreGadgetRun

func (m *KubeNameResolverInstance) PreGadgetRun() error

type KubeNameResolverInterface

type KubeNameResolverInterface interface {
	SetLocalPodDetails(owner, hostIP, podIP string, labels map[string]string)
}