pfs

package
v1.4.8 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2017 License: Apache-2.0 Imports: 7 Imported by: 155

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
Branch
Branches
File
Block
Object
Tag
RepoInfo
RepoInfos
CommitInfo
CommitInfos
FileInfo
FileInfos
ByteRange
BlockRef
ObjectInfo
CreateRepoRequest
InspectRepoRequest
ListRepoRequest
DeleteRepoRequest
StartCommitRequest
BuildCommitRequest
FinishCommitRequest
InspectCommitRequest
ListCommitRequest
ListBranchRequest
SetBranchRequest
DeleteBranchRequest
DeleteCommitRequest
FlushCommitRequest
SubscribeCommitRequest
GetFileRequest
PutFileRequest
InspectFileRequest
ListFileRequest
GlobFileRequest
DiffFileRequest
DiffFileResponse
DeleteFileRequest
PutObjectRequest
GetObjectsRequest
TagObjectRequest
ListObjectsRequest
ListTagsRequest
ListTagsResponse
DeleteObjectsRequest
DeleteObjectsResponse
DeleteTagsRequest
DeleteTagsResponse
CheckObjectRequest
CheckObjectResponse
ObjectIndex

Index

Constants

This section is empty.

Variables

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: "RESERVED",
	1: "FILE",
	2: "DIR",
}
View Source 
var FileType_value = map[string]int32{
	"RESERVED": 0,
	"FILE":     1,
	"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 RegisterObjectAPIServer added in v1.3.9 

func RegisterObjectAPIServer(s *grpc.Server, srv ObjectAPIServer)

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_protobuf.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_protobuf.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_protobuf.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_protobuf.Empty, error)
	// FlushCommit waits for downstream commits to finish
	FlushCommit(ctx context.Context, in *FlushCommitRequest, opts ...grpc.CallOption) (API_FlushCommitClient, error)
	// SubscribeCommit subscribes for new commits on a given branch
	SubscribeCommit(ctx context.Context, in *SubscribeCommitRequest, opts ...grpc.CallOption) (API_SubscribeCommitClient, error)
	// BuildCommit builds a commit that's backed by the given tree
	BuildCommit(ctx context.Context, in *BuildCommitRequest, opts ...grpc.CallOption) (*Commit, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(ctx context.Context, in *ListBranchRequest, opts ...grpc.CallOption) (*Branches, error)
	// SetBranch assigns a commit and its ancestors to a branch.
	SetBranch(ctx context.Context, in *SetBranchRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	// DeleteBranch deletes a branch; note that the commits still exist.
	DeleteBranch(ctx context.Context, in *DeleteBranchRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, 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)
	// GlobFile returns info about all files.
	GlobFile(ctx context.Context, in *GlobFileRequest, opts ...grpc.CallOption) (*FileInfos, error)
	// DiffFile returns the differences between 2 paths at 2 commits.
	DiffFile(ctx context.Context, in *DiffFileRequest, opts ...grpc.CallOption) (*DiffFileResponse, error)
	// DeleteFile deletes a file.
	DeleteFile(ctx context.Context, in *DeleteFileRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	// DeleteAll deletes everything
	DeleteAll(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.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_protobuf.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_protobuf.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_protobuf.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_protobuf.Empty, error)
	// FlushCommit waits for downstream commits to finish
	FlushCommit(*FlushCommitRequest, API_FlushCommitServer) error
	// SubscribeCommit subscribes for new commits on a given branch
	SubscribeCommit(*SubscribeCommitRequest, API_SubscribeCommitServer) error
	// BuildCommit builds a commit that's backed by the given tree
	BuildCommit(context.Context, *BuildCommitRequest) (*Commit, error)
	// ListBranch returns info about the heads of branches.
	ListBranch(context.Context, *ListBranchRequest) (*Branches, error)
	// SetBranch assigns a commit and its ancestors to a branch.
	SetBranch(context.Context, *SetBranchRequest) (*google_protobuf.Empty, error)
	// DeleteBranch deletes a branch; note that the commits still exist.
	DeleteBranch(context.Context, *DeleteBranchRequest) (*google_protobuf.Empty, 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)
	// GlobFile returns info about all files.
	GlobFile(context.Context, *GlobFileRequest) (*FileInfos, error)
	// DiffFile returns the differences between 2 paths at 2 commits.
	DiffFile(context.Context, *DiffFileRequest) (*DiffFileResponse, error)
	// DeleteFile deletes a file.
	DeleteFile(context.Context, *DeleteFileRequest) (*google_protobuf.Empty, error)
	// DeleteAll deletes everything
	DeleteAll(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error)
}

type API_FlushCommitClient added in v1.3.19 

type API_FlushCommitClient interface {
	Recv() (*CommitInfo, error)
	grpc.ClientStream
}

type API_FlushCommitServer added in v1.3.19 

type API_FlushCommitServer interface {
	Send(*CommitInfo) error
	grpc.ServerStream
}

type API_GetFileClient 

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

type API_GetFileServer 

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

type API_PutFileClient 

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

type API_PutFileServer 

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

type API_SubscribeCommitClient added in v1.3.19 

type API_SubscribeCommitClient interface {
	Recv() (*CommitInfo, error)
	grpc.ClientStream
}

type API_SubscribeCommitServer added in v1.3.19 

type API_SubscribeCommitServer interface {
	Send(*CommitInfo) error
	grpc.ServerStream
}

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 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 Branch added in v1.3.19 

type Branch struct {
	Name string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Head *Commit `protobuf:"bytes,2,opt,name=head" json:"head,omitempty"`
}

func (*Branch) Descriptor added in v1.3.19 

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

func (*Branch) GetHead added in v1.3.19 

func (m *Branch) GetHead() *Commit

func (*Branch) GetName added in v1.3.19 

func (m *Branch) GetName() string

func (*Branch) ProtoMessage added in v1.3.19 

func (*Branch) ProtoMessage()

func (*Branch) Reset added in v1.3.19 

func (m *Branch) Reset()

func (*Branch) String added in v1.3.19 

func (m *Branch) String() string

type Branches added in v1.2.0 

type Branches struct {
	Branches []*Branch `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() []*Branch

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 BuildCommitRequest added in v1.3.19 

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

func (*BuildCommitRequest) Descriptor added in v1.3.19 

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

func (*BuildCommitRequest) GetBranch added in v1.3.19 

func (m *BuildCommitRequest) GetBranch() string

func (*BuildCommitRequest) GetParent added in v1.3.19 

func (m *BuildCommitRequest) GetParent() *Commit

func (*BuildCommitRequest) GetProvenance added in v1.3.19 

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

func (*BuildCommitRequest) GetTree added in v1.3.19 

func (m *BuildCommitRequest) GetTree() *Object

func (*BuildCommitRequest) ProtoMessage added in v1.3.19 

func (*BuildCommitRequest) ProtoMessage()

func (*BuildCommitRequest) Reset added in v1.3.19 

func (m *BuildCommitRequest) Reset()

func (*BuildCommitRequest) String added in v1.3.19 

func (m *BuildCommitRequest) 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 CheckObjectRequest added in v1.4.7 

type CheckObjectRequest struct {
	Object *Object `protobuf:"bytes,1,opt,name=object" json:"object,omitempty"`
}

func (*CheckObjectRequest) Descriptor added in v1.4.7 

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

func (*CheckObjectRequest) GetObject added in v1.4.7 

func (m *CheckObjectRequest) GetObject() *Object

func (*CheckObjectRequest) ProtoMessage added in v1.4.7 

func (*CheckObjectRequest) ProtoMessage()

func (*CheckObjectRequest) Reset added in v1.4.7 

func (m *CheckObjectRequest) Reset()

func (*CheckObjectRequest) String added in v1.4.7 

func (m *CheckObjectRequest) String() string

type CheckObjectResponse added in v1.4.7 

type CheckObjectResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
}

func (*CheckObjectResponse) Descriptor added in v1.4.7 

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

func (*CheckObjectResponse) GetExists added in v1.4.7 

func (m *CheckObjectResponse) GetExists() bool

func (*CheckObjectResponse) ProtoMessage added in v1.4.7 

func (*CheckObjectResponse) ProtoMessage()

func (*CheckObjectResponse) Reset added in v1.4.7 

func (m *CheckObjectResponse) Reset()

func (*CheckObjectResponse) String added in v1.4.7 

func (m *CheckObjectResponse) 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) FullID added in v1.3.19 

func (c *Commit) FullID() string

FullID prints repoName/CommitID

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"`
	ParentCommit *Commit                     `protobuf:"bytes,2,opt,name=parent_commit,json=parentCommit" json:"parent_commit,omitempty"`
	Started      *google_protobuf1.Timestamp `protobuf:"bytes,3,opt,name=started" json:"started,omitempty"`
	Finished     *google_protobuf1.Timestamp `protobuf:"bytes,4,opt,name=finished" json:"finished,omitempty"`
	SizeBytes    uint64                      `protobuf:"varint,5,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	Provenance   []*Commit                   `protobuf:"bytes,6,rep,name=provenance" json:"provenance,omitempty"`
	// this is the block that stores the serialized form of a tree that
	// represents the entire file system hierarchy of the repo at this commit
	Tree *Object `protobuf:"bytes,7,opt,name=tree" json:"tree,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_protobuf1.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_protobuf1.Timestamp

func (*CommitInfo) GetTree added in v1.3.19 

func (m *CommitInfo) GetTree() *Object

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 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"`
	Description string  `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
}

func (*CreateRepoRequest) Descriptor 

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

func (*CreateRepoRequest) GetDescription added in v1.4.7 

func (m *CreateRepoRequest) GetDescription() string

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 DeleteBranchRequest added in v1.3.19 

type DeleteBranchRequest struct {
	Repo   *Repo  `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Branch string `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
}

func (*DeleteBranchRequest) Descriptor added in v1.3.19 

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

func (*DeleteBranchRequest) GetBranch added in v1.3.19 

func (m *DeleteBranchRequest) GetBranch() string

func (*DeleteBranchRequest) GetRepo added in v1.3.19 

func (m *DeleteBranchRequest) GetRepo() *Repo

func (*DeleteBranchRequest) ProtoMessage added in v1.3.19 

func (*DeleteBranchRequest) ProtoMessage()

func (*DeleteBranchRequest) Reset added in v1.3.19 

func (m *DeleteBranchRequest) Reset()

func (*DeleteBranchRequest) String added in v1.3.19 

func (m *DeleteBranchRequest) 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 DeleteObjectsRequest added in v1.4.7 

type DeleteObjectsRequest struct {
	Objects []*Object `protobuf:"bytes,1,rep,name=objects" json:"objects,omitempty"`
}

func (*DeleteObjectsRequest) Descriptor added in v1.4.7 

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

func (*DeleteObjectsRequest) GetObjects added in v1.4.7 

func (m *DeleteObjectsRequest) GetObjects() []*Object

func (*DeleteObjectsRequest) ProtoMessage added in v1.4.7 

func (*DeleteObjectsRequest) ProtoMessage()

func (*DeleteObjectsRequest) Reset added in v1.4.7 

func (m *DeleteObjectsRequest) Reset()

func (*DeleteObjectsRequest) String added in v1.4.7 

func (m *DeleteObjectsRequest) String() string

type DeleteObjectsResponse added in v1.4.7 

type DeleteObjectsResponse struct {
}

func (*DeleteObjectsResponse) Descriptor added in v1.4.7 

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

func (*DeleteObjectsResponse) ProtoMessage added in v1.4.7 

func (*DeleteObjectsResponse) ProtoMessage()

func (*DeleteObjectsResponse) Reset added in v1.4.7 

func (m *DeleteObjectsResponse) Reset()

func (*DeleteObjectsResponse) String added in v1.4.7 

func (m *DeleteObjectsResponse) 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"`
	All   bool  `protobuf:"varint,3,opt,name=all,proto3" json:"all,omitempty"`
}

func (*DeleteRepoRequest) Descriptor 

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

func (*DeleteRepoRequest) GetAll added in v1.4.8 

func (m *DeleteRepoRequest) GetAll() bool

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 DeleteTagsRequest added in v1.4.7 

type DeleteTagsRequest struct {
	Tags []string `protobuf:"bytes,1,rep,name=tags" json:"tags,omitempty"`
}

func (*DeleteTagsRequest) Descriptor added in v1.4.7 

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

func (*DeleteTagsRequest) GetTags added in v1.4.7 

func (m *DeleteTagsRequest) GetTags() []string

func (*DeleteTagsRequest) ProtoMessage added in v1.4.7 

func (*DeleteTagsRequest) ProtoMessage()

func (*DeleteTagsRequest) Reset added in v1.4.7 

func (m *DeleteTagsRequest) Reset()

func (*DeleteTagsRequest) String added in v1.4.7 

func (m *DeleteTagsRequest) String() string

type DeleteTagsResponse added in v1.4.7 

type DeleteTagsResponse struct {
}

func (*DeleteTagsResponse) Descriptor added in v1.4.7 

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

func (*DeleteTagsResponse) ProtoMessage added in v1.4.7 

func (*DeleteTagsResponse) ProtoMessage()

func (*DeleteTagsResponse) Reset added in v1.4.7 

func (m *DeleteTagsResponse) Reset()

func (*DeleteTagsResponse) String added in v1.4.7 

func (m *DeleteTagsResponse) 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 DiffFileRequest added in v1.4.8 

type DiffFileRequest struct {
	NewFile *File `protobuf:"bytes,1,opt,name=new_file,json=newFile" json:"new_file,omitempty"`
	// OldFile may be left nil in which case the same path in the parent of
	// NewFile's commit will be used.
	OldFile *File `protobuf:"bytes,2,opt,name=old_file,json=oldFile" json:"old_file,omitempty"`
}

func (*DiffFileRequest) Descriptor added in v1.4.8 

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

func (*DiffFileRequest) GetNewFile added in v1.4.8 

func (m *DiffFileRequest) GetNewFile() *File

func (*DiffFileRequest) GetOldFile added in v1.4.8 

func (m *DiffFileRequest) GetOldFile() *File

func (*DiffFileRequest) ProtoMessage added in v1.4.8 

func (*DiffFileRequest) ProtoMessage()

func (*DiffFileRequest) Reset added in v1.4.8 

func (m *DiffFileRequest) Reset()

func (*DiffFileRequest) String added in v1.4.8 

func (m *DiffFileRequest) String() string

type DiffFileResponse added in v1.4.8 

type DiffFileResponse struct {
	NewFiles []*FileInfo `protobuf:"bytes,1,rep,name=new_files,json=newFiles" json:"new_files,omitempty"`
	OldFiles []*FileInfo `protobuf:"bytes,2,rep,name=old_files,json=oldFiles" json:"old_files,omitempty"`
}

func (*DiffFileResponse) Descriptor added in v1.4.8 

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

func (*DiffFileResponse) GetNewFiles added in v1.4.8 

func (m *DiffFileResponse) GetNewFiles() []*FileInfo

func (*DiffFileResponse) GetOldFiles added in v1.4.8 

func (m *DiffFileResponse) GetOldFiles() []*FileInfo

func (*DiffFileResponse) ProtoMessage added in v1.4.8 

func (*DiffFileResponse) ProtoMessage()

func (*DiffFileResponse) Reset added in v1.4.8 

func (m *DiffFileResponse) Reset()

func (*DiffFileResponse) String added in v1.4.8 

func (m *DiffFileResponse) 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"`
	// the base names (i.e. just the filenames, not the full paths) of
	// the children
	Children []string  `protobuf:"bytes,6,rep,name=children" json:"children,omitempty"`
	Objects  []*Object `protobuf:"bytes,8,rep,name=objects" json:"objects,omitempty"`
	Hash     []byte    `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"`
}

func (*FileInfo) Descriptor 

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

func (*FileInfo) GetChildren 

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

func (*FileInfo) GetFile 

func (m *FileInfo) GetFile() *File

func (*FileInfo) GetFileType added in v1.3.5 

func (m *FileInfo) GetFileType() FileType

func (*FileInfo) GetHash added in v1.3.19 

func (m *FileInfo) GetHash() []byte

func (*FileInfo) GetObjects added in v1.4.6 

func (m *FileInfo) GetObjects() []*Object

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_RESERVED FileType = 0
	FileType_FILE     FileType = 1
	FileType_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"`
}

