Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Endpoint ¶
type Endpoint struct {
ContainerDClient containerdv1.ContainerDCaptureServiceClient
DiscoverClient discover.DiscoverServiceClient
}
Endpoint represent a kpture server endpoint in th daemonset
func NewEndpoint ¶
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 ¶
NewInclusterProxy create a new grpc server that will proxify the connection from the client to the requested daemonset endpoint
func NewOutclusterProxy ¶
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 ¶
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) UpdateDaemonSetMap ¶
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
Source Files