gocloud

May 23, 2023

Changes in this version

type DocstoreDatabase

+ func (db *DocstoreDatabase) Close(ctx context.Context) error

Nov 9, 2022

Changes in this version

+ func NewDocstoreDatabase(ctx context.Context, uri string) (offline.Database, error)

+ func NewPubSubQueue(ctx context.Context, uri string) (offline.Queue, error)

+ type DocstoreDatabase struct

+ func (db *DocstoreDatabase) AddJob(ctx context.Context, job *offline.Job) error

+ func (db *DocstoreDatabase) GetJob(ctx context.Context, id int64) (*offline.Job, error)

+ func (db *DocstoreDatabase) ListJobs(ctx context.Context, cb offline.ListJobsCallback) error

+ func (db *DocstoreDatabase) PruneJobs(ctx context.Context, status offline.Status, lastmodified int64) error

+ func (db *DocstoreDatabase) RemoveJob(ctx context.Context, job *offline.Job) error

+ func (db *DocstoreDatabase) UpdateJob(ctx context.Context, job *offline.Job) error

+ type PubSubQueue struct

+ func (q *PubSubQueue) Close(ctx context.Context) error

+ func (q *PubSubQueue) ScheduleJob(ctx context.Context, job_id int64) error