gadgettracermanager

Documentation

Index

• type Conf
• type GadgetTracerManager
  • func NewServer(conf *Conf) (*GadgetTracerManager, error)
  • func (g *GadgetTracerManager) AddContainer(_ context.Context, containerDefinition *pb.ContainerDefinition) (*pb.AddContainerResponse, error)
  • func (g *GadgetTracerManager) AddTracer(tracerID string, containerSelector containercollection.ContainerSelector) error
  • func (g *GadgetTracerManager) Close()
  • func (g *GadgetTracerManager) ContainersMap() *ebpf.Map
  • func (g *GadgetTracerManager) DumpState(_ context.Context, req *pb.DumpStateRequest) (*pb.Dump, error)
  • func (g *GadgetTracerManager) PublishEvent(tracerID string, line string) error
  • func (g *GadgetTracerManager) ReceiveStream(tracerID *pb.TracerID, stream pb.GadgetTracerManager_ReceiveStreamServer) error
  • func (g *GadgetTracerManager) RemoveContainer(_ context.Context, containerDefinition *pb.ContainerDefinition) (*pb.RemoveContainerResponse, error)
  • func (g *GadgetTracerManager) RemoveTracer(tracerID string) error
  • func (g *GadgetTracerManager) TracerMountNsMap(tracerID string) (*ebpf.Map, error)
• type SetGadgetTracerMgr

Types

type Conf

type Conf struct {
	NodeName            string
	HookMode            string
	FallbackPodInformer bool
	TestOnly            bool
}

type GadgetTracerManager

type GadgetTracerManager struct {
	pb.UnimplementedGadgetTracerManagerServer
	containercollection.ContainerCollection
	// contains filtered or unexported fields
}

func NewServer

func NewServer(conf *Conf) (*GadgetTracerManager, error)

func (*GadgetTracerManager) AddContainer

func (g *GadgetTracerManager) AddContainer(_ context.Context, containerDefinition *pb.ContainerDefinition) (*pb.AddContainerResponse, error)

func (*GadgetTracerManager) AddTracer

func (g *GadgetTracerManager) AddTracer(tracerID string, containerSelector containercollection.ContainerSelector) error

func (*GadgetTracerManager) Close

func (g *GadgetTracerManager) Close()

Close releases any resource that could be in use by the tracer manager, like ebpf maps.

func (*GadgetTracerManager) ContainersMap

func (g *GadgetTracerManager) ContainersMap() *ebpf.Map

func (*GadgetTracerManager) DumpState

func (g *GadgetTracerManager) DumpState(_ context.Context, req *pb.DumpStateRequest) (*pb.Dump, error)

func (*GadgetTracerManager) PublishEvent

func (g *GadgetTracerManager) PublishEvent(tracerID string, line string) error

func (*GadgetTracerManager) ReceiveStream

func (g *GadgetTracerManager) ReceiveStream(tracerID *pb.TracerID, stream pb.GadgetTracerManager_ReceiveStreamServer) error

func (*GadgetTracerManager) RemoveContainer

func (g *GadgetTracerManager) RemoveContainer(_ context.Context, containerDefinition *pb.ContainerDefinition) (*pb.RemoveContainerResponse, error)

func (*GadgetTracerManager) RemoveTracer

func (g *GadgetTracerManager) RemoveTracer(tracerID string) error

func (*GadgetTracerManager) TracerMountNsMap

func (g *GadgetTracerManager) TracerMountNsMap(tracerID string) (*ebpf.Map, error)

type SetGadgetTracerMgr

type SetGadgetTracerMgr interface {
	SetGadgetTracerMgr(*GadgetTracerManager)
}

SetGadgetTracerMgr is an interface that is implemented by KubeManager to be able to set a reference to GadgetTracerManager