Documentation
¶
Index ¶
Constants ¶
View Source
const TaskSendCsvDataToPg = "task:copy_sales_data_to_pg"
Variables ¶
This section is empty.
Functions ¶
func ConvertDateFormat ¶
Types ¶
type RedisTaskDistributor ¶
type RedisTaskDistributor struct {
// contains filtered or unexported fields
}
func (*RedisTaskDistributor) DistroDataOnCsv ¶
func (d *RedisTaskDistributor) DistroDataOnCsv(ctx context.Context, payload *multipart.FileHeader, options ...asynq.Option) error
type RedisTaskProcessor ¶
type RedisTaskProcessor struct {
// contains filtered or unexported fields
}
func (*RedisTaskProcessor) ProcessSendCsvDataToDb ¶
func (*RedisTaskProcessor) Start ¶
func (p *RedisTaskProcessor) Start() error
type TaskDistributor ¶
type TaskDistributor interface {
DistroDataOnCsv(ctx context.Context, payload *multipart.FileHeader, options ...asynq.Option) error
}
func NewTaskDistributor ¶
func NewTaskDistributor(r asynq.RedisConnOpt) TaskDistributor
type TaskProcessor ¶
type TaskProcessor interface {
Start() error
ProcessSendCsvDataToDb(
ctx context.Context,
task *asynq.Task,
) error
}
func NewTaskProcessor ¶
func NewTaskProcessor(opt asynq.RedisConnOpt, pool *pgxpool.Pool) TaskProcessor
Source Files
Click to show internal directories.
Click to hide internal directories.