pfs

package
v1.0.368 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2016 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package pfs is a generated protocol buffer package.

It is generated from these files: 

client/pfs/pfs.proto

It has these top-level messages: 

Repo
Commit
File
Block
Diff
RepoInfo
RepoInfos
CommitInfo
CommitInfos
FileInfo
FileInfos
ByteRange
BlockRef
BlockRefs
Append
BlockInfo
BlockInfos
DiffInfo
Shard
CreateRepoRequest
InspectRepoRequest
ListRepoRequest
DeleteRepoRequest
StartCommitRequest
FinishCommitRequest
InspectCommitRequest
ListCommitRequest
ListBranchRequest
DeleteCommitRequest
GetFileRequest
PutFileRequest
InspectFileRequest
ListFileRequest
DeleteFileRequest
GetBlockRequest
DeleteBlockRequest
InspectBlockRequest
ListBlockRequest
InspectDiffRequest
ListDiffRequest
DeleteDiffRequest

Package pfs is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var CommitType_name = map[int32]string{
	0: "COMMIT_TYPE_NONE",
	1: "COMMIT_TYPE_READ",
	2: "COMMIT_TYPE_WRITE",
}
View Source 
var CommitType_value = map[string]int32{
	"COMMIT_TYPE_NONE":  0,
	"COMMIT_TYPE_READ":  1,
	"COMMIT_TYPE_WRITE": 2,
}
View Source 
var FileType_name = map[int32]string{
	0: "FILE_TYPE_NONE",
	1: "FILE_TYPE_REGULAR",
	2: "FILE_TYPE_DIR",
}
View Source 
var FileType_value = map[string]int32{
	"FILE_TYPE_NONE":    0,
	"FILE_TYPE_REGULAR": 1,
	"FILE_TYPE_DIR":     2,
}

Functions

func CreateRepo 

func CreateRepo(apiClient APIClient, repoName string) error

func DeleteBlock 

func DeleteBlock(apiClient BlockAPIClient, block *Block) error

func DeleteCommit 

func DeleteCommit(apiClient APIClient, repoName string, commitID string) error

func DeleteFile 

func DeleteFile(apiClient APIClient, repoName string, commitID string, path string) error

func DeleteRepo 

func DeleteRepo(apiClient APIClient, repoName string) error

func FinishCommit 

func FinishCommit(apiClient APIClient, repoName string, commitID string) error

func GetBlock 

func GetBlock(apiClient BlockAPIClient, hash string, offsetBytes uint64, sizeBytes uint64) (io.Reader, error)

func GetFile 

func GetFile(apiClient APIClient, repoName string, commitID string, path string, offset int64, size int64, fromCommitID string, shard *Shard, writer io.Writer) error

func MakeDirectory 

func MakeDirectory(apiClient APIClient, repoName string, commitID string, path string) (retErr error)

func PutFile 

func PutFile(apiClient APIClient, repoName string, commitID string, path string, offset int64, reader io.Reader) (_ int, retErr error)

func RegisterAPIHandler 

func RegisterAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAPIHandler registers the http handlers for service API to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAPIHandlerFromEndpoint 

func RegisterAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAPIHandlerFromEndpoint is same as RegisterAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAPIServer 

func RegisterAPIServer(s *grpc.Server, srv APIServer)

func RegisterBlockAPIServer 

func RegisterBlockAPIServer(s *grpc.Server, srv BlockAPIServer)

func RegisterInternalAPIServer 

func RegisterInternalAPIServer(s *grpc.Server, srv InternalAPIServer)

Types

type APIClient 

