server

package
v1.5.3 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2017 License: Apache-2.0 Imports: 48 Imported by: 0

Documentation

Overview

Package server is a generated protocol buffer package.

It is generated from these files: 

server/pfs/server/driver.proto

It has these top-level messages: 

PutFileRecord
PutFileRecords

Index

Constants

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

Valid object storage backends

View Source 
const HTTPPort = 652

HTTPPort specifies the port the server will listen on

Variables

View Source 
var (
	ErrInvalidLengthDriver = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDriver   = fmt.Errorf("proto: integer overflow")
)

Functions

func IsPermissionError added in v1.4.1 

func IsPermissionError(err error) bool

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

func ValidateRepoName added in v1.4.1 

func ValidateRepoName(name string) error

ValidateRepoName determines if a repo name is valid

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

func NewLocalBlockAPIServer 

func NewLocalBlockAPIServer(dir string) (BlockAPIServer, error)

NewLocalBlockAPIServer creates a BlockAPIServer.

func NewObjBlockAPIServer 

func NewObjBlockAPIServer(dir string, cacheBytes int64, etcdAddress string, objClient obj.Client) (BlockAPIServer, error)

NewObjBlockAPIServer create a BlockAPIServer from an obj.Client.

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.

type ListFileMode added in v1.4.1 

type ListFileMode int

ListFileMode specifies how ListFile executes. 

const (
	// ListFileNORMAL computes sizes for files but not for directories
	ListFileNORMAL ListFileMode = iota
	// ListFileFAST does not compute sizes for files or directories
	ListFileFAST
	// ListFileRECURSE computes sizes for files and directories
	ListFileRECURSE
)

type PutFileRecord added in v1.4.1 

type PutFileRecord struct {
	SizeBytes  int64  `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	ObjectHash string `protobuf:"bytes,2,opt,name=objectHash,proto3" json:"objectHash,omitempty"`
}

PutFileRecord is used to record PutFile requests in etcd temporarily.

func (*PutFileRecord) Descriptor added in v1.4.1 

func (*PutFileRecord) Descriptor() ([]byte, []int)

func (*PutFileRecord) GetObjectHash added in v1.4.1 

func (m *PutFileRecord) GetObjectHash() string

func (*PutFileRecord) GetSizeBytes added in v1.4.1 

func (m *PutFileRecord) GetSizeBytes() int64

func (*PutFileRecord) Marshal added in v1.5.0 

func (m *PutFileRecord) Marshal() (dAtA []byte, err error)

func (*PutFileRecord) MarshalTo added in v1.5.0 

func (m *PutFileRecord) MarshalTo(dAtA []byte) (int, error)

func (*PutFileRecord) ProtoMessage added in v1.4.1 

func (*PutFileRecord) ProtoMessage()

func (*PutFileRecord) Reset added in v1.4.1 

func (m *PutFileRecord) Reset()

func (*PutFileRecord) Size added in v1.5.0 

func (m *PutFileRecord) Size() (n int)

func (*PutFileRecord) String added in v1.4.1 

func (m *PutFileRecord) String() string

func (*PutFileRecord) Unmarshal added in v1.5.0 

func (m *PutFileRecord) Unmarshal(dAtA []byte) error

type PutFileRecords added in v1.4.1 

type PutFileRecords struct {
	Split   bool             `protobuf:"varint,1,opt,name=split,proto3" json:"split,omitempty"`
	Records []*PutFileRecord `protobuf:"bytes,2,rep,name=records" json:"records,omitempty"`
}

func (*PutFileRecords) Descriptor added in v1.4.1 

func (*PutFileRecords) Descriptor() ([]byte, []int)

func (*PutFileRecords) GetRecords added in v1.4.1 

func (m *PutFileRecords) GetRecords() []*PutFileRecord

func (*PutFileRecords) GetSplit added in v1.4.1 

func (m *PutFileRecords) GetSplit() bool

func (*PutFileRecords) Marshal added in v1.5.0 

func (m *PutFileRecords) Marshal() (dAtA []byte, err error)

func (*PutFileRecords) MarshalTo added in v1.5.0 

func (m *PutFileRecords) MarshalTo(dAtA []byte) (int, error)

func (*PutFileRecords) ProtoMessage added in v1.4.1 

func (*PutFileRecords) ProtoMessage()

func (*PutFileRecords) Reset added in v1.4.1 

func (m *PutFileRecords) Reset()

func (*PutFileRecords) Size added in v1.5.0 

func (m *PutFileRecords) Size() (n int)

func (*PutFileRecords) String added in v1.4.1 

func (m *PutFileRecords) String() string

func (*PutFileRecords) Unmarshal added in v1.5.0 

func (m *PutFileRecords) Unmarshal(dAtA []byte) error

Source Files

View all Source files

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.