shopee_flow

Documentation

Index

• func CreateConfigConcurencyFromCmd() *shopee_upapp.UploadConcurencyConfig
• type CacheApi
• type CacheApiDriver
  • func NewCacheApiDriver() *CacheApiDriver
  • func (cache *CacheApiDriver) Get(akun *repo.AkunItem) (*api.TokopediaApi, func(), error)
• type CategoryEvent
• type ShopeeToTopedFlow
  • func NewShopeeToTopedFlow(rootBase string, ctx context.Context, db *mongo.Database, sqlitedb *gorm.DB, ...) *ShopeeToTopedFlow
  • func (flow *ShopeeToTopedFlow) GenerateHandler(akun *repo.AkunItem, spin shopeeuploader.SpinFunc) []uploader.UploadHandler
  • func (flow *ShopeeToTopedFlow) GenerateSpinHandler(akun *repo.AkunItem) shopeeuploader.SpinFunc
  • func (flow *ShopeeToTopedFlow) Run() error
  • func (flow *ShopeeToTopedFlow) RunTask()

Functions

func CreateConfigConcurencyFromCmd

func CreateConfigConcurencyFromCmd() *shopee_upapp.UploadConcurencyConfig

Types

type CacheApi

type CacheApi struct {
	Api         *api.TokopediaApi
	SaveCookies func()
}

type CacheApiDriver

type CacheApiDriver struct {
	sync.Mutex
	Data map[string]*CacheApi
}

func NewCacheApiDriver

func NewCacheApiDriver() *CacheApiDriver

func (*CacheApiDriver) Get

func (cache *CacheApiDriver) Get(akun *repo.AkunItem) (*api.TokopediaApi, func(), error)

type CategoryEvent

type CategoryEvent struct {
	CatID int
}

type ShopeeToTopedFlow

type ShopeeToTopedFlow struct {
	Ctx       context.Context
	CancelCtx func()

	ConfigFlow     *shopee_upapp.ConfigUploadFlow
	TopedPublicApi *api_public.TokopediaApiPublic
	AkunIterator   *repo.AkunUploadIterator
	CacheApi       *CacheApiDriver
	// contains filtered or unexported fields
}

func NewShopeeToTopedFlow

func NewShopeeToTopedFlow(
	rootBase string,
	ctx context.Context,
	db *mongo.Database,
	sqlitedb *gorm.DB,
	concurent *shopee_upapp.UploadConcurencyConfig,
	publicapi *api_public.TokopediaApiPublic,
	shopeePAgg shopee_repo.ProductAggregate,
	weightconfig *app_config.WeightPrediction,
) *ShopeeToTopedFlow

func (*ShopeeToTopedFlow) GenerateHandler

func (flow *ShopeeToTopedFlow) GenerateHandler(akun *repo.AkunItem, spin shopeeuploader.SpinFunc) []uploader.UploadHandler

func (*ShopeeToTopedFlow) GenerateSpinHandler

func (flow *ShopeeToTopedFlow) GenerateSpinHandler(akun *repo.AkunItem) shopeeuploader.SpinFunc

func (*ShopeeToTopedFlow) Run

func (flow *ShopeeToTopedFlow) Run() error

func (*ShopeeToTopedFlow) RunTask

func (flow *ShopeeToTopedFlow) RunTask()