k8s

package
v0.34.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 22, 2020 License: Apache-2.0 Imports: 31 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidServiceType = errors.New("Invalid service type")
	ErrNotFound           = status.Errorf(codes.NotFound, "Resource not found")
	ErrPodRunFailed       = status.Errorf(codes.Aborted, "Pod went into failed status")
	ErrPodStillRunning    = status.Errorf(codes.Unknown, "Pod still running")
)

Functions

This section is empty.

Types

type Client 

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

func New 

func New(conf *Config) (*Client, error)

func (*Client) AddressList added in v0.15.0 

func (k *Client) AddressList(namespace string) ([]*app.Address, error)

func (*Client) Autoscale added in v0.15.0 

func (k *Client) Autoscale(namespace string) (*app.Autoscale, error)

func (*Client) CloudProviderName added in v0.18.0 

func (c *Client) CloudProviderName() (string, error)

func (*Client) ContainerExplicitEnvVars added in v0.20.0 

func (c *Client) ContainerExplicitEnvVars(namespace, deployName, containerName string) ([]*app.EnvVar, error)

func (*Client) CreateNamespace added in v0.15.0 

func (k *Client) CreateNamespace(a *app.App, user string) error

func (*Client) CreateOrUpdateAutoscale added in v0.15.0 

func (k *Client) CreateOrUpdateAutoscale(a *app.App) error

func (*Client) CreateOrUpdateConfigMap added in v0.17.0 

func (k *Client) CreateOrUpdateConfigMap(namespace, name string, data map[string]string) error

func (*Client) CreateOrUpdateCronJob added in v0.16.0 

func (c *Client) CreateOrUpdateCronJob(cronJobSpec *spec.CronJob) error

func (*Client) CreateOrUpdateCronJobEnvVars added in v0.16.0 

func (c *Client) CreateOrUpdateCronJobEnvVars(namespace, name string, evs []*app.EnvVar) error

func (*Client) CreateOrUpdateCronJobSecretEnvVars added in v0.17.0 

func (c *Client) CreateOrUpdateCronJobSecretEnvVars(namespace, name, secretName string, secrets []string) error

func (*Client) CreateOrUpdateCronJobSecretFile added in v0.25.0 

func (c *Client) CreateOrUpdateCronJobSecretFile(namespace, cronjob, fileName string) error

func (*Client) CreateOrUpdateDeploy added in v0.15.0 

func (k *Client) CreateOrUpdateDeploy(deploySpec *spec.Deploy) error

func (*Client) CreateOrUpdateDeployEnvVars added in v0.15.0 

func (c *Client) CreateOrUpdateDeployEnvVars(namespace, name string, evs []*app.EnvVar) error

func (*Client) CreateOrUpdateDeploySecretEnvVars added in v0.17.0 

func (c *Client) CreateOrUpdateDeploySecretEnvVars(namespace, name, secretName string, secrets []string) error

func (*Client) CreateOrUpdateDeploySecretFile added in v0.25.0 

func (c *Client) CreateOrUpdateDeploySecretFile(namespace, deploy, filename string) error

func (*Client) CreateOrUpdateSecret added in v0.17.0 

func (c *Client) CreateOrUpdateSecret(namespace, secretName string, data map[string][]byte) error

func (*Client) CreateQuota added in v0.15.0 

func (k *Client) CreateQuota(a *app.App) error

func (*Client) CreateService added in v0.20.0 

func (k *Client) CreateService(svcSpec *spec.Service) error

func (*Client) DeleteConfigMap added in v0.19.0 

func (k *Client) DeleteConfigMap(namespace, name string) error

func (*Client) DeleteCronJobEnvVars added in v0.16.0 

func (k *Client) DeleteCronJobEnvVars(namespace, name string, evNames []string) error

func (*Client) DeleteCronJobSecrets added in v0.25.0 

func (c *Client) DeleteCronJobSecrets(namespace, cronjob string, envVars, volKeys []string) error

func (*Client) DeleteDeployEnvVars added in v0.15.0 

func (k *Client) DeleteDeployEnvVars(namespace, name string, evNames []string) error

func (*Client) DeleteDeploySecrets added in v0.25.0 

func (c *Client) DeleteDeploySecrets(namespace, deploy string, envVars, volKeys []string) error

func (*Client) DeleteNamespace added in v0.15.0 

func (k *Client) DeleteNamespace(namespace string) error

func (*Client) DeletePod added in v0.15.0 

func (k *Client) DeletePod(namespace, podName string) error

func (*Client) DeleteService added in v0.20.0 

func (k *Client) DeleteService(namespace, name string) error

func (*Client) DeployAnnotation added in v0.15.0 

func (k *Client) DeployAnnotation(namespace, deployName, annotation string) (string, error)

func (*Client) DeployRollbackToRevision added in v0.15.0 

func (k *Client) DeployRollbackToRevision(namespace, name, revision string) error

func (*Client) DeploySetReplicas added in v0.15.0 

func (k *Client) DeploySetReplicas(namespace, name string, replicas int32) error

