lib

type Config struct {
	Timeout   time.Duration
	URL       string
	UserEmail string
	AppID     string
}

type CreateJobPayload struct {
	Localized        bool        `json:"localized"`
	ExpiresAt        int64       `json:"expiresAt"`
	StartsAt         int64       `json:"startsAt"`
	Context          JSON        `json:"context"`
	Service          string      `json:"service"`
	Filters          JSON        `json:"filters"`
	Metadata         JSON        `json:"metadata"`
	CSVPath          string      `json:"csvPath"`
	PastTimeStrategy interface{} `json:"pastTimeStrategy"`
	ControlGroup     float64     `json:"controlGroup"`
}

type JSON map[string]interface{}

type Job struct {
	ID                  string  `json:"id"`
	TotalBatches        int     `json:"totalBatches"`
	CompletedBatches    int     `json:"completedBatches"`
	TotalUsers          int     `json:"totalUsers"`
	CompletedUsers      int     `json:"completedUsers"`
	CompletedTokens     int     `json:"completedTokens"`
	DBPageSize          int     `json:"dbPageSize"`
	Localized           bool    `json:"localized"`
	CompletedAt         int64   `json:"completedAt"`
	ExpiresAt           int64   `json:"expiresAt"`
	StartsAt            int64   `json:"startsAt"`
	Context             JSON    `json:"context"`
	Service             string  `json:"service"`
	Filters             JSON    `json:"filters"`
	Metadata            JSON    `json:"metadata"`
	CSVPath             string  `json:"csvPath"`
	TemplateName        string  `json:"templateName"`
	PastTimeStrategy    string  `json:"pastTimeStrategy"`
	Status              string  `json:"status"`
	AppID               string  `json:"appId"`
	CreatedBy           string  `json:"createdBy"`
	CreatedAt           int64   `json:"createdAt"`
	UpdatedAt           int64   `json:"updatedAt"`
	ControlGroup        float64 `json:"controlGroup"`
	ControlGroupCsvPath string  `json:"controlGroupCsvPath"`
}

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

type MarathonInterface interface {
	CreateJob(
		ctx context.Context,
		template string,
		payload *CreateJobPayload,
	) (*Job, error)

	ListJobs(
		ctx context.Context,
		template string,
	) ([]*Job, error)
}

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