filemanager

Dec 15, 2022

Changes in this version

type S3Manager

+ SessionConfig *awsutils.SessionConfig

+ func NewS3Manager(config map[string]interface{}) (*S3Manager, error)

Oct 20, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 19, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 19, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 19, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 14, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 12, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Changes in this version

type AzureBlobStorageConfig

+ Marker azblob.Marker

+ SASToken string

+ UseSASTokens bool

type DOSpacesConfig

+ ContinuationToken *string

+ IsTruncated bool

type GCSConfig

+ Iterator *storage.ObjectIterator

type MinioConfig

+ ContinuationToken string

+ IsTruncated bool

+ type ObjectIterator struct

+ func IterateFilesWithPrefix(ctx context.Context, startAfter, prefix string, maxItems int64, ...) *ObjectIterator

+ func (it *ObjectIterator) Err() error

+ func (it *ObjectIterator) Get() *FileObject

+ func (it *ObjectIterator) Next() bool

Sep 23, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Sep 15, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Sep 12, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Sep 8, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Aug 25, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Changes in this version

+ func GetProviderConfigForBackupsFromEnv(ctx context.Context) map[string]interface

type S3Config

+ ExternalID string

+ IAMRoleARN string

Oct 14, 2021 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Oct 14, 2021 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Changes in this version

+ type SpacesObject struct

+ Key string

+ LastModifiedTime time.Time

Aug 5, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jul 14, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jul 6, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jun 16, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jun 14, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Changes in this version

type AzureBlobStorageConfig

+ DisableSSL *bool

+ EndPoint *string

+ ForcePathStyle *bool

type AzureBlobStorageManager

+ Timeout *time.Duration

+ func (manager *AzureBlobStorageManager) DeleteObjects(ctx context.Context, keys []string) (err error)

+ func (manager *AzureBlobStorageManager) GetConfiguredPrefix() string

+ func (manager *AzureBlobStorageManager) GetDownloadKeyFromFileLocation(location string) string

+ func (manager *AzureBlobStorageManager) GetObjectNameFromLocation(location string) (string, error)

+ func (manager *AzureBlobStorageManager) ListFilesWithPrefix(ctx context.Context, prefix string, maxItems int64) (fileObjects []*FileObject, err error)

+ func (manager *AzureBlobStorageManager) SetTimeout(timeout *time.Duration)

+ type DOSpacesConfig struct

+ AccessKey string

+ AccessKeyID string

+ Bucket string

+ DisableSSL *bool

+ EndPoint string

+ ForcePathStyle *bool

+ Prefix string

+ Region *string

+ func GetDOSpacesConfig(config map[string]interface{}) *DOSpacesConfig

+ type DOSpacesManager struct

+ Config *DOSpacesConfig

+ Timeout *time.Duration

+ func (manager *DOSpacesManager) DeleteObjects(ctx context.Context, keys []string) (err error)

+ func (manager *DOSpacesManager) Download(ctx context.Context, output *os.File, key string) error

+ func (manager *DOSpacesManager) GetConfiguredPrefix() string

+ func (manager *DOSpacesManager) GetDownloadKeyFromFileLocation(location string) string

+ func (manager *DOSpacesManager) GetObjectNameFromLocation(location string) (string, error)

+ func (manager *DOSpacesManager) ListFilesWithPrefix(ctx context.Context, prefix string, maxItems int64) (fileObjects []*FileObject, err error)

+ func (manager *DOSpacesManager) SetTimeout(timeout *time.Duration)

+ func (manager *DOSpacesManager) Upload(ctx context.Context, file *os.File, prefixes ...string) (UploadOutput, error)

type FileManager

+ DeleteObjects func(ctx context.Context, keys []string) error

+ GetConfiguredPrefix func() string

+ GetDownloadKeyFromFileLocation func(location string) string

+ GetObjectNameFromLocation func(string) (string, error)

+ ListFilesWithPrefix func(ctx context.Context, prefix string, maxItems int64) (fileObjects []*FileObject, err error)

+ SetTimeout func(timeout *time.Duration)

+ type FileManagerFactory interface

+ New func(settings *SettingsT) (FileManager, error)

+ var DefaultFileManagerFactory FileManagerFactory

+ var ErrKeyNotFound = errors.New("NoSuchKey")

+ type FileManagerFactoryT struct

+ func (factory *FileManagerFactoryT) New(settings *SettingsT) (FileManager, error)

+ type FileObject struct

+ Key string

+ LastModified time.Time

type GCSConfig

+ DisableSSL *bool

+ EndPoint *string

+ ForcePathStyle *bool

type GCSManager

+ Timeout *time.Duration

