kubernetes

Documentation

Index

• Constants
• Variables
• func EnvsForApp(a provision.App, process string, version appTypes.AppVersion) []bindTypes.EnvVar
• func GetProvisioner() *kubernetesProvisioner
• type ClusterClient
  • func NewClusterClient(clust *provTypes.Cluster) (*ClusterClient, error)
  • func (c *ClusterClient) AppNamespace(ctx context.Context, app appTypes.App) (string, error)
  • func (c *ClusterClient) BuildServiceClient(pool string) (pb.BuildClient, *grpc.ClientConn, error)
  • func (c *ClusterClient) CPUBurstFactor(pool string) (float64, error)
  • func (c *ClusterClient) CPUOvercommitFactor(pool string) (float64, error)
  • func (c *ClusterClient) DisablePlatformBuild() bool
  • func (c *ClusterClient) EnableJobEventCreation() (bool, error)
  • func (c *ClusterClient) EnableVersionedServices() (bool, error)
  • func (c *ClusterClient) GetCluster() *provTypes.Cluster
  • func (c *ClusterClient) InsecureRegistry() bool
  • func (c *ClusterClient) MemoryOvercommitFactor(pool string) (float64, error)
  • func (c *ClusterClient) Namespace() string
  • func (c *ClusterClient) OvercommitFactor(pool string) (float64, error)
  • func (c *ClusterClient) PoolNamespace(pool string) string
  • func (c *ClusterClient) Registry() imgTypes.ImageRegistry
  • func (c *ClusterClient) RestConfig() *rest.Config
  • func (c *ClusterClient) ServiceAnnotations(key string) (map[string]string, error)
  • func (c *ClusterClient) SetTimeout(timeout time.Duration) error
  • func (c *ClusterClient) SinglePool() (bool, error)
  • func (c *ClusterClient) TopologySpreadConstraints(pool string) string
• type DeploymentRollbacker
  • func (r *DeploymentRollbacker) Rollback(ctx context.Context, w io.Writer, obj *appsv1.Deployment) error
• type InspectData

Constants

const (
	// AnnotationServiceAccountAppAnnotations can be used to add custom
	// annotations to an app service account, its value must be a serialized
	// json object that can be parsed as a map[string]string.
	AnnotationServiceAccountAppAnnotations = "app.tsuru.io/service-account-annotations"

	// AnnotationServiceAccountJobAnnotations can be used to add custom
	// annotations to a job service account, its value must be a serialized
	// json object that can be parsed as a map[string]string.
	AnnotationServiceAccountJobAnnotations = "job.tsuru.io/service-account-annotations"

	// ResourceMetadaPrefix is used to define an annotation or label for a subresource of the deployment
	// i.e: "app.tsuru.io/k8s-<resource-type>"
	// Example, setting a service annotation: 'app.tsuru.io/k8s-service={"label1": "value"}'
	ResourceMetadataPrefix = "app.tsuru.io/k8s-"

	// AnnotationEnableVPA is used to enable the creation of a recommendation
	// only VPA for the application. Its value must be a boolean.
	AnnotationEnableVPA = "app.tsuru.io/enable-vpa"
)

Variables

var BackendConfigClientForConfig = func(conf *rest.Config) (backendConfigClientSet.Interface, error) {
	return backendConfigClientSet.NewForConfig(conf)
}

var ClientForConfig = func(conf *rest.Config) (kubernetes.Interface, error) {
	return kubernetes.NewForConfig(conf)
}

var ExtensionsClientForConfig = func(conf *rest.Config) (apiextensionsclientset.Interface, error) {
	return apiextensionsclientset.NewForConfig(conf)
}

var InformerFactory = func(client *ClusterClient, tweak internalinterfaces.TweakListOptionsFunc) (informers.SharedInformerFactory, error) {
	args := newInformerFactoryArgs(client, tweak)
	cli, err := ClientForConfig(args.restConfig)
	if err != nil {
		return nil, err
	}
	return informers.NewFilteredSharedInformerFactory(cli, args.resync, metav1.NamespaceAll, args.tweak), nil
}

var KEDAClientForConfig = func(conf *rest.Config) (kedav1alpha1clientset.Interface, error) {
	return kedav1alpha1clientset.NewForConfig(conf)
}