func (*FinishCommitRequest) Descriptor 

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

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 {
	Commits []*Commit `protobuf:"bytes,1,rep,name=commits" json:"commits,omitempty"`
	ToRepos []*Repo   `protobuf:"bytes,2,rep,name=to_repos,json=toRepos" json:"to_repos,omitempty"`
}

func (*FlushCommitRequest) Descriptor 

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

func (*FlushCommitRequest) GetCommits added in v1.3.19 

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

func (*FlushCommitRequest) GetToRepos added in v1.3.19 

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

func (*FlushCommitRequest) ProtoMessage 

func (*FlushCommitRequest) ProtoMessage()

func (*FlushCommitRequest) Reset 

func (m *FlushCommitRequest) Reset()

func (*FlushCommitRequest) String 

func (m *FlushCommitRequest) 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"`
}

func (*GetFileRequest) Descriptor 

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

func (*GetFileRequest) GetFile 

func (m *GetFileRequest) GetFile() *File

func (*GetFileRequest) GetOffsetBytes added in v1.3.5 

func (m *GetFileRequest) GetOffsetBytes() int64

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 GetObjectsRequest added in v1.3.19 

type GetObjectsRequest struct {
	Objects     []*Object `protobuf:"bytes,1,rep,name=objects" json:"objects,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 (*GetObjectsRequest) Descriptor added in v1.3.19 

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

func (*GetObjectsRequest) GetObjects added in v1.3.19 

func (m *GetObjectsRequest) GetObjects() []*Object

func (*GetObjectsRequest) GetOffsetBytes added in v1.3.19 

func (m *GetObjectsRequest) GetOffsetBytes() uint64

func (*GetObjectsRequest) GetSizeBytes added in v1.3.19 

func (m *GetObjectsRequest) GetSizeBytes() uint64

func (*GetObjectsRequest) ProtoMessage added in v1.3.19 

func (*GetObjectsRequest) ProtoMessage()

func (*GetObjectsRequest) Reset added in v1.3.19 

func (m *GetObjectsRequest) Reset()

func (*GetObjectsRequest) String added in v1.3.19 

func (m *GetObjectsRequest) String() string

type GlobFileRequest added in v1.3.19 

type GlobFileRequest struct {
	Commit  *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	Pattern string  `protobuf:"bytes,2,opt,name=pattern,proto3" json:"pattern,omitempty"`
}

func (*GlobFileRequest) Descriptor added in v1.3.19 

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

func (*GlobFileRequest) GetCommit added in v1.3.19 

func (m *GlobFileRequest) GetCommit() *Commit

func (*GlobFileRequest) GetPattern added in v1.3.19 

func (m *GlobFileRequest) GetPattern() string

func (*GlobFileRequest) ProtoMessage added in v1.3.19 

func (*GlobFileRequest) ProtoMessage()

func (*GlobFileRequest) Reset added in v1.3.19 

func (m *GlobFileRequest) Reset()

func (*GlobFileRequest) String added in v1.3.19 

func (m *GlobFileRequest) 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"`
}

