local

package
v0.30.3 Latest Latest
Warning

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

Go to latest
Published: Oct 24, 2025 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrPortNotFound = errors.New("no matching port found")
View Source
var ErrUnableToInspect = errors.New("unable to inspect container")

Functions

This section is empty.

Types

type Cmd added in v0.14.1

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 added in v0.14.1

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

func (*Cmd) BeforeApply added in v0.14.1

func (c *Cmd) BeforeApply() error

type ContainerNotRunningError added in v0.14.1

type ContainerNotRunningError struct {
	Container string
	Status    string
}

func (ContainerNotRunningError) Error added in v0.14.1

func (e ContainerNotRunningError) Error() string

type CredentialsCmd added in v0.14.1

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 added in v0.14.1

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

type DeploymentsCmd added in v0.14.1

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

func (*DeploymentsCmd) Run added in v0.14.1

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

type InstallCmd added in v0.14.1

type InstallCmd struct {
	Chart           string   `help:"Path to chart." xor:"chartver"`
	ChartVersion    string   `help:"Version to install." xor:"chartver"`
	DisableAuth     bool     `help:"Disable auth."`
	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."`
	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>."`
}

InstallCmd contains the arguments used when executing the install command.

func (*InstallCmd) Run added in v0.14.1

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

Run executes the install command which creates the Kind cluster and installs the Airbyte service.

type InvalidPortError added in v0.14.1

type InvalidPortError struct {
	Port  string
	Inner error
}

func (InvalidPortError) Error added in v0.14.1

func (e InvalidPortError) Error() string

func (InvalidPortError) Unwrap added in v0.14.1

func (e InvalidPortError) Unwrap() error

type StatusCmd added in v0.14.1

type StatusCmd struct{}

func (*StatusCmd) Run added in v0.14.1

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

type UninstallCmd added in v0.14.1

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

func (*UninstallCmd) Run added in v0.14.1

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL