service

Documentation

Index

• func DefaultK8s(kubecfg, kubectx string) (k8s.Client, error)
• func DefaultManagerClientFactory(kubeConfig, kubeContext string) (k8s.Client, goHelm.Client, error)
• func EnablePsql17() (bool, error)
• func SupportMinio() (bool, error)
• type BrowserLauncher
• type HTTPClient
• type InstallOpts
  • func (i *InstallOpts) DockerAuth() bool
• type Manager
  • func NewManager(provider k8s.Provider, opts ...Option) (*Manager, error)
  • func (m *Manager) Install(ctx context.Context, opts *InstallOpts) error
  • func (m *Manager) PrepImages(ctx context.Context, cluster k8s.Cluster, opts *InstallOpts, ...)
  • func (m *Manager) Status(ctx context.Context) error
  • func (m *Manager) Uninstall(_ context.Context, opts UninstallOpts) error
• type ManagerClientFactory
• type Option
  • func WithBrowserLauncher(launcher BrowserLauncher) Option
  • func WithDockerClient(client *docker.Docker) Option
  • func WithHTTPClient(client HTTPClient) Option
  • func WithHelmClient(client goHelm.Client) Option
  • func WithK8sClient(client k8s.Client) Option
  • func WithPortHTTP(port int) Option
  • func WithSpinner(spinner *pterm.SpinnerPrinter) Option
  • func WithTelemetryClient(client telemetry.Client) Option
  • func WithUserHome(home string) Option
• type UninstallOpts

Functions

func DefaultK8s

func DefaultK8s(kubecfg, kubectx string) (k8s.Client, error)

DefaultK8s returns the default k8s client

func DefaultManagerClientFactory

func DefaultManagerClientFactory(kubeConfig, kubeContext string) (k8s.Client, goHelm.Client, error)

DefaultManagerClientFactory initializes and returns the default Kubernetes and Helm clients for the service manager.

func EnablePsql17

func EnablePsql17() (bool, error)

EnablePsql17 checks if PostgreSQL data needs patching by examining the local PostgreSQL data directory. It returns true if the directory doesn't exist or contains PostgreSQL version 17. Otherwise it returns false.

func SupportMinio

func SupportMinio() (bool, error)

SupportMinio checks if a MinIO persistent volume directory exists on the local filesystem. It returns true if the MinIO data directory exists. Otherwise it returns false.

Types

type BrowserLauncher

type BrowserLauncher func(url string) error

BrowserLauncher primarily for testing purposes.

type HTTPClient

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

type InstallOpts

type InstallOpts struct {
	HelmChartVersion string
	HelmValuesYaml   string
	AirbyteChartLoc  string
	Secrets          []string
	Hosts            []string
	LocalStorage     bool
	EnablePsql17     bool

	DockerServer string
	DockerUser   string
	DockerPass   string
	DockerEmail  string

	NoBrowser bool
}

func (*InstallOpts) DockerAuth

func (i *InstallOpts) DockerAuth() bool

type Manager

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

Manager for the Abctl service.

func NewManager

func NewManager(provider k8s.Provider, opts ...Option) (*Manager, error)

NewManager initializes the service manager.

func (*Manager) Install

func (m *Manager) Install(ctx context.Context, opts *InstallOpts) error

Install handles the installation of Airbyte

func (*Manager) PrepImages

func (m *Manager) PrepImages(ctx context.Context, cluster k8s.Cluster, opts *InstallOpts, withImages ...string)

PrepImages determines the docker images needed by the chart, pulls them, and loads them into the cluster. This is best effort, so errors are dropped here.

func (*Manager) Status

func (m *Manager) Status(ctx context.Context) error

Status handles the status of local Airbyte.

func (*Manager) Uninstall

func (m *Manager) Uninstall(_ context.Context, opts UninstallOpts) error

Uninstall handles the uninstallation of Airbyte.

type ManagerClientFactory

type ManagerClientFactory func(kubeConfig, kubeContext string) (k8s.Client, goHelm.Client, error)

ManagerClientFactory creates and returns the Kubernetes and Helm clients needed by the service manager.

type Option

type Option func(*Manager)

Option for configuring the Manager, primarily exists for testing

func WithBrowserLauncher

func WithBrowserLauncher(launcher BrowserLauncher) Option

WithBrowserLauncher define the browser launcher for this command.

func WithDockerClient

func WithDockerClient(client *docker.Docker) Option

func WithHTTPClient

func WithHTTPClient(client HTTPClient) Option

WithHTTPClient define the http client for this command.

func WithHelmClient

func WithHelmClient(client goHelm.Client) 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

type UninstallOpts struct {
	Persisted bool
}