func (*InspectFileRequest) Descriptor 

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

func (*InspectFileRequest) GetFile 

func (m *InspectFileRequest) GetFile() *File

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 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,opt,name=repo" json:"repo,omitempty"`
	From   *Commit `protobuf:"bytes,2,opt,name=from" json:"from,omitempty"`
	To     *Commit `protobuf:"bytes,3,opt,name=to" json:"to,omitempty"`
	Number uint64  `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
}

func (*ListCommitRequest) Descriptor 

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

func (*ListCommitRequest) GetFrom added in v1.3.19 

func (m *ListCommitRequest) GetFrom() *Commit

func (*ListCommitRequest) GetNumber added in v1.3.19 

func (m *ListCommitRequest) GetNumber() uint64

func (*ListCommitRequest) GetRepo 

func (m *ListCommitRequest) GetRepo() *Repo

func (*ListCommitRequest) GetTo added in v1.3.19 

func (m *ListCommitRequest) GetTo() *Commit

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"`
}

func (*ListFileRequest) Descriptor 

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

func (*ListFileRequest) GetFile 

func (m *ListFileRequest) GetFile() *File

func (*ListFileRequest) ProtoMessage 

func (*ListFileRequest) ProtoMessage()

func (*ListFileRequest) Reset 

func (m *ListFileRequest) Reset()

func (*ListFileRequest) String 

func (m *ListFileRequest) String() string

type ListObjectsRequest added in v1.4.7 

type ListObjectsRequest struct {
}

func (*ListObjectsRequest) Descriptor added in v1.4.7 

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

func (*ListObjectsRequest) ProtoMessage added in v1.4.7 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) Reset added in v1.4.7 

func (m *ListObjectsRequest) Reset()

func (*ListObjectsRequest) String added in v1.4.7 

func (m *ListObjectsRequest) 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 ListTagsRequest added in v1.4.7 

type ListTagsRequest struct {
	Prefix        string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	IncludeObject bool   `protobuf:"varint,2,opt,name=includeObject,proto3" json:"includeObject,omitempty"`
}

func (*ListTagsRequest) Descriptor added in v1.4.7 

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

func (*ListTagsRequest) GetIncludeObject added in v1.4.7 

func (m *ListTagsRequest) GetIncludeObject() bool

func (*ListTagsRequest) GetPrefix added in v1.4.7 

func (m *ListTagsRequest) GetPrefix() string

func (*ListTagsRequest) ProtoMessage added in v1.4.7 

func (*ListTagsRequest) ProtoMessage()

func (*ListTagsRequest) Reset added in v1.4.7 

func (m *ListTagsRequest) Reset()

