local

Documentation

Index

• Variables
• type Cmd
  • func (c *Cmd) AfterApply(provider k8s.Provider) error
  • func (c *Cmd) BeforeApply() error
• type ContainerNotRunningError
  • func (e ContainerNotRunningError) Error() string
• type CredentialsCmd
  • func (cc *CredentialsCmd) Run(ctx context.Context, provider k8s.Provider, telClient telemetry.Client) error
• type DeploymentsCmd
  • func (d *DeploymentsCmd) Run(ctx context.Context, telClient telemetry.Client, k8sClient k8s.Client) error
• type InstallCmd
  • func (i *InstallCmd) InstallOpts(ctx context.Context, user string) (*local.InstallOpts, error)
  • func (i *InstallCmd) Run(ctx context.Context, provider k8s.Provider, telClient telemetry.Client) error
• type InvalidPortError
  • func (e InvalidPortError) Error() string
  • func (e InvalidPortError) Unwrap() error
• type StatusCmd
  • func (s *StatusCmd) Run(ctx context.Context, provider k8s.Provider, telClient telemetry.Client) error
• type UninstallCmd
  • func (u *UninstallCmd) Run(ctx context.Context, provider k8s.Provider, telClient telemetry.Client) error

Variables

var ErrPortNotFound = errors.New("no matching port found")

var ErrUnableToInspect = errors.New("unable to inspect container")

Types

type Cmd

type Cmd struct {
	Credentials CredentialsCmd `cmd:"" help:"Get local Airbyte user credentials."`
	Install     InstallCmd     `cmd:"" help:"Install local Airbyte."`
	Deployments DeploymentsCmd `cmd:"" help:"View local Airbyte deployments."`
	Status      StatusCmd      `cmd:"" help:"Get local Airbyte status."`
	Uninstall   UninstallCmd   `cmd:"" help:"Uninstall local Airbyte."`
}

func (*Cmd) AfterApply

func (c *Cmd) AfterApply(provider k8s.Provider) error

func (*Cmd) BeforeApply

func (c *Cmd) BeforeApply() error

type ContainerNotRunningError

type ContainerNotRunningError struct {
	Container string
	Status    string
}

func (ContainerNotRunningError) Error

func (e ContainerNotRunningError) Error() string

type CredentialsCmd

type CredentialsCmd struct {
	Email    string `help:"Specify a new email address to use for authentication."`
	Password string `help:"Specify a new password to use for authentication."`
}

func (*CredentialsCmd) Run

func (cc *CredentialsCmd) Run(ctx context.Context, provider k8s.Provider, telClient telemetry.Client) error

type DeploymentsCmd

type DeploymentsCmd struct {
	Restart string `help:"Deployment to restart."`
}

func (*DeploymentsCmd) Run

func (d *DeploymentsCmd) Run(ctx context.Context, telClient telemetry.Client, k8sClient k8s.Client) error

type InstallCmd

type InstallCmd struct {
	Chart           string   `help:"Path to chart." xor:"chartver"`
	ChartVersion    string   `help:"Version to install." xor:"chartver"`
	DockerEmail     string   `group:"docker" help:"Docker email." env:"ABCTL_LOCAL_INSTALL_DOCKER_EMAIL"`
	DockerPassword  string   `group:"docker" help:"Docker password." env:"ABCTL_LOCAL_INSTALL_DOCKER_PASSWORD"`
	DockerServer    string   `group:"docker" default:"https://index.docker.io/v1/" help:"Docker server." env:"ABCTL_LOCAL_INSTALL_DOCKER_SERVER"`
	DockerUsername  string   `group:"docker" help:"Docker username." env:"ABCTL_LOCAL_INSTALL_DOCKER_USERNAME"`
	Host            []string `help:"HTTP ingress host."`
	InsecureCookies bool     `help:"Allow cookies to be served over HTTP."`
	LowResourceMode bool     `help:"Run Airbyte in low resource mode."`
	Migrate         bool     `help:"Migrate data from a previous Docker Compose Airbyte installation."`
	NoBrowser       bool     `help:"Disable launching a browser post install."`
	Port            int      `default:"8000" help:"HTTP ingress port."`
	Secret          []string `type:"existingfile" help:"An Airbyte helm chart secret file."`
	Values          string   `type:"existingfile" help:"An Airbyte helm chart values file to configure helm."`
	Volume          []string `help:"Additional volume mounts. Must be in the format <HOST_PATH>:<GUEST_PATH>."`
}

func (*InstallCmd) InstallOpts

func (i *InstallCmd) InstallOpts(ctx context.Context, user string) (*local.InstallOpts, error)

func (*InstallCmd) Run

func (i *InstallCmd) Run(ctx context.Context, provider k8s.Provider, telClient telemetry.Client) error

type InvalidPortError

type InvalidPortError struct {
	Port  string
	Inner error
}

func (InvalidPortError) Error

func (e InvalidPortError) Error() string

func (InvalidPortError) Unwrap

func (e InvalidPortError) Unwrap() error

type StatusCmd

type StatusCmd struct{}

func (*StatusCmd) Run

func (s *StatusCmd) Run(ctx context.Context, provider k8s.Provider, telClient telemetry.Client) error

type UninstallCmd

type UninstallCmd struct {
	Persisted bool `help:"Remove persisted data."`
}

func (*UninstallCmd) Run

func (u *UninstallCmd) Run(ctx context.Context, provider k8s.Provider, telClient telemetry.Client) error