storage

Documentation

Index

• Constants
• Variables
• type CloudClient
  • func NewCloudClient(cloudClient cloud.TestKubeCloudAPIClient, apiKey string) *CloudClient
  • func (c *CloudClient) CreateBucket(ctx context.Context, bucket string) error
  • func (c *CloudClient) DeleteBucket(ctx context.Context, bucket string, force bool) error
  • func (c *CloudClient) DeleteFile(ctx context.Context, bucketFolder, file string) error
  • func (c *CloudClient) DeleteFileFromBucket(ctx context.Context, bucket, bucketFolder, file string) error
  • func (c *CloudClient) DownloadFile(ctx context.Context, bucketFolder, file string) (*minio.Object, error)
  • func (c *CloudClient) DownloadFileFromBucket(ctx context.Context, bucket, bucketFolder, file string) (*minio.Object, error)
  • func (c *CloudClient) GetValidBucketName(parentType string, parentName string) string
  • func (c *CloudClient) ListBuckets(ctx context.Context) ([]string, error)
  • func (c *CloudClient) ListFiles(ctx context.Context, bucketFolder string) ([]testkube.Artifact, error)
  • func (c *CloudClient) PlaceFiles(ctx context.Context, bucketFolders []string, prefix string) error
  • func (c *CloudClient) SaveFile(ctx context.Context, bucketFolder, filePath string) error
  • func (c *CloudClient) UploadFile(ctx context.Context, bucketFolder string, filePath string, reader io.Reader, ...) error
  • func (c *CloudClient) UploadFileToBucket(ctx context.Context, bucket, bucketFolder, filePath string, reader io.Reader, ...) error
• type DeleteFileRequest
• type DeleteFileResponse
• type DownloadFileRequest
• type DownloadFileResponse
• type ListFilesRequest
• type ListFilesResponse
• type PlaceFilesRequest
• type PlaceFilesResponse
• type SaveFileRequest
• type SaveFileResponse

Constants

const (
	CmdStorageCreateBucket = "storage.createBucket"
	CmdStorageDeleteBucket = "storage.deleteBucket"
	CmdStorageListBuckets  = "storage.listBuckets"
	CmdStorageUploadFile   = "storage.uploadFile"
	CmdStorageDownloadFile = "storage.downloadFile"
	CmdStorageDeleteFile   = "storage.deleteFile"
	CmdStorageListFiles    = "storage.listFiles"
	CmdStorageSaveFile     = "storage.saveFile"
	CmdStoragePlaceFiles   = "storage.placeFiles"
)

Variables

var ErrNotAllowed = errors.New("operation not allowed in cloud mode")

Types

type CloudClient

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

func NewCloudClient

func NewCloudClient(cloudClient cloud.TestKubeCloudAPIClient, apiKey string) *CloudClient

func (*CloudClient) CreateBucket

func (c *CloudClient) CreateBucket(ctx context.Context, bucket string) error

func (*CloudClient) DeleteBucket

func (c *CloudClient) DeleteBucket(ctx context.Context, bucket string, force bool) error

func (*CloudClient) DeleteFile

func (c *CloudClient) DeleteFile(ctx context.Context, bucketFolder, file string) error

func (*CloudClient) DeleteFileFromBucket

func (c *CloudClient) DeleteFileFromBucket(ctx context.Context, bucket, bucketFolder, file string) error

func (*CloudClient) DownloadFile

func (c *CloudClient) DownloadFile(ctx context.Context, bucketFolder, file string) (*minio.Object, error)

func (*CloudClient) DownloadFileFromBucket

func (c *CloudClient) DownloadFileFromBucket(ctx context.Context, bucket, bucketFolder, file string) (*minio.Object, error)

func (*CloudClient) GetValidBucketName

func (c *CloudClient) GetValidBucketName(parentType string, parentName string) string

func (*CloudClient) ListBuckets

func (c *CloudClient) ListBuckets(ctx context.Context) ([]string, error)

func (*CloudClient) ListFiles

func (c *CloudClient) ListFiles(ctx context.Context, bucketFolder string) ([]testkube.Artifact, error)

func (*CloudClient) PlaceFiles

func (c *CloudClient) PlaceFiles(ctx context.Context, bucketFolders []string, prefix string) error

func (*CloudClient) SaveFile

func (c *CloudClient) SaveFile(ctx context.Context, bucketFolder, filePath string) error

func (*CloudClient) UploadFile

func (c *CloudClient) UploadFile(ctx context.Context, bucketFolder string, filePath string, reader io.Reader, objectSize int64) error

func (*CloudClient) UploadFileToBucket

func (c *CloudClient) UploadFileToBucket(ctx context.Context, bucket, bucketFolder, filePath string, reader io.Reader, objectSize int64) error

type DeleteFileRequest

type DeleteFileRequest struct {
	BucketFolder string
	File         string
}

type DeleteFileResponse

type DeleteFileResponse struct{}

type DownloadFileRequest

type DownloadFileRequest struct {
	BucketFolder string
	File         string
}

type DownloadFileResponse

type DownloadFileResponse struct {
	URL string
}

type ListFilesRequest

type ListFilesRequest struct {
	BucketFolder string
}

type ListFilesResponse

type ListFilesResponse struct {
	Artifacts []testkube.Artifact
}

type PlaceFilesRequest

type PlaceFilesRequest struct {
	BucketFolders []string
	Prefix        string
}

type PlaceFilesResponse

type PlaceFilesResponse struct{}

type SaveFileRequest

type SaveFileRequest struct {
	BucketFolder string
	FilePath     string
	Reader       io.Reader
	ObjectSize   int64
}

type SaveFileResponse

type SaveFileResponse struct{}