func (*ListTagsRequest) String added in v1.4.7 

func (m *ListTagsRequest) String() string

type ListTagsResponse added in v1.4.7 

type ListTagsResponse struct {
	Tag    string  `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Object *Object `protobuf:"bytes,2,opt,name=object" json:"object,omitempty"`
}

func (*ListTagsResponse) Descriptor added in v1.4.7 

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

func (*ListTagsResponse) GetObject added in v1.4.7 

func (m *ListTagsResponse) GetObject() *Object

func (*ListTagsResponse) GetTag added in v1.4.7 

func (m *ListTagsResponse) GetTag() string

func (*ListTagsResponse) ProtoMessage added in v1.4.7 

func (*ListTagsResponse) ProtoMessage()

func (*ListTagsResponse) Reset added in v1.4.7 

func (m *ListTagsResponse) Reset()

func (*ListTagsResponse) String added in v1.4.7 

func (m *ListTagsResponse) String() string

type Object added in v1.3.9 

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

func (*Object) Descriptor added in v1.3.9 

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

func (*Object) GetHash added in v1.3.9 

func (m *Object) GetHash() string

func (*Object) ProtoMessage added in v1.3.9 

func (*Object) ProtoMessage()

func (*Object) Reset added in v1.3.9 

func (m *Object) Reset()

func (*Object) String added in v1.3.9 

func (m *Object) String() string

type ObjectAPIClient added in v1.3.9 

type ObjectAPIClient interface {
	PutObject(ctx context.Context, opts ...grpc.CallOption) (ObjectAPI_PutObjectClient, error)
	GetObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (ObjectAPI_GetObjectClient, error)
	GetObjects(ctx context.Context, in *GetObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_GetObjectsClient, error)
	TagObject(ctx context.Context, in *TagObjectRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	InspectObject(ctx context.Context, in *Object, opts ...grpc.CallOption) (*ObjectInfo, error)
	// CheckObject checks if an object exists in the blob store without
	// actually reading the object.
	CheckObject(ctx context.Context, in *CheckObjectRequest, opts ...grpc.CallOption) (*CheckObjectResponse, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (ObjectAPI_ListObjectsClient, error)
	DeleteObjects(ctx context.Context, in *DeleteObjectsRequest, opts ...grpc.CallOption) (*DeleteObjectsResponse, error)
	GetTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (ObjectAPI_GetTagClient, error)
	InspectTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (*ObjectInfo, error)
	ListTags(ctx context.Context, in *ListTagsRequest, opts ...grpc.CallOption) (ObjectAPI_ListTagsClient, error)
	DeleteTags(ctx context.Context, in *DeleteTagsRequest, opts ...grpc.CallOption) (*DeleteTagsResponse, error)
	Compact(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
}

func NewObjectAPIClient added in v1.3.9 

func NewObjectAPIClient(cc *grpc.ClientConn) ObjectAPIClient

type ObjectAPIServer added in v1.3.9 

type ObjectAPIServer interface {
	PutObject(ObjectAPI_PutObjectServer) error
	GetObject(*Object, ObjectAPI_GetObjectServer) error
	GetObjects(*GetObjectsRequest, ObjectAPI_GetObjectsServer) error
	TagObject(context.Context, *TagObjectRequest) (*google_protobuf.Empty, error)
	InspectObject(context.Context, *Object) (*ObjectInfo, error)
	// CheckObject checks if an object exists in the blob store without
	// actually reading the object.
	CheckObject(context.Context, *CheckObjectRequest) (*CheckObjectResponse, error)
	ListObjects(*ListObjectsRequest, ObjectAPI_ListObjectsServer) error
	DeleteObjects(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error)
	GetTag(*Tag, ObjectAPI_GetTagServer) error
	InspectTag(context.Context, *Tag) (*ObjectInfo, error)
	ListTags(*ListTagsRequest, ObjectAPI_ListTagsServer) error
	DeleteTags(context.Context, *DeleteTagsRequest) (*DeleteTagsResponse, error)
	Compact(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error)
}

type ObjectAPI_GetObjectClient added in v1.3.9 

type ObjectAPI_GetObjectClient interface {
	Recv() (*google_protobuf2.BytesValue, error)
	grpc.ClientStream
}

type ObjectAPI_GetObjectServer added in v1.3.9 

type ObjectAPI_GetObjectServer interface {
	Send(*google_protobuf2.BytesValue) error
	grpc.ServerStream
}

type ObjectAPI_GetObjectsClient added in v1.3.19 

type ObjectAPI_GetObjectsClient interface {
	Recv() (*google_protobuf2.BytesValue, error)
	grpc.ClientStream
}

type ObjectAPI_GetObjectsServer added in v1.3.19 

type ObjectAPI_GetObjectsServer interface {
	Send(*google_protobuf2.BytesValue) error
	grpc.ServerStream
}

type ObjectAPI_GetTagClient added in v1.3.9 

type ObjectAPI_GetTagClient interface {
	Recv() (*google_protobuf2.BytesValue, error)
	grpc.ClientStream
}

type ObjectAPI_GetTagServer added in v1.3.9 

type ObjectAPI_GetTagServer interface {
	Send(*google_protobuf2.BytesValue) error
	grpc.ServerStream
}

type ObjectAPI_ListObjectsClient added in v1.4.7 

type ObjectAPI_ListObjectsClient interface {
	Recv() (*Object, error)
	grpc.ClientStream
}

type ObjectAPI_ListObjectsServer added in v1.4.7 

type ObjectAPI_ListObjectsServer interface {
	Send(*Object) error
	grpc.ServerStream
}

type ObjectAPI_ListTagsClient added in v1.4.7 

type ObjectAPI_ListTagsClient interface {
	Recv() (*ListTagsResponse, error)
	grpc.ClientStream
}

type ObjectAPI_ListTagsServer added in v1.4.7 

type ObjectAPI_ListTagsServer interface {
	Send(*ListTagsResponse) error
	grpc.ServerStream
}

type ObjectAPI_PutObjectClient added in v1.3.9 

type ObjectAPI_PutObjectClient interface {
	Send(*PutObjectRequest) error
	CloseAndRecv() (*Object, error)
	grpc.ClientStream
}

type ObjectAPI_PutObjectServer added in v1.3.9 

type ObjectAPI_PutObjectServer interface {
	SendAndClose(*Object) error
	Recv() (*PutObjectRequest, error)
	grpc.ServerStream
}

type ObjectIndex added in v1.3.9 

type ObjectIndex struct {
	Objects map[string]*BlockRef `` /* 141-byte string literal not displayed */
	Tags    map[string]*Object   `` /* 135-byte string literal not displayed */
}

func (*ObjectIndex) Descriptor added in v1.3.9 

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

func (*ObjectIndex) GetObjects added in v1.3.9 

func (m *ObjectIndex) GetObjects() map[string]*BlockRef

func (*ObjectIndex) GetTags added in v1.3.9 

func (m *ObjectIndex) GetTags() map[string]*Object

func (*ObjectIndex) ProtoMessage added in v1.3.9 

func (*ObjectIndex) ProtoMessage()

func (*ObjectIndex) Reset added in v1.3.9 

func (m *ObjectIndex) Reset()

func (*ObjectIndex) String added in v1.3.9 

func (m *ObjectIndex) String() string

type ObjectInfo added in v1.3.9 

type ObjectInfo struct {
	Object   *Object   `protobuf:"bytes,1,opt,name=object" json:"object,omitempty"`
	BlockRef *BlockRef `protobuf:"bytes,2,opt,name=block_ref,json=blockRef" json:"block_ref,omitempty"`
}

func (*ObjectInfo) Descriptor added in v1.3.9 

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

func (*ObjectInfo) GetBlockRef added in v1.3.9 

func (m *ObjectInfo) GetBlockRef() *BlockRef

func (*ObjectInfo) GetObject added in v1.3.9 

func (m *ObjectInfo) GetObject() *Object

func (*ObjectInfo) ProtoMessage added in v1.3.9 

func (*ObjectInfo) ProtoMessage()

func (*ObjectInfo) Reset added in v1.3.9 

func (m *ObjectInfo) Reset()

func (*ObjectInfo) String added in v1.3.9 

func (m *ObjectInfo) String() string

type PutFileRequest 

type PutFileRequest struct {
	File  *File  `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,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"`
	// Delimiter causes data to be broken up into separate files with File.Path
	// as a prefix.
	Delimiter Delimiter `protobuf:"varint,7,opt,name=delimiter,proto3,enum=pfs.Delimiter" json:"delimiter,omitempty"`
	// TargetFileDatums specifies the target number of datums in each written
	// file it may be lower if data does not split evenly, but will never be
	// higher, unless the value is 0.
	TargetFileDatums int64 `protobuf:"varint,8,opt,name=target_file_datums,json=targetFileDatums,proto3" json:"target_file_datums,omitempty"`
	// TargetFileBytes specifies the target number of bytes in each written
	// file, files may have more or fewer bytes than the target.
	TargetFileBytes int64 `protobuf:"varint,9,opt,name=target_file_bytes,json=targetFileBytes,proto3" json:"target_file_bytes,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) GetRecursive added in v1.3.5 

func (m *PutFileRequest) GetRecursive() bool

func (*PutFileRequest) GetTargetFileBytes added in v1.3.19 

func (m *PutFileRequest) GetTargetFileBytes() int64

func (*PutFileRequest) GetTargetFileDatums added in v1.3.19 

func (m *PutFileRequest) GetTargetFileDatums() int64

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 PutObjectRequest added in v1.3.9 

type PutObjectRequest struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Tags  []*Tag `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty"`
}

