k8s

Documentation

Index

• Constants
• func InitializeOperator(config *rest.Config, namespace string, logger logr.Logger, ...) error
• func LoadBytesFromFile(path string, name string) ([]byte, error)
• type Cert
• type ConfigmapCreator
  • func NewConfigmapCreator(client kubernetes.Interface, logger logr.Logger, scheme *runtime.Scheme) *ConfigmapCreator
  • func (cc *ConfigmapCreator) CreateConfigmap(rawYaml []byte, namespace string, owner *appsv1.Deployment) error
• type CrdCreator
  • func NewCrdCreator(clientset apiextensionsclient.Interface, logger logr.Logger) *CrdCreator
• type WebhookCreator
  • func NewWebhookCreator(client kubernetes.Interface, certs *Cert, logger logr.Logger, ...) (*WebhookCreator, error)
  • func (wc *WebhookCreator) CreateMutatingWebhookConfigurationFromFile(rawYaml []byte, namespace string, ...) error
  • func (wc *WebhookCreator) CreateValidatingWebhookConfigurationFromFile(rawYaml []byte, namespace string, ...) error
  • func (wc *WebhookCreator) CreateWebhookServiceFromFile(rawYaml []byte, namespace string, owner *appsv1.Deployment) error

Constants

const (
	CertsFolder = "/tmp/k8s-webhook-server/serving-certs"
	CertsTLSKey = "tls.key"
	CertsTLSCrt = "tls.crt"
	CertsTLSCa  = "ca.crt"

	ResourceFolder            = "/tmp/operator-resources"
	CRDFilename               = "crd.yaml"
	MutatingWebhookFilename   = "mutate.yaml"
	ValidatingWebhookFilename = "validate.yaml"
	ConfigMapFilename         = "configmap.yaml"
	ServiceFilename           = "service.yaml"

	ManagerDeploymentName = "seldon-controller-manager"
	CRDName               = "seldondeployments.machinelearning.seldon.io"
)

Functions

func InitializeOperator

func InitializeOperator(config *rest.Config, namespace string, logger logr.Logger, scheme *runtime.Scheme, watchNamespace bool) error

func LoadBytesFromFile

func LoadBytesFromFile(path string, name string) ([]byte, error)

Types

type Cert

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

type ConfigmapCreator

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

func NewConfigmapCreator

func NewConfigmapCreator(client kubernetes.Interface, logger logr.Logger, scheme *runtime.Scheme) *ConfigmapCreator

func (*ConfigmapCreator) CreateConfigmap

func (cc *ConfigmapCreator) CreateConfigmap(rawYaml []byte, namespace string, owner *appsv1.Deployment) error

type CrdCreator

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

func NewCrdCreator

func NewCrdCreator(clientset apiextensionsclient.Interface, logger logr.Logger) *CrdCreator

type WebhookCreator

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

func NewWebhookCreator

func NewWebhookCreator(client kubernetes.Interface, certs *Cert, logger logr.Logger, scheme *runtime.Scheme) (*WebhookCreator, error)

func (*WebhookCreator) CreateMutatingWebhookConfigurationFromFile

func (wc *WebhookCreator) CreateMutatingWebhookConfigurationFromFile(rawYaml []byte, namespace string, owner *apiextensionsv1beta1.CustomResourceDefinition, watchNamespace bool) error

func (*WebhookCreator) CreateValidatingWebhookConfigurationFromFile

func (wc *WebhookCreator) CreateValidatingWebhookConfigurationFromFile(rawYaml []byte, namespace string, owner *apiextensionsv1beta1.CustomResourceDefinition, watchNamespace bool) error

func (*WebhookCreator) CreateWebhookServiceFromFile

func (wc *WebhookCreator) CreateWebhookServiceFromFile(rawYaml []byte, namespace string, owner *appsv1.Deployment) error