seldondeployment

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• type AmbassadorConfig
• type AmbassadorRetryPolicy
• type ReconcileSeldonDeployment
  • func (r *ReconcileSeldonDeployment) Reconcile(request reconcile.Request) (reconcile.Result, error)

Constants

const (
	ANNOTATION_REST_READ_TIMEOUT       = "seldon.io/rest-read-timeout"
	ANNOTATION_GRPC_READ_TIMEOUT       = "seldon.io/grpc-read-timeout"
	ANNOTATION_AMBASSADOR_CUSTOM       = "seldon.io/ambassador-config"
	ANNOTATION_AMBASSADOR_WEIGHT       = "seldon.io/ambassador-weight"
	ANNOTATION_AMBASSADOR_SHADOW       = "seldon.io/ambassador-shadow"
	ANNOTATION_AMBASSADOR_SERVICE      = "seldon.io/ambassador-service-name"
	ANNOTATION_AMBASSADOR_HEADER       = "seldon.io/ambassador-header"
	ANNOTATION_AMBASSADOR_REGEX_HEADER = "seldon.io/ambassador-regex-header"

	YAML_SEP = "---\n"
)

const (
	ENV_ISTIO_ENABLED        = "ISTIO_ENABLED"
	ENV_ISTIO_GATEWAY        = "ISTIO_GATEWAY"
	ANNOTATION_ISTIO_GATEWAY = "seldon.io/istio-gateway"
)

const (
	ENV_DEFAULT_ENGINE_SERVER_PORT      = "ENGINE_SERVER_PORT"
	ENV_DEFAULT_ENGINE_SERVER_GRPC_PORT = "ENGINE_SERVER_GRPC_PORT"

	DEFAULT_ENGINE_CONTAINER_PORT = 8000
	DEFAULT_ENGINE_GRPC_PORT      = 5001
)

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new SeldonDeployment Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.

Types

type AmbassadorConfig

type AmbassadorConfig struct {
	ApiVersion   string                 `yaml:"apiVersion"`
	Kind         string                 `yaml:"kind"`
	Name         string                 `yaml:"name"`
	Grpc         *bool                  `yaml:"grpc,omitempty"`
	Prefix       string                 `yaml:"prefix"`
	Rewrite      string                 `yaml:"rewrite,omitempty"`
	Service      string                 `yaml:"service"`
	TimeoutMs    int                    `yaml:"timeout_ms"`
	Headers      map[string]string      `yaml:"headers,omitempty"`
	RegexHeaders map[string]string      `yaml:"regex_headers,omitempty"`
	Weight       int                    `yaml:"weight,omitempty"`
	Shadow       *bool                  `yaml:"shadow,omitempty"`
	RetryPolicy  *AmbassadorRetryPolicy `yaml:"retry_policy,omitempty"`
}

Struct for Ambassador configuration

type AmbassadorRetryPolicy

type AmbassadorRetryPolicy struct {
	RetryOn    string `yaml:"retry_on,omitempty"`
	NumRetries int    `yaml:"num_retries,omitempty"`
}

type ReconcileSeldonDeployment

type ReconcileSeldonDeployment struct {
	client.Client
	// contains filtered or unexported fields
}

ReconcileSeldonDeployment reconciles a SeldonDeployment object

func (*ReconcileSeldonDeployment) Reconcile

func (r *ReconcileSeldonDeployment) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a SeldonDeployment object and makes changes based on the state read and what is in the SeldonDeployment.Spec TODO(user): Modify this Reconcile function to implement your Controller logic. The scaffolding writes a Deployment as an example Automatically generate RBAC rules to allow the Controller to read and write Deployments +kubebuilder:rbac:groups=apps,resources=deployments,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=apps,resources=deployments/status,verbs=get;update;patch +kubebuilder:rbac:groups=v1,resources=services,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=v1,resources=services/status,verbs=get;update;patch +kubebuilder:rbac:groups=networking.istio.io,resources=virtualservices,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=networking.istio.io,resources=virtualservices/status,verbs=get;update;patch +kubebuilder:rbac:groups=networking.istio.io,resources=destinationrules,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=networking.istio.io,resources=destinationrules/status,verbs=get;update;patch +kubebuilder:rbac:groups=autoscaling,resources=horizontalpodautoscalers,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=autoscaling,resources=horizontalpodautoscalers/status,verbs=get;update;patch +kubebuilder:rbac:groups=machinelearning.seldon.io,resources=seldondeployments,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=machinelearning.seldon.io,resources=seldondeployments/status,verbs=get;update;patch