shopee_flow

package
v1.1.71 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 3, 2024 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v1.0.1

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL