storage

README

Storage

專案提供檔案存取library，支援google storage及本地檔案存取

Example

本地檔案存

func main() {
	hdstorage := storage.NewHdStorage("./test")
	key, err := hdstorage.Save("hello.txt", []byte("hello world"))
	fmt.Println(key, err)
}

gcp檔案存取

func main() {
	gcpConf := &storage.GcpConf{
		CredentialsFile: "./serviceAccountKey.json",
	}
	ctx := context.Background()
	ctx, cancel := context.WithTimeout(ctx, time.Second*10)
	defer cancel()
	sto, err := gcpConf.NewStorage(ctx, "private_in_volunteer")
	if err != nil {
		fmt.Println(err)
		return
	}
	path, err := sto.Save("product/hello.txt", []byte("hello world"))
	fmt.Println(path, err)

	list, err := sto.List("product/")
	fmt.Println(list, err)

	exist, err := sto.FileExist("product/hello.txt")
	fmt.Println(exist, err)

	exist, err = sto.FileExist("product/not_exist.txt")
	fmt.Println(exist, err)

	data, err := sto.Get("product/hello.txt")
	fmt.Println(string(data), err)

	err = sto.Delete("product/hello.txt")
	fmt.Println(err)

	fmt.Println(sto.GetDownloadUrl("product/hello.txt"))
}

container服務

README

Documentation

Index

• Constants
• type Config
  • func GetConfigFromEnv() (*Config, error)
  • func (c *Config) Close() error
  • func (c *Config) Copy() cfg.ModelCfg
  • func (c *Config) Init(uuid string, di di.DI) error
• type DownloadUrl
• type GcpConf
  • func (gcp *GcpConf) NewStorage(ctx context.Context) (GcpStorage, error)
• type GcpConfigMap
  • func LoadGcpConfigMap(file string) (GcpConfigMap, error)
• type GcpDI
• type GcpStorage
• type GrpcGcpStorage
  • func NewGrpcGcpStorage(ctx context.Context, address string, channel string) (GrpcGcpStorage, error)
• type HdStorage
  • func NewHdStorage(path string) HdStorage
• type ModelDI
• type Perm
• type Storage

Constants

const (
	PermPublic  = Perm("public")
	PermPrivate = Perm("private")
	PermTmp     = Perm("tmp")
)

Types

type Config

type Config struct {
	ConfMapPath string `env:"GCP_CONF_MAP_PATH"`

	ModelDI

	ConfMap GcpConfigMap
	Log     log.Logger
}

func GetConfigFromEnv

func GetConfigFromEnv() (*Config, error)

func (*Config) Close

func (c *Config) Close() error

func (*Config) Copy

func (c *Config) Copy() cfg.ModelCfg

func (*Config) Init

func (c *Config) Init(uuid string, di di.DI) error

type DownloadUrl

type DownloadUrl struct {
	IsPublic    bool
	Url         string
	AccessToken *oauth2.Token
}

type GcpConf

type GcpConf struct {
	CredentialsFile string `yaml:"credentailsFile"`
	CredentailsUrl  string `yaml:"credentailsUrl"`
	Bucket          string `yaml:"bucket"`
}

func (*GcpConf) NewStorage

func (gcp *GcpConf) NewStorage(ctx context.Context) (GcpStorage, error)

type GcpConfigMap

type GcpConfigMap interface {
	GetConfig(key string) *GcpConf
}

func LoadGcpConfigMap

func LoadGcpConfigMap(file string) (GcpConfigMap, error)

type GcpDI

type GcpDI interface {
	NewStorage(ctx context.Context, bucket string) (GcpStorage, error)
}

type GcpStorage

type GcpStorage interface {
	Storage
	GetAttr(key string) (*googstorage.ObjectAttrs, error)
	GetDownloadUrl(key string) (myurl *DownloadUrl, err error)
	Write(key string, writeData func(w io.Writer) error) (path string, err error)
	OpenFile(key string) (io.Reader, error)
	SignedURL(key string, contentType string, expDuration time.Duration) (url string, err error)
	GetAccessToken() (*oauth2.Token, error)
}

type GrpcGcpStorage

type GrpcGcpStorage interface {
	GcpStorage
	Close()
}

func NewGrpcGcpStorage

func NewGrpcGcpStorage(ctx context.Context, address string, channel string) (GrpcGcpStorage, error)

type HdStorage

type HdStorage interface {
	Storage
	FullPath(key string) string
}

func NewHdStorage

func NewHdStorage(path string) HdStorage

type ModelDI

type ModelDI interface {
	log.LoggerDI
}

type Perm

type Perm string

type Storage

type Storage interface {
	Save(filePath string, file []byte) (string, error)
	SaveByReader(fp string, reader io.Reader) (string, error)
	Delete(filePath string) error
	Get(filePath string) ([]byte, error)
	FileExist(fp string) (bool, error)
	List(dir string) ([]string, error)
}