task

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

type DownloadConfig struct {
	StartDate       *time.Time
	EndDate         *time.Time
	FilterGameTypes []string
	FilterGameState []string
	Out             *os.File
	PartitionSize   int
}

type Monitored interface {
	Progress(func(*ProgressEvent))
}

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

type ProcessFeedConfig struct {
	Source        string
	FilePattern   []string
	Pool          *pgxpool.Pool
	PartitionSize int
}

type ProgressEvent struct {
	CompletedPct float64
	Message      string
}

type Task interface {
	Run(context.Context) error
}

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

type UploadConfig struct {
	Source        string
	FilePattern   []string
	UploadType    string
	DSN           string
	PartitionSize int
}