asset

Documentation

Index

• Variables
• type Asset
• type AssetRepo
• type AssetUsecase
  • func NewAssetUsecase(repo AssetRepo) *AssetUsecase
  • func (a *AssetUsecase) Create(ctx context.Context, data *Asset) (*Asset, error)
  • func (a *AssetUsecase) FindList(ctx context.Context, param FindListParams) ([]*Asset, error)
  • func (a *AssetUsecase) FindOne(ctx context.Context, id int) (*Asset, error)
  • func (a *AssetUsecase) FindOneWithInstance(ctx context.Context, queries ...Query) (*Asset, error)
  • func (a *AssetUsecase) Update(ctx context.Context, data *Asset) (*Asset, error)
• type FindListParams
• type Inquirer
• type Query
  • func Cache(ttl int) Query
  • func CitySpliderIDEQ(id int) Query
  • func IDEQ(id int) Query
  • func IDIn(ids ...int) Query
  • func Limit(limit int) Query
  • func Offset(offset int) Query
  • func Order(order ...string) Query
  • func SourceIDEQ(sourceID uint64) Query
  • func SourceIDIn(sourceIDs []uint64) Query
  • func StatusEQ(status Status) Query
• type Status
  • func (s Status) String() string

Variables

var (
	Status_name = map[Status]string{
		StatusWaitSync:   "待同步",
		StatusWaitLoaded: "待加载",
		StatusFinished:   "已完成",
	}
)

Types

type Asset

type Asset struct {
	ID            int
	CitySpliderID int
	SourceID      uint64
	FileTitle     string
	FilePath      string
	FileSize      uint
	Status        Status
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type AssetRepo

type AssetRepo interface {
	Count(ctx context.Context, options ...Query) int
	FindList(ctx context.Context, options ...Query) ([]*Asset, error)
	FindOne(ctx context.Context, options ...Query) (*Asset, error)
	Save(ctx context.Context, data *Asset) (*Asset, error)
	Remove(ctx context.Context, options ...Query) error
}

type AssetUsecase

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

func NewAssetUsecase

func NewAssetUsecase(
	repo AssetRepo,
) *AssetUsecase

func (*AssetUsecase) Create

func (a *AssetUsecase) Create(ctx context.Context, data *Asset) (*Asset, error)

func (*AssetUsecase) FindList

func (a *AssetUsecase) FindList(ctx context.Context, param FindListParams) ([]*Asset, error)

func (*AssetUsecase) FindOne

func (a *AssetUsecase) FindOne(ctx context.Context, id int) (*Asset, error)

func (*AssetUsecase) FindOneWithInstance

func (a *AssetUsecase) FindOneWithInstance(ctx context.Context, queries ...Query) (*Asset, error)

func (*AssetUsecase) Update

func (a *AssetUsecase) Update(ctx context.Context, data *Asset) (*Asset, error)

type FindListParams

type FindListParams struct {
	CitySpliderID int
	SourceID      uint64
	Status        int
	Page          int
	PageSize      int
}

type Inquirer

type Inquirer interface {
	Limit(limit int)
	Offset(offset int)
	Order(order ...string)
	IDEQ(id int)
	IDIn(ids ...int)
	CitySpliderIDEQ(id int)
	SourceIDEQ(sourceID uint64)
	SourceIDIn(sourceIDs []uint64)
	StatusEQ(status Status)
}

type Query

type Query func(Inquirer)

func Cache

func Cache(ttl int) Query

func CitySpliderIDEQ

func CitySpliderIDEQ(id int) Query

func IDEQ

func IDEQ(id int) Query

func IDIn

func IDIn(ids ...int) Query

func Limit

func Limit(limit int) Query

func Offset

func Offset(offset int) Query

func Order

func Order(order ...string) Query

func SourceIDEQ

func SourceIDEQ(sourceID uint64) Query

func SourceIDIn

func SourceIDIn(sourceIDs []uint64) Query

func StatusEQ

func StatusEQ(status Status) Query

type Status

type Status int

const (
	StatusWaitSync   Status = 1
	StatusWaitLoaded Status = 2
	StatusFinished   Status = 99
)

func (Status) String

func (s Status) String() string