data_store

Documentation

Index

• Constants
• type DataStoreClient
  • func NewDataStoreClient(config DataStoreConfig) (DataStoreClient, error)
• type DataStoreConfig
• type IDataStoreClient
• type LocalClient
  • 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
  • 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

Constants

const (
	MinIOStorage = "minio"
	LocalStorage = "local"
)

Types

type DataStoreClient

type DataStoreClient struct {
	Client IDataStoreClient
}

func NewDataStoreClient

func NewDataStoreClient(config DataStoreConfig) (DataStoreClient, error)

type DataStoreConfig

type DataStoreConfig struct {
	Url      string
	User     string
	Password string
	Service  string
	DataPath string
}

type IDataStoreClient

type IDataStoreClient interface {
	GetFile(name string, location string) (*[]byte, error)
	UploadFile(name string, dest string) error
	List(dir string, prefix string) *[]string
	StorageType() string
}

type LocalClient

type LocalClient struct {
	DataPath string
}

func (LocalClient) GetFile

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

func (LocalClient) List

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

func (LocalClient) StorageType

func (c LocalClient) StorageType() string

func (LocalClient) UploadFile

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

type MinioClient

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

func (MinioClient) GetClient

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

func (MinioClient) GetFile

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

func (MinioClient) List

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

func (MinioClient) StorageType

func (c MinioClient) StorageType() string

func (MinioClient) UploadFile

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