client

Documentation

Index

• Constants
• func ExecuteSAR(shareName, podNamespace, podName, podSA string) (bool, error)
• func GetConfig() (*rest.Config, error)
• func GetPod(namespace, name string) (*corev1.Pod, error)
• func GetRecorder() record.EventRecorder
• func SetClient(client kubernetes.Interface)
• func SetConfigMapsLister(c corev1.ConfigMapLister)
• func SetSecretsLister(s corev1.SecretLister)
• func SetSharesLister(s sharev1alpha1.ShareLister)
• type Event
• type Listers
  • func GetListers() *Listers
• type ObjectAction

Constants

const (
	DefaultNamespace = "csi-driver-projected-resource"
	DriverName       = "csi-driver-projected-resource.openshift.io"
)

Functions

func ExecuteSAR

func ExecuteSAR(shareName, podNamespace, podName, podSA string) (bool, error)

func GetConfig

func GetConfig() (*rest.Config, error)

GetConfig creates a *rest.Config for talking to a Kubernetes apiserver. Otherwise will assume running in cluster and use the cluster provided kubeconfig.

Config precedence

* KUBECONFIG environment variable pointing at a file

* In-cluster config if running in cluster

* $HOME/.kube/config if exists

func GetPod

func GetPod(namespace, name string) (*corev1.Pod, error)

func GetRecorder

func GetRecorder() record.EventRecorder

func SetClient

func SetClient(client kubernetes.Interface)

SetClient sets the internal kubernetes client interface. Useful for testing.

func SetConfigMapsLister

func SetConfigMapsLister(c corev1.ConfigMapLister)

func SetSecretsLister

func SetSecretsLister(s corev1.SecretLister)

func SetSharesLister

func SetSharesLister(s sharev1alpha1.ShareLister)

Types

type Event

type Event struct {
	Object runtime.Object
	Verb   ObjectAction
}

type Listers

type Listers struct {
	Secrets    corev1.SecretLister
	ConfigMaps corev1.ConfigMapLister
	Shares     sharev1alpha1.ShareLister
}

func GetListers

func GetListers() *Listers

type ObjectAction

type ObjectAction string

const (
	AddObjectAction    ObjectAction = "add"
	UpdateObjectAction ObjectAction = "upd"
	DeleteObjectAction ObjectAction = "del"
)