remotestorage

Documentation

Overview

Package remotestorage wraps cloud storage API.

Index

• type GoogleCloudStorage
  • func (g *GoogleCloudStorage) UploadDir(bucket, src, dst string, opts ...OpOption) error
  • func (g *GoogleCloudStorage) UploadFile(bucket, src, dst string, opts ...OpOption) error
• type Op
• type OpOption
  • func WithContentType(t string) OpOption
• type Uploader
  • func NewGoogleCloudStorage(key []byte, project string) (Uploader, error)

Examples

• GoogleCloudStorage.UploadDir
• GoogleCloudStorage.UploadFile

Types

type GoogleCloudStorage

type GoogleCloudStorage struct {
	JSONKey []byte
	Project string
	Config  *jwt.Config
}

GoogleCloudStorage wraps Google Cloud Storage API.

func (*GoogleCloudStorage) UploadDir

func (g *GoogleCloudStorage) UploadDir(bucket, src, dst string, opts ...OpOption) error

UploadDir uploads a directory to Google Cloud Storage.

Example

package main

import (
	"io/ioutil"
	"log"

	"github.com/coreos/dbtester/pkg/remotestorage"
)

func main() {
	kbs, err := ioutil.ReadFile("key.json")
	if err != nil {
		log.Fatal(err)
	}
	u, err := remotestorage.NewGoogleCloudStorage(kbs, "my-project")
	if err != nil {
		log.Fatal(err)
	}
	if err := u.UploadDir("test-bucket", "articles", "articles"); err != nil {
		log.Fatal(err)
	}
}

func (*GoogleCloudStorage) UploadFile

func (g *GoogleCloudStorage) UploadFile(bucket, src, dst string, opts ...OpOption) error

UploadFile uploads a file to Google Cloud Storage.

Example

package main

import (
	"io/ioutil"
	"log"

	"github.com/coreos/dbtester/pkg/remotestorage"
)

func main() {
	kbs, err := ioutil.ReadFile("key.json")
	if err != nil {
		log.Fatal(err)
	}
	u, err := remotestorage.NewGoogleCloudStorage(kbs, "my-project")
	if err != nil {
		log.Fatal(err)
	}
	if err := u.UploadFile("test-bucket", "agent.log", "dir/agent.log", remotestorage.WithContentType("text/plain")); err != nil {
		log.Fatal(err)
	}
}

type Op

type Op struct {
	ContentType string
}

type OpOption

type OpOption func(*Op)

func WithContentType

func WithContentType(t string) OpOption

type Uploader

type Uploader interface {
	// UploadFile uploads a file.
	UploadFile(bucket, src, dst string, opts ...OpOption) error

	// UploadDir uploads a directory.
	UploadDir(bucket, src, dst string, opts ...OpOption) error
}

Uploader defines storage uploader.

func NewGoogleCloudStorage

func NewGoogleCloudStorage(key []byte, project string) (Uploader, error)

NewGoogleCloudStorage creates a new uploader.