bucket_connector

Documentation

Index

• Constants
• func Module(scope string) fx.Option
• type BucketConnector
  • func (c *BucketConnector) DeleteFile(filePath string) error
  • func (c *BucketConnector) DeleteFileWithPrefix(filePath string) error
  • func (c *BucketConnector) GetBucket() *storage.BucketHandle
  • func (c *BucketConnector) GetClient() *storage.Client
  • func (c *BucketConnector) SaveFile(req *UploaderReq) (string, error)
  • func (c *BucketConnector) WriteAsFile(filePath string, content []byte) (string, error)
• type Params
• type UploaderReq

Constants

const (
	DefaultBucketName = "example.com"
	DefaultJsonKey    = "gcp.json"
)

Functions

func Module

func Module(scope string) fx.Option

Types

type BucketConnector

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

func (*BucketConnector) DeleteFile

func (c *BucketConnector) DeleteFile(filePath string) error

func (*BucketConnector) DeleteFileWithPrefix

func (c *BucketConnector) DeleteFileWithPrefix(filePath string) error

func (*BucketConnector) GetBucket

func (c *BucketConnector) GetBucket() *storage.BucketHandle

func (*BucketConnector) GetClient

func (c *BucketConnector) GetClient() *storage.Client

func (*BucketConnector) SaveFile

func (c *BucketConnector) SaveFile(req *UploaderReq) (string, error)

func (*BucketConnector) WriteAsFile

func (c *BucketConnector) WriteAsFile(filePath string, content []byte) (string, error)

type Params

type Params struct {
	fx.In

	Lifecycle fx.Lifecycle
	Logger    *zap.Logger
}

type UploaderReq

type UploaderReq struct {
	FileName string `json:"file_name"`
	Category string `json:"category"`
	RawData  string `json:"rowData"`
}