kube

Documentation

Index

• func NewServer(client *Client) kubepb.KubeAPIServer
• type AddListener
• type Client
  • func NewClient(log *logging.Logger, podName, kvisorNamespace string, version Version, ...) *Client
  • func (c *Client) GetClusterInfo() (*ClusterInfo, bool)
  • func (c *Client) GetIPInfo(ip netip.Addr) (IPInfo, bool)
  • func (c *Client) GetKvisorAgentImageDetails() (ImageDetails, error)
  • func (c *Client) GetOwnerUID(obj Object) string
  • func (c *Client) GetPodInfo(uid string) (*PodInfo, bool)
  • func (c *Client) RegisterHandlers(factory informers.SharedInformerFactory)
  • func (c *Client) RegisterKubernetesChangeListener(l KubernetesChangeEventListener)
  • func (c *Client) RegisterPodsHandlers(factory informers.SharedInformerFactory)
  • func (c *Client) Run(ctx context.Context) error
  • func (c *Client) UnregisterKubernetesChangeListener(l KubernetesChangeEventListener)
• type ClusterInfo
• type DeleteListener
• type EventType
• type IPEndpoint
• type IPInfo
• type ImageDetails
• type Index
  • func NewIndex() *Index
• type KubernetesChangeEventListener
• type Object
• type PodInfo
• type PodLogProvider
  • func NewPodLogReader(client kubernetes.Interface) PodLogProvider
• type Server
  • func (s *Server) GetClusterInfo(ctx context.Context, req *kubepb.GetClusterInfoRequest) (*kubepb.GetClusterInfoResponse, error)
  • func (s *Server) GetIPInfo(ctx context.Context, req *kubepb.GetIPInfoRequest) (*kubepb.GetIPInfoResponse, error)
  • func (s *Server) GetPod(ctx context.Context, req *kubepb.GetPodRequest) (*kubepb.GetPodResponse, error)
• type UpdateListener
• type Version
  • func GetVersion(clientset kubernetes.Interface) (Version, error)

Functions

func NewServer

func NewServer(client *Client) kubepb.KubeAPIServer

Types

type AddListener

type AddListener interface {
	OnAdd(obj Object)
}

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(
	log *logging.Logger,
	podName, kvisorNamespace string,
	version Version,
	client kubernetes.Interface,
) *Client

func (*Client) GetClusterInfo

func (c *Client) GetClusterInfo() (*ClusterInfo, bool)

func (*Client) GetIPInfo

func (c *Client) GetIPInfo(ip netip.Addr) (IPInfo, bool)

func (*Client) GetKvisorAgentImageDetails

func (c *Client) GetKvisorAgentImageDetails() (ImageDetails, error)

GetKvisorAgentImageDetails returns kvisor agent image details. This is used for image analyzer and kube-bench dynamic jobs to schedule using the same image.

func (*Client) GetOwnerUID

func (c *Client) GetOwnerUID(obj Object) string

func (*Client) GetPodInfo

func (c *Client) GetPodInfo(uid string) (*PodInfo, bool)

func (*Client) RegisterHandlers

func (c *Client) RegisterHandlers(factory informers.SharedInformerFactory)

func (*Client) RegisterKubernetesChangeListener

func (c *Client) RegisterKubernetesChangeListener(l KubernetesChangeEventListener)

func (*Client) RegisterPodsHandlers

func (c *Client) RegisterPodsHandlers(factory informers.SharedInformerFactory)

func (*Client) Run

func (c *Client) Run(ctx context.Context) error

func (*Client) UnregisterKubernetesChangeListener

func (c *Client) UnregisterKubernetesChangeListener(l KubernetesChangeEventListener)

type ClusterInfo

type ClusterInfo struct {
	PodCidr     string
	ServiceCidr string
}

type DeleteListener

type DeleteListener interface {
	OnDelete(obj Object)
}

type EventType

type EventType string

const (
	EventAdd    EventType = "add"
	EventUpdate EventType = "update"
	EventDelete EventType = "delete"
)

type IPEndpoint

type IPEndpoint struct {
	ID        string
	Name      string
	Namespace string
	Labels    map[string]string
}

type IPInfo

type IPInfo struct {
	IP       string
	PodInfo  *PodInfo
	Service  *corev1.Service
	Node     *corev1.Node
	Endpoint *IPEndpoint
}

type ImageDetails

type ImageDetails struct {
	ScannerImageName string
	ImagePullSecrets []corev1.LocalObjectReference
}

type Index

type Index struct {
	// contains filtered or unexported fields
}

func NewIndex

func NewIndex() *Index

type KubernetesChangeEventListener

type KubernetesChangeEventListener interface {
	RequiredTypes() []reflect.Type
}

type Object

type Object interface {
	runtime.Object
	metav1.Object
}

type PodInfo

type PodInfo struct {
	Pod   *corev1.Pod
	Owner metav1.OwnerReference
	Zone  string
}

type PodLogProvider

type PodLogProvider interface {
	GetLogReader(ctx context.Context, podNs, podName string) (io.ReadCloser, error)
}

func NewPodLogReader

func NewPodLogReader(client kubernetes.Interface) PodLogProvider

type Server

type Server struct {
	// contains filtered or unexported fields
}

func (*Server) GetClusterInfo

func (s *Server) GetClusterInfo(ctx context.Context, req *kubepb.GetClusterInfoRequest) (*kubepb.GetClusterInfoResponse, error)

func (*Server) GetIPInfo

func (s *Server) GetIPInfo(ctx context.Context, req *kubepb.GetIPInfoRequest) (*kubepb.GetIPInfoResponse, error)

func (*Server) GetPod

func (s *Server) GetPod(ctx context.Context, req *kubepb.GetPodRequest) (*kubepb.GetPodResponse, error)

type UpdateListener

type UpdateListener interface {
	OnUpdate(obj Object)
}

type Version

type Version struct {
	Full     string
	MinorInt int
}

func GetVersion

func GetVersion(clientset kubernetes.Interface) (Version, error)