models

type Account struct {
	// ID is the ID of the Account.
	ID bson.ObjectId `bson:"_id"`

	// Name is display name for the Account.
	Name *string `bson:"name,omitempty"`

	// Key is the secret key to authenticate the Account ID.
	Key string `bson:"key"`

	// Deleted
	Deleted bool `bson:"deleted"`
}

type Application struct {
	// ID is the ID of the Application.
	ID bson.ObjectId `bson:"_id"`

	// Account is the ID of the Account owning the Application.
	Account bson.ObjectId `bson:"account"`

	// Name is the Application's name.
	Name string `bson:"name"`

	// Deleted
	Deleted bool `bson:"deleted"`
}

type Attempt struct {
	// ID is the ID of the attempt.
	ID bson.ObjectId `bson:"_id"`

	// Account is the ID of the Account owning the Task.
	Account bson.ObjectId `bson:"account"`

	// Application is the name of the parent Application.
	Application string `bson:"application"`

	// Task is the task's name.
	Task string `bson:"task"`

	// TaskID is the ID of the parent Task of this attempt.
	TaskID bson.ObjectId `bson:"task_id"`

	// Queue is the name of the parent Queue.
	Queue string `bson:"queue"`

	// QueueID is the ID of the parent Queue
	QueueID bson.ObjectId `bson:"queue_id"`

	// URL is the URL that the worker with requests.
	URL string `bson:"url"`

	// HTTPAuth is the HTTP authentication to use if any.
	HTTPAuth HTTPAuth `json:"auth"`

	// Method is the HTTP method that will be used to execute the request.
	Method string `bson:"method"`

	// Headers are the HTTP headers that will be used when executing the request.
	Headers map[string]string `bson:"headers"`

	// Payload is a arbitrary data that will be POSTed on the URL.
	Payload string `bson:"payload"`

	// Reserved is a Unix timestamp until when the attempt is reserved by a worker.
	Reserved int64 `bson:"reserved"`

	// At is a Unix timestamp representing the time a request must be performed.
	At int64 `bson:"at"`

	// Finished is a Unix timestamp representing the time the attempt finished.
	Finished int64 `bson:"finished,omitempty"`

	// Status is either `pending`, `running`, `success` or `error`
	Status string `bson:"status"`

	// StatusCode is the HTTP status code.
	StatusCode int32 `bson:"status_code,omitempty"`

	// StatusMessage is a human readable message related to the Status.
	StatusMessage string `bson:"status_message,omitempty"`

	// Acked
	Acked bool `bson:"acked"`

	// Deleted
	Deleted bool `bson:"deleted"`
}

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

type HTTPAuth struct {
	Username string `json:"username,omitempty" bson:"username,omitempty"`
	Password string `json:"password,omitempty" bson:"password,omitempty"`
}

type ListParams struct {
	Fields  []string
	Filters map[string]string
	Sort    map[string]string
	Page    int
	Limit   int
}

type ListResult struct {
	List    interface{} `json:"list"`
	HasMore bool        `json:"hasMore"`
	Total   int         `json:"total"`
	Count   int         `json:"count"`
	Page    int         `json:"page"`
	Pages   int         `json:"pages"`
}

type Queue struct {
	// ID is the ID of the Queue.
	ID bson.ObjectId `bson:"_id"`

	// Account is the ID of the Account owning the Queue.
	Account bson.ObjectId `bson:"account"`

	// Application is the name of the parent Application.
	Application string `bson:"application"`

	// Name is the Queue's name.
	Name string `bson:"name"`

	// Retry is the retry strategy parameters in case of errors.
	Retry *Retry `bson:"retry"`

	// Deleted
	Deleted bool `bson:"deleted"`

	// MaxInFlight is the maximum number of attempts executed in parallel.
	MaxInFlight int `bson:"max_in_flight"`

	// AvailableInFlight is the available number of slots to execute tasks in parallel.
	AvailableInFlight int `bson:"available_in_flight"`

	// AttemptsInFlight is the list of attempts currently in flight.
	AttemptsInFlight []bson.ObjectId `bson:"attempts_in_flight"`
}

type Retry struct {
	// Attempts is the current number of attempts we did.
	Attempts int `bson:"attempts" json:"attempts"`
	// MaxAttempts is the maximum number of attempts we will try.
	MaxAttempts int `bson:"max_attempts" json:"maxAttempts"`
	// Factor is factor to increase the duration between each attempts.
	Factor float64 `bson:"factor" json:"factor"`
	// Min is the minimum duration between each attempts in seconds.
	Min int `bson:"min" json:"min"`
	// Max is the maximum duration between each attempts in seconds.
	Max int `bson:"max" json:"max"`
}

type Task struct {
	// ID is the ID of the Task.
	ID bson.ObjectId `bson:"_id"`

	// Account is the ID of the Account owning the Task.
	Account bson.ObjectId `bson:"account"`

	// Application is the name of the parent Application.
	Application string `bson:"application"`

	// Name is the task's name.
	Name string `bson:"name"`

	// Queue is the name of the parent Queue.
	Queue string `bson:"queue"`

	// QueueID is the ID of the parent Queue
	QueueID bson.ObjectId `bson:"queue_id"`

	// URL is the URL that the worker with requests.
	URL string `bson:"url"`

	// HTTPAuth is the HTTP authentication to use if any.
	HTTPAuth HTTPAuth `bson:"auth"`

	// Method is the HTTP method that will be used to execute the request.
	Method string `bson:"method"`

	// Headers are the HTTP headers that will be used when executing the request.
	Headers map[string]string `bson:"headers,omitempty"`

	// Payload is arbitrary data that will be POSTed on the URL.
	Payload string `bson:"payload,omitempty"`

	// Schedule is a cron specification describing the recurrency if any.
	Schedule string `bson:"schedule"`

	// At is a Unix timestamp representing the next time a request must be performed.
	At int64 `bson:"at"`

	// Status is either `pending`, `retrying`, `canceled`, `success` or `error`
	Status string `bson:"status"`

	// Executed is the timestamp of the last time a attempt was executed.
	Executed int64 `bson:"executed,omitempty"`

	// Active is the task active.
	Active bool `bson:"active"`

	// Errors counts the number of attempts that failed.
	Errors int `bson:"errors,omitempty"`

	// LastError is the timestamp of the last attempt in error status
	LastError int64 `bson:"last_error,omitempty"`

	// LastSuccess is the timestamp of the last attempt in success status
	LastSuccess int64 `bson:"last_success,omitempty"`

	// Executions counts the number of attempts that were executed.
	Executions int `bson:"executions,omitempty"`

	// Retry is the retry strategy parameters in case of errors.
	Retry *Retry `bson:"retry"`

	// CurrentAttempt is the current attempt ID for this task.
	CurrentAttempt bson.ObjectId `bson:"current_attempt"`

	// AttemptQueued is set to true when the attempt as been successfully created.
	AttemptQueued bool `bson:"attempt_queued"`

	// AttemptUpdated is the Unix timestamp of the last update of the current attempt.
	AttemptUpdated int64 `bson:"attempt_updated"`

	// Deleted
	Deleted bool `bson:"deleted"`
}