shell

Documentation

Index

• func NewHTTPClient() *http.Client
• func NewSwitchArchiveWriter(writer io.Writer) contracts.ArchiveWriter
• func NewZipArchiveReader(reader io.Reader) io.ReadCloser
• func NewZipArchiveWriter(writer io.Writer, level int) contracts.ArchiveWriter
• type DiskFileSystem
  • func NewDiskFileSystem(root string) *DiskFileSystem
  • func (this *DiskFileSystem) Chmod(name string, mode os.FileMode) error
  • func (this *DiskFileSystem) Create(path string) io.WriteCloser
  • func (this *DiskFileSystem) CreateSymlink(source, target string)
  • func (this *DiskFileSystem) Delete(path string)
  • func (this *DiskFileSystem) Listing() (listing []contracts.FileInfo)
  • func (this *DiskFileSystem) Open(path string) io.ReadCloser
  • func (this *DiskFileSystem) ReadFile(path string) ([]byte, error)
  • func (this *DiskFileSystem) RootPath() string
  • func (this *DiskFileSystem) Stat(path string) (contracts.FileInfo, error)
  • func (this *DiskFileSystem) WriteFile(path string, content []byte)
• type Environment
  • func NewEnvironment() *Environment
  • func (this *Environment) LookupEnv(key string) (value string, set bool)
• type FileInfo
  • func (this FileInfo) ModTime() time.Time
  • func (this FileInfo) Mode() os.FileMode
  • func (this FileInfo) Path() string
  • func (this FileInfo) Size() int64
  • func (this FileInfo) Symlink() string
• type GoogleCloudStorageClient
  • func NewGoogleCloudStorageClient(client *http.Client, credentials gcs.Credentials, expectedStatus []int) *GoogleCloudStorageClient
  • func (this *GoogleCloudStorageClient) Download(request url.URL) (io.ReadCloser, error)
  • func (this *GoogleCloudStorageClient) Seek(request url.URL, start, end int64) (io.ReadCloser, error)
  • func (this *GoogleCloudStorageClient) Size(request url.URL) (int64, error)
  • func (this *GoogleCloudStorageClient) Upload(request contracts.UploadRequest) error
• type TarArchiveWriter
  • func NewTarArchiveWriter(writer io.Writer) *TarArchiveWriter
  • func (this *TarArchiveWriter) WriteHeader(header contracts.ArchiveHeader)
• type ZipArchiveReader
  • func (this *ZipArchiveReader) Close() error
  • func (this *ZipArchiveReader) Next() (*tar.Header, error)
  • func (this *ZipArchiveReader) Read(p []byte) (n int, err error)
  • func (this *ZipArchiveReader) ReadAt(p []byte, off int64) (n int, err error)
  • func (this *ZipArchiveReader) SetDownloader(request url.URL, downloader contracts.Downloader)
• type ZipArchiveWriter
  • func (this *ZipArchiveWriter) Close() (err error)
  • func (this *ZipArchiveWriter) Write(buffer []byte) (int, error)
  • func (this *ZipArchiveWriter) WriteHeader(header contracts.ArchiveHeader)

Functions

func NewHTTPClient

func NewHTTPClient() *http.Client

func NewSwitchArchiveWriter

func NewSwitchArchiveWriter(writer io.Writer) contracts.ArchiveWriter

func NewZipArchiveReader

func NewZipArchiveReader(reader io.Reader) io.ReadCloser

func NewZipArchiveWriter

func NewZipArchiveWriter(writer io.Writer, level int) contracts.ArchiveWriter

Types

type DiskFileSystem

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

func NewDiskFileSystem

func NewDiskFileSystem(root string) *DiskFileSystem

func (*DiskFileSystem) Chmod

func (this *DiskFileSystem) Chmod(name string, mode os.FileMode) error

func (*DiskFileSystem) Create

func (this *DiskFileSystem) Create(path string) io.WriteCloser

func (*DiskFileSystem) CreateSymlink

func (this *DiskFileSystem) CreateSymlink(source, target string)

func (*DiskFileSystem) Delete

func (this *DiskFileSystem) Delete(path string)

func (*DiskFileSystem) Listing

func (this *DiskFileSystem) Listing() (listing []contracts.FileInfo)

func (*DiskFileSystem) Open

func (this *DiskFileSystem) Open(path string) io.ReadCloser

func (*DiskFileSystem) ReadFile

func (this *DiskFileSystem) ReadFile(path string) ([]byte, error)

func (*DiskFileSystem) RootPath

func (this *DiskFileSystem) RootPath() string

func (*DiskFileSystem) Stat

func (this *DiskFileSystem) Stat(path string) (contracts.FileInfo, error)

func (*DiskFileSystem) WriteFile

func (this *DiskFileSystem) WriteFile(path string, content []byte)

type Environment

type Environment struct{}

func NewEnvironment

func NewEnvironment() *Environment

func (*Environment) LookupEnv

func (this *Environment) LookupEnv(key string) (value string, set bool)

type FileInfo

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

func (FileInfo) ModTime

func (this FileInfo) ModTime() time.Time

func (FileInfo) Mode

func (this FileInfo) Mode() os.FileMode

func (FileInfo) Path

func (this FileInfo) Path() string

func (FileInfo) Size

func (this FileInfo) Size() int64

func (FileInfo) Symlink

func (this FileInfo) Symlink() string

type GoogleCloudStorageClient

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

func NewGoogleCloudStorageClient

func NewGoogleCloudStorageClient(client *http.Client, credentials gcs.Credentials, expectedStatus []int) *GoogleCloudStorageClient

func (*GoogleCloudStorageClient) Download

func (this *GoogleCloudStorageClient) Download(request url.URL) (io.ReadCloser, error)

func (*GoogleCloudStorageClient) Seek

func (this *GoogleCloudStorageClient) Seek(request url.URL, start, end int64) (io.ReadCloser, error)

func (*GoogleCloudStorageClient) Size

func (this *GoogleCloudStorageClient) Size(request url.URL) (int64, error)

Size uses an HTTP HEAD to find out how many bytes are available in total.

func (*GoogleCloudStorageClient) Upload

func (this *GoogleCloudStorageClient) Upload(request contracts.UploadRequest) error

type TarArchiveWriter

type TarArchiveWriter struct {
	*tar.Writer
}

func NewTarArchiveWriter

func NewTarArchiveWriter(writer io.Writer) *TarArchiveWriter

func (*TarArchiveWriter) WriteHeader

func (this *TarArchiveWriter) WriteHeader(header contracts.ArchiveHeader)

type ZipArchiveReader

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

func (*ZipArchiveReader) Close

func (this *ZipArchiveReader) Close() error

func (*ZipArchiveReader) Next

func (this *ZipArchiveReader) Next() (*tar.Header, error)

func (*ZipArchiveReader) Read

func (this *ZipArchiveReader) Read(p []byte) (n int, err error)

func (*ZipArchiveReader) ReadAt

func (this *ZipArchiveReader) ReadAt(p []byte, off int64) (n int, err error)

func (*ZipArchiveReader) SetDownloader

func (this *ZipArchiveReader) SetDownloader(request url.URL, downloader contracts.Downloader)

type ZipArchiveWriter

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

func (*ZipArchiveWriter) Close

func (this *ZipArchiveWriter) Close() (err error)

func (*ZipArchiveWriter) Write

func (this *ZipArchiveWriter) Write(buffer []byte) (int, error)

func (*ZipArchiveWriter) WriteHeader

func (this *ZipArchiveWriter) WriteHeader(header contracts.ArchiveHeader)