Versions in this module Expand all Collapse all v1 v1.5.0 Apr 3, 2024 v1.4.0 Mar 29, 2023 Changes in this version + var Log func(string, ...interface{}) + func Exists(path string) bool + type AWSSession struct + func NewAWSSession(akid string, secret string, endpoint string, region string, bucket string) (*AWSSession, error) + func NewAWSSessionFromEnvironment() (*AWSSession, error) + func (a *AWSSession) Cancel() + func (a *AWSSession) DownloadCompressedDirectory(s3FilePath string, localRootDirectory string) error + func (a *AWSSession) DownloadFile(s3FilePath string, localFile string) error + func (a *AWSSession) GetBucket() string + func (a *AWSSession) GetCredentials() (credentials.Value, error) + func (a *AWSSession) UploadCompressedDirectory(localDirectoy string, s3FilePath string) error + func (a *AWSSession) UploadFile(localFile string, s3FilePath string) error + type Env struct + Name string + Value string + type K8sClient struct + func GetKubernetesClient() (*K8sClient, error) + func (k8s *K8sClient) NewPod(ctx context.Context, name string, image string, namespace string, ...) (*Pod, error) + type Mount struct + Name string + PathInContainer string + type Pod struct + func (p *Pod) Close() error + func (p *Pod) Run(workDir string, cmdArgs []string) error