var MetricsClientForConfig = func(conf *rest.Config) (metricsclientset.Interface, error) {
	return metricsclientset.NewForConfig(conf)
}

var TsuruClientForConfig = func(conf *rest.Config) (tsuruv1clientset.Interface, error) {
	return tsuruv1clientset.NewForConfig(conf)
}

var VPAClientForConfig = func(conf *rest.Config) (vpaclientset.Interface, error) {
	return vpaclientset.NewForConfig(conf)
}

var VPAInformerFactory = func(client *ClusterClient) (vpaInformers.SharedInformerFactory, error) {
	args := newInformerFactoryArgs(client, tsuruServiceTweakFunc())
	cli, err := VPAClientForConfig(args.restConfig)
	if err != nil {
		return nil, err
	}
	tweak := vpaInternalInterfaces.TweakListOptionsFunc(args.tweak)
	return vpaInformers.NewFilteredSharedInformerFactory(cli, args.resync, metav1.NamespaceAll, tweak), nil
}

Functions

func EnvsForApp

func EnvsForApp(a provision.App, process string, version appTypes.AppVersion) []bindTypes.EnvVar

func GetProvisioner

func GetProvisioner() *kubernetesProvisioner

Types

type ClusterClient

type ClusterClient struct {
	kubernetes.Interface `json:"-" bson:"-"`
	*provTypes.Cluster
	// contains filtered or unexported fields
}

func NewClusterClient

func NewClusterClient(clust *provTypes.Cluster) (*ClusterClient, error)

func (*ClusterClient) AppNamespace

func (c *ClusterClient) AppNamespace(ctx context.Context, app appTypes.App) (string, error)

func (*ClusterClient) BuildServiceClient

func (c *ClusterClient) BuildServiceClient(pool string) (pb.BuildClient, *grpc.ClientConn, error)

func (*ClusterClient) CPUBurstFactor

func (c *ClusterClient) CPUBurstFactor(pool string) (float64, error)

func (*ClusterClient) CPUOvercommitFactor

func (c *ClusterClient) CPUOvercommitFactor(pool string) (float64, error)

func (*ClusterClient) DisablePlatformBuild

func (c *ClusterClient) DisablePlatformBuild() bool

func (*ClusterClient) EnableJobEventCreation

func (c *ClusterClient) EnableJobEventCreation() (bool, error)

func (*ClusterClient) EnableVersionedServices

func (c *ClusterClient) EnableVersionedServices() (bool, error)

func (*ClusterClient) GetCluster

func (c *ClusterClient) GetCluster() *provTypes.Cluster

func (*ClusterClient) InsecureRegistry

func (c *ClusterClient) InsecureRegistry() bool

func (*ClusterClient) MemoryOvercommitFactor

func (c *ClusterClient) MemoryOvercommitFactor(pool string) (float64, error)

func (*ClusterClient) Namespace

func (c *ClusterClient) Namespace() string

Namespace returns the namespace to be used by Custom Resources

func (*ClusterClient) OvercommitFactor

func (c *ClusterClient) OvercommitFactor(pool string) (float64, error)

func (*ClusterClient) PoolNamespace

func (c *ClusterClient) PoolNamespace(pool string) string

func (*ClusterClient) Registry

func (c *ClusterClient) Registry() imgTypes.ImageRegistry

func (*ClusterClient) RestConfig

func (c *ClusterClient) RestConfig() *rest.Config

func (*ClusterClient) ServiceAnnotations

func (c *ClusterClient) ServiceAnnotations(key string) (map[string]string, error)

func (*ClusterClient) SetTimeout

func (c *ClusterClient) SetTimeout(timeout time.Duration) error

func (*ClusterClient) SinglePool

func (c *ClusterClient) SinglePool() (bool, error)

func (*ClusterClient) TopologySpreadConstraints

func (c *ClusterClient) TopologySpreadConstraints(pool string) string

type DeploymentRollbacker

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

func (*DeploymentRollbacker) Rollback

func (r *DeploymentRollbacker) Rollback(ctx context.Context, w io.Writer, obj *appsv1.Deployment) error

type InspectData

type InspectData struct {
	Image     docker.Image
	TsuruYaml provTypes.TsuruYamlData
	Procfile  string
}