gocloud

README

go-offline-gocloud

Go package implementing the sfomuseum/go-offline interfaces using the Go Cloud abstraction libraries.

Work in progress.

Documentation

Documentation is incomplete at this time.

See also

• https://github.com/sfomuseum/go-offline
• https://gocloud.dev/

Documentation

Index

• func NewDocstoreDatabase(ctx context.Context, uri string) (offline.Database, error)
• func NewPubSubQueue(ctx context.Context, uri string) (offline.Queue, error)
• type DocstoreDatabase
  • func (db *DocstoreDatabase) AddJob(ctx context.Context, job *offline.Job) error
  • func (db *DocstoreDatabase) Close(ctx context.Context) 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
  • func (q *PubSubQueue) Close(ctx context.Context) error
  • func (q *PubSubQueue) ScheduleJob(ctx context.Context, job_id int64) error

Functions

func NewDocstoreDatabase

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

func NewPubSubQueue

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

Types

type DocstoreDatabase

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

func (*DocstoreDatabase) AddJob

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

func (*DocstoreDatabase) Close

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

func (*DocstoreDatabase) GetJob

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

func (*DocstoreDatabase) ListJobs

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

func (*DocstoreDatabase) PruneJobs

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

func (*DocstoreDatabase) RemoveJob

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

func (*DocstoreDatabase) UpdateJob

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

type PubSubQueue

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

func (*PubSubQueue) Close

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

func (*PubSubQueue) ScheduleJob

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