kube

Documentation

Index

• type Client
  • func NewClient(log *logging.Logger, podName, kvisorNamespace string, version Version, ...) *Client
  • func (c *Client) GetKvisorAgentImageDetails() (ImageDetails, bool)
  • func (c *Client) GetOwnerUID(obj Object) string
  • 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
• type EventType
• type ImageDetails
• type KubernetesChangeEventListener
• type Object
• type PodLogProvider
  • func NewPodLogReader(client kubernetes.Interface) PodLogProvider
• type Version
  • func GetVersion(clientset kubernetes.Interface) (Version, error)

Types

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) GetKvisorAgentImageDetails

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

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) 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

type EventType

type EventType string

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

type ImageDetails

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

type KubernetesChangeEventListener

type KubernetesChangeEventListener interface {
	OnAdd(obj Object)
	OnDelete(obj Object)
	OnUpdate(newObj Object)
	RequiredTypes() []reflect.Type
}

type Object

type Object interface {
	runtime.Object
	metav1.Object
}

type PodLogProvider

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

func NewPodLogReader

func NewPodLogReader(client kubernetes.Interface) PodLogProvider

type Version

type Version struct {
	Full     string
	MinorInt int
}

func GetVersion

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