Versions in this module Expand all Collapse all v1 v1.0.1 Apr 30, 2025 v1.0.0 Mar 31, 2025 Changes in this version + type BufferedWriter struct + func NewBufferedWriter(writer io.Writer) *BufferedWriter + func (w *BufferedWriter) Bytes() []byte + func (w *BufferedWriter) Write(data []byte) (int, error) + type Docker struct + func NewDocker(executor os.CommandExecutor) *Docker + func (docker *Docker) Build(ctx context.Context, options *DockerBuildOptions) error + func (docker *Docker) Login(ctx context.Context, username, password, registryURL string) error + func (docker *Docker) NetworkGateway(ctx context.Context, name string) (string, error) + func (docker *Docker) NetworkInspect(ctx context.Context, name string) (*DockerNetwork, error) + func (docker *Docker) Pull(ctx context.Context, image string) error + func (docker *Docker) Push(ctx context.Context, image string) error + func (docker *Docker) Tag(ctx context.Context, oldImage, newImage string) error + type DockerBuildOptions struct + BuildArgs []string + CacheFrom []string + ContextDir string + File string + Hosts map[string]string + Tag string + Target string + type DockerNetwork struct + ID string + IPAM struct{ ... } + Name string + type ExecuteLogger struct + func NewExecuteLogger(osExecutor os.OsExecutor, log logger.Logger) *ExecuteLogger + func NewExecuteLoggerWithLogLevel(osExecutor os.OsExecutor, log logger.Logger, logLevel logger.Level) *ExecuteLogger + func (c *ExecuteLogger) Execute(cmd string, arg []string, env []string, dir string) ([]byte, []byte, error) + func (c *ExecuteLogger) ExecuteContext(ctx context.Context, cmd string, arg []string, env []string, dir string) ([]byte, []byte, error) + type Git struct + func NewGit(executor os.CommandExecutor, url, dir string, env []string) *Git + func (git *Git) Add(file string) error + func (git *Git) CheckoutClean() error + func (git *Git) Clone() error + func (git *Git) CloneWithoutCheckout() error + func (git *Git) Commit(message string) error + func (git *Git) Config(ctx context.Context, key, value string) error + func (git *Git) CreateAndSwitchToBranch(ctx context.Context, name string) error + func (git *Git) DeleteLocalBranch(ctx context.Context, name string) error + func (git *Git) DeleteRemoteBranch(ctx context.Context, name string) error + func (git *Git) DisableSparseCheckout() error + func (git *Git) EnableSparseCheckout() error + func (git *Git) Fetch() error + func (git *Git) GetCurrentHash() (string, error) + func (git *Git) GetCurrentHashForPath(path string) (string, error) + func (git *Git) GetURL() string + func (git *Git) HasDiff() (bool, error) + func (git *Git) ListBranches() ([]string, error) + func (git *Git) ListTags() ([]string, error) + func (git *Git) Pull() error + func (git *Git) Push(destination string, isForce bool) error + func (git *Git) SetSparseCheckoutPaths(paths []string) error + func (git *Git) SwitchAndReset(branch string) error + func (git *Git) SwitchToBranch(ctx context.Context, name string) error + type Helm struct + func NewHelm(executor os.CommandExecutor) *Helm + func (h *Helm) GetManifest(location string, name string, namespace string, ...) (string, error) + func (h *Helm) Package(dir, dest string) (string, error) + func (h *Helm) ResetExecutor(commandExecutor os.CommandExecutor) os.CommandExecutor + type Kubectl struct + GlobalOptions map[string]string + func NewKubectl(commandExecutor pkgOs.CommandExecutor, ...) *Kubectl + func (k *Kubectl) Apply(manifest string, namespace string) error + func (k *Kubectl) ApplyConfigmap(name, namespace string, data map[string]string) error + func (k *Kubectl) ApplyService(service *KubernetesService) error + func (k *Kubectl) ClusterInfo() error + func (k *Kubectl) Create(manifest string) error + func (k *Kubectl) Delete(manifest string) error + func (k *Kubectl) DeleteAllResources(namespace, resourceType string) error + func (k *Kubectl) DeleteAllResourcesByLabel(namespace string, labels map[string]string) error + func (k *Kubectl) DeleteResource(namespace, resourceType, resourceName string) error + func (k *Kubectl) GetIngressHost(namespace, name string) (string, error) + func (k *Kubectl) GetIngresses(namespace string) ([]*KubernetesIngress, error) + func (k *Kubectl) GetService(name, namespace string) (*KubernetesService, error) + func (k *Kubectl) GetServiceAccountSecret(namespace, name, dataKeyName string) (string, error) + func (k *Kubectl) GetServiceFQDN(namespace, serviceName string) (string, error) + func (k *Kubectl) GetServiceMeta(namespace, serviceName, key string) (string, error) + func (k *Kubectl) GetServicePort(namespace, serviceName, portName string) (string, error) + func (k *Kubectl) GetServices(namespace string) ([]*KubernetesService, error) + func (k *Kubectl) GetToken() ([]byte, error) + func (k *Kubectl) JobStatus(name, namespace string) (KubernetesJobStatus, error) + func (k *Kubectl) ResetExecutor(commandExecutor pkgOs.CommandExecutor) pkgOs.CommandExecutor + func (k *Kubectl) RolloutStatus(timeout time.Duration, resource, namespace string) error + type KubectlIngressInfo struct + Spec struct{ ... } + type KubectlInterface interface + Apply func(manifest string, namespace string) error + ApplyConfigmap func(name, namespace string, data map[string]string) error + ApplyService func(service *KubernetesService) error + ClusterInfo func() error + Create func(manifest string) error + Delete func(manifest string) error + DeleteAllResources func(namespace, resourceType string) error + DeleteAllResourcesByLabel func(namespace string, labels map[string]string) error + DeleteResource func(namespace, resourceType, resourceName string) error + GetIngressHost func(namespace, name string) (string, error) + GetIngresses func(namespace string) ([]*KubernetesIngress, error) + GetService func(name, namespace string) (*KubernetesService, error) + GetServiceAccountSecret func(namespace, name, dataKeyName string) (string, error) + GetServiceFQDN func(namespace, serviceName string) (string, error) + GetServiceMeta func(namespace, serviceName, key string) (string, error) + GetServicePort func(namespace, serviceName, portName string) (string, error) + GetServices func(namespace string) ([]*KubernetesService, error) + GetToken func() ([]byte, error) + JobStatus func(name, namespace string) (KubernetesJobStatus, error) + ResetExecutor func(commandExecutor pkgOs.CommandExecutor) pkgOs.CommandExecutor + RolloutStatus func(timeout time.Duration, resource, namespace string) error + type KubectlSecretInfo struct + Data struct{ ... } + type KubectlServiceAccountInfo struct + Secrets []struct{ ... } + type KubernetesIngress struct + Metadata *KubernetesIngressMetadata + Spec *KubernetesIngressSpec + type KubernetesIngressFirstAddress struct + Host string + type KubernetesIngressMetadata struct + Annotations map[string]string + Name string + Namespace string + type KubernetesIngressRule struct + Host string + type KubernetesIngressSpec struct + Rules []*KubernetesIngressRule + type KubernetesIngressesResponse struct + Items []*KubernetesIngress + type KubernetesJobStatus int + const KubernetesJobStatusActive + const KubernetesJobStatusComplete + const KubernetesJobStatusFailed + const KubernetesJobStatusUnknown + type KubernetesService struct + APIVersion string + Kind string + Metadata *KubernetesServiceMetadata + Spec *KubernetesServiceSpec + type KubernetesServiceMetadata struct + Annotations map[string]string + Labels map[string]string + Name string + Namespace string + type KubernetesServiceSpec struct + ClusterIP string + ExternalTrafficPolicy string + Ports []*KubernetesServiceSpecPort + Selector map[string]string + SessionAffinity string + Type string + type KubernetesServiceSpecPort struct + Name string + NodePort json.Number + Port json.Number + Protocol string + TargetPort json.Number + type KubernetesServicesResponse struct + Items []*KubernetesService + type RealtimeStdoutExecutor struct + func NewRealtimeStdoutExecutor(osExecutor os.OsExecutor) *RealtimeStdoutExecutor + func (executor *RealtimeStdoutExecutor) Execute(cmd string, arg []string, env []string, dir string) ([]byte, []byte, error) + func (executor *RealtimeStdoutExecutor) ExecuteContext(ctx context.Context, cmd string, arg []string, env []string, dir string) ([]byte, []byte, error) + type RealtimeWriter struct + func NewRealtimeWriter(log logger.Logger, logLevel logger.Level) *RealtimeWriter + func (writer *RealtimeWriter) GetOutput() string + func (writer *RealtimeWriter) Write(p []byte) (int, error)
Go to main page