gdrive

package module
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

README

Services Test Gdrive

gdrive

Google Drive service support for go-storage.

Install

go get github.com/rgglez/go-storage/services/gdrive

Usage

import (
	"log"

	_ "github.com/rgglez/go-storage/services/gdrive"
	"github.com/rgglez/go-storage/v5/services"
)

func main() {
	store, err := services.NewStoragerFromString("gdrive://path/to/work_dir?name=<a_meaningful_name>?credential=file:<absolute_path_to_credentials>")
	if err != nil {
		log.Fatal(err)
	}

	// Write data from io.Reader into hello.txt
	n, err := store.Write("hello.txt", r, length)
}

Documentation

Overview

Copyright The go-storage Authors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package gdrive provided support for local file system.

Code generated by go generate via cmd/definitions; DO NOT EDIT.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Examples

Constants

View Source 
const Type = "gdrive"

Type is the type for gdrive

Variables

This section is empty.

Functions

func NewServicer 

func NewServicer(pairs ...types.Pair) (types.Servicer, error)

NewServicer is not usable, only for generate code

func NewStorager 

func NewStorager(pairs ...types.Pair) (types.Storager, error)

NewStorager will create Storager only.

Example

ExampleNewStorager demonstrates how to initialize a Google Drive backend.

Create a service account in the Google Cloud Console and download the JSON key. Share the target Drive folder with the service account email address. 

export GDRIVE_CREDENTIAL=file:/path/to/service-account-key.json
export GDRIVE_FOLDER=My Drive Folder

package main

import (
	"fmt"
	"os"

	"github.com/rgglez/go-storage/v5/pairs"
	"github.com/rgglez/go-storage/v5/types"

	"github.com/rgglez/go-storage/services/gdrive"
)

func main() {
	ps := []types.Pair{
		// Credential: path to the Google service account JSON key file.
		// Format: "file:/absolute/path/to/key.json"
		pairs.WithCredential(os.Getenv("GDRIVE_CREDENTIAL")),
		pairs.WithName(os.Getenv("GDRIVE_FOLDER")),
	}
	if wd := os.Getenv("GDRIVE_WORK_DIR"); wd != "" {
		ps = append(ps, pairs.WithWorkDir(wd))
	}

	store, err := gdrive.NewStorager(ps...)
	if err != nil {
		fmt.Printf("ERROR: %v\n", err)
		return
	}
	fmt.Printf("storager: %s\n", store)
}

Types

type DefaultServicePairs deprecated 

type DefaultServicePairs = types.DefaultServicePairs

Deprecated: Use types.DefaultServicePairs instead.

type DefaultStoragePairs deprecated 

type DefaultStoragePairs = types.DefaultStoragePairs

Deprecated: Use types.DefaultStoragePairs instead.

type Factory 

type Factory struct {
	Credential string
	Name       string
	WorkDir    string
}

func (*Factory) FromMap 

func (f *Factory) FromMap(m map[string]interface{}) (err error)

func (*Factory) FromString 

func (f *Factory) FromString(conn string) (err error)

func (*Factory) NewServicer 

func (f *Factory) NewServicer() (srv types.Servicer, err error)

func (*Factory) NewStorager 

func (f *Factory) NewStorager() (sto types.Storager, err error)

func (*Factory) WithPairs 

func (f *Factory) WithPairs(ps ...types.Pair) (err error)

type ObjectSystemMetadata 

type ObjectSystemMetadata struct {
}

ObjectSystemMetadata stores system metadata for object.

func GetObjectSystemMetadata 

func GetObjectSystemMetadata(o *types.Object) ObjectSystemMetadata

GetObjectSystemMetadata will get ObjectSystemMetadata from Object.

- This function should not be called by service implementer. - The returning ObjectServiceMetadata is read only and should not be modified.

type Service 

type Service struct {
	types.UnimplementedServicer
	// contains filtered or unexported fields
}

Service is the gdrive config. It is not usable, only for generate code

func (*Service) Create 

func (s *Service) Create(name string, pairs ...types.Pair) (store types.Storager, err error)

func (*Service) CreateWithContext 

func (s *Service) CreateWithContext(ctx context.Context, name string, pairs ...types.Pair) (store types.Storager, err error)

func (*Service) Delete 

func (s *Service) Delete(name string, pairs ...types.Pair) (err error)

func (*Service) DeleteWithContext 

func (s *Service) DeleteWithContext(ctx context.Context, name string, pairs ...types.Pair) (err error)

func (*Service) Features 

func (s *Service) Features() types.ServiceFeatures

func (*Service) Get 

func (s *Service) Get(name string, pairs ...types.Pair) (store types.Storager, err error)

func (*Service) GetWithContext 

func (s *Service) GetWithContext(ctx context.Context, name string, pairs ...types.Pair) (store types.Storager, err error)

func (*Service) List 

func (s *Service) List(pairs ...types.Pair) (sti *types.StoragerIterator, err error)

func (*Service) ListWithContext 

func (s *Service) ListWithContext(ctx context.Context, pairs ...types.Pair) (sti *types.StoragerIterator, err error)

func (*Service) String 

func (s *Service) String() string

String implements Servicer.String

type ServiceFeatures deprecated 

type ServiceFeatures = types.ServiceFeatures

Deprecated: Use types.ServiceFeatures instead.

type Storage 

type Storage struct {
	types.UnimplementedStorager
	// contains filtered or unexported fields
}

Storage is the example client.

func (*Storage) CombineBlock 

func (s *Storage) CombineBlock(o *types.Object, bids []string, pairs ...types.Pair) (err error)

func (*Storage) CombineBlockWithContext 

func (s *Storage) CombineBlockWithContext(ctx context.Context, o *types.Object, bids []string, pairs ...types.Pair) (err error)

func (*Storage) CommitAppend 

func (s *Storage) CommitAppend(o *types.Object, pairs ...types.Pair) (err error)

func (*Storage) CommitAppendWithContext 

func (s *Storage) CommitAppendWithContext(ctx context.Context, o *types.Object, pairs ...types.Pair) (err error)

func (*Storage) CompleteMultipart 

func (s *Storage) CompleteMultipart(o *types.Object, parts []*types.Part, pairs ...types.Pair) (err error)

func (*Storage) CompleteMultipartWithContext 

func (s *Storage) CompleteMultipartWithContext(ctx context.Context, o *types.Object, parts []*types.Part, pairs ...types.Pair) (err error)

func (*Storage) Copy 

func (s *Storage) Copy(src string, dst string, pairs ...types.Pair) (err error)

func (*Storage) CopyWithContext 

func (s *Storage) CopyWithContext(ctx context.Context, src string, dst string, pairs ...types.Pair) (err error)

func (*Storage) Create 

func (s *Storage) Create(path string, pairs ...types.Pair) (o *types.Object)

func (*Storage) CreateAppend 

func (s *Storage) CreateAppend(path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreateAppendWithContext 

func (s *Storage) CreateAppendWithContext(ctx context.Context, path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreateBlock 

func (s *Storage) CreateBlock(path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreateBlockWithContext 

func (s *Storage) CreateBlockWithContext(ctx context.Context, path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreateDir 

func (s *Storage) CreateDir(path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreateDirWithContext 

func (s *Storage) CreateDirWithContext(ctx context.Context, path string, pairs ...types.Pair) (o *types.Object, err error)
func (s *Storage) CreateLink(path string, target string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreateLinkWithContext 

func (s *Storage) CreateLinkWithContext(ctx context.Context, path string, target string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreateMultipart 

func (s *Storage) CreateMultipart(path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreateMultipartWithContext 

func (s *Storage) CreateMultipartWithContext(ctx context.Context, path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreatePage 

func (s *Storage) CreatePage(path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) CreatePageWithContext 

func (s *Storage) CreatePageWithContext(ctx context.Context, path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) Delete 

func (s *Storage) Delete(path string, pairs ...types.Pair) (err error)

func (*Storage) DeleteWithContext 

func (s *Storage) DeleteWithContext(ctx context.Context, path string, pairs ...types.Pair) (err error)

func (*Storage) Features 

func (s *Storage) Features() types.StorageFeatures

func (*Storage) Fetch 

func (s *Storage) Fetch(path string, url string, pairs ...types.Pair) (err error)

func (*Storage) FetchWithContext 

func (s *Storage) FetchWithContext(ctx context.Context, path string, url string, pairs ...types.Pair) (err error)

func (*Storage) List 

func (s *Storage) List(path string, pairs ...types.Pair) (oi *types.ObjectIterator, err error)

func (*Storage) ListBlock 

func (s *Storage) ListBlock(o *types.Object, pairs ...types.Pair) (bi *types.BlockIterator, err error)

func (*Storage) ListBlockWithContext 

func (s *Storage) ListBlockWithContext(ctx context.Context, o *types.Object, pairs ...types.Pair) (bi *types.BlockIterator, err error)

func (*Storage) ListMultipart 

func (s *Storage) ListMultipart(o *types.Object, pairs ...types.Pair) (pi *types.PartIterator, err error)

func (*Storage) ListMultipartWithContext 

func (s *Storage) ListMultipartWithContext(ctx context.Context, o *types.Object, pairs ...types.Pair) (pi *types.PartIterator, err error)

func (*Storage) ListWithContext 

func (s *Storage) ListWithContext(ctx context.Context, path string, pairs ...types.Pair) (oi *types.ObjectIterator, err error)

func (*Storage) Metadata 

func (s *Storage) Metadata(pairs ...types.Pair) (meta *types.StorageMeta)

func (*Storage) Move 

func (s *Storage) Move(src string, dst string, pairs ...types.Pair) (err error)

func (*Storage) MoveWithContext 

func (s *Storage) MoveWithContext(ctx context.Context, src string, dst string, pairs ...types.Pair) (err error)

func (*Storage) QuerySignHTTPCompleteMultipart 

func (s *Storage) QuerySignHTTPCompleteMultipart(o *types.Object, parts []*types.Part, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPCompleteMultipartWithContext 

func (s *Storage) QuerySignHTTPCompleteMultipartWithContext(ctx context.Context, o *types.Object, parts []*types.Part, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPCreateMultipart 

func (s *Storage) QuerySignHTTPCreateMultipart(path string, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPCreateMultipartWithContext 

func (s *Storage) QuerySignHTTPCreateMultipartWithContext(ctx context.Context, path string, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPDelete 

func (s *Storage) QuerySignHTTPDelete(path string, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPDeleteWithContext 

func (s *Storage) QuerySignHTTPDeleteWithContext(ctx context.Context, path string, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPListMultipart 

func (s *Storage) QuerySignHTTPListMultipart(o *types.Object, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPListMultipartWithContext 

func (s *Storage) QuerySignHTTPListMultipartWithContext(ctx context.Context, o *types.Object, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPRead 

func (s *Storage) QuerySignHTTPRead(path string, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPReadWithContext 

func (s *Storage) QuerySignHTTPReadWithContext(ctx context.Context, path string, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPWrite 

func (s *Storage) QuerySignHTTPWrite(path string, size int64, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPWriteMultipart 

func (s *Storage) QuerySignHTTPWriteMultipart(o *types.Object, size int64, index int, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPWriteMultipartWithContext 

func (s *Storage) QuerySignHTTPWriteMultipartWithContext(ctx context.Context, o *types.Object, size int64, index int, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) QuerySignHTTPWriteWithContext 

func (s *Storage) QuerySignHTTPWriteWithContext(ctx context.Context, path string, size int64, expire time.Duration, pairs ...types.Pair) (req *http.Request, err error)

func (*Storage) Read 

func (s *Storage) Read(path string, w io.Writer, pairs ...types.Pair) (n int64, err error)

func (*Storage) ReadWithContext 

func (s *Storage) ReadWithContext(ctx context.Context, path string, w io.Writer, pairs ...types.Pair) (n int64, err error)

func (*Storage) Stat 

func (s *Storage) Stat(path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) StatWithContext 

func (s *Storage) StatWithContext(ctx context.Context, path string, pairs ...types.Pair) (o *types.Object, err error)

func (*Storage) String 

func (s *Storage) String() string

String implements Storager.String

func (*Storage) Write 

func (s *Storage) Write(path string, r io.Reader, size int64, pairs ...types.Pair) (n int64, err error)
Example

ExampleStorage_Write demonstrates the Write → Stat → Read → List → Delete cycle. 

package main

import (
	"bytes"
	"errors"
	"fmt"
	"strings"

	"github.com/rgglez/go-storage/v5/pairs"
	"github.com/rgglez/go-storage/v5/types"

	"github.com/rgglez/go-storage/services/gdrive"
)

func main() {
	store, err := gdrive.NewStorager(
		pairs.WithCredential("file:/path/to/service-account-key.json"),
		pairs.WithName("My Drive Folder"),
	)
	if err != nil {
		return
	}

	const path = "go-storage-example/hello.txt"
	const content = "Hello from go-storage gdrive example!"

	n, err := store.Write(path, strings.NewReader(content), int64(len(content)))
	if err != nil {
		return
	}
	fmt.Printf("write  %q → %d bytes\n", path, n)

	o, err := store.Stat(path)
	if err != nil {
		return
	}
	size, _ := o.GetContentLength()
	fmt.Printf("stat   %q → size=%d\n", path, size)

	var buf bytes.Buffer
	n, err = store.Read(path, &buf)
	if err != nil {
		return
	}
	fmt.Printf("read   %q → %d bytes\n", path, n)

	it, err := store.List("go-storage-example/")
	if err != nil {
		return
	}
	for {
		obj, err := it.Next()
		if errors.Is(err, types.IterateDone) {
			break
		}
		if err != nil {
			return
		}
		fmt.Printf("  - %s\n", obj.Path)
	}

	if err := store.Delete(path); err != nil {
		return
	}
	fmt.Printf("delete %q → ok\n", path)
}

func (*Storage) WriteAppend 

func (s *Storage) WriteAppend(o *types.Object, r io.Reader, size int64, pairs ...types.Pair) (n int64, err error)

func (*Storage) WriteAppendWithContext 

func (s *Storage) WriteAppendWithContext(ctx context.Context, o *types.Object, r io.Reader, size int64, pairs ...types.Pair) (n int64, err error)

func (*Storage) WriteBlock 

func (s *Storage) WriteBlock(o *types.Object, r io.Reader, size int64, bid string, pairs ...types.Pair) (n int64, err error)

func (*Storage) WriteBlockWithContext 

func (s *Storage) WriteBlockWithContext(ctx context.Context, o *types.Object, r io.Reader, size int64, bid string, pairs ...types.Pair) (n int64, err error)

func (*Storage) WriteMultipart 

func (s *Storage) WriteMultipart(o *types.Object, r io.Reader, size int64, index int, pairs ...types.Pair) (n int64, part *types.Part, err error)

func (*Storage) WriteMultipartWithContext 

func (s *Storage) WriteMultipartWithContext(ctx context.Context, o *types.Object, r io.Reader, size int64, index int, pairs ...types.Pair) (n int64, part *types.Part, err error)

func (*Storage) WritePage 

func (s *Storage) WritePage(o *types.Object, r io.Reader, size int64, offset int64, pairs ...types.Pair) (n int64, err error)

func (*Storage) WritePageWithContext 

func (s *Storage) WritePageWithContext(ctx context.Context, o *types.Object, r io.Reader, size int64, offset int64, pairs ...types.Pair) (n int64, err error)

func (*Storage) WriteWithContext 

func (s *Storage) WriteWithContext(ctx context.Context, path string, r io.Reader, size int64, pairs ...types.Pair) (n int64, err error)

type StorageFeatures deprecated 

type StorageFeatures = types.StorageFeatures

Deprecated: Use types.StorageFeatures instead.

type StorageSystemMetadata 

type StorageSystemMetadata struct {
}

StorageSystemMetadata stores system metadata for object.

func GetStorageSystemMetadata 

func GetStorageSystemMetadata(s *types.StorageMeta) StorageSystemMetadata

GetStorageSystemMetadata will get StorageSystemMetadata from Storage.

- This function should not be called by service implementer. - The returning StorageServiceMetadata is read only and should not be modified.

Source Files

View all Source files

Directories

Path Synopsis
examples
basic command
internal
cmd command

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.