+ func (manager *GCSManager) DeleteObjects(ctx context.Context, locations []string) (err error)

+ func (manager *GCSManager) GetConfiguredPrefix() string

+ func (manager *GCSManager) GetDownloadKeyFromFileLocation(location string) string

+ func (manager *GCSManager) GetObjectNameFromLocation(location string) (string, error)

+ func (manager *GCSManager) ListFilesWithPrefix(ctx context.Context, prefix string, maxItems int64) (fileObjects []*FileObject, err error)

+ func (manager *GCSManager) SetTimeout(timeout *time.Duration)

type MinioManager

+ Timeout *time.Duration

+ func (manager *MinioManager) DeleteObjects(ctx context.Context, keys []string) (err error)

+ func (manager *MinioManager) GetConfiguredPrefix() string

+ func (manager *MinioManager) GetDownloadKeyFromFileLocation(location string) string

+ func (manager *MinioManager) GetObjectNameFromLocation(location string) (string, error)

+ func (manager *MinioManager) ListFilesWithPrefix(ctx context.Context, prefix string, maxItems int64) (fileObjects []*FileObject, err error)

+ func (manager *MinioManager) SetTimeout(timeout *time.Duration)

type S3Config

+ ContinuationToken *string

+ DisableSSL *bool

+ EnableSSE bool

+ Endpoint *string

+ IsTruncated bool

+ Region *string

+ RegionHint string

+ S3ForcePathStyle *bool

+ StartAfter string

+ UseGlue bool

type S3Manager

+ Timeout *time.Duration

+ func (manager *S3Manager) DeleteObjects(ctx context.Context, keys []string) (err error)

+ func (manager *S3Manager) GetConfiguredPrefix() string

+ func (manager *S3Manager) GetDownloadKeyFromFileLocation(location string) string

+ func (manager *S3Manager) GetObjectNameFromLocation(location string) (string, error)

+ func (manager *S3Manager) SetTimeout(timeout *time.Duration)

type UploadOutput

+ ObjectName string

Jun 24, 2022 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Apr 30, 2020 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Changes in this version

+ func GetProviderConfigFromEnv() map[string]interface

+ type AzureBlobStorageConfig struct

+ AccountKey string

+ AccountName string

+ Container string

+ Prefix string

+ func GetAzureBlogStorageConfig(config map[string]interface{}) *AzureBlobStorageConfig

+ type AzureBlobStorageManager struct

+ Config *AzureBlobStorageConfig

+ func (manager *AzureBlobStorageManager) Download(output *os.File, key string) error

+ func (manager *AzureBlobStorageManager) Upload(file *os.File, prefixes ...string) (UploadOutput, error)

+ type FileManager interface

+ Download func(*os.File, string) error

+ Upload func(*os.File, ...string) (UploadOutput, error)

+ func New(settings *SettingsT) (FileManager, error)

+ type GCSConfig struct

+ Bucket string

+ Credentials string

+ Prefix string

+ func GetGCSConfig(config map[string]interface{}) *GCSConfig

+ type GCSManager struct

+ Config *GCSConfig

+ func (manager *GCSManager) Download(output *os.File, key string) error

+ func (manager *GCSManager) Upload(file *os.File, prefixes ...string) (UploadOutput, error)

+ type MinioConfig struct

+ AccessKeyID string

+ Bucket string

+ EndPoint string

+ Prefix string

+ SecretAccessKey string

+ UseSSL bool

+ func GetMinioConfig(config map[string]interface{}) *MinioConfig

+ type MinioManager struct

+ Config *MinioConfig

+ func (manager *MinioManager) Download(file *os.File, key string) error

+ func (manager *MinioManager) ObjectUrl(objectName string) string

+ func (manager *MinioManager) Upload(file *os.File, prefixes ...string) (UploadOutput, error)

+ type S3Config struct

+ AccessKey string

+ AccessKeyID string

+ Bucket string

+ Prefix string

+ func GetS3Config(config map[string]interface{}) *S3Config

+ type S3Manager struct

+ Config *S3Config

+ func (manager *S3Manager) Download(output *os.File, key string) error

+ func (manager *S3Manager) ListFilesWithPrefix(prefix string) ([]*S3Object, error)

+ func (manager *S3Manager) Upload(file *os.File, prefixes ...string) (UploadOutput, error)

+ type S3Object struct

+ Key string

+ LastModifiedTime time.Time

+ type SettingsT struct

+ Config map[string]interface{}

+ Provider string

+ type UploadOutput struct

+ Location string

Jun 20, 2020 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jun 16, 2020 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server

Jun 20, 2020 GO-2023-1863

  GO-2023-1863: rudder-server is vulnerable to SQL injection in github.com/rudderlabs/rudder-server