deploy

Documentation

Index

• type CmdRunResultBuffer
  • func NewCmdRunResultBuffer() *CmdRunResultBuffer
  • func (w *CmdRunResultBuffer) Copy() exec.CmdRunResult
  • func (w *CmdRunResultBuffer) WriteStderr(data []byte) (int, error)
  • func (w *CmdRunResultBuffer) WriteStdout(data []byte) (int, error)
• type Deploy
• type Factory
  • func NewFactory(coreClient kubernetes.Interface) Factory
  • func (f Factory) NewKapp(opts v1alpha1.AppDeployKapp, saName string, clusterOpts *v1alpha1.AppCluster, ...) (*Kapp, error)
  • func (f Factory) NewKappPrivileged(opts v1alpha1.AppDeployKapp, genericOpts GenericOpts, cancelCh chan struct{}) (*Kapp, error)
• type GenericOpts
• type Kapp
  • func NewKapp(opts v1alpha1.AppDeployKapp, genericOpts ProcessedGenericOpts, ...) *Kapp
  • func (a *Kapp) Delete(startedApplyingFunc func(), changedFunc func(exec.CmdRunResult)) exec.CmdRunResult
  • func (a *Kapp) Deploy(tplOutput string, startedApplyingFunc func(), ...) exec.CmdRunResult
  • func (a *Kapp) Inspect() exec.CmdRunResult
• type KubeconfigRestricted
  • func NewKubeconfigRestricted(input string) (*KubeconfigRestricted, error)
  • func (r *KubeconfigRestricted) AsYAML() string
• type KubeconfigSecrets
  • func NewKubeconfigSecrets(coreClient kubernetes.Interface) *KubeconfigSecrets
  • func (s *KubeconfigSecrets) Find(genericOpts GenericOpts, clusterOpts *v1alpha1.AppCluster) (ProcessedGenericOpts, error)
• type ProcessedGenericOpts
• type ServiceAccounts
  • func NewServiceAccounts(coreClient kubernetes.Interface) *ServiceAccounts
  • func (s *ServiceAccounts) Find(genericOpts GenericOpts, saName string) (ProcessedGenericOpts, error)
• type WriterFunc
  • func (f WriterFunc) Write(data []byte) (int, error)

Types

type CmdRunResultBuffer

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

func NewCmdRunResultBuffer

func NewCmdRunResultBuffer() *CmdRunResultBuffer

func (*CmdRunResultBuffer) Copy

func (w *CmdRunResultBuffer) Copy() exec.CmdRunResult

func (*CmdRunResultBuffer) WriteStderr

func (w *CmdRunResultBuffer) WriteStderr(data []byte) (int, error)

func (*CmdRunResultBuffer) WriteStdout

func (w *CmdRunResultBuffer) WriteStdout(data []byte) (int, error)

type Deploy

type Deploy interface {
	Deploy(tplOutput string, startedApplyingFunc func(),
		changedFunc func(exec.CmdRunResult)) exec.CmdRunResult

	Delete(startedApplyingFunc func(),
		changedFunc func(exec.CmdRunResult)) exec.CmdRunResult

	Inspect() exec.CmdRunResult
}

type Factory

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

func NewFactory

func NewFactory(coreClient kubernetes.Interface) Factory

func (Factory) NewKapp

func (f Factory) NewKapp(opts v1alpha1.AppDeployKapp, saName string,
	clusterOpts *v1alpha1.AppCluster, genericOpts GenericOpts, cancelCh chan struct{}) (*Kapp, error)

func (Factory) NewKappPrivileged

func (f Factory) NewKappPrivileged(opts v1alpha1.AppDeployKapp,
	genericOpts GenericOpts, cancelCh chan struct{}) (*Kapp, error)

NewKappPrivileged is used for package repositories where users aren't required to provide a service account, so it will install resources using its own privileges.

type GenericOpts

type GenericOpts struct {
	Name      string
	Namespace string
}

type Kapp

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

func NewKapp

func NewKapp(opts v1alpha1.AppDeployKapp, genericOpts ProcessedGenericOpts, cancelCh chan struct{}) *Kapp

NewKapp takes the kapp yaml from spec.deploy.kapp as arg kapp, additional info from the larger app resource (e.g. service account, name, namespace) as genericOpts, and a cancel channel that gets passed through to the exec call that runs kapp.

func (*Kapp) Delete

func (a *Kapp) Delete(startedApplyingFunc func(), changedFunc func(exec.CmdRunResult)) exec.CmdRunResult

func (*Kapp) Deploy

func (a *Kapp) Deploy(tplOutput string, startedApplyingFunc func(),
	changedFunc func(exec.CmdRunResult)) exec.CmdRunResult

func (*Kapp) Inspect

func (a *Kapp) Inspect() exec.CmdRunResult

type KubeconfigRestricted

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

func NewKubeconfigRestricted

func NewKubeconfigRestricted(input string) (*KubeconfigRestricted, error)

NewKubeconfigRestricted takes kubeconfig yaml as input and returns kubeconfig yaml with certain fields restricted (removed). Developers may find it informative to view their own config at ~/.kube/config

func (*KubeconfigRestricted) AsYAML

func (r *KubeconfigRestricted) AsYAML() string

type KubeconfigSecrets

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

func NewKubeconfigSecrets

func NewKubeconfigSecrets(coreClient kubernetes.Interface) *KubeconfigSecrets

func (*KubeconfigSecrets) Find

func (s *KubeconfigSecrets) Find(genericOpts GenericOpts,
	clusterOpts *v1alpha1.AppCluster) (ProcessedGenericOpts, error)

type ProcessedGenericOpts

type ProcessedGenericOpts struct {
	Name      string
	Namespace string

	Kubeconfig                    *KubeconfigRestricted
	DangerousUsePodServiceAccount bool
}

type ServiceAccounts

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

func NewServiceAccounts

func NewServiceAccounts(coreClient kubernetes.Interface) *ServiceAccounts

func (*ServiceAccounts) Find

func (s *ServiceAccounts) Find(genericOpts GenericOpts, saName string) (ProcessedGenericOpts, error)

type WriterFunc

type WriterFunc func([]byte) (int, error)

func (WriterFunc) Write

func (f WriterFunc) Write(data []byte) (int, error)