task

Documentation

Index

• type Download
  • func NewDownload(config *DownloadConfig) *Download
  • func (m Download) Add(delta int, msg string)
  • func (m Download) Progress(cb func(e *ProgressEvent))
  • func (t *Download) Run(ctx context.Context) error
  • func (m Download) SetExpected(n int)
• type DownloadConfig
• type Monitored
• type ProcessFeed
  • func NewProcessFeed(config *ProcessFeedConfig) *ProcessFeed
  • func (m ProcessFeed) Add(delta int, msg string)
  • func (m ProcessFeed) Progress(cb func(e *ProgressEvent))
  • func (t *ProcessFeed) Run(ctx context.Context) error
  • func (m ProcessFeed) SetExpected(n int)
• type ProcessFeedConfig
• type ProgressEvent
• type Task
• type Upload
  • func NewUpload(config *UploadConfig) *Upload
  • func (m Upload) Add(delta int, msg string)
  • func (m Upload) Progress(cb func(e *ProgressEvent))
  • func (t *Upload) Run(ctx context.Context) error
  • func (m Upload) SetExpected(n int)
• type UploadConfig

Types

type Download

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

func NewDownload

func NewDownload(config *DownloadConfig) *Download

func (Download) Add

func (m Download) Add(delta int, msg string)

func (Download) Progress

func (m Download) Progress(cb func(e *ProgressEvent))

func (*Download) Run

func (t *Download) Run(ctx context.Context) error

func (Download) SetExpected

func (m Download) SetExpected(n int)

type DownloadConfig

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

type Monitored

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

type ProcessFeed

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

func NewProcessFeed

func NewProcessFeed(config *ProcessFeedConfig) *ProcessFeed

func (ProcessFeed) Add

func (m ProcessFeed) Add(delta int, msg string)

func (ProcessFeed) Progress

func (m ProcessFeed) Progress(cb func(e *ProgressEvent))

func (*ProcessFeed) Run

func (t *ProcessFeed) Run(ctx context.Context) error

func (ProcessFeed) SetExpected

func (m ProcessFeed) SetExpected(n int)

type ProcessFeedConfig

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

type ProgressEvent

type ProgressEvent struct {
	CompletedPct float64
	Message      string
}

type Task

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

type Upload

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

func NewUpload

func NewUpload(config *UploadConfig) *Upload

func (Upload) Add

func (m Upload) Add(delta int, msg string)

func (Upload) Progress

func (m Upload) Progress(cb func(e *ProgressEvent))

func (*Upload) Run

func (t *Upload) Run(ctx context.Context) error

func (Upload) SetExpected

func (m Upload) SetExpected(n int)

type UploadConfig

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