worker

type Batch struct {
	UserIds *[]string
	PageID  int
}

type BatchPart struct {
	Start      int
	Size       int
	TotalParts int
	TotalSize  int
	Part       int
	Job        model.Job
}

type BatchWorkerMessage struct {
	JobID   uuid.UUID
	AppName string
	Users   []User
}

type CSVSplitWorker struct {
	Workers *Worker
	Logger  zap.Logger
}

type CreateBatchesWorker struct {
	Workers *Worker
	Logger  zap.Logger
}

type DBPage struct {
	Page       int
	SmallestID string
	BiggestID  string
	Last       bool
}

type DirectPartMsg struct {
	SmallestSeqID uint64 // not in the interval
	BiggestSeqID  uint64 // in the interval
	JobUUID       uuid.UUID
}

type DirectWorker struct {
	Logger  zap.Logger
	Workers *Worker
}

type JobCompletedWorker struct {
	Workers *Worker
	Logger  zap.Logger
}

type ProcessBatchWorker struct {
	Logger  zap.Logger
	Workers *Worker
}

type ResumeJobWorker struct {
	Logger  zap.Logger
	Workers *Worker
}

type SentBatches struct {
	NumBatches  int
	TotalTokens int
}

type StageStatus struct {
	JobID       string
	Stage       string
	StageKey    string
	Description string
	Client      *redis.Client

	MaxProgress     int
	CurrentProgress int
	Completed       bool

	SubStageStatus []*StageStatus
}

type User struct {
	UserID string `json:"user_id,omitempty" sql:"user_id"`
	Token  string `json:"token,omitempty" sql:"token"`
	Locale string `json:"locale,omitempty" sql:"locale"`
	Region string `json:"region,omitempty" sql:"region"`
	Tz     string `json:"tz,omitempty" sql:"tz"`
}

type Worker struct {
	Logger                    zap.Logger
	PushDB                    interfaces.DB
	MarathonDB                interfaces.DB
	Config                    *viper.Viper
	DBPageSize                int
	S3Client                  interfaces.S3
	PageProcessingConcurrency int
	Statsd                    *statsd.Client
	RedisClient               *redis.Client
	ConfigPath                string
	SendgridClient            *extensions.SendgridClient
	Kafka                     interfaces.PushProducer
}