pfs

package
v1.0.1-RCX15 Latest Latest
Warning

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

Go to latest
Published: Jun 27, 2016 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package pfs is a generated protocol buffer package.

It is generated from these files:

client/pfs/pfs.proto

It has these top-level messages:

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

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterAPIServer

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

func RegisterBlockAPIServer

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

func RegisterInternalAPIServer

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

Types

type APIClient

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

func NewAPIClient

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer

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

type API_GetFileClient

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

type API_GetFileServer

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

type API_PutFileClient

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

type API_PutFileServer

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

type Append

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

func (*Append) Descriptor

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

func (*Append) GetBlockRefs

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

func (*Append) GetChildren

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

func (*Append) GetHandleDeletes

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

func (*Append) GetHandles

func (m *Append) GetHandles() map[string]*BlockRefs

func (*Append) GetLastRef

func (m *Append) GetLastRef() *Commit

func (*Append) ProtoMessage

func (*Append) ProtoMessage()

func (*Append) Reset

func (m *Append) Reset()

func (*Append) String

func (m *Append) String() string

type Block

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

func (*Block) Descriptor

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

func (*Block) ProtoMessage

func (*Block) ProtoMessage()

func (*Block) Reset

func (m *Block) Reset()

func (*Block) String

func (m *Block) String() string

type BlockAPIClient

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

func NewBlockAPIClient

func NewBlockAPIClient(cc *grpc.ClientConn) BlockAPIClient

type BlockAPI_GetBlockClient

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

type BlockAPI_GetBlockServer

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

type BlockAPI_ListDiffClient

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

type BlockAPI_ListDiffServer

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

type BlockAPI_PutBlockClient

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

type BlockAPI_PutBlockServer

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

type BlockInfo

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

func (*BlockInfo) Descriptor

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

func (*BlockInfo) GetBlock

func (m *BlockInfo) GetBlock() *Block

func (*BlockInfo) GetCreated

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

func (*BlockInfo) ProtoMessage

func (*BlockInfo) ProtoMessage()

func (*BlockInfo) Reset

func (m *BlockInfo) Reset()

func (*BlockInfo) String

func (m *BlockInfo) String() string

type BlockInfos

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

func (*BlockInfos) Descriptor

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

func (*BlockInfos) GetBlockInfo

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

func (*BlockInfos) ProtoMessage

func (*BlockInfos) ProtoMessage()

func (*BlockInfos) Reset

func (m *BlockInfos) Reset()

func (*BlockInfos) String

func (m *BlockInfos) String() string

type BlockRef

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

func (*BlockRef) Descriptor

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

func (*BlockRef) GetBlock

func (m *BlockRef) GetBlock() *Block

func (*BlockRef) GetRange

func (m *BlockRef) GetRange() *ByteRange

func (*BlockRef) ProtoMessage

func (*BlockRef) ProtoMessage()

func (*BlockRef) Reset

func (m *BlockRef) Reset()

func (*BlockRef) String

func (m *BlockRef) String() string

type BlockRefs

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

func (*BlockRefs) Descriptor

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

func (*BlockRefs) GetBlockRef

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

func (*BlockRefs) ProtoMessage

func (*BlockRefs) ProtoMessage()

func (*BlockRefs) Reset

func (m *BlockRefs) Reset()

func (*BlockRefs) String

func (m *BlockRefs) String() string

type ByteRange

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

func (*ByteRange) Descriptor

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

func (*ByteRange) ProtoMessage

func (*ByteRange) ProtoMessage()

func (*ByteRange) Reset

func (m *ByteRange) Reset()

func (*ByteRange) String

func (m *ByteRange) String() string

type Commit

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

func (*Commit) Descriptor

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

func (*Commit) GetRepo

func (m *Commit) GetRepo() *Repo

func (*Commit) ProtoMessage

func (*Commit) ProtoMessage()

func (*Commit) Reset

func (m *Commit) Reset()

func (*Commit) String

func (m *Commit) String() string

type CommitInfo

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

func (*CommitInfo) Descriptor

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

func (*CommitInfo) GetCommit

func (m *CommitInfo) GetCommit() *Commit

func (*CommitInfo) GetFinished

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

func (*CommitInfo) GetParentCommit

func (m *CommitInfo) GetParentCommit() *Commit

func (*CommitInfo) GetProvenance

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

func (*CommitInfo) GetStarted

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

func (*CommitInfo) ProtoMessage

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) Reset

func (m *CommitInfo) Reset()

func (*CommitInfo) String

func (m *CommitInfo) String() string

type CommitInfos

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

func (*CommitInfos) Descriptor

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

func (*CommitInfos) GetCommitInfo

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

func (*CommitInfos) ProtoMessage

func (*CommitInfos) ProtoMessage()

func (*CommitInfos) Reset

func (m *CommitInfos) Reset()

func (*CommitInfos) String

func (m *CommitInfos) String() string

type CommitType

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

func (CommitType) EnumDescriptor

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

func (CommitType) String

func (x CommitType) String() string

type CreateRepoRequest

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

func (*CreateRepoRequest) Descriptor

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

func (*CreateRepoRequest) GetCreated

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

func (*CreateRepoRequest) GetProvenance

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

func (*CreateRepoRequest) GetRepo

func (m *CreateRepoRequest) GetRepo() *Repo

func (*CreateRepoRequest) ProtoMessage

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) Reset

func (m *CreateRepoRequest) Reset()

func (*CreateRepoRequest) String

func (m *CreateRepoRequest) String() string

type DeleteBlockRequest

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

func (*DeleteBlockRequest) Descriptor

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

func (*DeleteBlockRequest) GetBlock

func (m *DeleteBlockRequest) GetBlock() *Block

func (*DeleteBlockRequest) ProtoMessage

func (*DeleteBlockRequest) ProtoMessage()

func (*DeleteBlockRequest) Reset

func (m *DeleteBlockRequest) Reset()

func (*DeleteBlockRequest) String

func (m *DeleteBlockRequest) String() string

type DeleteCommitRequest

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

func (*DeleteCommitRequest) Descriptor

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

func (*DeleteCommitRequest) GetCommit

func (m *DeleteCommitRequest) GetCommit() *Commit

func (*DeleteCommitRequest) ProtoMessage

func (*DeleteCommitRequest) ProtoMessage()

func (*DeleteCommitRequest) Reset

func (m *DeleteCommitRequest) Reset()

func (*DeleteCommitRequest) String

func (m *DeleteCommitRequest) String() string

type DeleteDiffRequest

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

func (*DeleteDiffRequest) Descriptor

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

func (*DeleteDiffRequest) GetDiff

func (m *DeleteDiffRequest) GetDiff() *Diff

func (*DeleteDiffRequest) ProtoMessage

func (*DeleteDiffRequest) ProtoMessage()

func (*DeleteDiffRequest) Reset

func (m *DeleteDiffRequest) Reset()

func (*DeleteDiffRequest) String

func (m *DeleteDiffRequest) String() string

type DeleteFileRequest

