pfs

package
v1.0.368 Latest Latest
Warning

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

Go to latest
Published: Apr 12, 2016 License: Apache-2.0 Imports: 16 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
GetFileRequest
PutFileRequest
InspectFileRequest
ListFileRequest
DeleteFileRequest
GetBlockRequest
DeleteBlockRequest
InspectBlockRequest
ListBlockRequest
InspectDiffRequest
ListDiffRequest
DeleteDiffRequest

Package pfs is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

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 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 CreateRepo

func CreateRepo(apiClient APIClient, repoName string) error

func DeleteBlock

func DeleteBlock(apiClient BlockAPIClient, block *Block) error

func DeleteCommit

func DeleteCommit(apiClient APIClient, repoName string, commitID string) error

func DeleteFile

func DeleteFile(apiClient APIClient, repoName string, commitID string, path string) error

func DeleteRepo

func DeleteRepo(apiClient APIClient, repoName string) error

func FinishCommit

func FinishCommit(apiClient APIClient, repoName string, commitID string) error

func GetBlock

func GetBlock(apiClient BlockAPIClient, hash string, offsetBytes uint64, sizeBytes uint64) (io.Reader, error)

func GetFile

func GetFile(apiClient APIClient, repoName string, commitID string, path string, offset int64, size int64, fromCommitID string, shard *Shard, writer io.Writer) error

func MakeDirectory

func MakeDirectory(apiClient APIClient, repoName string, commitID string, path string) (retErr error)

func PutFile

func PutFile(apiClient APIClient, repoName string, commitID string, path string, offset int64, reader io.Reader) (_ int, retErr error)

func RegisterAPIHandler

func RegisterAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAPIHandler registers the http handlers for service API to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAPIHandlerFromEndpoint

func RegisterAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAPIHandlerFromEndpoint is same as RegisterAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

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

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

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

func (*Append) Descriptor

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

func (*Append) GetBlockRefs

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

func (*Append) GetChildren

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

func (*Append) GetLastRef

func (m *Append) GetLastRef() *Commit

func (*Append) ProtoMessage

func (*Append) ProtoMessage()

func (*Append) Reset

func (m *Append) Reset()

func (*Append) String

func (m *Append) String() string

type Block

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

func NewBlock

func NewBlock(hash string) *Block

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

type BlockAPI_PutBlockServer

type BlockAPI_PutBlockServer interface {
	SendAndClose(*BlockRefs) error
	Recv() (*google_protobuf3.BytesValue, 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 InspectBlock

func InspectBlock(apiClient BlockAPIClient, hash string) (*BlockInfo, error)

func ListBlock

func ListBlock(apiClient BlockAPIClient) ([]*BlockInfo, error)

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 PutBlock

func PutBlock(apiClient BlockAPIClient, reader io.Reader) (*BlockRefs, error)

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 NewCommit

func NewCommit(repoName string, commitID string) *Commit

func StartCommit

func StartCommit(apiClient APIClient, repoName string, parentCommit string, branch string) (*Commit, error)

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

func InspectCommit

func InspectCommit(apiClient APIClient, repoName string, commitID string) (*CommitInfo, error)

func ListBranch

func ListBranch(apiClient APIClient, repoName string) ([]*CommitInfo, error)

func ListCommit

func ListCommit(apiClient APIClient, repoNames []string, fromCommitIDs []string, block bool) ([]*CommitInfo, error)

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

func (*CreateRepoRequest) Descriptor

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

func (*CreateRepoRequest) GetCreated

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

func (*CreateRepoRequest) GetRepo

func (m *CreateRepoRequest) GetRepo() *Repo

func (*CreateRepoRequest) ProtoMessage

func (*CreateRepoRequest) ProtoMessage()

func (*CreateRepoRequest) Reset

func (m *CreateRepoRequest) Reset()

func (*CreateRepoRequest) String

func (m *CreateRepoRequest) String() string

type DeleteBlockRequest

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

func (*DeleteBlockRequest) Descriptor

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

func (*DeleteBlockRequest) GetBlock

func (m *DeleteBlockRequest) GetBlock() *Block

func (*DeleteBlockRequest) ProtoMessage

func (*DeleteBlockRequest) ProtoMessage()

func (*DeleteBlockRequest) Reset

func (m *DeleteBlockRequest) Reset()

func (*DeleteBlockRequest) String

func (m *DeleteBlockRequest) String() string

type DeleteCommitRequest

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

func (*DeleteCommitRequest) Descriptor

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

func (*DeleteCommitRequest) GetCommit

func (m *DeleteCommitRequest) GetCommit() *Commit

func (*DeleteCommitRequest) ProtoMessage

func (*DeleteCommitRequest) ProtoMessage()

func (*DeleteCommitRequest) Reset

func (m *DeleteCommitRequest) Reset()

func (*DeleteCommitRequest) String

func (m *DeleteCommitRequest) String() string

type DeleteDiffRequest

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

func (*DeleteDiffRequest) Descriptor

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

func (*DeleteDiffRequest) GetDiff

func (m *DeleteDiffRequest) GetDiff() *Diff

func (*DeleteDiffRequest) ProtoMessage

func (*DeleteDiffRequest) ProtoMessage()

func (*DeleteDiffRequest) Reset

func (m *DeleteDiffRequest) Reset()

func (*DeleteDiffRequest) String

func (m *DeleteDiffRequest) String() string

type DeleteFileRequest

type DeleteFileRequest struct {
	File *File `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
}

func (*DeleteFileRequest) Descriptor

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

func (*DeleteFileRequest) GetFile

func (m *DeleteFileRequest) GetFile() *File

func (*DeleteFileRequest) ProtoMessage

func (*DeleteFileRequest) ProtoMessage()

func (*DeleteFileRequest) Reset

func (m *DeleteFileRequest) Reset()

func (*DeleteFileRequest) String

func (m *DeleteFileRequest) String() string

type DeleteRepoRequest

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

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 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 NewDiff

func NewDiff(repoName string, commitID string, shard uint64) *Diff

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

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

func NewFile(repoName string, commitID string, path string) *File

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

func InspectFile

func InspectFile(apiClient APIClient, repoName string, commitID string, path string, fromCommitID string, shard *Shard) (*FileInfo, error)

func ListFile

func ListFile(apiClient APIClient, repoName string, commitID string, path string, fromCommitID string, shard *Shard) ([]*FileInfo, error)

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

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

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

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

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"`
	Block      bool       `protobuf:"varint,4,opt,name=block" json:"block,omitempty"`
}

func (*ListCommitRequest) Descriptor

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

func (*ListCommitRequest) GetFromCommit

func (m *ListCommitRequest) GetFromCommit() []*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"`
}

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

func (*ListRepoRequest) Descriptor

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

func (*ListRepoRequest) ProtoMessage

func (*ListRepoRequest) ProtoMessage()

func (*ListRepoRequest) Reset

func (m *ListRepoRequest) Reset()

func (*ListRepoRequest) String

func (m *ListRepoRequest) 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"`
	OffsetBytes int64    `protobuf:"varint,3,opt,name=offset_bytes,json=offsetBytes" json:"offset_bytes,omitempty"`
	Value       []byte   `protobuf:"bytes,4,opt,name=value,proto3" json:"value,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 NewRepo

func NewRepo(repoName string) *Repo

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

func InspectRepo

func InspectRepo(apiClient APIClient, repoName string) (*RepoInfo, error)

func ListRepo

func ListRepo(apiClient APIClient) ([]*RepoInfo, error)

func (*RepoInfo) Descriptor

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

func (*RepoInfo) GetCreated

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

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

func (*StartCommitRequest) Descriptor

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

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