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) GlobalParams() api.Params
  • func (k *KubeIPResolver) Init(params *params.Params) error
  • func (k *KubeIPResolver) InstanceParams() api.Params
  • func (k *KubeIPResolver) Instantiate(gadgetCtx operators.GadgetContext, gadgetInstance any, params *params.Params) (operators.OperatorInstance, error)
  • func (k *KubeIPResolver) InstantiateDataOperator(gadgetCtx operators.GadgetContext, instanceParamValues api.ParamValues) (operators.DataOperatorInstance, error)
  • func (k *KubeIPResolver) Name() string
  • func (k *KubeIPResolver) ParamDescs() params.ParamDescs
  • func (k *KubeIPResolver) Priority() int
• type KubeIPResolverInstance
  • func (m *KubeIPResolverInstance) EnrichEvent(ev any) error
  • func (m *KubeIPResolverInstance) Name() string
  • func (m *KubeIPResolverInstance) PostGadgetRun() error
  • func (m *KubeIPResolverInstance) PostStop(gadgetCtx operators.GadgetContext) error
  • func (m *KubeIPResolverInstance) PreGadgetRun() error
  • func (m *KubeIPResolverInstance) PreStart(gadgetCtx operators.GadgetContext) error
  • func (m *KubeIPResolverInstance) Start(gadgetCtx operators.GadgetContext) error
  • func (m *KubeIPResolverInstance) Stop(gadgetCtx operators.GadgetContext) error
• type KubeIPResolverInterface

Constants

const (
	OperatorName = "KubeIPResolver"
	Priority     = 10
)

Types

type KubeIPResolver

type KubeIPResolver struct{}

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) GlobalParams

func (k *KubeIPResolver) GlobalParams() api.Params

func (*KubeIPResolver) Init

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

func (*KubeIPResolver) InstanceParams

func (k *KubeIPResolver) InstanceParams() api.Params

func (*KubeIPResolver) Instantiate

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

func (*KubeIPResolver) InstantiateDataOperator

func (k *KubeIPResolver) InstantiateDataOperator(gadgetCtx operators.GadgetContext, instanceParamValues api.ParamValues) (operators.DataOperatorInstance, error)

func (*KubeIPResolver) Name

func (k *KubeIPResolver) Name() string

func (*KubeIPResolver) ParamDescs

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

func (*KubeIPResolver) Priority

func (k *KubeIPResolver) Priority() int

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) PostStop

func (m *KubeIPResolverInstance) PostStop(gadgetCtx operators.GadgetContext) error

func (*KubeIPResolverInstance) PreGadgetRun

func (m *KubeIPResolverInstance) PreGadgetRun() error

func (*KubeIPResolverInstance) PreStart

func (m *KubeIPResolverInstance) PreStart(gadgetCtx operators.GadgetContext) error

func (*KubeIPResolverInstance) Start

func (m *KubeIPResolverInstance) Start(gadgetCtx operators.GadgetContext) error

func (*KubeIPResolverInstance) Stop

func (m *KubeIPResolverInstance) Stop(gadgetCtx operators.GadgetContext) error

type KubeIPResolverInterface

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