type DeleteFileRequest struct {
	File   *File  `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	Unsafe bool   `protobuf:"varint,2,opt,name=unsafe" json:"unsafe,omitempty"`
	Handle string `protobuf:"bytes,3,opt,name=handle" json:"handle,omitempty"`
}

func (*DeleteFileRequest) Descriptor

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

func (*DeleteFileRequest) GetFile

func (m *DeleteFileRequest) GetFile() *File

func (*DeleteFileRequest) ProtoMessage

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) String

func (m *DeleteFileRequest) String() string

type DeleteRepoRequest

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

func (*DeleteRepoRequest) Descriptor

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

func (*DeleteRepoRequest) GetRepo

func (m *DeleteRepoRequest) GetRepo() *Repo

func (*DeleteRepoRequest) ProtoMessage

func (*DeleteRepoRequest) ProtoMessage()

func (*DeleteRepoRequest) Reset

func (m *DeleteRepoRequest) Reset()

func (*DeleteRepoRequest) String

func (m *DeleteRepoRequest) String() string

type Delimiter

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

func (Delimiter) EnumDescriptor

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

func (Delimiter) String

func (x Delimiter) String() string

type Diff

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

func (*Diff) Descriptor

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

func (*Diff) GetCommit

func (m *Diff) GetCommit() *Commit

func (*Diff) ProtoMessage

func (*Diff) ProtoMessage()

func (*Diff) Reset

func (m *Diff) Reset()

func (*Diff) String

func (m *Diff) String() string

type DiffInfo

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

func (*DiffInfo) Descriptor

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

func (*DiffInfo) GetAppends

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

func (*DiffInfo) GetDiff

func (m *DiffInfo) GetDiff() *Diff

func (*DiffInfo) GetFinished

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

func (*DiffInfo) GetParentCommit

func (m *DiffInfo) GetParentCommit() *Commit

func (*DiffInfo) GetProvenance

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

func (*DiffInfo) GetStarted

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

func (*DiffInfo) ProtoMessage

func (*DiffInfo) ProtoMessage()

func (*DiffInfo) Reset

func (m *DiffInfo) Reset()

func (*DiffInfo) String

func (m *DiffInfo) String() string

type File

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

func (*File) Descriptor

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

func (*File) GetCommit

func (m *File) GetCommit() *Commit

func (*File) ProtoMessage

func (*File) ProtoMessage()

func (*File) Reset

func (m *File) Reset()

func (*File) String

func (m *File) String() string

type FileInfo

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

func (*FileInfo) Descriptor

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

func (*FileInfo) GetChildren

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

func (*FileInfo) GetCommitModified

func (m *FileInfo) GetCommitModified() *Commit

func (*FileInfo) GetFile

func (m *FileInfo) GetFile() *File

func (*FileInfo) GetModified

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

func (*FileInfo) ProtoMessage

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset

func (m *FileInfo) Reset()

func (*FileInfo) String

func (m *FileInfo) String() string

type FileInfos

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

func (*FileInfos) Descriptor

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

func (*FileInfos) GetFileInfo

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

func (*FileInfos) ProtoMessage

func (*FileInfos) ProtoMessage()

func (*FileInfos) Reset

func (m *FileInfos) Reset()

func (*FileInfos) String

func (m *FileInfos) String() string

type FileType

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

func (FileType) EnumDescriptor

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

func (FileType) String

func (x FileType) String() string

type FinishCommitRequest

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

func (*FinishCommitRequest) Descriptor

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

func (*FinishCommitRequest) GetCommit

func (m *FinishCommitRequest) GetCommit() *Commit

func (*FinishCommitRequest) GetFinished

func (*FinishCommitRequest) ProtoMessage

func (*FinishCommitRequest) ProtoMessage()

func (*FinishCommitRequest) Reset

func (m *FinishCommitRequest) Reset()

func (*FinishCommitRequest) String

func (m *FinishCommitRequest) String() string

type FlushCommitRequest

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

func (*FlushCommitRequest) Descriptor

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

func (*FlushCommitRequest) GetCommit

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

func (*FlushCommitRequest) GetToRepo

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

func (*FlushCommitRequest) ProtoMessage

func (*FlushCommitRequest) ProtoMessage()

func (*FlushCommitRequest) Reset

func (m *FlushCommitRequest) Reset()

func (*FlushCommitRequest) String

func (m *FlushCommitRequest) String() string

type GetBlockRequest

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

func (*GetBlockRequest) Descriptor

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

func (*GetBlockRequest) GetBlock

func (m *GetBlockRequest) GetBlock() *Block

func (*GetBlockRequest) ProtoMessage

func (*GetBlockRequest) ProtoMessage()

func (*GetBlockRequest) Reset

func (m *GetBlockRequest) Reset()

func (*GetBlockRequest) String

func (m *GetBlockRequest) String() string

type GetFileRequest

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

func (*GetFileRequest) Descriptor

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

func (*GetFileRequest) GetFile

func (m *GetFileRequest) GetFile() *File

func (*GetFileRequest) GetFromCommit

func (m *GetFileRequest) GetFromCommit() *Commit

func (*GetFileRequest) GetShard

func (m *GetFileRequest) GetShard() *Shard

func (*GetFileRequest) ProtoMessage

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) Reset

func (m *GetFileRequest) Reset()

func (*GetFileRequest) String

func (m *GetFileRequest) String() string

type InspectBlockRequest

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

func (*InspectBlockRequest) Descriptor

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

func (*InspectBlockRequest) GetBlock

func (m *InspectBlockRequest) GetBlock() *Block

func (*InspectBlockRequest) ProtoMessage

func (*InspectBlockRequest) ProtoMessage()

func (*InspectBlockRequest) Reset

func (m *InspectBlockRequest) Reset()

func (*InspectBlockRequest) String

func (m *InspectBlockRequest) String() string

type InspectCommitRequest

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

func (*InspectCommitRequest) Descriptor

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

func (*InspectCommitRequest) GetCommit

func (m *InspectCommitRequest) GetCommit() *Commit

func (*InspectCommitRequest) ProtoMessage

func (*InspectCommitRequest) ProtoMessage()

func (*InspectCommitRequest) Reset

func (m *InspectCommitRequest) Reset()

func (*InspectCommitRequest) String

func (m *InspectCommitRequest) String() string

type InspectDiffRequest

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

func (*InspectDiffRequest) Descriptor

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

func (*InspectDiffRequest) GetDiff

func (m *InspectDiffRequest) GetDiff() *Diff

func (*InspectDiffRequest) ProtoMessage

func (*InspectDiffRequest) ProtoMessage()

func (*InspectDiffRequest) Reset

func (m *InspectDiffRequest) Reset()

func (*InspectDiffRequest) String

func (m *InspectDiffRequest) String() string

type InspectFileRequest

type InspectFileRequest struct {
	File       *File   `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	Shard      *Shard  `protobuf:"bytes,2,opt,name=shard" json:"shard,omitempty"`
	FromCommit *Commit `protobuf:"bytes,3,opt,name=from_commit,json=fromCommit" json:"from_commit,omitempty"`
	Unsafe     bool    `protobuf:"varint,4,opt,name=unsafe" json:"unsafe,omitempty"`
	Handle     string  `protobuf:"bytes,5,opt,name=handle" json:"handle,omitempty"`
}

