artifact

Documentation

Index

• Constants
• Variables
• type CloudArtifactsStorage
  • func NewCloudArtifactsStorage(cloudClient cloud.TestKubeCloudAPIClient, grpcConn *grpc.ClientConn, ...) *CloudArtifactsStorage
  • func (c *CloudArtifactsStorage) DownloadArchive(ctx context.Context, executionID string, masks []string) (io.Reader, error)
  • func (c *CloudArtifactsStorage) DownloadFile(ctx context.Context, file, executionID, testName, testSuiteName string) (io.Reader, error)
  • func (c *CloudArtifactsStorage) GetValidBucketName(parentType string, parentName string) string
  • func (c *CloudArtifactsStorage) ListFiles(ctx context.Context, executionID, testName, testSuiteName string) ([]testkube.Artifact, error)
  • func (c *CloudArtifactsStorage) PlaceFiles(ctx context.Context, bucketFolders []string, prefix string) error
  • func (c *CloudArtifactsStorage) UploadFile(ctx context.Context, bucketFolder string, filePath string, reader io.Reader, ...) error
• type CloudUploader
  • func NewCloudUploader(executor executor.Executor) *CloudUploader
  • func (u *CloudUploader) Close() error
  • func (u *CloudUploader) Upload(ctx context.Context, object *scraper.Object, execution testkube.Execution) error
• type DownloadFileRequest
• type DownloadFileResponse
• type ListFilesRequest
• type ListFilesResponse
• type PutObjectSignedURLRequest
• type PutObjectSignedURLResponse

Constants

const (
	CmdArtifactsListFiles    executor.Command = "artifacts.listFiles"
	CmdArtifactsDownloadFile executor.Command = "artifacts.downloadFile"
)

const (
	CmdScraperPutObjectSignedURL executor.Command = "put_object_signed_url"
)

Variables

var ErrOperationNotSupported = errors.New("operation not supported")

Types

type CloudArtifactsStorage

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

func NewCloudArtifactsStorage

func NewCloudArtifactsStorage(cloudClient cloud.TestKubeCloudAPIClient, grpcConn *grpc.ClientConn, apiKey string) *CloudArtifactsStorage

func (*CloudArtifactsStorage) DownloadArchive

func (c *CloudArtifactsStorage) DownloadArchive(ctx context.Context, executionID string, masks []string) (io.Reader, error)

func (*CloudArtifactsStorage) DownloadFile

func (c *CloudArtifactsStorage) DownloadFile(ctx context.Context, file, executionID, testName, testSuiteName string) (io.Reader, error)

func (*CloudArtifactsStorage) GetValidBucketName

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

func (*CloudArtifactsStorage) ListFiles

func (c *CloudArtifactsStorage) ListFiles(ctx context.Context, executionID, testName, testSuiteName string) ([]testkube.Artifact, error)

func (*CloudArtifactsStorage) PlaceFiles

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

func (*CloudArtifactsStorage) UploadFile

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

type CloudUploader

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

func NewCloudUploader

func NewCloudUploader(executor executor.Executor) *CloudUploader

func (*CloudUploader) Close

func (u *CloudUploader) Close() error

func (*CloudUploader) Upload

func (u *CloudUploader) Upload(ctx context.Context, object *scraper.Object, execution testkube.Execution) error

type DownloadFileRequest

type DownloadFileRequest struct {
	File          string
	ExecutionID   string
	TestName      string
	TestSuiteName string
}

type DownloadFileResponse

type DownloadFileResponse struct {
	URL string
}

type ListFilesRequest

type ListFilesRequest struct {
	ExecutionID   string
	TestName      string
	TestSuiteName string
}

type ListFilesResponse

type ListFilesResponse struct {
	Artifacts []testkube.Artifact
}

type PutObjectSignedURLRequest

type PutObjectSignedURLRequest struct {
	Object        string `json:"object"`
	ExecutionID   string `json:"executionId"`
	TestName      string `json:"testName"`
	TestSuiteName string `json:"testSuiteName"`
}

type PutObjectSignedURLResponse

type PutObjectSignedURLResponse struct {
	URL string
}