pfs

package
v1.2.0-RC1 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2016 License: Apache-2.0 Imports: 8 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
Commits
File
Block
Diff
RepoInfo
RepoInfos
CommitInfo
CommitInfos
FileInfo
FileInfos
ByteRange
BlockRef
BlockRefs
Append
BlockInfo
BlockInfos
DiffInfo
Shard
CreateRepoRequest
InspectRepoRequest
ListRepoRequest
DeleteRepoRequest
StartCommitRequest
FinishCommitRequest
ArchiveCommitRequest
InspectCommitRequest
ListCommitRequest
ListBranchRequest
DeleteCommitRequest
FlushCommitRequest
DiffMethod
GetFileRequest
PutFileRequest
InspectFileRequest
ListFileRequest
DeleteFileRequest
MergeRequest
PutBlockRequest
GetBlockRequest
DeleteBlockRequest
InspectBlockRequest
ListBlockRequest
InspectDiffRequest
ListDiffRequest
DeleteDiffRequest

Index

Constants

This section is empty.

Variables

View Source 
var CommitStatus_name = map[int32]string{
	0: "NORMAL",
	1: "ARCHIVED",
	2: "CANCELLED",
	3: "ALL",
}
View Source 
var CommitStatus_value = map[string]int32{
	"NORMAL":    0,
	"ARCHIVED":  1,
	"CANCELLED": 2,
	"ALL":       3,
}
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 Delimiter_name = map[int32]string{
	0: "NONE",
	1: "JSON",
	2: "LINE",
}
View Source 
var Delimiter_value = map[string]int32{
	"NONE": 0,
	"JSON": 1,
	"LINE": 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,
}
View Source 
var MergeStrategy_name = map[int32]string{
	0: "SQUASH",
	1: "REPLAY",
}
View Source 
var MergeStrategy_value = map[string]int32{
	"SQUASH": 0,
	"REPLAY": 1,
}

