pfs

package
v1.3.6 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2017 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
Branches
File
Block
RepoInfo
RepoInfos
CommitInfo
CommitInfos
FileInfo
FileInfos
ByteRange
BlockRef
BlockRefs
Append
BlockInfo
BlockInfos
Shard
CreateRepoRequest
InspectRepoRequest
ListRepoRequest
DeleteRepoRequest
StartCommitRequest
ForkCommitRequest
FinishCommitRequest
ArchiveCommitRequest
InspectCommitRequest
ListCommitRequest
ListBranchRequest
DeleteCommitRequest
FlushCommitRequest
DiffMethod
GetFileRequest
PutFileRequest
InspectFileRequest
ListFileRequest
DeleteFileRequest
SquashCommitRequest
ReplayCommitRequest
PutBlockRequest
GetBlockRequest
DeleteBlockRequest
InspectBlockRequest
ListBlockRequest

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 ListFileMode_name = map[int32]string{
	0: "ListFile_NORMAL",
	1: "ListFile_FAST",
	2: "ListFile_RECURSE",
}
View Source 
var ListFileMode_value = map[string]int32{
	"ListFile_NORMAL":  0,
	"ListFile_FAST":    1,
	"ListFile_RECURSE": 2,
}

Functions

func RegisterAPIServer 

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

