filerepohelper

Documentation

Index

• type FileRepoHelper
  • func New(fileRepo repoiface.FileRepository, config FileTableShardingConfig) *FileRepoHelper
  • func (h *FileRepoHelper) Add(ctx context.Context, file *models.File) (err error)
  • func (h *FileRepoHelper) GetTableNameByHash() filerepo.GetTableNameFunc
  • func (h *FileRepoHelper) GetTableNameById() filerepo.GetTableNameFunc
  • func (h *FileRepoHelper) Remove(ctx context.Context, file *models.File) error
  • func (h *FileRepoHelper) Update(ctx context.Context, file *models.File) error
• type FileTableShardingConfig

Types

type FileRepoHelper

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

func New

func New(fileRepo repoiface.FileRepository, config FileTableShardingConfig) *FileRepoHelper

func (*FileRepoHelper) Add

func (h *FileRepoHelper) Add(ctx context.Context, file *models.File) (err error)

func (*FileRepoHelper) GetTableNameByHash

func (h *FileRepoHelper) GetTableNameByHash() filerepo.GetTableNameFunc

func (*FileRepoHelper) GetTableNameById

func (h *FileRepoHelper) GetTableNameById() filerepo.GetTableNameFunc

func (*FileRepoHelper) Remove

func (h *FileRepoHelper) Remove(ctx context.Context, file *models.File) error

func (*FileRepoHelper) Update

func (h *FileRepoHelper) Update(ctx context.Context, file *models.File) error

type FileTableShardingConfig

type FileTableShardingConfig interface {
	GetShardingNumber(tableName, domainName, bizName string) int64
}