type APIClient interface {
	// Repo rpcs
	// CreateRepo creates a new repo.
	// An error is returned if the repo already exists.
	CreateRepo(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// InspectRepo returns info about a repo.
	InspectRepo(ctx context.Context, in *InspectRepoRequest, opts ...grpc.CallOption) (*RepoInfo, error)
	// ListRepo returns info about all repos.
	ListRepo(ctx context.Context, in *ListRepoRequest, opts ...grpc.CallOption) (*RepoInfos, error)
	// DeleteRepo deletes a repo.
	DeleteRepo(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// Commit rpcs
	// StartCommit creates a new write commit from a parent commit.
	StartCommit(ctx context.Context, in *StartCommitRequest, opts ...grpc.CallOption) (*Commit, error)
	// FinishCommit turns a write commit into a read commit.
	FinishCommit(ctx context.Context, in *FinishCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// InspectCommit returns the info about a commit.
	InspectCommit(ctx context.Context, in *InspectCommitRequest, opts ...grpc.CallOption) (*CommitInfo, error)
	// ListCommit returns info about all commits.
	ListCommit(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (*CommitInfos, error)
	// DeleteCommit deletes a commit.
	DeleteCommit(ctx context.Context, in *DeleteCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(ctx context.Context, in *ListBranchRequest, opts ...grpc.CallOption) (*CommitInfos, error)
	// File rpcs
	// PutFile writes the specified file to pfs.
	PutFile(ctx context.Context, opts ...grpc.CallOption) (API_PutFileClient, error)
	// GetFile returns a byte stream of the contents of the file.
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (API_GetFileClient, error)
	// InspectFile returns info about a file.
	InspectFile(ctx context.Context, in *InspectFileRequest, opts ...grpc.CallOption) (*FileInfo, error)
	// ListFile returns info about all files.
	ListFile(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (*FileInfos, error)
	// DeleteFile deletes a file.
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
}

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

type APIServer interface {
	// Repo rpcs
	// CreateRepo creates a new repo.
	// An error is returned if the repo already exists.
	CreateRepo(context.Context, *CreateRepoRequest) (*google_protobuf1.Empty, error)
	// InspectRepo returns info about a repo.
	InspectRepo(context.Context, *InspectRepoRequest) (*RepoInfo, error)
	// ListRepo returns info about all repos.
	ListRepo(context.Context, *ListRepoRequest) (*RepoInfos, error)
	// DeleteRepo deletes a repo.
	DeleteRepo(context.Context, *DeleteRepoRequest) (*google_protobuf1.Empty, error)
	// Commit rpcs
	// StartCommit creates a new write commit from a parent commit.
	StartCommit(context.Context, *StartCommitRequest) (*Commit, error)
	// FinishCommit turns a write commit into a read commit.
	FinishCommit(context.Context, *FinishCommitRequest) (*google_protobuf1.Empty, error)
	// InspectCommit returns the info about a commit.
	InspectCommit(context.Context, *InspectCommitRequest) (*CommitInfo, error)
	// ListCommit returns info about all commits.
	ListCommit(context.Context, *ListCommitRequest) (*CommitInfos, error)
	// DeleteCommit deletes a commit.
	DeleteCommit(context.Context, *DeleteCommitRequest) (*google_protobuf1.Empty, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(context.Context, *ListBranchRequest) (*CommitInfos, error)
	// File rpcs
	// PutFile writes the specified file to pfs.
	PutFile(API_PutFileServer) error
	// GetFile returns a byte stream of the contents of the file.
	GetFile(*GetFileRequest, API_GetFileServer) error
	// InspectFile returns info about a file.
	InspectFile(context.Context, *InspectFileRequest) (*FileInfo, error)
	// ListFile returns info about all files.
	ListFile(context.Context, *ListFileRequest) (*FileInfos, error)
	// DeleteFile deletes a file.
	DeleteFile(context.Context, *DeleteFileRequest) (*google_protobuf1.Empty, error)
}

type API_GetFileClient 

type API_GetFileClient interface {
	Recv() (*google_protobuf3.BytesValue, error)
	grpc.ClientStream
}

type API_GetFileServer 

type API_GetFileServer interface {
	Send(*google_protobuf3.BytesValue) error
	grpc.ServerStream
}

type API_PutFileClient 

type API_PutFileClient interface {
	Send(*PutFileRequest) error
	CloseAndRecv() (*google_protobuf1.Empty, error)
	grpc.ClientStream
}

type API_PutFileServer 

type API_PutFileServer interface {
	SendAndClose(*google_protobuf1.Empty) error
	Recv() (*PutFileRequest, error)
	grpc.ServerStream
}

type Append 

type Append struct {
	BlockRefs []*BlockRef     `protobuf:"bytes,1,rep,name=block_refs,json=blockRefs" json:"block_refs,omitempty"`
	Children  map[string]bool `` /* 137-byte string literal not displayed */
	LastRef   *Commit         `protobuf:"bytes,3,opt,name=last_ref,json=lastRef" json:"last_ref,omitempty"`
	Delete    bool            `protobuf:"varint,4,opt,name=delete" json:"delete,omitempty"`
}

func (*Append) Descriptor 

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

func (*Append) GetBlockRefs 

func (m *Append) GetBlockRefs() []*BlockRef

func (*Append) GetChildren 

func (m *Append) GetChildren() map[string]bool

func (*Append) GetLastRef 

func (m *Append) GetLastRef() *Commit

func (*Append) ProtoMessage 

func (*Append) ProtoMessage()

func (*Append) Reset 

func (m *Append) Reset()

func (*Append) String 

func (m *Append) String() string

type Block 

type Block struct {
	Hash string `protobuf:"bytes,1,opt,name=hash" json:"hash,omitempty"`
}

func NewBlock 

func NewBlock(hash string) *Block

func (*Block) Descriptor 

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

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) Reset 

func (m *Block) Reset()

func (*Block) String 

func (m *Block) String() string

type BlockAPIClient 

type BlockAPIClient interface {
	PutBlock(ctx context.Context, opts ...grpc.CallOption) (BlockAPI_PutBlockClient, error)
	GetBlock(ctx context.Context, in *GetBlockRequest, opts ...grpc.CallOption) (BlockAPI_GetBlockClient, error)
	DeleteBlock(ctx context.Context, in *DeleteBlockRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	InspectBlock(ctx context.Context, in *InspectBlockRequest, opts ...grpc.CallOption) (*BlockInfo, error)
	ListBlock(ctx context.Context, in *ListBlockRequest, opts ...grpc.CallOption) (*BlockInfos, error)
	CreateDiff(ctx context.Context, in *DiffInfo, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	InspectDiff(ctx context.Context, in *InspectDiffRequest, opts ...grpc.CallOption) (*DiffInfo, error)
	ListDiff(ctx context.Context, in *ListDiffRequest, opts ...grpc.CallOption) (BlockAPI_ListDiffClient, error)
	DeleteDiff(ctx context.Context, in *DeleteDiffRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
}

func NewBlockAPIClient 

func NewBlockAPIClient(cc *grpc.ClientConn) BlockAPIClient

type BlockAPIServer 

type BlockAPIServer interface {
	PutBlock(BlockAPI_PutBlockServer) error
	GetBlock(*GetBlockRequest, BlockAPI_GetBlockServer) error
	DeleteBlock(context.Context, *DeleteBlockRequest) (*google_protobuf1.Empty, error)
	InspectBlock(context.Context, *InspectBlockRequest) (*BlockInfo, error)
	ListBlock(context.Context, *ListBlockRequest) (*BlockInfos, error)
	CreateDiff(context.Context, *DiffInfo) (*google_protobuf1.Empty, error)
	InspectDiff(context.Context, *InspectDiffRequest) (*DiffInfo, error)
	ListDiff(*ListDiffRequest, BlockAPI_ListDiffServer) error
	DeleteDiff(context.Context, *DeleteDiffRequest) (*google_protobuf1.Empty, error)
}

type BlockAPI_GetBlockClient 

type BlockAPI_GetBlockClient interface {
	Recv() (*google_protobuf3.BytesValue, error)
	grpc.ClientStream
}

type BlockAPI_GetBlockServer 

type BlockAPI_GetBlockServer interface {
	Send(*google_protobuf3.BytesValue) error
	grpc.ServerStream
}

type BlockAPI_ListDiffClient 

type BlockAPI_ListDiffClient interface {
	Recv() (*DiffInfo, error)
	grpc.ClientStream
}

type BlockAPI_ListDiffServer 

type BlockAPI_ListDiffServer interface {
	Send(*DiffInfo) error
	grpc.ServerStream
}

type BlockAPI_PutBlockClient 

type BlockAPI_PutBlockClient interface {
	Send(*google_protobuf3.BytesValue) error
	CloseAndRecv() (*BlockRefs, error)
	grpc.ClientStream
}

type BlockAPI_PutBlockServer 

type BlockAPI_PutBlockServer interface {
	SendAndClose(*BlockRefs) error
	Recv() (*google_protobuf3.BytesValue, error)
	grpc.ServerStream
}

type BlockInfo 

type BlockInfo struct {
	Block     *Block                      `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
	Created   *google_protobuf2.Timestamp `protobuf:"bytes,2,opt,name=created" json:"created,omitempty"`
	SizeBytes uint64                      `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes" json:"size_bytes,omitempty"`
}

func InspectBlock 

func InspectBlock(apiClient BlockAPIClient, hash string) (*BlockInfo, error)

func ListBlock 

func ListBlock(apiClient BlockAPIClient) ([]*BlockInfo, error)

func (*BlockInfo) Descriptor 

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

func (*BlockInfo) GetBlock 

func (m *BlockInfo) GetBlock() *Block

func (*BlockInfo) GetCreated 

func (m *BlockInfo) GetCreated() *google_protobuf2.Timestamp

func (*BlockInfo) ProtoMessage 

func (*BlockInfo) ProtoMessage()

func (*BlockInfo) Reset 

func (m *BlockInfo) Reset()

func (*BlockInfo) String 

func (m *BlockInfo) String() string

type BlockInfos 

type BlockInfos struct {
	BlockInfo []*BlockInfo `protobuf:"bytes,1,rep,name=block_info,json=blockInfo" json:"block_info,omitempty"`
}

func (*BlockInfos) Descriptor 

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

func (*BlockInfos) GetBlockInfo 

func (m *BlockInfos) GetBlockInfo() []*BlockInfo

func (*BlockInfos) ProtoMessage 

func (*BlockInfos) ProtoMessage()

func (*BlockInfos) Reset 

func (m *BlockInfos) Reset()

func (*BlockInfos) String 

func (m *BlockInfos) String() string

type BlockRef 

type BlockRef struct {
	Block *Block     `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
	Range *ByteRange `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"`
}

func (*BlockRef) Descriptor 

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

func (*BlockRef) GetBlock 

func (m *BlockRef) GetBlock() *Block

func (*BlockRef) GetRange 

func (m *BlockRef) GetRange() *ByteRange

func (*BlockRef) ProtoMessage 

func (*BlockRef) ProtoMessage()

func (*BlockRef) Reset 

func (m *BlockRef) Reset()

func (*BlockRef) String 

func (m *BlockRef) String() string

type BlockRefs 

type BlockRefs struct {
	BlockRef []*BlockRef `protobuf:"bytes,1,rep,name=block_ref,json=blockRef" json:"block_ref,omitempty"`
}

func PutBlock 

func PutBlock(apiClient BlockAPIClient, reader io.Reader) (*BlockRefs, error)

func (*BlockRefs) Descriptor 

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

func (*BlockRefs) GetBlockRef 

func (m *BlockRefs) GetBlockRef() []*BlockRef

func (*BlockRefs) ProtoMessage 

func (*BlockRefs) ProtoMessage()

func (*BlockRefs) Reset 

func (m *BlockRefs) Reset()

func (*BlockRefs) String 

func (m *BlockRefs) String() string

type ByteRange 

type ByteRange struct {
	Lower uint64 `protobuf:"varint,1,opt,name=lower" json:"lower,omitempty"`
	Upper uint64 `protobuf:"varint,2,opt,name=upper" json:"upper,omitempty"`
}

func (*ByteRange) Descriptor 

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

func (*ByteRange) ProtoMessage 

func (*ByteRange) ProtoMessage()

func (*ByteRange) Reset 

func (m *ByteRange) Reset()

func (*ByteRange) String 

func (m *ByteRange) String() string

type Commit 

type Commit struct {
	Repo *Repo  `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	ID   string `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
}

func NewCommit 

func NewCommit(repoName string, commitID string) *Commit

func StartCommit 

func StartCommit(apiClient APIClient, repoName string, parentCommit string, branch string) (*Commit, error)

func (*Commit) Descriptor 

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

func (*Commit) GetRepo 

func (m *Commit) GetRepo() *Repo

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) Reset 

func (m *Commit) Reset()

func (*Commit) String 

func (m *Commit) String() string

type CommitInfo 

type CommitInfo struct {
	Commit       *Commit                     `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	Branch       string                      `protobuf:"bytes,2,opt,name=branch" json:"branch,omitempty"`
	CommitType   CommitType                  `protobuf:"varint,3,opt,name=commit_type,json=commitType,enum=pfs.CommitType" json:"commit_type,omitempty"`
	ParentCommit *Commit                     `protobuf:"bytes,4,opt,name=parent_commit,json=parentCommit" json:"parent_commit,omitempty"`
	Started      *google_protobuf2.Timestamp `protobuf:"bytes,5,opt,name=started" json:"started,omitempty"`
	Finished     *google_protobuf2.Timestamp `protobuf:"bytes,6,opt,name=finished" json:"finished,omitempty"`
	SizeBytes    uint64                      `protobuf:"varint,7,opt,name=size_bytes,json=sizeBytes" json:"size_bytes,omitempty"`
}

func InspectCommit 

func InspectCommit(apiClient APIClient, repoName string, commitID string) (*CommitInfo, error)

func ListBranch 

func ListBranch(apiClient APIClient, repoName string) ([]*CommitInfo, error)

func ListCommit 

func ListCommit(apiClient APIClient, repoNames []string, fromCommitIDs []string, block bool) ([]*CommitInfo, error)

func (*CommitInfo) Descriptor 

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

func (*CommitInfo) GetCommit 

func (m *CommitInfo) GetCommit() *Commit

func (*CommitInfo) GetFinished 

func (m *CommitInfo) GetFinished() *google_protobuf2.Timestamp

func (*CommitInfo) GetParentCommit 

func (m *CommitInfo) GetParentCommit() *Commit

func (*CommitInfo) GetStarted 

func (m *CommitInfo) GetStarted() *google_protobuf2.Timestamp

func (*CommitInfo) ProtoMessage 

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) Reset 

func (m *CommitInfo) Reset()

func (*CommitInfo) String 

func (m *CommitInfo) String() string

type CommitInfos 

type CommitInfos struct {
	CommitInfo []*CommitInfo `protobuf:"bytes,1,rep,name=commit_info,json=commitInfo" json:"commit_info,omitempty"`
}

func (*CommitInfos) Descriptor 

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

func (*CommitInfos) GetCommitInfo 

func (m *CommitInfos) GetCommitInfo() []*CommitInfo

func (*CommitInfos) ProtoMessage 

func (*CommitInfos) ProtoMessage()

func (*CommitInfos) Reset 

func (m *CommitInfos) Reset()

func (*CommitInfos) String 

func (m *CommitInfos) String() string

type CommitType 

type CommitType int32
const (
	CommitType_COMMIT_TYPE_NONE  CommitType = 0
	CommitType_COMMIT_TYPE_READ  CommitType = 1
	CommitType_COMMIT_TYPE_WRITE CommitType = 2
)

func (CommitType) EnumDescriptor 

func (CommitType) EnumDescriptor() ([]byte, []int)

func (CommitType) String 

func (x CommitType) String() string

type CreateRepoRequest 

type CreateRepoRequest struct {
	Repo    *Repo                       `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Created *google_protobuf2.Timestamp `protobuf:"bytes,2,opt,name=created" json:"created,omitempty"`
}

func (*CreateRepoRequest) Descriptor 

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

func (*CreateRepoRequest) GetCreated 

func (m *CreateRepoRequest) GetCreated() *google_protobuf2.Timestamp

func (*CreateRepoRequest) GetRepo 

func (m *CreateRepoRequest) GetRepo() *Repo

func (*CreateRepoRequest) ProtoMessage 

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) Reset 

func (m *CreateRepoRequest) Reset()

func (*CreateRepoRequest) String 

func (m *CreateRepoRequest) String() string

type DeleteBlockRequest 

type DeleteBlockRequest struct {
	Block *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
}

func (*DeleteBlockRequest) Descriptor 

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

func (*DeleteBlockRequest) GetBlock 

func (m *DeleteBlockRequest) GetBlock() *Block

func (*DeleteBlockRequest) ProtoMessage 

func (*DeleteBlockRequest) ProtoMessage()

func (*DeleteBlockRequest) Reset 

func (m *DeleteBlockRequest) Reset()

func (*DeleteBlockRequest) String 

func (m *DeleteBlockRequest) String() string

type DeleteCommitRequest 

type DeleteCommitRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
}

func (*DeleteCommitRequest) Descriptor 

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

func (*DeleteCommitRequest) GetCommit 

func (m *DeleteCommitRequest) GetCommit() *Commit

func (*DeleteCommitRequest) ProtoMessage 

func (*DeleteCommitRequest) ProtoMessage()

func (*DeleteCommitRequest) Reset 

func (m *DeleteCommitRequest) Reset()

func (*DeleteCommitRequest) String 

func (m *DeleteCommitRequest) String() string

type DeleteDiffRequest 

type DeleteDiffRequest struct {
	Diff *Diff `protobuf:"bytes,1,opt,name=diff" json:"diff,omitempty"`
}

func (*DeleteDiffRequest) Descriptor 

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

func (*DeleteDiffRequest) GetDiff 

func (m *DeleteDiffRequest) GetDiff() *Diff

func (*DeleteDiffRequest) ProtoMessage 

func (*DeleteDiffRequest) ProtoMessage()

func (*DeleteDiffRequest) Reset 

func (m *DeleteDiffRequest) Reset()

func (*DeleteDiffRequest) String 

func (m *DeleteDiffRequest) String() string

type DeleteFileRequest 

type DeleteFileRequest struct {
	File *File `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
}

func (*DeleteFileRequest) Descriptor 

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

func (*DeleteFileRequest) GetFile 

func (m *DeleteFileRequest) GetFile() *File

func (*DeleteFileRequest) ProtoMessage 

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset 

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) String 

func (m *DeleteFileRequest) String() string

type DeleteRepoRequest 

type DeleteRepoRequest struct {
	Repo *Repo `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
}

func (*DeleteRepoRequest) Descriptor 

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

func (*DeleteRepoRequest) GetRepo 

func (m *DeleteRepoRequest) GetRepo() *Repo

func (*DeleteRepoRequest) ProtoMessage 

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) Reset 

func (m *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) String 

func (m *DeleteRepoRequest) String() string

type Diff 

type Diff struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	Shard  uint64  `protobuf:"varint,2,opt,name=shard" json:"shard,omitempty"`
}

func NewDiff 

func NewDiff(repoName string, commitID string, shard uint64) *Diff

func (*Diff) Descriptor 

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

func (*Diff) GetCommit 

func (m *Diff) GetCommit() *Commit

func (*Diff) ProtoMessage 

func (*Diff) ProtoMessage()

func (*Diff) Reset 

func (m *Diff) Reset()

func (*Diff) String 

func (m *Diff) String() string

type DiffInfo 

type DiffInfo struct {
	Diff         *Diff                       `protobuf:"bytes,1,opt,name=diff" json:"diff,omitempty"`
	ParentCommit *Commit                     `protobuf:"bytes,2,opt,name=parent_commit,json=parentCommit" json:"parent_commit,omitempty"`
	Branch       string                      `protobuf:"bytes,3,opt,name=branch" json:"branch,omitempty"`
	Started      *google_protobuf2.Timestamp `protobuf:"bytes,4,opt,name=started" json:"started,omitempty"`
	Finished     *google_protobuf2.Timestamp `protobuf:"bytes,5,opt,name=finished" json:"finished,omitempty"`
	// Appends is the BlockRefs which have been append to files indexed by path.
	Appends   map[string]*Append `` /* 134-byte string literal not displayed */
	SizeBytes uint64             `protobuf:"varint,7,opt,name=size_bytes,json=sizeBytes" json:"size_bytes,omitempty"`
}

func (*DiffInfo) Descriptor 

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

func (*DiffInfo) GetAppends 

func (m *DiffInfo) GetAppends() map[string]*Append

func (*DiffInfo) GetDiff 

func (m *DiffInfo) GetDiff() *Diff

func (*DiffInfo) GetFinished 

func (m *DiffInfo) GetFinished() *google_protobuf2.Timestamp

func (*DiffInfo) GetParentCommit 

func (m *DiffInfo) GetParentCommit() *Commit

func (*DiffInfo) GetStarted 

func (m *DiffInfo) GetStarted() *google_protobuf2.Timestamp

func (*DiffInfo) ProtoMessage 

func (*DiffInfo) ProtoMessage()

func (*DiffInfo) Reset 

func (m *DiffInfo) Reset()

func (*DiffInfo) String 

func (m *DiffInfo) String() string

type File 

type File struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	Path   string  `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
}

func NewFile 

func NewFile(repoName string, commitID string, path string) *File

func (*File) Descriptor 

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

func (*File) GetCommit 

func (m *File) GetCommit() *Commit

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) Reset 

func (m *File) Reset()

func (*File) String 

func (m *File) String() string

type FileInfo 

type FileInfo struct {
	File           *File                       `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	FileType       FileType                    `protobuf:"varint,2,opt,name=file_type,json=fileType,enum=pfs.FileType" json:"file_type,omitempty"`
	SizeBytes      uint64                      `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes" json:"size_bytes,omitempty"`
	Perm           uint32                      `protobuf:"varint,4,opt,name=perm" json:"perm,omitempty"`
	Modified       *google_protobuf2.Timestamp `protobuf:"bytes,5,opt,name=modified" json:"modified,omitempty"`
	CommitModified *Commit                     `protobuf:"bytes,6,opt,name=commit_modified,json=commitModified" json:"commit_modified,omitempty"`
	Children       []*File                     `protobuf:"bytes,7,rep,name=children" json:"children,omitempty"`
}

func InspectFile 

func InspectFile(apiClient APIClient, repoName string, commitID string, path string, fromCommitID string, shard *Shard) (*FileInfo, error)

func ListFile 

func ListFile(apiClient APIClient, repoName string, commitID string, path string, fromCommitID string, shard *Shard) ([]*FileInfo, error)

func (*FileInfo) Descriptor 

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

func (*FileInfo) GetChildren 

func (m *FileInfo) GetChildren() []*File

func (*FileInfo) GetCommitModified 

func (m *FileInfo) GetCommitModified() *Commit

func (*FileInfo) GetFile 

func (m *FileInfo) GetFile() *File

func (*FileInfo) GetModified 

func (m *FileInfo) GetModified() *google_protobuf2.Timestamp

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset 

func (m *FileInfo) Reset()

func (*FileInfo) String 

func (m *FileInfo) String() string

type FileInfos 

type FileInfos struct {
	FileInfo []*FileInfo `protobuf:"bytes,1,rep,name=file_info,json=fileInfo" json:"file_info,omitempty"`
}

func (*FileInfos) Descriptor 

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

func (*FileInfos) GetFileInfo 

func (m *FileInfos) GetFileInfo() []*FileInfo

func (*FileInfos) ProtoMessage 

func (*FileInfos) ProtoMessage()

func (*FileInfos) Reset 

func (m *FileInfos) Reset()

func (*FileInfos) String 

func (m *FileInfos) String() string

type FileType 

type FileType int32
const (
	FileType_FILE_TYPE_NONE    FileType = 0
	FileType_FILE_TYPE_REGULAR FileType = 1
	FileType_FILE_TYPE_DIR     FileType = 2
)

func (FileType) EnumDescriptor 

func (FileType) EnumDescriptor() ([]byte, []int)

func (FileType) String 

func (x FileType) String() string

type FinishCommitRequest 

type FinishCommitRequest struct {
	Commit   *Commit                     `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	Finished *google_protobuf2.Timestamp `protobuf:"bytes,3,opt,name=finished" json:"finished,omitempty"`
}

func (*FinishCommitRequest) Descriptor 

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

func (*FinishCommitRequest) GetCommit 

func (m *FinishCommitRequest) GetCommit() *Commit

func (*FinishCommitRequest) GetFinished 

func (m *FinishCommitRequest) GetFinished() *google_protobuf2.Timestamp

func (*FinishCommitRequest) ProtoMessage 

func (*FinishCommitRequest) ProtoMessage()

func (*FinishCommitRequest) Reset 

func (m *FinishCommitRequest) Reset()

func (*FinishCommitRequest) String 

func (m *FinishCommitRequest) String() string

type GetBlockRequest 

type GetBlockRequest struct {
	Block       *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
	OffsetBytes uint64 `protobuf:"varint,2,opt,name=offset_bytes,json=offsetBytes" json:"offset_bytes,omitempty"`
	SizeBytes   uint64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes" json:"size_bytes,omitempty"`
}

func (*GetBlockRequest) Descriptor 

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

func (*GetBlockRequest) GetBlock 

func (m *GetBlockRequest) GetBlock() *Block

func (*GetBlockRequest) ProtoMessage 

func (*GetBlockRequest) ProtoMessage()

func (*GetBlockRequest) Reset 

func (m *GetBlockRequest) Reset()

func (*GetBlockRequest) String 

func (m *GetBlockRequest) String() string

type GetFileRequest 

type GetFileRequest struct {
	File        *File   `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	OffsetBytes int64   `protobuf:"varint,2,opt,name=offset_bytes,json=offsetBytes" json:"offset_bytes,omitempty"`
	SizeBytes   int64   `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes" json:"size_bytes,omitempty"`
	Shard       *Shard  `protobuf:"bytes,4,opt,name=shard" json:"shard,omitempty"`
	FromCommit  *Commit `protobuf:"bytes,5,opt,name=from_commit,json=fromCommit" json:"from_commit,omitempty"`
}

func (*GetFileRequest) Descriptor 

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

func (*GetFileRequest) GetFile 

func (m *GetFileRequest) GetFile() *File

func (*GetFileRequest) GetFromCommit 

func (m *GetFileRequest) GetFromCommit() *Commit

func (*GetFileRequest) GetShard 

func (m *GetFileRequest) GetShard() *Shard

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) Reset 

func (m *GetFileRequest) Reset()

func (*GetFileRequest) String 

func (m *GetFileRequest) String() string

type InspectBlockRequest 

type InspectBlockRequest struct {
	Block *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
}

func (*InspectBlockRequest) Descriptor 

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

func (*InspectBlockRequest) GetBlock 

func (m *InspectBlockRequest) GetBlock() *Block

func (*InspectBlockRequest) ProtoMessage 

func (*InspectBlockRequest) ProtoMessage()

func (*InspectBlockRequest) Reset 

func (m *InspectBlockRequest) Reset()

func (*InspectBlockRequest) String 

func (m *InspectBlockRequest) String() string

type InspectCommitRequest 

type InspectCommitRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
}

func (*InspectCommitRequest) Descriptor 

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

func (*InspectCommitRequest) GetCommit 

func (m *InspectCommitRequest) GetCommit() *Commit

func (*InspectCommitRequest) ProtoMessage 

func (*InspectCommitRequest) ProtoMessage()

func (*InspectCommitRequest) Reset 

func (m *InspectCommitRequest) Reset()

func (*InspectCommitRequest) String 

func (m *InspectCommitRequest) String() string

type InspectDiffRequest 

type InspectDiffRequest struct {
	Diff *Diff `protobuf:"bytes,1,opt,name=diff" json:"diff,omitempty"`
}

func (*InspectDiffRequest) Descriptor 

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

func (*InspectDiffRequest) GetDiff 

func (m *InspectDiffRequest) GetDiff() *Diff

func (*InspectDiffRequest) ProtoMessage 

func (*InspectDiffRequest) ProtoMessage()

func (*InspectDiffRequest) Reset 

func (m *InspectDiffRequest) Reset()

func (*InspectDiffRequest) String 

func (m *InspectDiffRequest) String() string

type InspectFileRequest 

type InspectFileRequest struct {
	File       *File   `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	Shard      *Shard  `protobuf:"bytes,2,opt,name=shard" json:"shard,omitempty"`
	FromCommit *Commit `protobuf:"bytes,3,opt,name=from_commit,json=fromCommit" json:"from_commit,omitempty"`
}

func (*InspectFileRequest) Descriptor 

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

func (*InspectFileRequest) GetFile 

func (m *InspectFileRequest) GetFile() *File

func (*InspectFileRequest) GetFromCommit 

func (m *InspectFileRequest) GetFromCommit() *Commit

func (*InspectFileRequest) GetShard 

func (m *InspectFileRequest) GetShard() *Shard

func (*InspectFileRequest) ProtoMessage 

func (*InspectFileRequest) ProtoMessage()

func (*InspectFileRequest) Reset 

func (m *InspectFileRequest) Reset()

func (*InspectFileRequest) String 

func (m *InspectFileRequest) String() string

type InspectRepoRequest 

type InspectRepoRequest struct {
	Repo *Repo `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
}

func (*InspectRepoRequest) Descriptor 

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

func (*InspectRepoRequest) GetRepo 

func (m *InspectRepoRequest) GetRepo() *Repo

func (*InspectRepoRequest) ProtoMessage 

func (*InspectRepoRequest) ProtoMessage()

func (*InspectRepoRequest) Reset 

func (m *InspectRepoRequest) Reset()

func (*InspectRepoRequest) String 

func (m *InspectRepoRequest) String() string

type InternalAPIClient 

type InternalAPIClient interface {
	// Repo rpcs
	// CreateRepo creates a new repo.
	// An error is returned if the repo already exists.
	CreateRepo(ctx context.Context, in *CreateRepoRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// InspectRepo returns info about a repo.
	InspectRepo(ctx context.Context, in *InspectRepoRequest, opts ...grpc.CallOption) (*RepoInfo, error)
	// ListRepo returns info about all repos.
	ListRepo(ctx context.Context, in *ListRepoRequest, opts ...grpc.CallOption) (*RepoInfos, error)
	// DeleteRepo deletes a repo.
	DeleteRepo(ctx context.Context, in *DeleteRepoRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// Commit rpcs
	// StartCommit creates a new write commit from a parent commit.
	StartCommit(ctx context.Context, in *StartCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// FinishCommit turns a write commit into a read commit.
	FinishCommit(ctx context.Context, in *FinishCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// InspectCommit returns the info about a commit.
	InspectCommit(ctx context.Context, in *InspectCommitRequest, opts ...grpc.CallOption) (*CommitInfo, error)
	// ListCommit returns info about all commits.
	ListCommit(ctx context.Context, in *ListCommitRequest, opts ...grpc.CallOption) (*CommitInfos, error)
	// DeleteCommit deletes a commit.
	DeleteCommit(ctx context.Context, in *DeleteCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(ctx context.Context, in *ListBranchRequest, opts ...grpc.CallOption) (*CommitInfos, error)
	// File rpcs
	// PutFile writes the specified file to pfs.
	PutFile(ctx context.Context, opts ...grpc.CallOption) (InternalAPI_PutFileClient, error)
	// GetFile returns a byte stream of the contents of the file.
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (InternalAPI_GetFileClient, error)
	// InspectFile returns info about a file.
	InspectFile(ctx context.Context, in *InspectFileRequest, opts ...grpc.CallOption) (*FileInfo, error)
	// ListFile returns info about all files.
	ListFile(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (*FileInfos, error)
	// DeleteFile deletes a file.
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
}

func NewInternalAPIClient 

func NewInternalAPIClient(cc *grpc.ClientConn) InternalAPIClient

type InternalAPIServer 

type InternalAPIServer interface {
	// Repo rpcs
	// CreateRepo creates a new repo.
	// An error is returned if the repo already exists.
	CreateRepo(context.Context, *CreateRepoRequest) (*google_protobuf1.Empty, error)
	// InspectRepo returns info about a repo.
	InspectRepo(context.Context, *InspectRepoRequest) (*RepoInfo, error)
	// ListRepo returns info about all repos.
	ListRepo(context.Context, *ListRepoRequest) (*RepoInfos, error)
	// DeleteRepo deletes a repo.
	DeleteRepo(context.Context, *DeleteRepoRequest) (*google_protobuf1.Empty, error)
	// Commit rpcs
	// StartCommit creates a new write commit from a parent commit.
	StartCommit(context.Context, *StartCommitRequest) (*google_protobuf1.Empty, error)
	// FinishCommit turns a write commit into a read commit.
	FinishCommit(context.Context, *FinishCommitRequest) (*google_protobuf1.Empty, error)
	// InspectCommit returns the info about a commit.
	InspectCommit(context.Context, *InspectCommitRequest) (*CommitInfo, error)
	// ListCommit returns info about all commits.
	ListCommit(context.Context, *ListCommitRequest) (*CommitInfos, error)
	// DeleteCommit deletes a commit.
	DeleteCommit(context.Context, *DeleteCommitRequest) (*google_protobuf1.Empty, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(context.Context, *ListBranchRequest) (*CommitInfos, error)
	// File rpcs
	// PutFile writes the specified file to pfs.
	PutFile(InternalAPI_PutFileServer) error
	// GetFile returns a byte stream of the contents of the file.
	GetFile(*GetFileRequest, InternalAPI_GetFileServer) error
	// InspectFile returns info about a file.
	InspectFile(context.Context, *InspectFileRequest) (*FileInfo, error)
	// ListFile returns info about all files.
	ListFile(context.Context, *ListFileRequest) (*FileInfos, error)
	// DeleteFile deletes a file.
	DeleteFile(context.Context, *DeleteFileRequest) (*google_protobuf1.Empty, error)
}

type InternalAPI_GetFileClient 

type InternalAPI_GetFileClient interface {
	Recv() (*google_protobuf3.BytesValue, error)
	grpc.ClientStream
}

type InternalAPI_GetFileServer 

type InternalAPI_GetFileServer interface {
	Send(*google_protobuf3.BytesValue) error
	grpc.ServerStream
}

type InternalAPI_PutFileClient 

type InternalAPI_PutFileClient interface {
	Send(*PutFileRequest) error
	CloseAndRecv() (*google_protobuf1.Empty, error)
	grpc.ClientStream
}

type InternalAPI_PutFileServer 

type InternalAPI_PutFileServer interface {
	SendAndClose(*google_protobuf1.Empty) error
	Recv() (*PutFileRequest, error)
	grpc.ServerStream
}

type ListBlockRequest 

type ListBlockRequest struct {
}

func (*ListBlockRequest) Descriptor 

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

func (*ListBlockRequest) ProtoMessage 

func (*ListBlockRequest) ProtoMessage()

func (*ListBlockRequest) Reset 

func (m *ListBlockRequest) Reset()

func (*ListBlockRequest) String 

func (m *ListBlockRequest) String() string

type ListBranchRequest 

type ListBranchRequest struct {
	Repo *Repo `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
}

func (*ListBranchRequest) Descriptor 

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

func (*ListBranchRequest) GetRepo 

func (m *ListBranchRequest) GetRepo() *Repo

func (*ListBranchRequest) ProtoMessage 

func (*ListBranchRequest) ProtoMessage()

func (*ListBranchRequest) Reset 

func (m *ListBranchRequest) Reset()

func (*ListBranchRequest) String 

func (m *ListBranchRequest) String() string

type ListCommitRequest 

type ListCommitRequest struct {
	Repo       []*Repo    `protobuf:"bytes,1,rep,name=repo" json:"repo,omitempty"`
	CommitType CommitType `protobuf:"varint,2,opt,name=commit_type,json=commitType,enum=pfs.CommitType" json:"commit_type,omitempty"`
	FromCommit []*Commit  `protobuf:"bytes,3,rep,name=from_commit,json=fromCommit" json:"from_commit,omitempty"`
	Block      bool       `protobuf:"varint,4,opt,name=block" json:"block,omitempty"`
}

func (*ListCommitRequest) Descriptor 

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

func (*ListCommitRequest) GetFromCommit 

func (m *ListCommitRequest) GetFromCommit() []*Commit

func (*ListCommitRequest) GetRepo 

func (m *ListCommitRequest) GetRepo() []*Repo

func (*ListCommitRequest) ProtoMessage 

func (*ListCommitRequest) ProtoMessage()

func (*ListCommitRequest) Reset 

func (m *ListCommitRequest) Reset()

func (*ListCommitRequest) String 

func (m *ListCommitRequest) String() string

type ListDiffRequest 

type ListDiffRequest struct {
	Shard uint64 `protobuf:"varint,1,opt,name=shard" json:"shard,omitempty"`
}

func (*ListDiffRequest) Descriptor 

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

func (*ListDiffRequest) ProtoMessage 

func (*ListDiffRequest) ProtoMessage()

func (*ListDiffRequest) Reset 

func (m *ListDiffRequest) Reset()

func (*ListDiffRequest) String 

func (m *ListDiffRequest) String() string

type ListFileRequest 

type ListFileRequest struct {
	File       *File   `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	Shard      *Shard  `protobuf:"bytes,2,opt,name=shard" json:"shard,omitempty"`
	FromCommit *Commit `protobuf:"bytes,3,opt,name=from_commit,json=fromCommit" json:"from_commit,omitempty"`
}

func (*ListFileRequest) Descriptor 

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

func (*ListFileRequest) GetFile 

func (m *ListFileRequest) GetFile() *File

func (*ListFileRequest) GetFromCommit 

func (m *ListFileRequest) GetFromCommit() *Commit

func (*ListFileRequest) GetShard 

func (m *ListFileRequest) GetShard() *Shard

func (*ListFileRequest) ProtoMessage 

func (*ListFileRequest) ProtoMessage()

func (*ListFileRequest) Reset 

func (m *ListFileRequest) Reset()

func (*ListFileRequest) String 

func (m *ListFileRequest) String() string

type ListRepoRequest 

type ListRepoRequest struct {
}

func (*ListRepoRequest) Descriptor 

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

func (*ListRepoRequest) ProtoMessage 

func (*ListRepoRequest) ProtoMessage()

func (*ListRepoRequest) Reset 

func (m *ListRepoRequest) Reset()

func (*ListRepoRequest) String 

func (m *ListRepoRequest) String() string

type PutFileRequest 

type PutFileRequest struct {
	File        *File    `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	FileType    FileType `protobuf:"varint,2,opt,name=file_type,json=fileType,enum=pfs.FileType" json:"file_type,omitempty"`
	OffsetBytes int64    `protobuf:"varint,3,opt,name=offset_bytes,json=offsetBytes" json:"offset_bytes,omitempty"`
	Value       []byte   `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
}

func (*PutFileRequest) Descriptor 

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

func (*PutFileRequest) GetFile 

func (m *PutFileRequest) GetFile() *File

func (*PutFileRequest) ProtoMessage 

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) Reset 

func (m *PutFileRequest) Reset()

func (*PutFileRequest) String 

func (m *PutFileRequest) String() string

type Repo 

type Repo struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func NewRepo 

func NewRepo(repoName string) *Repo

func (*Repo) Descriptor 

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

func (*Repo) ProtoMessage 

func (*Repo) ProtoMessage()

func (*Repo) Reset 

func (m *Repo) Reset()

func (*Repo) String 

func (m *Repo) String() string

type RepoInfo 

type RepoInfo struct {
	Repo      *Repo                       `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Created   *google_protobuf2.Timestamp `protobuf:"bytes,2,opt,name=created" json:"created,omitempty"`
	SizeBytes uint64                      `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes" json:"size_bytes,omitempty"`
}

func InspectRepo 

func InspectRepo(apiClient APIClient, repoName string) (*RepoInfo, error)

func ListRepo 

func ListRepo(apiClient APIClient) ([]*RepoInfo, error)

func (*RepoInfo) Descriptor 

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

func (*RepoInfo) GetCreated 

func (m *RepoInfo) GetCreated() *google_protobuf2.Timestamp

func (*RepoInfo) GetRepo 

func (m *RepoInfo) GetRepo() *Repo

func (*RepoInfo) ProtoMessage 

func (*RepoInfo) ProtoMessage()

func (*RepoInfo) Reset 

func (m *RepoInfo) Reset()

func (*RepoInfo) String 

func (m *RepoInfo) String() string

type RepoInfos 

type RepoInfos struct {
	RepoInfo []*RepoInfo `protobuf:"bytes,1,rep,name=repo_info,json=repoInfo" json:"repo_info,omitempty"`
}

func (*RepoInfos) Descriptor 

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

func (*RepoInfos) GetRepoInfo 

func (m *RepoInfos) GetRepoInfo() []*RepoInfo

func (*RepoInfos) ProtoMessage 

func (*RepoInfos) ProtoMessage()

func (*RepoInfos) Reset 

func (m *RepoInfos) Reset()

func (*RepoInfos) String 

func (m *RepoInfos) String() string

type Shard 

type Shard struct {
	FileNumber   uint64 `protobuf:"varint,1,opt,name=file_number,json=fileNumber" json:"file_number,omitempty"`
	FileModulus  uint64 `protobuf:"varint,2,opt,name=file_modulus,json=fileModulus" json:"file_modulus,omitempty"`
	BlockNumber  uint64 `protobuf:"varint,3,opt,name=block_number,json=blockNumber" json:"block_number,omitempty"`
	BlockModulus uint64 `protobuf:"varint,4,opt,name=block_modulus,json=blockModulus" json:"block_modulus,omitempty"`
}

func (*Shard) Descriptor 

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

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) Reset 

func (m *Shard) Reset()

func (*Shard) String 

func (m *Shard) String() string

type StartCommitRequest 

type StartCommitRequest struct {
	Repo     *Repo                       `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	ID       string                      `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
	ParentID string                      `protobuf:"bytes,3,opt,name=parent_id,json=parentId" json:"parent_id,omitempty"`
	Branch   string                      `protobuf:"bytes,4,opt,name=branch" json:"branch,omitempty"`
	Started  *google_protobuf2.Timestamp `protobuf:"bytes,5,opt,name=started" json:"started,omitempty"`
}

func (*StartCommitRequest) Descriptor 

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

func (*StartCommitRequest) GetRepo 

func (m *StartCommitRequest) GetRepo() *Repo

func (*StartCommitRequest) GetStarted 

func (m *StartCommitRequest) GetStarted() *google_protobuf2.Timestamp

func (*StartCommitRequest) ProtoMessage 

func (*StartCommitRequest) ProtoMessage()

func (*StartCommitRequest) Reset 

func (m *StartCommitRequest) Reset()

func (*StartCommitRequest) String 

func (m *StartCommitRequest) String() string

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.