dao

Documentation

Index

• type Bfs
  • func NewBfs(c *conf.Config) *Bfs
  • func (b *Bfs) Authorize(key, secret, method, bucket, fileName string, expire int64) (authorization string)
  • func (b *Bfs) SpecificUpload(ctx context.Context, contentType, auth, bucket, fileName string, data []byte) (location, etag string, err error)
  • func (b *Bfs) Upload(ctx context.Context, up *model.UploadParam, data []byte) (location, etag string, err error)
• type Dao
  • func New(c *conf.Config) (dao *Dao)
  • func (d *Dao) Close()
  • func (d *Dao) CreateTable(c context.Context, table string) error
  • func (d *Dao) Ping(c context.Context) error

Types

type Bfs

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

Bfs .

func NewBfs

func NewBfs(c *conf.Config) *Bfs

NewBfs .

func (*Bfs) Authorize

func (b *Bfs) Authorize(key, secret, method, bucket, fileName string, expire int64) (authorization string)

Authorize .

func (*Bfs) SpecificUpload

func (b *Bfs) SpecificUpload(ctx context.Context, contentType, auth, bucket, fileName string, data []byte) (location, etag string, err error)

SpecificUpload .

func (*Bfs) Upload

func (b *Bfs) Upload(ctx context.Context, up *model.UploadParam, data []byte) (location, etag string, err error)

Upload with watermark

type Dao

type Dao struct {
	Bfs *Bfs
	// contains filtered or unexported fields
}

Dao dao

func New

func New(c *conf.Config) (dao *Dao)

New init mysql db

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) CreateTable

func (d *Dao) CreateTable(c context.Context, table string) error

CreateTable . TODO check namespace

func (*Dao) Ping

func (d *Dao) Ping(c context.Context) error

Ping dao ping