func RegisterBlockAPIServer 

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

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)
	// Fork creates a commit on a new branch.
	ForkCommit(ctx context.Context, in *ForkCommitRequest, 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 commits 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) (*Branches, error)
	// Squash returns the head of the commit of the merge
	SquashCommit(ctx context.Context, in *SquashCommitRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// Replay returns the head of the commit of the merge
	ReplayCommit(ctx context.Context, in *ReplayCommitRequest, 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)
	// Fork creates a commit on a new branch.
	ForkCommit(context.Context, *ForkCommitRequest) (*Commit, error)
	// FinishCommit turns a write commit into a read commit.
	FinishCommit(context.Context, *FinishCommitRequest) (*google_protobuf1.Empty, error)
	// ArchiveCommit marks commits 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) (*Branches, error)
	// Squash returns the head of the commit of the merge
	SquashCommit(context.Context, *SquashCommitRequest) (*google_protobuf1.Empty, error)
	// Replay returns the head of the commit of the merge
	ReplayCommit(context.Context, *ReplayCommitRequest) (*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 `` /* 151-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,proto3" json:"delete,omitempty"`
	FileType  FileType        `protobuf:"varint,5,opt,name=file_type,json=fileType,proto3,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) GetDelete added in v1.3.5 

func (m *Append) GetDelete() bool

func (*Append) GetFileType added in v1.3.5 

func (m *Append) GetFileType() FileType

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,proto3" json:"hash,omitempty"`
}

func (*Block) Descriptor 

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

func (*Block) GetHash added in v1.3.5 

func (m *Block) GetHash() string

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

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

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_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,proto3" 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) GetSizeBytes added in v1.3.5 

func (m *BlockInfo) GetSizeBytes() uint64

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 Branches added in v1.2.0 

type Branches struct {
	Branches []string `protobuf:"bytes,1,rep,name=branches" json:"branches,omitempty"`
}

func (*Branches) Descriptor added in v1.2.0 

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

func (*Branches) GetBranches added in v1.3.5 

func (m *Branches) GetBranches() []string

func (*Branches) ProtoMessage added in v1.2.0 

func (*Branches) ProtoMessage()

func (*Branches) Reset added in v1.2.0 

func (m *Branches) Reset()

func (*Branches) String added in v1.2.0 

func (m *Branches) String() string

type ByteRange 

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

func (*ByteRange) Descriptor 

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

func (*ByteRange) GetLower added in v1.3.5 

func (m *ByteRange) GetLower() uint64

func (*ByteRange) GetUpper added in v1.3.5 

func (m *ByteRange) GetUpper() uint64

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,proto3" json:"id,omitempty"`
}

func (*Commit) Descriptor 

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

func (*Commit) GetID added in v1.3.5 

func (m *Commit) GetID() string

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,proto3" json:"branch,omitempty"`
	CommitType   CommitType                  `protobuf:"varint,3,opt,name=commit_type,json=commitType,proto3,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,proto3" json:"size_bytes,omitempty"`
	Cancelled    bool                        `protobuf:"varint,8,opt,name=cancelled,proto3" json:"cancelled,omitempty"`
	Archived     bool                        `protobuf:"varint,9,opt,name=archived,proto3" json:"archived,omitempty"`
	Provenance   []*Commit                   `protobuf:"bytes,10,rep,name=provenance" json:"provenance,omitempty"`
}

func (*CommitInfo) Descriptor 

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

func (*CommitInfo) GetArchived added in v1.3.5 

func (m *CommitInfo) GetArchived() bool

func (*CommitInfo) GetBranch added in v1.3.5 

func (m *CommitInfo) GetBranch() string

func (*CommitInfo) GetCancelled added in v1.3.5 

func (m *CommitInfo) GetCancelled() bool

func (*CommitInfo) GetCommit 

func (m *CommitInfo) GetCommit() *Commit

func (*CommitInfo) GetCommitType added in v1.3.5 

func (m *CommitInfo) GetCommitType() CommitType

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) GetSizeBytes added in v1.3.5 

func (m *CommitInfo) GetSizeBytes() uint64

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 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,proto3" json:"force,omitempty"`
}

func (*DeleteRepoRequest) Descriptor 

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

func (*DeleteRepoRequest) GetForce added in v1.3.5 

func (m *DeleteRepoRequest) GetForce() bool

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 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,proto3" 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) GetFullFile added in v1.3.5 

func (m *DiffMethod) GetFullFile() bool

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,proto3" json:"path,omitempty"`
}

func (*File) Descriptor 

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

func (*File) GetCommit 

func (m *File) GetCommit() *Commit

func (*File) GetPath added in v1.3.5 

func (m *File) GetPath() string

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,proto3,enum=pfs.FileType" json:"file_type,omitempty"`
	SizeBytes      uint64                      `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" 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) GetFileType added in v1.3.5 

func (m *FileInfo) GetFileType() FileType

func (*FileInfo) GetModified 

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

func (*FileInfo) GetSizeBytes added in v1.3.5 

func (m *FileInfo) GetSizeBytes() uint64

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,proto3" json:"cancel,omitempty"`
}

func (*FinishCommitRequest) Descriptor 

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

func (*FinishCommitRequest) GetCancel added in v1.3.5 

func (m *FinishCommitRequest) GetCancel() bool

func (*FinishCommitRequest) GetCommit 

func (m *FinishCommitRequest) GetCommit() *Commit

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 ForkCommitRequest added in v1.2.0 

type ForkCommitRequest struct {
	Parent     *Commit   `protobuf:"bytes,1,opt,name=parent" json:"parent,omitempty"`
	Branch     string    `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
	Provenance []*Commit `protobuf:"bytes,3,rep,name=provenance" json:"provenance,omitempty"`
}

func (*ForkCommitRequest) Descriptor added in v1.2.0 

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

func (*ForkCommitRequest) GetBranch added in v1.3.5 

func (m *ForkCommitRequest) GetBranch() string

func (*ForkCommitRequest) GetParent added in v1.2.0 

func (m *ForkCommitRequest) GetParent() *Commit

func (*ForkCommitRequest) GetProvenance added in v1.2.0 

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

func (*ForkCommitRequest) ProtoMessage added in v1.2.0 

func (*ForkCommitRequest) ProtoMessage()

func (*ForkCommitRequest) Reset added in v1.2.0 

func (m *ForkCommitRequest) Reset()

func (*ForkCommitRequest) String added in v1.2.0 

func (m *ForkCommitRequest) 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,proto3" json:"offset_bytes,omitempty"`
	SizeBytes   uint64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
}

func (*GetBlockRequest) Descriptor 

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

func (*GetBlockRequest) GetBlock 

func (m *GetBlockRequest) GetBlock() *Block

func (*GetBlockRequest) GetOffsetBytes added in v1.3.5 

func (m *GetBlockRequest) GetOffsetBytes() uint64

func (*GetBlockRequest) GetSizeBytes added in v1.3.5 

func (m *GetBlockRequest) GetSizeBytes() uint64

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,proto3" json:"offset_bytes,omitempty"`
	SizeBytes   int64       `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" 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) GetOffsetBytes added in v1.3.5 

func (m *GetFileRequest) GetOffsetBytes() int64

func (*GetFileRequest) GetShard 

func (m *GetFileRequest) GetShard() *Shard

func (*GetFileRequest) GetSizeBytes added in v1.3.5 

func (m *GetFileRequest) GetSizeBytes() int64

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 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 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"`
	Status CommitStatus `protobuf:"varint,2,opt,name=status,proto3,enum=pfs.CommitStatus" json:"status,omitempty"`
}

func (*ListBranchRequest) Descriptor 

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

func (*ListBranchRequest) GetRepo 

func (m *ListBranchRequest) GetRepo() *Repo

func (*ListBranchRequest) GetStatus added in v1.3.5 

func (m *ListBranchRequest) GetStatus() CommitStatus

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 {
	Exclude    []*Commit    `protobuf:"bytes,1,rep,name=exclude" json:"exclude,omitempty"`
	Include    []*Commit    `protobuf:"bytes,6,rep,name=include" json:"include,omitempty"`
	Provenance []*Commit    `protobuf:"bytes,2,rep,name=provenance" json:"provenance,omitempty"`
	CommitType CommitType   `protobuf:"varint,3,opt,name=commit_type,json=commitType,proto3,enum=pfs.CommitType" json:"commit_type,omitempty"`
	Status     CommitStatus `protobuf:"varint,4,opt,name=status,proto3,enum=pfs.CommitStatus" json:"status,omitempty"`
	Block      bool         `protobuf:"varint,5,opt,name=block,proto3" json:"block,omitempty"`
}

func (*ListCommitRequest) Descriptor 

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

func (*ListCommitRequest) GetBlock added in v1.3.5 

func (m *ListCommitRequest) GetBlock() bool

func (*ListCommitRequest) GetCommitType added in v1.3.5 

func (m *ListCommitRequest) GetCommitType() CommitType

func (*ListCommitRequest) GetExclude added in v1.2.4 

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

func (*ListCommitRequest) GetInclude added in v1.2.4 

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

func (*ListCommitRequest) GetProvenance 

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

func (*ListCommitRequest) GetStatus added in v1.3.5 

func (m *ListCommitRequest) GetStatus() CommitStatus

func (*ListCommitRequest) ProtoMessage 

func (*ListCommitRequest) ProtoMessage()

func (*ListCommitRequest) Reset 

func (m *ListCommitRequest) Reset()

func (*ListCommitRequest) String 

func (m *ListCommitRequest) String() string

type ListFileMode added in v1.2.3 

type ListFileMode int32
const (
	ListFileMode_ListFile_NORMAL  ListFileMode = 0
	ListFileMode_ListFile_FAST    ListFileMode = 1
	ListFileMode_ListFile_RECURSE ListFileMode = 2
)

func (ListFileMode) EnumDescriptor added in v1.2.3 

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

func (ListFileMode) String added in v1.2.3 

func (x ListFileMode) 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"`
	Mode       ListFileMode `protobuf:"varint,4,opt,name=mode,proto3,enum=pfs.ListFileMode" json:"mode,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) GetMode added in v1.3.5 

func (m *ListFileRequest) GetMode() ListFileMode

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 PutBlockRequest 

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

func (*PutBlockRequest) Descriptor 

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

func (*PutBlockRequest) GetDelimiter added in v1.3.5 

func (m *PutBlockRequest) GetDelimiter() Delimiter

func (*PutBlockRequest) GetValue added in v1.3.5 

func (m *PutBlockRequest) GetValue() []byte

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,proto3,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,proto3,enum=pfs.Delimiter" json:"delimiter,omitempty"`
	Url       string    `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	// applies only to URLs that can be recursively walked, for example s3:// URLs
	Recursive bool `protobuf:"varint,6,opt,name=recursive,proto3" json:"recursive,omitempty"`
}

func (*PutFileRequest) Descriptor 

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

func (*PutFileRequest) GetDelimiter added in v1.3.5 

func (m *PutFileRequest) GetDelimiter() Delimiter

func (*PutFileRequest) GetFile 

func (m *PutFileRequest) GetFile() *File

func (*PutFileRequest) GetFileType added in v1.3.5 

func (m *PutFileRequest) GetFileType() FileType

func (*PutFileRequest) GetRecursive added in v1.3.5 

func (m *PutFileRequest) GetRecursive() bool

func (*PutFileRequest) GetUrl added in v1.3.5 

func (m *PutFileRequest) GetUrl() string

func (*PutFileRequest) GetValue added in v1.3.5 

func (m *PutFileRequest) GetValue() []byte

func (*PutFileRequest) ProtoMessage 

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) Reset 

func (m *PutFileRequest) Reset()

func (*PutFileRequest) String 

func (m *PutFileRequest) String() string

type ReplayCommitRequest added in v1.2.0 

type ReplayCommitRequest struct {
	FromCommits []*Commit `protobuf:"bytes,1,rep,name=from_commits,json=fromCommits" json:"from_commits,omitempty"`
	ToBranch    string    `protobuf:"bytes,2,opt,name=to_branch,json=toBranch,proto3" json:"to_branch,omitempty"`
}

func (*ReplayCommitRequest) Descriptor added in v1.2.0 

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

func (*ReplayCommitRequest) GetFromCommits added in v1.2.0 

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

func (*ReplayCommitRequest) GetToBranch added in v1.3.5 

func (m *ReplayCommitRequest) GetToBranch() string

func (*ReplayCommitRequest) ProtoMessage added in v1.2.0 

func (*ReplayCommitRequest) ProtoMessage()

func (*ReplayCommitRequest) Reset added in v1.2.0 

func (m *ReplayCommitRequest) Reset()

func (*ReplayCommitRequest) String added in v1.2.0 

func (m *ReplayCommitRequest) String() string

type Repo 

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

func (*Repo) Descriptor 

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

func (*Repo) GetName added in v1.3.5 

func (m *Repo) GetName() string

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,proto3" 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) GetSizeBytes added in v1.3.5 

func (m *RepoInfo) GetSizeBytes() uint64

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,proto3" json:"file_number,omitempty"`
	FileModulus  uint64 `protobuf:"varint,2,opt,name=file_modulus,json=fileModulus,proto3" json:"file_modulus,omitempty"`
	BlockNumber  uint64 `protobuf:"varint,3,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	BlockModulus uint64 `protobuf:"varint,4,opt,name=block_modulus,json=blockModulus,proto3" json:"block_modulus,omitempty"`
}

func (*Shard) Descriptor 

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

func (*Shard) GetBlockModulus added in v1.3.5 

func (m *Shard) GetBlockModulus() uint64

func (*Shard) GetBlockNumber added in v1.3.5 

func (m *Shard) GetBlockNumber() uint64

func (*Shard) GetFileModulus added in v1.3.5 

func (m *Shard) GetFileModulus() uint64

func (*Shard) GetFileNumber added in v1.3.5 

func (m *Shard) GetFileNumber() uint64

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) Reset 

func (m *Shard) Reset()

func (*Shard) String 

func (m *Shard) String() string

type SquashCommitRequest added in v1.2.0 

type SquashCommitRequest struct {
	FromCommits []*Commit `protobuf:"bytes,1,rep,name=from_commits,json=fromCommits" json:"from_commits,omitempty"`
	ToCommit    *Commit   `protobuf:"bytes,2,opt,name=to_commit,json=toCommit" json:"to_commit,omitempty"`
}

func (*SquashCommitRequest) Descriptor added in v1.2.0 

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

func (*SquashCommitRequest) GetFromCommits added in v1.2.0 

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

func (*SquashCommitRequest) GetToCommit added in v1.2.0 

func (m *SquashCommitRequest) GetToCommit() *Commit

func (*SquashCommitRequest) ProtoMessage added in v1.2.0 

func (*SquashCommitRequest) ProtoMessage()

func (*SquashCommitRequest) Reset added in v1.2.0 

func (m *SquashCommitRequest) Reset()

func (*SquashCommitRequest) String added in v1.2.0 

func (m *SquashCommitRequest) String() string

type StartCommitRequest 

type StartCommitRequest struct {
	Parent     *Commit   `protobuf:"bytes,1,opt,name=parent" json:"parent,omitempty"`
	Provenance []*Commit `protobuf:"bytes,2,rep,name=provenance" json:"provenance,omitempty"`
}

func (*StartCommitRequest) Descriptor 

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

func (*StartCommitRequest) GetParent added in v1.2.0 

func (m *StartCommitRequest) GetParent() *Commit

func (*StartCommitRequest) GetProvenance 

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

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.