func (*Client) ExposeDeploy added in v0.15.0 

func (k *Client) ExposeDeploy(namespace, appName, svcType, portName string, vHosts []string, ingressClass string, w io.Writer) error

ExposeDeploy creates a service and/or a ingress if needed

func (*Client) GetSecret added in v0.17.0 

func (c *Client) GetSecret(namespace, secretName string) (map[string][]byte, error)

func (*Client) HasAnotherIngress added in v0.33.0 

func (k *Client) HasAnotherIngress(namespace, appName string) (bool, error)

HasAnotherIngress will check if there is another ingress than the one with the same name as the app

func (*Client) HasIngress added in v0.17.0 

func (k *Client) HasIngress(namespace, appName string) (bool, error)

func (*Client) HealthCheck added in v0.15.0 

func (k *Client) HealthCheck() error

func (*Client) IngressAnnotations added in v0.30.0 

func (c *Client) IngressAnnotations(namespace, ingName string) (map[string]string, error)

func (*Client) IngressEnabled added in v0.22.0 

func (c *Client) IngressEnabled() bool

func (*Client) IsAlreadyExists added in v0.15.0 

func (k *Client) IsAlreadyExists(err error) bool

func (*Client) IsInvalid added in v0.16.0 

func (k *Client) IsInvalid(err error) bool

func (*Client) IsNotFound added in v0.15.0 

func (k *Client) IsNotFound(err error) bool

func (*Client) IsUnknown added in v0.26.0 

func (k *Client) IsUnknown(err error) bool

func (*Client) Limits added in v0.15.0 

func (k *Client) Limits(namespace, name string) (*app.Limits, error)

func (*Client) NamespaceAnnotation added in v0.15.0 

func (k *Client) NamespaceAnnotation(namespace, annotation string) (string, error)

func (*Client) NamespaceLabel added in v0.15.0 

func (k *Client) NamespaceLabel(namespace, label string) (string, error)

func (*Client) NamespaceListByLabel added in v0.15.0 

func (k *Client) NamespaceListByLabel(label, value string) ([]string, error)

func (*Client) PodList added in v0.15.0 

func (k *Client) PodList(namespace string, opts *app.PodListOptions) ([]*app.Pod, error)

func (*Client) PodLogs added in v0.15.0 

func (k *Client) PodLogs(namespace string, podName string, opts *app.LogOptions) (io.ReadCloser, error)

func (*Client) PodRun added in v0.15.0 

func (k *Client) PodRun(podSpec *spec.Pod) (io.ReadCloser, <-chan int, error)

func (*Client) ReplicaSetListByLabel added in v0.15.0 

func (k *Client) ReplicaSetListByLabel(namespace, label, value string) ([]*deploy.ReplicaSetListItem, error)

func (*Client) ResumeCronJob added in v0.26.0 

func (k *Client) ResumeCronJob(namespace, name string) error

func (*Client) Service added in v0.24.0 

func (c *Client) Service(namespace, svcName string) (*spec.Service, error)

func (*Client) ServiceAnnotations added in v0.18.0 

func (c *Client) ServiceAnnotations(namespace, svcName string) (map[string]string, error)

func (*Client) SetIngressAnnotations added in v0.30.0 

func (c *Client) SetIngressAnnotations(namespace, ingName string, annotations map[string]string) error

func (*Client) SetLoadBalancerSourceRanges added in v0.24.0 

func (c *Client) SetLoadBalancerSourceRanges(namespace, svcName string, sourceRanges []string) error

func (*Client) SetNamespaceAnnotations added in v0.15.0 

func (k *Client) SetNamespaceAnnotations(namespace string, annotations map[string]string) error

func (*Client) SetNamespaceLabels added in v0.15.0 

func (k *Client) SetNamespaceLabels(namespace string, labels map[string]string) error

func (*Client) SetServiceAnnotations added in v0.18.0 

func (c *Client) SetServiceAnnotations(namespace, svcName string, annotations map[string]string) error

func (*Client) Status added in v0.15.0 

func (k *Client) Status(namespace string) (*app.Status, error)

func (*Client) SuspendCronJob added in v0.26.0 

func (k *Client) SuspendCronJob(namespace, name string) error

func (*Client) UpdateIngress added in v0.26.0 

func (k *Client) UpdateIngress(namespace, name string, vHosts []string) error

func (*Client) UpdateServicePorts added in v0.18.0 

func (c *Client) UpdateServicePorts(namespace, svcName string, ports []spec.ServicePort) error

func (*Client) WatchDeploy added in v0.20.0 

func (c *Client) WatchDeploy(namespace, deployName string) error

func (*Client) WatchServiceURL added in v0.20.0 

func (c *Client) WatchServiceURL(namespace, name string) ([]string, error)

type Config 

type Config struct {
	ConfigFile          string        `split_words:"true"`
	PodRunTimeout       time.Duration `split_words:"true" default:"30m"`
	Ingress             bool          `split_words:"true" default:"false"`
	CheckAnotherIngress bool          `split_words:"true" default:"true"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.