implementations

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

type DummyFlattener struct {
}

type FileAdapter interface {
	io.Closer
	Type() string
	Ping() error
	UploadBytes(fileName string, fileBytes []byte) error
	Upload(fileName string, fileReader io.ReadSeeker) error
	// GetObjectURL returns http URL to uploaded object.
	// It is short-lived signed URL if the corresponding setting (e.g. S3Config.UsePresignedURL ) is enabled on adapter config
	// Otherwise, it returns URL build with public URL template which won't work if the object is private
	GetObjectURL(fileName string) (url string, err error)
	Download(fileName string) ([]byte, error)
	DeleteObject(key string) error
	Path(fileName string) string
	AddFileExtension(fileName string) string
	Format() types.FileFormat
	Compression() types.FileCompression
}

type FileConfig struct {
	Folder      string                `mapstructure:"folder" json:"folder,omitempty" yaml:"folder,omitempty"`
	Format      types.FileFormat      `mapstructure:"format,omitempty" json:"format,omitempty" yaml:"format,omitempty"`
	Compression types.FileCompression `mapstructure:"compression,omitempty" json:"compression,omitempty" yaml:"compression,omitempty"`
}

type Flattener interface {
	FlattenObject(object types.Object, notFlatteningKeys types2.Set[string]) (types.Object, error)
}

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

type GoogleCloudStorage struct {
	AbstractFileAdapter
	// contains filtered or unexported fields
}

type GoogleConfig struct {
	FileConfig `mapstructure:",squash" json:",inline" yaml:",inline"`
	Bucket     string `mapstructure:"gcsBucket,omitempty" json:"gcsBucket,omitempty" yaml:"gcsBucket,omitempty"`
	Project    string `mapstructure:"project,omitempty" json:"project,omitempty" yaml:"project,omitempty"`
	Dataset    string `mapstructure:"bqDataset,omitempty" json:"bqDataset,omitempty" yaml:"bqDataset,omitempty"`
	KeyFile    any    `mapstructure:"keyFile,omitempty" json:"keyFile,omitempty" yaml:"keyFile,omitempty"`

	//will be set on validation
	Credentials option.ClientOption
}

type S3 struct {
	AbstractFileAdapter
	// contains filtered or unexported fields
}

type S3Config struct {
	FileConfig           `mapstructure:",squash" json:",inline" yaml:",inline"`
	AuthenticationMethod string `mapstructure:"authenticationMethod,omitempty" json:"authenticationMethod,omitempty" yaml:"authenticationMethod,omitempty"`
	AccessKeyID          string `mapstructure:"accessKeyId,omitempty" json:"accessKeyId,omitempty" yaml:"accessKeyId,omitempty"`
	SecretAccessKey      string `mapstructure:"secretAccessKey,omitempty" json:"secretAccessKey,omitempty" yaml:"secretAccessKey,omitempty"`
	Bucket               string `mapstructure:"bucket,omitempty" json:"bucket,omitempty" yaml:"bucket,omitempty"`
	Region               string `mapstructure:"region,omitempty" json:"region,omitempty" yaml:"region,omitempty"`
	Endpoint             string `mapstructure:"endpoint,omitempty" json:"endpoint,omitempty" yaml:"endpoint,omitempty"`
	UsePresignedURL      bool   `mapstructure:"usePresignedURL,omitempty" json:"usePresignedURL,omitempty" yaml:"usePresignedURL,omitempty"`

	RoleARN       string        `mapstructure:"roleARN" json:"roleARN" yaml:"roleARN"`
	RoleARNExpiry time.Duration `json:"roleARNExpiry"` // default: 15m
	ExternalID    string        `mapstructure:"externalID" json:"externalID" yaml:"externalID"`
}