Documentation ¶
Index ¶
- func ValidateSTSProvider(bucketProvider string, sts *sourcev1.BucketSTSSpec) error
- func ValidateSTSSecret(stsProvider string, secret *corev1.Secret) error
- func ValidateSecret(secret *corev1.Secret) error
- type MinioClient
- func (c *MinioClient) Close(_ context.Context)
- func (c *MinioClient) FGetObject(ctx context.Context, bucketName, objectName, localPath string) (string, error)
- func (c *MinioClient) ObjectIsNotFound(err error) bool
- func (c *MinioClient) VisitObjects(ctx context.Context, bucketName string, prefix string, ...) error
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ValidateSTSProvider ¶ added in v1.4.0
func ValidateSTSProvider(bucketProvider string, sts *sourcev1.BucketSTSSpec) error
ValidateSTSProvider validates the STS provider.
func ValidateSTSSecret ¶ added in v1.4.0
ValidateSTSSecret validates the STS secret. The provided Secret may be nil.
func ValidateSecret ¶
ValidateSecret validates the credential secret. The provided Secret may be nil.
Types ¶
type MinioClient ¶
type MinioClient struct {
*minio.Client
}
MinioClient is a minimal Minio client for fetching files from S3 compatible storage APIs.
func NewClient ¶
func NewClient(bucket *sourcev1.Bucket, opts ...Option) (*MinioClient, error)
NewClient creates a new Minio storage client.
func (*MinioClient) Close ¶
func (c *MinioClient) Close(_ context.Context)
Close closes the Minio Client and logs any useful errors.
func (*MinioClient) FGetObject ¶
func (c *MinioClient) FGetObject(ctx context.Context, bucketName, objectName, localPath string) (string, error)
FGetObject gets the object from the provided object storage bucket, and writes it to targetPath. It returns the etag of the successfully fetched file, or any error.
func (*MinioClient) ObjectIsNotFound ¶
func (c *MinioClient) ObjectIsNotFound(err error) bool
ObjectIsNotFound checks if the error provided is a minio.ErrResponse with "NoSuchKey" code.
func (*MinioClient) VisitObjects ¶
func (c *MinioClient) VisitObjects(ctx context.Context, bucketName string, prefix string, visit func(key, etag string) error) error
VisitObjects iterates over the items in the provided object storage bucket, calling visit for every item. If the underlying client or the visit callback returns an error, it returns early.
type Option ¶ added in v1.4.0
type Option func(*options)
Option is a function that configures the Minio client.
func WithProxyURL ¶ added in v1.4.0
WithProxyURL sets the proxy URL for the Minio client.
func WithSTSSecret ¶ added in v1.4.0
WithSTSSecret sets the STS secret for the Minio client.
func WithSTSTLSConfig ¶ added in v1.4.0
WithSTSTLSConfig sets the STS TLS configuration for the Minio client.
func WithSecret ¶ added in v1.4.0
WithSecret sets the secret for the Minio client.
func WithTLSConfig ¶ added in v1.4.0
WithTLSConfig sets the TLS configuration for the Minio client.