Functions

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)
	// ArchiveCommit marks a commit as archived, it will be excluded from ListCommit.
	ArchiveCommit(ctx context.Context, in *ArchiveCommitRequest, 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)
	// FlushCommit waits for downstream commits to finish
	FlushCommit(ctx context.Context, in *FlushCommitRequest, opts ...grpc.CallOption) (*CommitInfos, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(ctx context.Context, in *ListBranchRequest, opts ...grpc.CallOption) (*CommitInfos, error)
	// Merge returns the head of the commit of the merge
	Merge(ctx context.Context, in *MergeRequest, opts ...grpc.CallOption) (*Commits, 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)
	// DeleteAll deletes everything
	DeleteAll(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// ArchiveAll archives everything
	ArchiveAll(ctx context.Context, in *google_protobuf1.Empty, 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)
	// ArchiveCommit marks a commit as archived, it will be excluded from ListCommit.
	ArchiveCommit(context.Context, *ArchiveCommitRequest) (*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)
	// FlushCommit waits for downstream commits to finish
	FlushCommit(context.Context, *FlushCommitRequest) (*CommitInfos, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(context.Context, *ListBranchRequest) (*CommitInfos, error)
	// Merge returns the head of the commit of the merge
	Merge(context.Context, *MergeRequest) (*Commits, 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)
	// DeleteAll deletes everything
	DeleteAll(context.Context, *google_protobuf1.Empty) (*google_protobuf1.Empty, error)
	// ArchiveAll archives everything
	ArchiveAll(context.Context, *google_protobuf1.Empty) (*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"`
	FileType  FileType        `protobuf:"varint,5,opt,name=file_type,json=fileType,enum=pfs.FileType" json:"file_type,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 ArchiveCommitRequest added in v1.2.0 

type ArchiveCommitRequest struct {
	Commits []*Commit `protobuf:"bytes,1,rep,name=commits" json:"commits,omitempty"`
}

func (*ArchiveCommitRequest) Descriptor added in v1.2.0 

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

func (*ArchiveCommitRequest) GetCommits added in v1.2.0 

func (m *ArchiveCommitRequest) GetCommits() []*Commit

func (*ArchiveCommitRequest) ProtoMessage added in v1.2.0 

func (*ArchiveCommitRequest) ProtoMessage()

func (*ArchiveCommitRequest) Reset added in v1.2.0 

func (m *ArchiveCommitRequest) Reset()

func (*ArchiveCommitRequest) String added in v1.2.0 

func (m *ArchiveCommitRequest) String() string

type Block 

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

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(*PutBlockRequest) error
	CloseAndRecv() (*BlockRefs, error)
	grpc.ClientStream
}

type BlockAPI_PutBlockServer 

type BlockAPI_PutBlockServer interface {
	SendAndClose(*BlockRefs) error
	Recv() (*PutBlockRequest, 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 (*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 (*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 (*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"`
	Cancelled    bool                        `protobuf:"varint,8,opt,name=cancelled" json:"cancelled,omitempty"`
	Archived     bool                        `protobuf:"varint,9,opt,name=archived" json:"archived,omitempty"`
	Provenance   []*Commit                   `protobuf:"bytes,10,rep,name=provenance" json:"provenance,omitempty"`
}

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) GetProvenance 

func (m *CommitInfo) GetProvenance() []*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 CommitStatus added in v1.2.0 

type CommitStatus int32
const (
	CommitStatus_NORMAL    CommitStatus = 0
	CommitStatus_ARCHIVED  CommitStatus = 1
	CommitStatus_CANCELLED CommitStatus = 2
	CommitStatus_ALL       CommitStatus = 3
)

func (CommitStatus) EnumDescriptor added in v1.2.0 

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

func (CommitStatus) String added in v1.2.0 

func (x CommitStatus) 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 Commits added in v1.2.0 

type Commits struct {
	Commit []*Commit `protobuf:"bytes,1,rep,name=commit" json:"commit,omitempty"`
}

func (*Commits) Descriptor added in v1.2.0 

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

func (*Commits) GetCommit added in v1.2.0 

func (m *Commits) GetCommit() []*Commit

func (*Commits) ProtoMessage added in v1.2.0 

func (*Commits) ProtoMessage()

func (*Commits) Reset added in v1.2.0 

func (m *Commits) Reset()

func (*Commits) String added in v1.2.0 

func (m *Commits) String() string

type CreateRepoRequest 

type CreateRepoRequest struct {
	Repo       *Repo   `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Provenance []*Repo `protobuf:"bytes,2,rep,name=provenance" json:"provenance,omitempty"`
}

func (*CreateRepoRequest) Descriptor 

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

func (*CreateRepoRequest) GetProvenance 

func (m *CreateRepoRequest) GetProvenance() []*Repo

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"`
	Force bool  `protobuf:"varint,2,opt,name=force" json:"force,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 Delimiter 

type Delimiter int32
const (
	Delimiter_NONE Delimiter = 0
	Delimiter_JSON Delimiter = 1
	Delimiter_LINE Delimiter = 2
)

func (Delimiter) EnumDescriptor 

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

func (Delimiter) String 

func (x Delimiter) 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 (*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"`
	Cancelled  bool               `protobuf:"varint,8,opt,name=cancelled" json:"cancelled,omitempty"`
	Provenance []*Commit          `protobuf:"bytes,9,rep,name=provenance" json:"provenance,omitempty"`
	Archived   bool               `protobuf:"varint,10,opt,name=archived" json:"archived,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) GetProvenance 

func (m *DiffInfo) GetProvenance() []*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 DiffMethod added in v1.2.0 

type DiffMethod struct {
	FromCommit *Commit `protobuf:"bytes,1,opt,name=from_commit,json=fromCommit" json:"from_commit,omitempty"`
	FullFile   bool    `protobuf:"varint,2,opt,name=full_file,json=fullFile" json:"full_file,omitempty"`
}

DiffMethod specifies how file operations represent changes to files. If FromCommit is nil then the whole file will be returned. If FromCommit is not nil and FullFile is false then only the changes since FromCommit will be returned. If FromCommit is not nil and FullFile is true then the whole file will be returned if there have been changes since FromCommit.

func (*DiffMethod) Descriptor added in v1.2.0 

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

func (*DiffMethod) GetFromCommit added in v1.2.0 

func (m *DiffMethod) GetFromCommit() *Commit

func (*DiffMethod) ProtoMessage added in v1.2.0 

func (*DiffMethod) ProtoMessage()

func (*DiffMethod) Reset added in v1.2.0 

func (m *DiffMethod) Reset()

func (*DiffMethod) String added in v1.2.0 

func (m *DiffMethod) 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 (*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"`
	Modified       *google_protobuf2.Timestamp `protobuf:"bytes,4,opt,name=modified" json:"modified,omitempty"`
	CommitModified *Commit                     `protobuf:"bytes,5,opt,name=commit_modified,json=commitModified" json:"commit_modified,omitempty"`
	Children       []*File                     `protobuf:"bytes,6,rep,name=children" json:"children,omitempty"`
}

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"`
	Cancel   bool                        `protobuf:"varint,2,opt,name=cancel" json:"cancel,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 FlushCommitRequest 

type FlushCommitRequest struct {
	Commit []*Commit `protobuf:"bytes,1,rep,name=commit" json:"commit,omitempty"`
	ToRepo []*Repo   `protobuf:"bytes,2,rep,name=to_repo,json=toRepo" json:"to_repo,omitempty"`
}

func (*FlushCommitRequest) Descriptor 

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

func (*FlushCommitRequest) GetCommit 

func (m *FlushCommitRequest) GetCommit() []*Commit

func (*FlushCommitRequest) GetToRepo 

func (m *FlushCommitRequest) GetToRepo() []*Repo

func (*FlushCommitRequest) ProtoMessage 

func (*FlushCommitRequest) ProtoMessage()

func (*FlushCommitRequest) Reset 

func (m *FlushCommitRequest) Reset()

func (*FlushCommitRequest) String 

func (m *FlushCommitRequest) 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"`
	DiffMethod  *DiffMethod `protobuf:"bytes,5,opt,name=diff_method,json=diffMethod" json:"diff_method,omitempty"`
}

func (*GetFileRequest) Descriptor 

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

func (*GetFileRequest) GetDiffMethod added in v1.2.0 

func (m *GetFileRequest) GetDiffMethod() *DiffMethod

func (*GetFileRequest) GetFile 

func (m *GetFileRequest) GetFile() *File

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"`
	DiffMethod *DiffMethod `protobuf:"bytes,3,opt,name=diff_method,json=diffMethod" json:"diff_method,omitempty"`
}

