Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

executor

package

Go to main page

Versions in this module

v1

v1.1.0

Apr 23, 2026

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)