redisqueue

type Producer struct {
	QueueName QueueName
	Redis     *appredis.Handle
	Clock     clock.Clock
}

type QueueItem struct {
	AppID  string `json:"app_id,omitempty"`
	TaskID string `json:"task_id,omitempty"`
}

type QueueName string

type Task struct {
	ID          string              `json:"id,omitempty"`
	AppID       string              `json:"app_id,omitempty"`
	CreatedAt   *time.Time          `json:"created_at,omitempty"`
	CompletedAt *time.Time          `json:"completed_at,omitempty"`
	Status      TaskStatus          `json:"status,omitempty"`
	Input       json.RawMessage     `json:"input,omitempty"`
	Output      json.RawMessage     `json:"output,omitempty"`
	Error       *apierrors.APIError `json:"error,omitempty"`
}

type TaskStatus string

type UserExportProducer struct {
	*Producer
}

type UserImportProducer struct {
	*Producer
}

type UserReindexProducer struct {
	*Producer
}