func (*InspectFileRequest) Descriptor

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

func (*InspectFileRequest) GetFile

func (m *InspectFileRequest) GetFile() *File

func (*InspectFileRequest) GetFromCommit

func (m *InspectFileRequest) GetFromCommit() *Commit

func (*InspectFileRequest) GetShard

func (m *InspectFileRequest) GetShard() *Shard

func (*InspectFileRequest) ProtoMessage

func (*InspectFileRequest) ProtoMessage()

func (*InspectFileRequest) Reset

func (m *InspectFileRequest) Reset()

func (*InspectFileRequest) String

func (m *InspectFileRequest) String() string

type InspectRepoRequest

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

func (*InspectRepoRequest) Descriptor

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

func (*InspectRepoRequest) GetRepo

func (m *InspectRepoRequest) GetRepo() *Repo

func (*InspectRepoRequest) ProtoMessage

func (*InspectRepoRequest) ProtoMessage()

func (*InspectRepoRequest) Reset

func (m *InspectRepoRequest) Reset()

func (*InspectRepoRequest) String

func (m *InspectRepoRequest) String() string

type InternalAPIClient

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

func NewInternalAPIClient

func NewInternalAPIClient(cc *grpc.ClientConn) InternalAPIClient

type InternalAPIServer

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

type InternalAPI_GetFileClient

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

type InternalAPI_GetFileServer

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

type InternalAPI_PutFileClient

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

type InternalAPI_PutFileServer

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

type ListBlockRequest

type ListBlockRequest struct {
}

func (*ListBlockRequest) Descriptor

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

func (*ListBlockRequest) ProtoMessage

func (*ListBlockRequest) ProtoMessage()

func (*ListBlockRequest) Reset

func (m *ListBlockRequest) Reset()

func (*ListBlockRequest) String

func (m *ListBlockRequest) String() string

type ListBranchRequest

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

func (*ListBranchRequest) Descriptor

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

func (*ListBranchRequest) GetRepo

func (m *ListBranchRequest) GetRepo() *Repo

func (*ListBranchRequest) ProtoMessage

func (*ListBranchRequest) ProtoMessage()

func (*ListBranchRequest) Reset

func (m *ListBranchRequest) Reset()

func (*ListBranchRequest) String

func (m *ListBranchRequest) String() string

type ListCommitRequest

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

func (*ListCommitRequest) Descriptor

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

func (*ListCommitRequest) GetFromCommit

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

func (*ListCommitRequest) GetProvenance

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

func (*ListCommitRequest) GetRepo

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

func (*ListCommitRequest) ProtoMessage

func (*ListCommitRequest) ProtoMessage()

func (*ListCommitRequest) Reset

func (m *ListCommitRequest) Reset()

func (*ListCommitRequest) String

func (m *ListCommitRequest) String() string

type ListDiffRequest

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

func (*ListDiffRequest) Descriptor

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

func (*ListDiffRequest) ProtoMessage

func (*ListDiffRequest) ProtoMessage()

func (*ListDiffRequest) Reset

func (m *ListDiffRequest) Reset()

func (*ListDiffRequest) String

func (m *ListDiffRequest) String() string

type ListFileRequest