func (*InspectFileRequest) Descriptor 

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

func (*InspectFileRequest) GetDiffMethod added in v1.2.0 

func (m *InspectFileRequest) GetDiffMethod() *DiffMethod

func (*InspectFileRequest) GetFile 

func (m *InspectFileRequest) GetFile() *File

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)
	// ArchiveCommit marks a commit as archived, it will be excluded from ListCommit.
	ArchiveCommit(ctx context.Context, in *ArchiveCommitRequest, 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)
	// Merge merges commits
	Merge(ctx context.Context, in *MergeRequest, opts ...grpc.CallOption) (*Commits, error)
	// DeleteCommit deletes a commit.
	DeleteCommit(ctx context.Context, in *DeleteCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// FlushCommit waits for downstream commits to finish
	FlushCommit(ctx context.Context, in *FlushCommitRequest, opts ...grpc.CallOption) (*CommitInfos, 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)
	// DeleteAll deletes everything
	DeleteAll(ctx context.Context, in *google_protobuf1.Empty, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// ArchiveAll archives everything
	ArchiveAll(ctx context.Context, in *google_protobuf1.Empty, 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)
	// ArchiveCommit marks a commit as archived, it will be excluded from ListCommit.
	ArchiveCommit(context.Context, *ArchiveCommitRequest) (*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)
	// Merge merges commits
	Merge(context.Context, *MergeRequest) (*Commits, error)
	// DeleteCommit deletes a commit.
	DeleteCommit(context.Context, *DeleteCommitRequest) (*google_protobuf1.Empty, error)
	// FlushCommit waits for downstream commits to finish
	FlushCommit(context.Context, *FlushCommitRequest) (*CommitInfos, 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)
	// DeleteAll deletes everything
	DeleteAll(context.Context, *google_protobuf1.Empty) (*google_protobuf1.Empty, error)
	// ArchiveAll archives everything
	ArchiveAll(context.Context, *google_protobuf1.Empty) (*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"`
	Provenance []*Commit    `protobuf:"bytes,4,rep,name=provenance" json:"provenance,omitempty"`
	Status     CommitStatus `protobuf:"varint,5,opt,name=status,enum=pfs.CommitStatus" json:"status,omitempty"`
	Block      bool         `protobuf:"varint,6,opt,name=block" json:"block,omitempty"`
}

func (*ListCommitRequest) Descriptor 

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

func (*ListCommitRequest) GetFromCommit 

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

func (*ListCommitRequest) GetProvenance 

func (m *ListCommitRequest) GetProvenance() []*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"`
	DiffMethod *DiffMethod `protobuf:"bytes,3,opt,name=diff_method,json=diffMethod" json:"diff_method,omitempty"`
	Recurse    bool        `protobuf:"varint,4,opt,name=recurse" json:"recurse,omitempty"`
}

func (*ListFileRequest) Descriptor 

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

func (*ListFileRequest) GetDiffMethod added in v1.2.0 

func (m *ListFileRequest) GetDiffMethod() *DiffMethod

func (*ListFileRequest) GetFile 

func (m *ListFileRequest) GetFile() *File

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 {
	Provenance []*Repo `protobuf:"bytes,1,rep,name=provenance" json:"provenance,omitempty"`
}

func (*ListRepoRequest) Descriptor 

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

func (*ListRepoRequest) GetProvenance 

func (m *ListRepoRequest) GetProvenance() []*Repo

func (*ListRepoRequest) ProtoMessage 

func (*ListRepoRequest) ProtoMessage()

func (*ListRepoRequest) Reset 

func (m *ListRepoRequest) Reset()

func (*ListRepoRequest) String 

func (m *ListRepoRequest) String() string

type MergeRequest 

type MergeRequest struct {
	Repo        *Repo         `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	FromCommits []*Commit     `protobuf:"bytes,2,rep,name=from_commits,json=fromCommits" json:"from_commits,omitempty"`
	To          string        `protobuf:"bytes,3,opt,name=to" json:"to,omitempty"`
	Strategy    MergeStrategy `protobuf:"varint,4,opt,name=strategy,enum=pfs.MergeStrategy" json:"strategy,omitempty"`
	Cancel      bool          `protobuf:"varint,5,opt,name=cancel" json:"cancel,omitempty"`
}

func (*MergeRequest) Descriptor 

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

func (*MergeRequest) GetFromCommits 

func (m *MergeRequest) GetFromCommits() []*Commit

func (*MergeRequest) GetRepo 

func (m *MergeRequest) GetRepo() *Repo

func (*MergeRequest) ProtoMessage 

func (*MergeRequest) ProtoMessage()

func (*MergeRequest) Reset 

func (m *MergeRequest) Reset()

func (*MergeRequest) String 

func (m *MergeRequest) String() string

type MergeStrategy 

type MergeStrategy int32
const (
	MergeStrategy_SQUASH MergeStrategy = 0
	MergeStrategy_REPLAY MergeStrategy = 1
)

func (MergeStrategy) EnumDescriptor 

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

func (MergeStrategy) String 

func (x MergeStrategy) String() string

type PutBlockRequest 

type PutBlockRequest struct {
	Value     []byte    `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Delimiter Delimiter `protobuf:"varint,2,opt,name=delimiter,enum=pfs.Delimiter" json:"delimiter,omitempty"`
}

func (*PutBlockRequest) Descriptor 

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

func (*PutBlockRequest) ProtoMessage 

func (*PutBlockRequest) ProtoMessage()

func (*PutBlockRequest) Reset 

func (m *PutBlockRequest) Reset()

func (*PutBlockRequest) String 

func (m *PutBlockRequest) 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"`
	Value     []byte    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Delimiter Delimiter `protobuf:"varint,4,opt,name=delimiter,enum=pfs.Delimiter" json:"delimiter,omitempty"`
	Url       string    `protobuf:"bytes,5,opt,name=url" json:"url,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 (*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"`
	Provenance []*Repo                     `protobuf:"bytes,4,rep,name=provenance" json:"provenance,omitempty"`
}

func (*RepoInfo) Descriptor 

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

func (*RepoInfo) GetCreated 

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

func (*RepoInfo) GetProvenance 

func (m *RepoInfo) GetProvenance() []*Repo

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"`
	Provenance []*Commit                   `protobuf:"bytes,6,rep,name=provenance" json:"provenance,omitempty"`
}

func (*StartCommitRequest) Descriptor 

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

func (*StartCommitRequest) GetProvenance 

func (m *StartCommitRequest) GetProvenance() []*Commit

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.