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 DeleteFileRequest PutObjectRequest GetObjectsRequest TagObjectRequest ObjectIndex
Index ¶
- Variables
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- func RegisterObjectAPIServer(s *grpc.Server, srv ObjectAPIServer)
- type APIClient
- type APIServer
- type API_FlushCommitClient
- type API_FlushCommitServer
- type API_GetFileClient
- type API_GetFileServer
- type API_PutFileClient
- type API_PutFileServer
- type API_SubscribeCommitClient
- type API_SubscribeCommitServer
- type Block
- type BlockRef
- type Branch
- type Branches
- type BuildCommitRequest
- func (*BuildCommitRequest) Descriptor() ([]byte, []int)
- func (m *BuildCommitRequest) GetBranch() string
- func (m *BuildCommitRequest) GetParent() *Commit
- func (m *BuildCommitRequest) GetProvenance() []*Commit
- func (m *BuildCommitRequest) GetTree() *Object
- func (*BuildCommitRequest) ProtoMessage()
- func (m *BuildCommitRequest) Reset()
- func (m *BuildCommitRequest) String() string
- type ByteRange
- type Commit
- type CommitInfo
- func (*CommitInfo) Descriptor() ([]byte, []int)
- func (m *CommitInfo) GetCommit() *Commit
- func (m *CommitInfo) GetFinished() *google_protobuf1.Timestamp
- func (m *CommitInfo) GetParentCommit() *Commit
- func (m *CommitInfo) GetProvenance() []*Commit
- func (m *CommitInfo) GetSizeBytes() uint64
- func (m *CommitInfo) GetStarted() *google_protobuf1.Timestamp
- func (m *CommitInfo) GetTree() *Object
- func (*CommitInfo) ProtoMessage()
- func (m *CommitInfo) Reset()
- func (m *CommitInfo) String() string
- type CommitInfos
- type Commits
- type CreateRepoRequest
- func (*CreateRepoRequest) Descriptor() ([]byte, []int)
- func (m *CreateRepoRequest) GetDescription() string
- func (m *CreateRepoRequest) GetProvenance() []*Repo
- func (m *CreateRepoRequest) GetRepo() *Repo
- func (*CreateRepoRequest) ProtoMessage()
- func (m *CreateRepoRequest) Reset()
- func (m *CreateRepoRequest) String() string
- type DeleteBranchRequest
- type DeleteCommitRequest
- type DeleteFileRequest
- type DeleteRepoRequest
- type Delimiter
- type File
- type FileInfo
- func (*FileInfo) Descriptor() ([]byte, []int)
- func (m *FileInfo) GetChildren() []string
- func (m *FileInfo) GetFile() *File
- func (m *FileInfo) GetFileType() FileType
- func (m *FileInfo) GetHash() []byte
- func (m *FileInfo) GetObjects() []*Object
- func (m *FileInfo) GetSizeBytes() uint64
- func (*FileInfo) ProtoMessage()
- func (m *FileInfo) Reset()
- func (m *FileInfo) String() string
- type FileInfos
- type FileType
- type FinishCommitRequest
- type FlushCommitRequest
- type GetFileRequest
- type GetObjectsRequest
- func (*GetObjectsRequest) Descriptor() ([]byte, []int)
- func (m *GetObjectsRequest) GetObjects() []*Object
- func (m *GetObjectsRequest) GetOffsetBytes() uint64
- func (m *GetObjectsRequest) GetSizeBytes() uint64
- func (*GetObjectsRequest) ProtoMessage()
- func (m *GetObjectsRequest) Reset()
- func (m *GetObjectsRequest) String() string
- type GlobFileRequest
- type InspectCommitRequest
- type InspectFileRequest
- type InspectRepoRequest
- type ListBranchRequest
- type ListCommitRequest
- func (*ListCommitRequest) Descriptor() ([]byte, []int)
- func (m *ListCommitRequest) GetFrom() *Commit
- func (m *ListCommitRequest) GetNumber() uint64
- func (m *ListCommitRequest) GetRepo() *Repo
- func (m *ListCommitRequest) GetTo() *Commit
- func (*ListCommitRequest) ProtoMessage()
- func (m *ListCommitRequest) Reset()
- func (m *ListCommitRequest) String() string
- type ListFileMode
- type ListFileRequest
- type ListRepoRequest
- type Object
- type ObjectAPIClient
- type ObjectAPIServer
- type ObjectAPI_GetObjectClient
- type ObjectAPI_GetObjectServer
- type ObjectAPI_GetObjectsClient
- type ObjectAPI_GetObjectsServer
- type ObjectAPI_GetTagClient
- type ObjectAPI_GetTagServer
- type ObjectAPI_PutObjectClient
- type ObjectAPI_PutObjectServer
- type ObjectIndex
- type ObjectInfo
- type PutFileRequest
- func (*PutFileRequest) Descriptor() ([]byte, []int)
- func (m *PutFileRequest) GetDelimiter() Delimiter
- func (m *PutFileRequest) GetFile() *File
- func (m *PutFileRequest) GetRecursive() bool
- func (m *PutFileRequest) GetTargetFileBytes() int64
- func (m *PutFileRequest) GetTargetFileDatums() int64
- func (m *PutFileRequest) GetUrl() string
- func (m *PutFileRequest) GetValue() []byte
- func (*PutFileRequest) ProtoMessage()
- func (m *PutFileRequest) Reset()
- func (m *PutFileRequest) String() string
- type PutObjectRequest
- type Repo
- type RepoInfo
- func (*RepoInfo) Descriptor() ([]byte, []int)
- func (m *RepoInfo) GetCreated() *google_protobuf1.Timestamp
- func (m *RepoInfo) GetDescription() string
- func (m *RepoInfo) GetProvenance() []*Repo
- func (m *RepoInfo) GetRepo() *Repo
- func (m *RepoInfo) GetSizeBytes() uint64
- func (*RepoInfo) ProtoMessage()
- func (m *RepoInfo) Reset()
- func (m *RepoInfo) String() string
- type RepoInfos
- type SetBranchRequest
- type StartCommitRequest
- func (*StartCommitRequest) Descriptor() ([]byte, []int)
- func (m *StartCommitRequest) GetBranch() string
- func (m *StartCommitRequest) GetParent() *Commit
- func (m *StartCommitRequest) GetProvenance() []*Commit
- func (*StartCommitRequest) ProtoMessage()
- func (m *StartCommitRequest) Reset()
- func (m *StartCommitRequest) String() string
- type SubscribeCommitRequest
- func (*SubscribeCommitRequest) Descriptor() ([]byte, []int)
- func (m *SubscribeCommitRequest) GetBranch() string
- func (m *SubscribeCommitRequest) GetFrom() *Commit
- func (m *SubscribeCommitRequest) GetRepo() *Repo
- func (*SubscribeCommitRequest) ProtoMessage()
- func (m *SubscribeCommitRequest) Reset()
- func (m *SubscribeCommitRequest) String() string
- type Tag
- type TagObjectRequest
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 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) // 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) // 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) ProtoMessage ¶
func (*Block) ProtoMessage()
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) ProtoMessage ¶
func (*BlockRef) ProtoMessage()
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) ProtoMessage ¶ added in v1.3.19
func (*Branch) ProtoMessage()
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) GetBranches ¶ added in v1.3.5
func (*Branches) ProtoMessage ¶ added in v1.2.0
func (*Branches) ProtoMessage()
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) ProtoMessage ¶
func (*ByteRange) ProtoMessage()
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) ProtoMessage ¶
func (*Commit) ProtoMessage()
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) ProtoMessage ¶ added in v1.2.0
func (*Commits) ProtoMessage()
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 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 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) ProtoMessage ¶
func (*File) ProtoMessage()
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) GetChildren ¶
func (*FileInfo) GetFileType ¶ added in v1.3.5
func (*FileInfo) GetObjects ¶ added in v1.4.6
func (*FileInfo) GetSizeBytes ¶ added in v1.3.5
func (*FileInfo) ProtoMessage ¶
func (*FileInfo) ProtoMessage()
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) GetFileInfo ¶
func (*FileInfos) ProtoMessage ¶
func (*FileInfos) ProtoMessage()
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 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 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) ProtoMessage ¶ added in v1.3.9
func (*Object) ProtoMessage()
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) GetTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (ObjectAPI_GetTagClient, error) InspectTag(ctx context.Context, in *Tag, opts ...grpc.CallOption) (*ObjectInfo, 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) GetTag(*Tag, ObjectAPI_GetTagServer) error InspectTag(context.Context, *Tag) (*ObjectInfo, 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_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) ProtoMessage ¶
func (*Repo) ProtoMessage()
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) GetCreated ¶
func (m *RepoInfo) GetCreated() *google_protobuf1.Timestamp
func (*RepoInfo) GetDescription ¶ added in v1.4.7
func (*RepoInfo) GetProvenance ¶
func (*RepoInfo) GetSizeBytes ¶ added in v1.3.5
func (*RepoInfo) ProtoMessage ¶
func (*RepoInfo) ProtoMessage()
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) GetRepoInfo ¶
func (*RepoInfos) ProtoMessage ¶
func (*RepoInfos) ProtoMessage()
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) ProtoMessage ¶ added in v1.3.9
func (*Tag) ProtoMessage()
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
Click to show internal directories.
Click to hide internal directories.