gcsemu

type GcsEmu struct {
	// contains filtered or unexported fields
}

type GcsParams struct {
	Bucket   string
	Object   string
	IsPublic bool
}

type HttpBaseUrl string

type ListOptions struct {
	// Prefix restricts the results to objects whose name begins with Prefix.
	Prefix string

	// Delimiter, when non-empty, rolls objects whose name contains Delimiter
	// after Prefix up into the returned Prefixes instead of returning them as objects.
	Delimiter string

	// Cursor is an exclusive lower bound on the object names to return.
	// It is the object name encoded in the caller's page token; see gcsutil.DecodePageToken.
	Cursor string

	// MatchGlob, when non-empty, restricts the results to objects whose full name
	// matches the given glob pattern. See compileGlob for the supported syntax.
	MatchGlob string

	// MaxResults caps the combined number of objects and rolled-up prefixes returned,
	// counting each prefix once however many objects it stands for.
	// If <= 0 or above MaxResults, MaxResults is used.
	MaxResults int
}

type LocalStore interface {
	// LocalPath returns the path holding the given object, or the bucket's own
	// directory when filename is empty.
	LocalPath(bucket string, filename string) (string, error)
}

type Options struct {
	// A storage layer to use; if nil, defaults to in-mem storage.
	Store Store

	// If true, log verbosely.
	Verbose bool

	// Optional log function. `err` will be `nil` for informational/debug messages.
	Log func(err error, fmt string, args ...interface{})
}

type Server struct {
	Addr string
	*httptest.Server
	*GcsEmu
}

type Store interface {
	// CreateBucket creates a bucket; no error if the bucket already exists.
	CreateBucket(bucket string) error

	// Get returns a bucket's metadata.
	GetBucketMeta(baseUrl HttpBaseUrl, bucket string) (*storage.Bucket, error)

	// Get returns a file's contents and metadata.
	Get(url HttpBaseUrl, bucket string, filename string) (*storage.Object, []byte, error)

	// GetMeta returns a file's metadata.
	GetMeta(url HttpBaseUrl, bucket string, filename string) (*storage.Object, error)

	// Add creates the specified file.
	Add(bucket string, filename string, contents []byte, meta *storage.Object) error

	// UpdateMeta updates the given file's metadata.
	UpdateMeta(bucket string, filename string, meta *storage.Object, metagen int64) error

	// Copy copies the file
	Copy(srcBucket string, srcFile string, dstBucket string, dstFile string) (bool, error)

	// Delete deletes the file.
	Delete(bucket string, filename string) error

	// ReadMeta reads the GCS metadata for a file, when you already have file info.
	ReadMeta(url HttpBaseUrl, bucket string, filename string, fInfo os.FileInfo) (*storage.Object, error)

	// Walks the given bucket.
	Walk(ctx context.Context, bucket string, cb func(ctx context.Context, filename string, fInfo os.FileInfo) error) error
}