worker

Documentation

Index

• Constants
• type Config
• type WorkerImpl
  • func NewWorkerImpl(cfg Config, db *gorm.DB) *WorkerImpl
  • func (w *WorkerImpl) Start(ctx context.Context) error

Constants

const FileTimeFormat = "20060102_150405"

Types

type Config

type Config struct {
	TableName        string
	TimeFieldName    string
	ArchiveBatchSize int
	ArchivePath      string
	UnzipNames       []string
	Frequency        string
}

type WorkerImpl

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

func NewWorkerImpl

func NewWorkerImpl(cfg Config, db *gorm.DB) *WorkerImpl

func (*WorkerImpl) Start

func (w *WorkerImpl) Start(ctx context.Context) error