cloud

Documentation

Index

• Variables
• func Exists(path string) bool
• type AWSSession
  • 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
• type K8sClient
  • func GetKubernetesClient() (*K8sClient, error)
  • func (k8s *K8sClient) NewPod(ctx context.Context, name string, image string, namespace string, ...) (*Pod, error)
• type Mount
• type Pod
  • func (p *Pod) Close() error
  • func (p *Pod) Run(workDir string, cmdArgs []string) error

Variables

var Log func(string, ...interface{})

Functions

func Exists

func Exists(path string) bool

Types

type AWSSession

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

func NewAWSSession

func NewAWSSession(akid string, secret string, endpoint string, region string, bucket string) (*AWSSession, error)

func NewAWSSessionFromEnvironment

func NewAWSSessionFromEnvironment() (*AWSSession, error)

func (*AWSSession) Cancel

func (a *AWSSession) Cancel()

func (*AWSSession) DownloadCompressedDirectory

func (a *AWSSession) DownloadCompressedDirectory(s3FilePath string, localRootDirectory string) error

func (*AWSSession) DownloadFile

func (a *AWSSession) DownloadFile(s3FilePath string, localFile string) error

func (*AWSSession) GetBucket

func (a *AWSSession) GetBucket() string

func (*AWSSession) GetCredentials

func (a *AWSSession) GetCredentials() (credentials.Value, error)

func (*AWSSession) UploadCompressedDirectory

func (a *AWSSession) UploadCompressedDirectory(localDirectoy string, s3FilePath string) error

func (*AWSSession) UploadFile

func (a *AWSSession) UploadFile(localFile string, s3FilePath string) error

type Env

type Env struct {
	Name  string
	Value string
}

type K8sClient

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

func GetKubernetesClient

func GetKubernetesClient() (*K8sClient, error)

func (*K8sClient) NewPod

func (k8s *K8sClient) NewPod(ctx context.Context, name string, image string, namespace string, storageLimit string, workDir string, mount []Mount, environs []Env) (*Pod, error)

type Mount

type Mount struct {
	Name            string
	PathInContainer string
}

type Pod

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

func (*Pod) Close

func (p *Pod) Close() error

func (*Pod) Run

func (p *Pod) Run(workDir string, cmdArgs []string) error