repo

Documentation

Index

• type AkunItem
• type AkunRepo
  • func NewAkunRepo(db *gorm.DB) *AkunRepo
• type AkunUploadIterator
  • func NewAkunUploadIterator(db *gorm.DB) *AkunUploadIterator
  • func (iter *AkunUploadIterator) DeactiveAll() error
  • func (iter *AkunUploadIterator) Get() (akun *AkunItem, updateinc func(count int, err error) error, ...)
  • func (iter *AkunUploadIterator) GetStatus() (*UploadStatus, error)
  • func (iter *AkunUploadIterator) InProcessCount() (int64, error)
  • func (iter *AkunUploadIterator) Reset() error
• type AkunUploadStatus
• type BaseInterface
• type CategoryRepo
  • func NewCategoryRepo(base BaseInterface) *CategoryRepo
  • func (repo *CategoryRepo) Get() *api.CategoryAllListLiteRes
  • func (repo *CategoryRepo) Save() error
  • func (repo *CategoryRepo) UpdateCateg(payload *UpdateTopedCategoryPayload) error
• type ProductAggregateIpml
  • func (agg *ProductAggregateIpml) IterCategory(namespace string, ...) error
• type TopedAggregateCategory
• type UpdateTopedCategoryPayload
• type UploadStatus

Types

type AkunItem

type AkunItem struct {
	AkunUploadStatus
	Username     string `json:"username" gorm:"primarykey"`
	Password     string `json:"password"`
	Secret       string `json:"secret"`
	Markup       string `json:"markup"`
	Spin         string `json:"spin"`
	Collection   string `json:"collection"`
	Hastag       string `json:"hastag"`
	TitlePattern string `json:"title_pattern"`
}

type AkunRepo

type AkunRepo struct {
	DB *gorm.DB
}

func NewAkunRepo

func NewAkunRepo(db *gorm.DB) *AkunRepo

type AkunUploadIterator

type AkunUploadIterator struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewAkunUploadIterator

func NewAkunUploadIterator(db *gorm.DB) *AkunUploadIterator

func (*AkunUploadIterator) DeactiveAll

func (iter *AkunUploadIterator) DeactiveAll() error

func (*AkunUploadIterator) Get

func (iter *AkunUploadIterator) Get() (akun *AkunItem, updateinc func(count int, err error) error, finish func() error, err error)

func (*AkunUploadIterator) GetStatus

func (iter *AkunUploadIterator) GetStatus() (*UploadStatus, error)

func (*AkunUploadIterator) InProcessCount

func (iter *AkunUploadIterator) InProcessCount() (int64, error)

func (*AkunUploadIterator) Reset

func (iter *AkunUploadIterator) Reset() error

type AkunUploadStatus

type AkunUploadStatus struct {
	LimitUpload int    `json:"limit_upload"`
	CountUpload int    `json:"count_upload"`
	Active      bool   `json:"active_upload"`
	Lastup      int64  `json:"lastup"`
	InUpload    bool   `json:"in_upload"`
	LastError   string `json:"last_error"`
}

type BaseInterface

type BaseInterface interface {
	Path(item ...string) string
}

type CategoryRepo

type CategoryRepo struct {
	Data *api.CategoryAllListLiteRes
	// contains filtered or unexported fields
}

func NewCategoryRepo

func NewCategoryRepo(base BaseInterface) *CategoryRepo

func (*CategoryRepo) Get

func (repo *CategoryRepo) Get() *api.CategoryAllListLiteRes

func (*CategoryRepo) Save

func (repo *CategoryRepo) Save() error

func (*CategoryRepo) UpdateCateg

func (repo *CategoryRepo) UpdateCateg(payload *UpdateTopedCategoryPayload) error

type ProductAggregateIpml

type ProductAggregateIpml struct {
	Collection *mongo.Collection
}

func (*ProductAggregateIpml) IterCategory

func (agg *ProductAggregateIpml) IterCategory(namespace string, handler func(tokopediaID int, count int, name []string) error) error

type TopedAggregateCategory

type TopedAggregateCategory interface {
	IterCategory(namespace string, handler func(tokopediaID int, count int, name []string) error) error
}

type UpdateTopedCategoryPayload

type UpdateTopedCategoryPayload struct {
	Username string `json:"username" form:"username"`
	Password string `json:"password" form:"password"`
	Secret   string `json:"secret" form:"secret"`
}

type UploadStatus

type UploadStatus struct {
	AkunCount   int `json:"akun_count"`
	CountUpload int `json:"count_upload"`
	LimitUpload int `json:"limit_upload"`
}