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
}

Endpoint represent a kpture server endpoint in th daemonset

func NewEndpoint

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

NewEndpoint create a new grpc client to the kpture server endpoint

type Proxy

type Proxy struct {
	k8s.UnimplementedK8SCaptureServiceServer
	discover.UnimplementedDiscoverServiceServer

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

Proxy represent the kpture proxy

func NewInclusterProxy

func NewInclusterProxy() (*Proxy, error)

NewInclusterProxy create a new grpc server that will proxify the connection from the client to the requested daemonset endpoint

func NewOutclusterProxy

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

NewOutclusterProxy create a proxy from outside cluster for developement purposes

func (*Proxy) Capture

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

Capture is the main function of the proxy. It fetches the containerD information from the pod and namespace request and sends it to the kpture containerD server.

func (*Proxy) ServerInformation

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

ServerInformation return information about the kpture server It will ask every daemon set endpoint for its information and return them as an array

func (*Proxy) Start

func (p *Proxy) Start()

Start the proxy

func (*Proxy) UpdateDaemonSetMap

func (p *Proxy) UpdateDaemonSetMap() error

UpdateDaemonSetMap update the map of daemonset endpoints

func (*Proxy) WatchDaemonSet

func (p *Proxy) WatchDaemonSet()

WatchDaemonSet watch the daemonset and update the map of daemonset endpoints