server

package
v1.7.0-6f456f1e02272f5... Latest Latest
Warning

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

Go to latest
Published: Mar 6, 2018 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MinioBackendEnvVar     = "MINIO"
	AmazonBackendEnvVar    = "AMAZON"
	GoogleBackendEnvVar    = "GOOGLE"
	MicrosoftBackendEnvVar = "MICROSOFT"
	LocalBackendEnvVar     = "LOCAL"
)

Valid object storage backends

View Source
const HTTPPort = 652

HTTPPort specifies the port the server will listen on

Variables

This section is empty.

Functions

func IsPermissionError added in v1.4.1

func IsPermissionError(err error) bool

IsPermissionError returns true if a given error is a permission error.

Types

type APIServer

type APIServer interface {
	pfsclient.APIServer
}

APIServer represents and api server.

func NewAPIServer

func NewAPIServer(address string, etcdAddresses []string, etcdPrefix string, cacheSize int64) (APIServer, error)

NewAPIServer creates an APIServer. cacheSize is the number of commit trees which will be cached in the server.

type BlockAPIServer added in v1.3.9

type BlockAPIServer interface {
	pfsclient.ObjectAPIServer
}

BlockAPIServer combines BlockAPIServer and ObjectAPIServer.

func NewBlockAPIServer

func NewBlockAPIServer(dir string, cacheBytes int64, backend string, etcdAddress string) (BlockAPIServer, error)

NewBlockAPIServer creates a BlockAPIServer using the credentials it finds in the environment

type CommitEvent added in v1.4.1

type CommitEvent struct {
	Err   error
	Value *pfs.CommitInfo
}

CommitEvent is an event that contains a CommitInfo or an error

type CommitStream added in v1.4.1

type CommitStream interface {
	Stream() <-chan CommitEvent
	Close()
}

CommitStream is a stream of CommitInfos

type HTTPServer added in v1.5.1

type HTTPServer struct {
	*httprouter.Router
	// contains filtered or unexported fields
}

HTTPServer serves GetFile requests over HTTP e.g. http://localhost:30652/v1/pfs/repos/foo/commits/b7a1923be56744f6a3f1525ec222dc3b/files/ttt.log

func NewHTTPServer added in v1.5.1

func NewHTTPServer(address string, etcdAddresses []string, etcdPrefix string, cacheSize int64) (*HTTPServer, error)

NewHTTPServer creates an APIServer. cacheSize is the number of commit trees which will be cached in the server.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL