data_store

Aug 30, 2023

Changes in this version

type DataStoreConfig

+ S3DelayRetries int

+ S3MaxRetries int

Aug 16, 2023

Changes in this version

+ var ErrFileNotFound = fmt.Errorf("file not found")

Apr 18, 2023

Changes in this version

+ const Localurl

type IDataStoreClient

+ DeleteFiles func(name string, location string) error

+ RenameFile func(oldName string, newName string, bucket string) error

type LocalClient

+ func (c *LocalClient) DeleteFiles(object string, bucket string) error

+ func (c *LocalClient) RenameFile(oldObject string, newObject string, bucket string) error

type MinioClient

+ func (c *MinioClient) DeleteFiles(object string, bucket string) error

+ func (c *MinioClient) RenameFile(oldObject string, newObject string, bucket string) error

type S5cmdClient

+ func (c *S5cmdClient) DeleteFiles(object string, bucket string) error

+ func (c *S5cmdClient) RenameFile(oldObject string, newObject string, bucket string) error

Mar 20, 2023

Changes in this version

type DataStoreConfig

+ NoVerifySSL bool

Mar 20, 2023

Changes in this version

+ const ContentType

+ const DataPath

+ const S3url

+ const S5Storage

type DataStoreConfig

+ ContentType string

type IDataStoreClient

+ UploadFromReader func(data io.Reader, size int64, destFolder string, destName string) error

type LocalClient

+ func (c *LocalClient) GetDataPath() string

+ func (c *LocalClient) UploadFromReader(data io.Reader, size int64, folder string, name string) error

type MinioClient

+ func (c *MinioClient) GetContentType() string

+ func (c *MinioClient) UploadFromReader(data io.Reader, size int64, folder string, name string) error

+ type S5cmdClient struct

+ func (c *S5cmdClient) GetClient() *s5store.S3

+ func (c *S5cmdClient) GetContentType() string

+ func (c *S5cmdClient) GetFile(object string, bucket string) ([]byte, error)

+ func (c *S5cmdClient) List(bucket string, prefix string) ([]string, error)

+ func (c *S5cmdClient) ListChan(ctx context.Context, bucket string, prefix string) (<-chan string, error)

+ func (c *S5cmdClient) StorageType() string

+ func (c *S5cmdClient) UploadFromBytes(data []byte, folder string, name string) error

+ func (c *S5cmdClient) UploadFromFile(name string, folder string) error

+ func (c *S5cmdClient) UploadFromReader(data io.Reader, size int64, folder string, name string) error

+ type S5cmdList struct

+ Key string

Mar 8, 2023

Changes in this version

type IDataStoreClient

+ ListChan func(ctx context.Context, dir string, prefix string) (<-chan string, error)

type LocalClient

+ func (c LocalClient) ListChan(ctx context.Context, bucket string, prefix string) (<-chan string, error)

type MinioClient

+ func (c MinioClient) ListChan(ctx context.Context, bucket string, prefix string) (<-chan string, error)

Mar 3, 2023

Changes in this version

+ const S3Storage

type DataStoreConfig

+ UseHttps bool

type IDataStoreClient

+ UploadFromBytes func(data []byte, destFolder string, destName string) error

+ UploadFromFile func(filePath string, dest string) error

type LocalClient

+ func (c LocalClient) UploadFromBytes(data []byte, destFolder string, destName string) error

+ func (c LocalClient) UploadFromFile(name string, dest string) error

type MinioClient

+ func (c MinioClient) UploadFromBytes(data []byte, destFolder string, destName string) error

+ func (c MinioClient) UploadFromFile(name string, dest string) error

Feb 9, 2022

Changes in this version

+ const LocalStorage

+ const MinIOStorage

+ type DataStoreClient struct

+ Client IDataStoreClient

+ func NewDataStoreClient(config DataStoreConfig) (DataStoreClient, error)

+ type DataStoreConfig struct

+ DataPath string

+ Password string

+ Service string

+ Url string

+ User string

+ type IDataStoreClient interface

+ GetFile func(name string, location string) (*[]byte, error)

+ List func(dir string, prefix string) *[]string

+ StorageType func() string

+ UploadFile func(name string, dest string) error

+ type LocalClient struct

+ DataPath string

+ func (c LocalClient) GetFile(object string, bucket string) (*[]byte, error)

+ func (c LocalClient) List(bucket string, prefix string) *[]string

+ func (c LocalClient) StorageType() string

+ func (c LocalClient) UploadFile(name string, dest string) error

+ type MinioClient struct

+ func (c MinioClient) GetClient() *minio.Client

+ func (c MinioClient) GetFile(object string, bucket string) (*[]byte, error)

+ func (c MinioClient) List(bucket string, prefix string) *[]string

+ func (c MinioClient) StorageType() string

+ func (c MinioClient) UploadFile(name string, dest string) error