func (*PutObjectRequest) Descriptor added in v1.3.9 

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

func (*PutObjectRequest) GetTags added in v1.3.9 

func (m *PutObjectRequest) GetTags() []*Tag

func (*PutObjectRequest) GetValue added in v1.3.9 

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

func (*PutObjectRequest) ProtoMessage added in v1.3.9 

func (*PutObjectRequest) ProtoMessage()

func (*PutObjectRequest) Reset added in v1.3.9 

func (m *PutObjectRequest) Reset()

func (*PutObjectRequest) String added in v1.3.9 

func (m *PutObjectRequest) 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_protobuf1.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"`
	Description string                      `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
}

func (*RepoInfo) Descriptor 

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

func (*RepoInfo) GetCreated 

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

func (*RepoInfo) GetDescription added in v1.4.7 

func (m *RepoInfo) GetDescription() string

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 SetBranchRequest added in v1.3.19 

type SetBranchRequest struct {
	Commit *Commit `protobuf:"bytes,1,opt,name=commit" json:"commit,omitempty"`
	Branch string  `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
}

func (*SetBranchRequest) Descriptor added in v1.3.19 

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

func (*SetBranchRequest) GetBranch added in v1.3.19 

func (m *SetBranchRequest) GetBranch() string

func (*SetBranchRequest) GetCommit added in v1.3.19 

