proxy

Documentation

Index

• type Endpoint
  • func NewEndpoint(IP string) (*Endpoint, error)
• type Proxy
  • func NewInclusterProxy() (*Proxy, error)
  • func NewOutclusterProxy(kubeconfig string) (*Proxy, error)
  • func (p *Proxy) Capture(req *types.K8SCapture, stream k8s.K8SCaptureService_CaptureServer) error
  • func (p *Proxy) ServerInformation(context.Context, *discover.Empty) (*types.ServerInfo, error)
  • func (p *Proxy) Start()
  • func (p *Proxy) UpdateDaemonSetMap() error
  • func (p *Proxy) WatchDaemonSet()

Types

type Endpoint

type Endpoint struct {
	ContainerDClient containerdv1.ContainerDCaptureServiceClient
	DiscoverClient   discover.DiscoverServiceClient
}

func NewEndpoint

func NewEndpoint(IP string) (*Endpoint, error)

type Proxy

type Proxy struct {
	k8s.UnimplementedK8SCaptureServiceServer
	discover.UnimplementedDiscoverServiceServer

	DaemonSetEndpoints map[string]*Endpoint
	// contains filtered or unexported fields
}

func NewInclusterProxy

func NewInclusterProxy() (*Proxy, error)

func NewOutclusterProxy

func NewOutclusterProxy(kubeconfig string) (*Proxy, error)

func (*Proxy) Capture

func (p *Proxy) Capture(req *types.K8SCapture, stream k8s.K8SCaptureService_CaptureServer) error

At the moment we only use containerD api Need to use generic OpenContainerInterface later

func (*Proxy) ServerInformation

func (p *Proxy) ServerInformation(context.Context, *discover.Empty) (*types.ServerInfo, error)

func (*Proxy) Start

func (p *Proxy) Start()

func (*Proxy) UpdateDaemonSetMap

func (p *Proxy) UpdateDaemonSetMap() error

func (*Proxy) WatchDaemonSet

func (p *Proxy) WatchDaemonSet()