k8s

Documentation

Index

• Constants
• func GetServerVersion(client discovery.DiscoveryInterface, logger logr.Logger) (string, error)
• func InitializeOperator(ctx context.Context, 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(ctx context.Context, rawYaml []byte, namespace string, ...) error
• type CrdCreator
  • func NewCrdCreator(ctx context.Context, apiExtensionsClient apiextensionsclient.Interface, ...) *CrdCreator
• type WebhookCreator
  • func NewWebhookCreator(client kubernetes.Interface, certs *Cert, logger logr.Logger, ...) *WebhookCreator
  • func (wc *WebhookCreator) CreateValidatingWebhookConfigurationFromFile(ctx context.Context, rawYaml []byte, namespace string, owner v1.Object, ...) error
  • func (wc *WebhookCreator) CreateWebhookServiceFromFile(ctx context.Context, rawYaml []byte, namespace string, ...) error

Constants

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

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

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

const DefaultMinorVersion = 18

This will cause CRD V1 to be installed

const MutatingWebhookName = "seldon-mutating-webhook-configuration"

Functions

func GetServerVersion

func GetServerVersion(client discovery.DiscoveryInterface, logger logr.Logger) (string, error)

func InitializeOperator

func InitializeOperator(ctx context.Context, 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(ctx context.Context, rawYaml []byte, namespace string, owner *appsv1.Deployment) error

type CrdCreator

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

func NewCrdCreator

func NewCrdCreator(ctx context.Context, apiExtensionsClient apiextensionsclient.Interface, discoveryClient discovery.DiscoveryInterface, 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

func (*WebhookCreator) CreateValidatingWebhookConfigurationFromFile

func (wc *WebhookCreator) CreateValidatingWebhookConfigurationFromFile(ctx context.Context, rawYaml []byte, namespace string, owner v1.Object, watchNamespace bool) error

func (*WebhookCreator) CreateWebhookServiceFromFile

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