kubeipresolver

Documentation

Overview

Package kubeipresolver provides an operator that enriches events by looking up IP addresses in Kubernetes resources such as pods and services.

Index

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

Constants

const (
	OperatorName = "KubeIPResolver"
)

Types

type KubeIPResolver

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

func (*KubeIPResolver) CanOperateOn

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

func (*KubeIPResolver) Close

func (k *KubeIPResolver) Close() error

func (*KubeIPResolver) Dependencies

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

func (*KubeIPResolver) Description

func (k *KubeIPResolver) Description() string

func (*KubeIPResolver) GlobalParamDescs

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

func (*KubeIPResolver) Init

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

func (*KubeIPResolver) Instantiate

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

func (*KubeIPResolver) Name

func (k *KubeIPResolver) Name() string

func (*KubeIPResolver) ParamDescs

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

type KubeIPResolverInstance

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

func (*KubeIPResolverInstance) EnrichEvent

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

func (*KubeIPResolverInstance) Name

func (m *KubeIPResolverInstance) Name() string

func (*KubeIPResolverInstance) PostGadgetRun

func (m *KubeIPResolverInstance) PostGadgetRun() error

func (*KubeIPResolverInstance) PreGadgetRun

func (m *KubeIPResolverInstance) PreGadgetRun() error

type KubeIPResolverInterface

type KubeIPResolverInterface interface {
	GetEndpoints() []*types.L3Endpoint
}