offline

type Database interface {
	// AddJob adds a `Job` instance to the database.
	AddJob(context.Context, *Job) error
	// Retrieve a specific `Job` instance from the database using its unique identifier.
	GetJob(context.Context, int64) (*Job, error)
	// Update a specific `Job` instance in the database.
	UpdateJob(context.Context, *Job) error
	// Remove a specific `Job` instance from the database.
	RemoveJob(context.Context, *Job) error
	// Prune zero or more `Job` instances matching a specific `Status` type and created date from the database.
	PruneJobs(context.Context, Status, int64) error
	// List all of the `Jobs` in the database.
	ListJobs(context.Context, ListJobsCallback) error
	// Close closes any underlying database connections
	Close(context.Context) error
}

type DatabaseInitializationFunc func(ctx context.Context, uri string) (Database, error)

type DocstoreDatabase struct {
	Database
	// contains filtered or unexported fields
}

type Job struct {
	Id           int64  `json:"id"`
	Type         string `json:"type"`
	Status       Status `json:"status"`
	Creator      string `json:"creator"`
	Created      int64  `json:"created"`
	LastModified int64  `json:"lastmodified"`
	Instructions string `json:"instructions"`
	Results      string `json:"results,omitempty"`
	Error        string `json:"error,omitempty"`
}

type JobStatusResponse struct {
	JobId        string `json:"job_id"` // because JavaScript 58-bit integer hoohah
	Status       string `json:"status"`
	LastModified int64  `json:"lastmodified"`
	Results      string `json:"results,omitempty"`
	Error        string `json:"error,omitempty"`
}

type ListJobsCallback func(context.Context, *Job) error

type NullQueue struct {
	Queue
}

type ProcessJobCallbackFunc func(context.Context, *Job) (string, error)

type ProcessJobOptions struct {
	Database Database
	Callback ProcessJobCallbackFunc
	JobId    int64
}

type PubSubQueue struct {
	Queue
	// contains filtered or unexported fields
}

type Queue interface {
	ScheduleJob(context.Context, int64) error
	Close(context.Context) error
}

type QueueInitializationFunc func(ctx context.Context, uri string) (Queue, error)

type SlogQueue struct {
	Queue
}

type Status int

type SyncMapDatabase struct {
	Database
	// contains filtered or unexported fields
}