gcs

Documentation

Index

• Variables
• func NewWorkQueue(client ClientInterface, limit int) workqueue.Interface
• type ClientInterface

Variables

var RefreshInterval = 5 * time.Minute

RefreshInterval is the period on which we refresh the lease of owned objects It is surfaced as a global, so that it can be mutated by tests and exposed as a flag by binaries wrapping this library. However, binary authors should use caution to pass consistent values to the key ingress and dispatchers, or they may see unexpected behavior. TODO(mattmoor): What's the right balance here?

Functions

func NewWorkQueue

func NewWorkQueue(client ClientInterface, limit int) workqueue.Interface

NewWorkQueue creates a new GCS-backed workqueue.

Types

type ClientInterface

type ClientInterface interface {
	Object(name string) *storage.ObjectHandle
	Objects(ctx context.Context, q *storage.Query) *storage.ObjectIterator
}

ClientInterface is an interface that abstracts the GCS client.