type ListFileRequest struct {
	File       *File   `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	Shard      *Shard  `protobuf:"bytes,2,opt,name=shard" json:"shard,omitempty"`
	FromCommit *Commit `protobuf:"bytes,3,opt,name=from_commit,json=fromCommit" json:"from_commit,omitempty"`
	Recurse    bool    `protobuf:"varint,4,opt,name=recurse" json:"recurse,omitempty"`
	Unsafe     bool    `protobuf:"varint,5,opt,name=unsafe" json:"unsafe,omitempty"`
	Handle     string  `protobuf:"bytes,6,opt,name=handle" json:"handle,omitempty"`
}

func (*ListFileRequest) Descriptor

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

func (*ListFileRequest) GetFile

func (m *ListFileRequest) GetFile() *File

func (*ListFileRequest) GetFromCommit

func (m *ListFileRequest) GetFromCommit() *Commit

func (*ListFileRequest) GetShard

func (m *ListFileRequest) GetShard() *Shard

func (*ListFileRequest) ProtoMessage

func (*ListFileRequest) ProtoMessage()

func (*ListFileRequest) Reset

func (m *ListFileRequest) Reset()

func (*ListFileRequest) String

func (m *ListFileRequest) String() string

type ListRepoRequest

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

func (*ListRepoRequest) Descriptor

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

func (*ListRepoRequest) GetProvenance

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

func (*ListRepoRequest) ProtoMessage

func (*ListRepoRequest) ProtoMessage()

func (*ListRepoRequest) Reset

func (m *ListRepoRequest) Reset()

func (*ListRepoRequest) String

func (m *ListRepoRequest) String() string

type PutBlockRequest

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

func (*PutBlockRequest) Descriptor

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

func (*PutBlockRequest) ProtoMessage

func (*PutBlockRequest) ProtoMessage()

func (*PutBlockRequest) Reset

func (m *PutBlockRequest) Reset()

func (*PutBlockRequest) String

func (m *PutBlockRequest) String() string

type PutFileRequest

type PutFileRequest struct {
	File      *File     `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	FileType  FileType  `protobuf:"varint,2,opt,name=file_type,json=fileType,enum=pfs.FileType" json:"file_type,omitempty"`
	Value     []byte    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Handle    string    `protobuf:"bytes,4,opt,name=handle" json:"handle,omitempty"`
	Delimiter Delimiter `protobuf:"varint,5,opt,name=delimiter,enum=pfs.Delimiter" json:"delimiter,omitempty"`
}

func (*PutFileRequest) Descriptor

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

func (*PutFileRequest) GetFile

func (m *PutFileRequest) GetFile() *File

func (*PutFileRequest) ProtoMessage

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) Reset

func (m *PutFileRequest) Reset()

func (*PutFileRequest) String

func (m *PutFileRequest) String() string

type Repo

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

func (*Repo) Descriptor

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

func (*Repo) ProtoMessage

func (*Repo) ProtoMessage()

func (*Repo) Reset

func (m *Repo) Reset()

func (*Repo) String

func (m *Repo) String() string

type RepoInfo

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

func (*RepoInfo) Descriptor

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

func (*RepoInfo) GetCreated

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

func (*RepoInfo) GetProvenance

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

func (*RepoInfo) GetRepo

func (m *RepoInfo) GetRepo() *Repo

func (*RepoInfo) ProtoMessage

func (*RepoInfo) ProtoMessage()

func (*RepoInfo) Reset

func (m *RepoInfo) Reset()

func (*RepoInfo) String

func (m *RepoInfo) String() string

type RepoInfos

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

func (*RepoInfos) Descriptor

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

func (*RepoInfos) GetRepoInfo

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

func (*RepoInfos) ProtoMessage

func (*RepoInfos) ProtoMessage()

func (*RepoInfos) Reset

func (m *RepoInfos) Reset()

func (*RepoInfos) String

func (m *RepoInfos) String() string

type Shard

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

func (*Shard) Descriptor

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

func (*Shard) ProtoMessage

func (*Shard) ProtoMessage()

func (*Shard) Reset

func (m *Shard) Reset()

func (*Shard) String

func (m *Shard) String() string

type StartCommitRequest

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

func (*StartCommitRequest) Descriptor

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

func (*StartCommitRequest) GetProvenance

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

func (*StartCommitRequest) GetRepo

func (m *StartCommitRequest) GetRepo() *Repo

func (*StartCommitRequest) GetStarted

func (*StartCommitRequest) ProtoMessage

func (*StartCommitRequest) ProtoMessage()

func (*StartCommitRequest) Reset

func (m *StartCommitRequest) Reset()

func (*StartCommitRequest) String

func (m *StartCommitRequest) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL