storage

Documentation

Index

• Constants
• func CreateObject(server *fakestorage.Server, object fakestorage.Object)
• func NewDebugBucket(wrapped gcs.Bucket) (b gcs.Bucket)
• type FakeStorage
  • func NewFakeStorage() FakeStorage
• type MockBucket
  • func NewMockBucket(c oglemock.Controller, desc string) MockBucket
• type StorageHandle
  • func NewStorageHandle(ctx context.Context, clientConfig storageutil.StorageClientConfig) (sh StorageHandle, err error)

Constants

const ContentInTestGzipObjectCompressed string = "\x1f\x8b\b\b\x9d\xab\xd5d\x02\xfftmp1bg8d7ug\x00\v\xc9\xc8,\xe6\x02\x00~r\xe2V\x05\x00\x00\x00"

ContentInTestGzipObjectCompressed is a gzip-compressed content for gzip tests. It was created by uploading a small file to GCS using `gsutil cp -Z` and then downloading it as it is (compressed as present on GCS) using go storage client library. To view/change it, open it in a gzip.newReader() ur using a gzip plugin in the IDE. If you do change it, remember to update ContentInTestGzipObjectDecompressed too correspondingly.

const ContentInTestGzipObjectDecompressed string = "This\n"

const ContentInTestObject string = "Hello GCSFuse!!!"

const ContentInTestSubObject string = "Hello GCSFuse From SubObject!!!"

const MetaDataKey string = "key"

const MetaDataValue string = "metaData"

const TestBucketName string = "gcsfuse-default-bucket"

const TestGzipObjectGeneration int64 = 781

const TestGzipObjectName string = "gcsfuse/test_gzip.txt"

Data specific to content-encoding gzip tests

const TestObjectGeneration int64 = 780

const TestObjectName string = "gcsfuse/default.txt"

const TestObjectRootFolderName string = "gcsfuse/"

const TestObjectSubRootFolderName string = "gcsfuse/SubFolder/"

const TestSubObjectName string = "gcsfuse/SubFolder/default.txt"

Functions

func CreateObject

func CreateObject(server *fakestorage.Server, object fakestorage.Object)

func NewDebugBucket

func NewDebugBucket(
	wrapped gcs.Bucket) (b gcs.Bucket)

Wrap the supplied bucket in a layer that prints debug messages.

Types

type FakeStorage

type FakeStorage interface {
	CreateStorageHandle() (sh StorageHandle)

	ShutDown()
}

func NewFakeStorage

func NewFakeStorage() FakeStorage

type MockBucket

type MockBucket interface {
	gcs.Bucket
	oglemock.MockObject
}

func NewMockBucket

func NewMockBucket(
	c oglemock.Controller,
	desc string) MockBucket

type StorageHandle

type StorageHandle interface {
	// In case of non-empty billingProject, this project is set as user-project for
	// all subsequent calls on the bucket. Calls with user-project will be billed
	// to that project rather than to the bucket's owning project.
	//
	// A user-project is required for all operations on Requester Pays buckets.
	BucketHandle(bucketName string, billingProject string) (bh *bucketHandle)
}

func NewStorageHandle

func NewStorageHandle(ctx context.Context, clientConfig storageutil.StorageClientConfig) (sh StorageHandle, err error)

NewStorageHandle returns the handle of Go storage client containing customized http client. We can configure the http client using the storageClientConfig parameter.