local

package
v0.7.1 Latest Latest
Warning

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

Go to latest
Published: Jul 9, 2024 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source
const Port = 8000

Port is the default port that Airbyte will deploy to.

Variables

This section is empty.

Functions

This section is empty.

Types

type BrowserLauncher

type BrowserLauncher func(url string) error

BrowserLauncher primarily for testing purposes.

type Command

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

Command is the local command, responsible for installing, uninstalling, or other local actions.

func New

func New(provider k8s.Provider, opts ...Option) (*Command, error)

New creates a new Command

func (*Command) Install

func (c *Command) Install(ctx context.Context, opts InstallOpts) error

Install handles the installation of Airbyte

func (*Command) Status added in v0.6.0

func (c *Command) Status(_ context.Context) error

Status handles the status of local Airbyte.

func (*Command) Uninstall

func (c *Command) Uninstall(_ context.Context, opts UninstallOpts) error

Uninstall handles the uninstallation of Airbyte.

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type HelmClient

type HelmClient interface {
	AddOrUpdateChartRepo(entry repo.Entry) error
	GetChart(string, *action.ChartPathOptions) (*chart.Chart, string, error)
	GetRelease(name string) (*release.Release, error)
	InstallOrUpgradeChart(ctx context.Context, spec *helmclient.ChartSpec, opts *helmclient.GenericHelmOptions) (*release.Release, error)
	UninstallReleaseByName(string) error
}

HelmClient primarily for testing purposes

type InstallOpts added in v0.6.0

type InstallOpts struct {
	BasicAuthUser string
	BasicAuthPass string

	HelmChartVersion string
	ValuesFile       string
	Migrate          bool

	Docker *docker.Docker

	DockerServer string
	DockerUser   string
	DockerPass   string
	DockerEmail  string
}

type Option

type Option func(*Command)

Option for configuring the Command, primarily exists for testing

func WithBrowserLauncher

func WithBrowserLauncher(launcher BrowserLauncher) Option

WithBrowserLauncher define the browser launcher for this command.

func WithHTTPClient

func WithHTTPClient(client HTTPClient) Option

WithHTTPClient define the http client for this command.

func WithHelmClient

func WithHelmClient(client HelmClient) Option

WithHelmClient define the helm client for this command.

func WithK8sClient

func WithK8sClient(client k8s.Client) Option

WithK8sClient define the k8s client for this command.

func WithPortHTTP

func WithPortHTTP(port int) Option

func WithSpinner

func WithSpinner(spinner *pterm.SpinnerPrinter) Option

func WithTelemetryClient

func WithTelemetryClient(client telemetry.Client) Option

WithTelemetryClient define the telemetry client for this command.

func WithUserHome

func WithUserHome(home string) Option

WithUserHome define the user's home directory.

type UninstallOpts added in v0.6.0

type UninstallOpts struct {
	Persisted bool
}

Jump to

Keyboard shortcuts

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