minio

package
v1.16.25-beta003 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 31, 2024 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrArtifactsNotFound = errors.New("Execution doesn't have any artifacts associated with it")

ErrArtifactsNotFound contains error for not existing artifacts

Functions

This section is empty.

Types

type ArtifactClient added in v1.10.41 

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

func NewMinIOArtifactClient added in v1.10.41 

func NewMinIOArtifactClient(client storage.Client) *ArtifactClient

NewMinIOArtifactClient returns new MinIO client

func (*ArtifactClient) DownloadArchive added in v1.10.45 

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

DownloadArrchive downloads archive from bucket from the config

func (*ArtifactClient) DownloadFile added in v1.10.41 

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

DownloadFile downloads file from bucket from the config

func (*ArtifactClient) GetValidBucketName added in v1.10.44 

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

func (*ArtifactClient) ListFiles added in v1.10.41 

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

ListFiles lists available files in the bucket from the config

func (*ArtifactClient) PlaceFiles added in v1.10.44 

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

PlaceFiles saves the content of the buckets to the filesystem

func (*ArtifactClient) UploadFile added in v1.10.44 

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

UploadFile saves a file to be copied into a running execution

type Client 

type Client struct {
	Log *zap.SugaredLogger
	// contains filtered or unexported fields
}

Client for managing MinIO storage server

func NewClient 

func NewClient(endpoint, accessKeyID, secretAccessKey, region, token, bucket string, opts ...Option) *Client

NewClient returns new MinIO client

func (*Client) Connect added in v0.6.16 

func (c *Client) Connect() error

Connect connects to MinIO server

func (*Client) CreateBucket 

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

CreateBucket creates new S3 like bucket

func (*Client) DeleteBucket 

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

DeleteBucket deletes bucket by name

func (*Client) DeleteFile added in v1.8.20 

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

DeleteFile deletes a file from a bucket folder where bucket is provided by config

func (*Client) DeleteFileFromBucket added in v1.9.3 

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

DeleteFileFromBucket deletes a file from a bucket folder

func (*Client) DownloadArchive added in v1.10.45 

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

DownloadArchive downloads archive from bucket from the config

func (*Client) DownloadArchiveFromBucket added in v1.10.45 

func (c *Client) DownloadArchiveFromBucket(ctx context.Context, bucket, bucketFolder string, masks []string) (io.Reader, error)

DownloadArrchiveFromBucket downloads archive from given bucket

func (*Client) DownloadFile 

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

DownloadFile downloads file from bucket from the config

func (*Client) DownloadFileFromBucket added in v1.9.3 

func (c *Client) DownloadFileFromBucket(ctx context.Context, bucket, bucketFolder, file string) (io.Reader, error)

DownloadFileFromBucket downloads file from given bucket

func (*Client) GetValidBucketName added in v1.6.38 

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

GetValidBucketName returns a minio-compatible bucket name

func (*Client) IsConnectionPossible added in v1.14.0 

func (c *Client) IsConnectionPossible(ctx context.Context) (bool, error)

IsConnectionPossible checks if the connection to minio is possible

func (*Client) ListBuckets 

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

ListBuckets lists available buckets

func (*Client) ListFiles 

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

ListFiles lists available files in the bucket from the config

func (*Client) PlaceFiles added in v1.6.38 

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

PlaceFiles saves the content of the buckets to the filesystem

func (*Client) SaveFile 

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

SaveFile saves file defined by local filePath to S3 bucket from the config

func (*Client) SaveFileDirect added in v1.9.23 

func (c *Client) SaveFileDirect(ctx context.Context, folder, file string, data io.Reader, size int64, opts minio.PutObjectOptions) error

func (*Client) ScrapeArtefacts 

func (c *Client) ScrapeArtefacts(ctx context.Context, id string, directories ...string) error

ScrapeArtefacts pushes local files located in directories to given folder with given id located in the configured bucket

func (*Client) SetExpirationPolicy added in v1.10.47 

func (c *Client) SetExpirationPolicy(expirationDays int) error

func (*Client) UploadFile added in v1.6.38 

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

UploadFile saves a file to be copied into a running execution

func (*Client) UploadFileToBucket added in v1.9.3 

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

UploadFileToBucket saves a file to be copied into a running execution

type Connecter added in v1.16.25 

type Connecter struct {
	Endpoint        string
	AccessKeyID     string
	SecretAccessKey string
	Region          string
	Token           string
	Bucket          string
	Ssl             bool
	TlsConfig       *tls.Config
	Opts            []Option
	Log             *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewConnecter added in v1.16.25 

func NewConnecter(endpoint, accessKeyID, secretAccessKey, region, token, bucket string, log *zap.SugaredLogger, opts ...Option) *Connecter

NewConnecter creates a new Connecter

func (*Connecter) GetClient added in v1.16.25 

func (c *Connecter) GetClient() (*minio.Client, error)

GetClient() connects to MinIO

type Option added in v1.16.10 

type Option func(*Connecter) error

func ClientCert added in v1.16.10 

func ClientCert(certFile, keyFile string) Option

ClientCert is a helper option to provide the client certificate from a file. If Secure is not already set this will set it as well.

func GetTLSOptions added in v1.16.10 

func GetTLSOptions(ssl, skipVerify bool, certFile, keyFile, caFile string) []Option

func Insecure added in v1.16.10 

func Insecure() Option

Insecure is an Option to enable TLS secure connections that skip server verification.

func RootCAs added in v1.16.10 

func RootCAs(file ...string) Option

RootCAs is a helper option to provide the RootCAs pool from a list of filenames. If Secure is not already set this will set it as well.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.