kubernetes

Documentation

Index

• Constants
• func Client() *kubernetes.Clientset
• func FindTokenVolumeName(volumes []corev1.Volume) string
• func FindVolumeMount(volumes []corev1.VolumeMount, name string) corev1.VolumeMount
• func GetAnnotationValue(pod corev1.Pod, name *registeredAnnotation, defaultValue string) string
• func GetDeploymentName(name string) (string, error)
• func InitLogrus(engine *gin.Engine)
• func Load(file string, c interface{})
• func Log() *logrus.Logger
• func LoggerWithLogrus(log *logrus.Logger) gin.HandlerFunc
• func Pod(raw []byte, pod *corev1.Pod) error
• func PotentialNamespace(req *v1beta1.AdmissionRequest, pod *corev1.Pod) string
• func PotentialPodName(metadata *metav1.ObjectMeta) string
• func ToAdmissionResponse(err error) *v1beta1.AdmissionResponse
• type KiamData
• type KiamInject
• type PatchOperation
• type WebHook
  • func (wk *WebHook) Mutate(context *gin.Context)
• type WebHookConfig

Constants

const GIN = "[GIN]"

const (
	KiamConfig = "kiam-config"
)

Functions

func Client

func Client() *kubernetes.Clientset

func FindTokenVolumeName

func FindTokenVolumeName(volumes []corev1.Volume) string

func FindVolumeMount

func FindVolumeMount(volumes []corev1.VolumeMount, name string) corev1.VolumeMount

func GetAnnotationValue

func GetAnnotationValue(pod corev1.Pod, name *registeredAnnotation, defaultValue string) string

func GetDeploymentName

func GetDeploymentName(name string) (string, error)

func InitLogrus

func InitLogrus(engine *gin.Engine)

func Load

func Load(file string, c interface{})

func Log

func Log() *logrus.Logger

func LoggerWithLogrus

func LoggerWithLogrus(log *logrus.Logger) gin.HandlerFunc

func Pod

func Pod(raw []byte, pod *corev1.Pod) error

func PotentialNamespace

func PotentialNamespace(req *v1beta1.AdmissionRequest, pod *corev1.Pod) string

func PotentialPodName

func PotentialPodName(metadata *metav1.ObjectMeta) string

Deal with potential empty fields, e.g., when the pod is created by a deployment

func ToAdmissionResponse

func ToAdmissionResponse(err error) *v1beta1.AdmissionResponse

Types

type KiamData

type KiamData struct {
	Name      string
	Container corev1.Container
}

type KiamInject

type KiamInject struct {
	Annotations map[string]string
}

type PatchOperation

type PatchOperation struct {
	Op    string      `json:"op"`
	Path  string      `json:"path"`
	Value interface{} `json:"value,omitempty"`
}

type WebHook

type WebHook struct {
	Config     *WebHookConfig
	KiamConfig *KiamInject
}

func (*WebHook) Mutate

func (wk *WebHook) Mutate(context *gin.Context)

type WebHookConfig

type WebHookConfig struct {
	Template   string `json:"template"`
	KiamConfig string `json:"kiam-config"`
}