util

Documentation

Index

• func GetMinIOClient(cfg *pipelinesmeta.MinIOConfig, credsGetter MinIOCredentialsGetter) (*minio.Client, error)
• type MinIOCredentialsGetter
  • func MinIOSinkCredentialsFromEnv() MinIOCredentialsGetter
  • func MinIOSrcCredentialsFromEnv() MinIOCredentialsGetter
  • func MinIOWatchCredentialsFromCR(client client.Client, cr types.Pipeline) MinIOCredentialsGetter

Functions

func GetMinIOClient

func GetMinIOClient(cfg *pipelinesmeta.MinIOConfig, credsGetter MinIOCredentialsGetter) (*minio.Client, error)

GetMinIOClient is a utility function for returning a MinIO client to the given configuration.

Types

type MinIOCredentialsGetter

type MinIOCredentialsGetter interface {
	GetCredentials() (*credentials.Credentials, error)
}

MinIOCredentialsGetter is a credential getter for minio clients. Various credentials sources are implemented in this package.

func MinIOSinkCredentialsFromEnv

func MinIOSinkCredentialsFromEnv() MinIOCredentialsGetter

MinIOSinkCredentialsFromEnv returns a credentials getter that retrieves the credentials from the environment variables configured by the controller for the sink.

func MinIOSrcCredentialsFromEnv

func MinIOSrcCredentialsFromEnv() MinIOCredentialsGetter

MinIOSrcCredentialsFromEnv returns a credentials getter that retrieves the credentials from the environment variables configured by the controller for the src.

func MinIOWatchCredentialsFromCR

func MinIOWatchCredentialsFromCR(client client.Client, cr types.Pipeline) MinIOCredentialsGetter

MinIOWatchCredentialsFromCR returns a credentials getter that uses the given client and CR to produce credentials to the bucket being watched for transformations.