func (m *SetBranchRequest) GetCommit() *Commit

func (*SetBranchRequest) ProtoMessage added in v1.3.19 

func (*SetBranchRequest) ProtoMessage()

func (*SetBranchRequest) Reset added in v1.3.19 

func (m *SetBranchRequest) Reset()

func (*SetBranchRequest) String added in v1.3.19 

func (m *SetBranchRequest) String() string

type StartCommitRequest 

type StartCommitRequest struct {
	// Parent.ID may be empty in which case the commit that Branch points to will be used as the parent.
	// If branch is empty, or if branch does not exist, the commit will have no parent.
	Parent     *Commit   `protobuf:"bytes,1,opt,name=parent" json:"parent,omitempty"`
	Branch     string    `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"`
	Provenance []*Commit `protobuf:"bytes,2,rep,name=provenance" json:"provenance,omitempty"`
}

func (*StartCommitRequest) Descriptor 

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

func (*StartCommitRequest) GetBranch added in v1.3.19 

func (m *StartCommitRequest) GetBranch() string

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

type SubscribeCommitRequest added in v1.3.19 

type SubscribeCommitRequest struct {
	Repo   *Repo  `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Branch string `protobuf:"bytes,2,opt,name=branch,proto3" json:"branch,omitempty"`
	// only commits created since this commit are returned
	From *Commit `protobuf:"bytes,3,opt,name=from" json:"from,omitempty"`
}

func (*SubscribeCommitRequest) Descriptor added in v1.3.19 

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

func (*SubscribeCommitRequest) GetBranch added in v1.3.19 

func (m *SubscribeCommitRequest) GetBranch() string

func (*SubscribeCommitRequest) GetFrom added in v1.3.19 

func (m *SubscribeCommitRequest) GetFrom() *Commit

func (*SubscribeCommitRequest) GetRepo added in v1.3.19 

func (m *SubscribeCommitRequest) GetRepo() *Repo

func (*SubscribeCommitRequest) ProtoMessage added in v1.3.19 

func (*SubscribeCommitRequest) ProtoMessage()

func (*SubscribeCommitRequest) Reset added in v1.3.19 

func (m *SubscribeCommitRequest) Reset()

func (*SubscribeCommitRequest) String added in v1.3.19 

func (m *SubscribeCommitRequest) String() string

type Tag added in v1.3.9 

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

func (*Tag) Descriptor added in v1.3.9 

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

func (*Tag) GetName added in v1.3.9 

func (m *Tag) GetName() string

func (*Tag) ProtoMessage added in v1.3.9 

func (*Tag) ProtoMessage()

func (*Tag) Reset added in v1.3.9 

func (m *Tag) Reset()

func (*Tag) String added in v1.3.9 

func (m *Tag) String() string

type TagObjectRequest added in v1.3.9 

type TagObjectRequest struct {
	Object *Object `protobuf:"bytes,1,opt,name=object" json:"object,omitempty"`
	Tags   []*Tag  `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty"`
}

func (*TagObjectRequest) Descriptor added in v1.3.9 

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

func (*TagObjectRequest) GetObject added in v1.3.9 

func (m *TagObjectRequest) GetObject() *Object

func (*TagObjectRequest) GetTags added in v1.3.9 

func (m *TagObjectRequest) GetTags() []*Tag

func (*TagObjectRequest) ProtoMessage added in v1.3.9 

func (*TagObjectRequest) ProtoMessage()

func (*TagObjectRequest) Reset added in v1.3.9 

func (m *TagObjectRequest) Reset()

func (*TagObjectRequest) String added in v1.3.9 

func (m *TagObjectRequest) 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.