admin

Oct 29, 2019

Changes in this version

+ var ErrUnexpectedEndOfGroupAdmin = fmt.Errorf("proto: unexpected end of group")

Oct 2, 2019

Changes in this version

type Op1_9

+ Block *pfs2.PutBlockRequest

+ CreateObject *pfs2.CreateObjectRequest

+ Job *pps2.CreateJobRequest

+ func (m *Op1_9) GetBlock() *pfs2.PutBlockRequest

+ func (m *Op1_9) GetCreateObject() *pfs2.CreateObjectRequest

+ func (m *Op1_9) GetJob() *pps2.CreateJobRequest

Sep 11, 2019

Changes in this version

type ClusterInfo

+ func (m *ClusterInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ExtractPipelineRequest

+ func (m *ExtractPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ExtractRequest

+ func (m *ExtractRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type Op

+ Op1_9 *Op1_9

+ func (m *Op) GetOp1_9() *Op1_9

+ func (m *Op) MarshalToSizedBuffer(dAtA []byte) (int, error)

type Op1_7

+ func (m *Op1_7) MarshalToSizedBuffer(dAtA []byte) (int, error)

type Op1_8

+ func (m *Op1_8) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ type Op1_9 struct

+ Branch *pfs2.CreateBranchRequest

+ Commit *pfs2.BuildCommitRequest

+ Object *pfs2.PutObjectRequest

+ Pipeline *pps2.CreatePipelineRequest

+ Repo *pfs2.CreateRepoRequest

+ Tag *pfs2.TagObjectRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Op1_9) Descriptor() ([]byte, []int)

+ func (*Op1_9) ProtoMessage()

+ func (m *Op1_9) GetBranch() *pfs2.CreateBranchRequest

+ func (m *Op1_9) GetCommit() *pfs2.BuildCommitRequest

+ func (m *Op1_9) GetObject() *pfs2.PutObjectRequest

+ func (m *Op1_9) GetPipeline() *pps2.CreatePipelineRequest

+ func (m *Op1_9) GetRepo() *pfs2.CreateRepoRequest

+ func (m *Op1_9) GetTag() *pfs2.TagObjectRequest

+ func (m *Op1_9) Marshal() (dAtA []byte, err error)

+ func (m *Op1_9) MarshalTo(dAtA []byte) (int, error)

+ func (m *Op1_9) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Op1_9) Reset()

+ func (m *Op1_9) Size() (n int)

+ func (m *Op1_9) String() string

+ func (m *Op1_9) Unmarshal(dAtA []byte) error

+ func (m *Op1_9) XXX_DiscardUnknown()

+ func (m *Op1_9) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Op1_9) XXX_Merge(src proto.Message)

+ func (m *Op1_9) XXX_Size() int

+ func (m *Op1_9) XXX_Unmarshal(b []byte) error

type RestoreRequest

+ func (m *RestoreRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

May 28, 2019

Changes in this version

+ type UnimplementedAPIServer struct

+ func (*UnimplementedAPIServer) Extract(req *ExtractRequest, srv API_ExtractServer) error

+ func (*UnimplementedAPIServer) ExtractPipeline(ctx context.Context, req *ExtractPipelineRequest) (*Op, error)

+ func (*UnimplementedAPIServer) InspectCluster(ctx context.Context, req *types.Empty) (*ClusterInfo, error)

+ func (*UnimplementedAPIServer) Restore(srv API_RestoreServer) error

Dec 19, 2018

Changes in this version

type Op

+ Op1_8 *Op1_8

+ func (m *Op) GetOp1_8() *Op1_8

+ type Op1_8 struct

+ Branch *pfs.CreateBranchRequest

+ Commit *pfs.BuildCommitRequest

+ Object *pfs.PutObjectRequest

+ Pipeline *pps.CreatePipelineRequest

+ Repo *pfs.CreateRepoRequest

+ Tag *pfs.TagObjectRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Op1_8) Descriptor() ([]byte, []int)

+ func (*Op1_8) ProtoMessage()

+ func (dst *Op1_8) XXX_Merge(src proto.Message)

+ func (m *Op1_8) GetBranch() *pfs.CreateBranchRequest

+ func (m *Op1_8) GetCommit() *pfs.BuildCommitRequest

+ func (m *Op1_8) GetObject() *pfs.PutObjectRequest

+ func (m *Op1_8) GetPipeline() *pps.CreatePipelineRequest

+ func (m *Op1_8) GetRepo() *pfs.CreateRepoRequest

+ func (m *Op1_8) GetTag() *pfs.TagObjectRequest

+ func (m *Op1_8) Marshal() (dAtA []byte, err error)

+ func (m *Op1_8) MarshalTo(dAtA []byte) (int, error)

+ func (m *Op1_8) Reset()

+ func (m *Op1_8) Size() (n int)

+ func (m *Op1_8) String() string

+ func (m *Op1_8) Unmarshal(dAtA []byte) error

+ func (m *Op1_8) XXX_DiscardUnknown()

+ func (m *Op1_8) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Op1_8) XXX_Size() int

+ func (m *Op1_8) XXX_Unmarshal(b []byte) error

May 2, 2019

Changes in this version

type ClusterInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ClusterInfo) XXX_DiscardUnknown()

+ func (m *ClusterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterInfo) XXX_Merge(src proto.Message)

+ func (m *ClusterInfo) XXX_Size() int

+ func (m *ClusterInfo) XXX_Unmarshal(b []byte) error

type ExtractPipelineRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ExtractPipelineRequest) XXX_DiscardUnknown()

+ func (m *ExtractPipelineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExtractPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *ExtractPipelineRequest) XXX_Size() int

+ func (m *ExtractPipelineRequest) XXX_Unmarshal(b []byte) error

type ExtractRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ExtractRequest) XXX_DiscardUnknown()

+ func (m *ExtractRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExtractRequest) XXX_Merge(src proto.Message)

+ func (m *ExtractRequest) XXX_Size() int

+ func (m *ExtractRequest) XXX_Unmarshal(b []byte) error

type Op

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Op) XXX_DiscardUnknown()

+ func (m *Op) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Op) XXX_Merge(src proto.Message)

+ func (m *Op) XXX_Size() int

+ func (m *Op) XXX_Unmarshal(b []byte) error

type Op1_7

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Op1_7) XXX_DiscardUnknown()

+ func (m *Op1_7) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Op1_7) XXX_Merge(src proto.Message)

+ func (m *Op1_7) XXX_Size() int

+ func (m *Op1_7) XXX_Unmarshal(b []byte) error

type RestoreRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RestoreRequest) XXX_DiscardUnknown()

+ func (m *RestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RestoreRequest) XXX_Merge(src proto.Message)

+ func (m *RestoreRequest) XXX_Size() int

+ func (m *RestoreRequest) XXX_Unmarshal(b []byte) error

Mar 27, 2018

Changes in this version

type APIClient

+ ExtractPipeline func(ctx context.Context, in *ExtractPipelineRequest, opts ...grpc.CallOption) (*Op, error)

+ InspectCluster func(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*ClusterInfo, error)

type APIServer

+ ExtractPipeline func(context.Context, *ExtractPipelineRequest) (*Op, error)

+ InspectCluster func(context.Context, *google_protobuf.Empty) (*ClusterInfo, error)

+ type ClusterInfo struct

+ ID string

+ func (*ClusterInfo) Descriptor() ([]byte, []int)

+ func (*ClusterInfo) ProtoMessage()

+ func (m *ClusterInfo) GetID() string

+ func (m *ClusterInfo) Marshal() (dAtA []byte, err error)

+ func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterInfo) Reset()

+ func (m *ClusterInfo) Size() (n int)

+ func (m *ClusterInfo) String() string

+ func (m *ClusterInfo) Unmarshal(dAtA []byte) error

+ type ExtractPipelineRequest struct

+ Pipeline *pps.Pipeline

+ func (*ExtractPipelineRequest) Descriptor() ([]byte, []int)

+ func (*ExtractPipelineRequest) ProtoMessage()

+ func (m *ExtractPipelineRequest) GetPipeline() *pps.Pipeline

+ func (m *ExtractPipelineRequest) Marshal() (dAtA []byte, err error)

+ func (m *ExtractPipelineRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExtractPipelineRequest) Reset()

+ func (m *ExtractPipelineRequest) Size() (n int)

+ func (m *ExtractPipelineRequest) String() string

+ func (m *ExtractPipelineRequest) Unmarshal(dAtA []byte) error

Feb 27, 2018

Changes in this version

+ var ErrIntOverflowAdmin = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthAdmin = fmt.Errorf("proto: negative length found during unmarshaling")

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

+ type APIClient interface

+ Extract func(ctx context.Context, in *ExtractRequest, opts ...grpc.CallOption) (API_ExtractClient, error)

+ Restore func(ctx context.Context, opts ...grpc.CallOption) (API_RestoreClient, error)

+ func NewAPIClient(cc *grpc.ClientConn) APIClient

+ type APIServer interface

+ Extract func(*ExtractRequest, API_ExtractServer) error

+ Restore func(API_RestoreServer) error

+ type API_ExtractClient interface

+ Recv func() (*Op, error)

+ type API_ExtractServer interface

+ Send func(*Op) error

+ type API_RestoreClient interface

+ CloseAndRecv func() (*google_protobuf.Empty, error)

+ Send func(*RestoreRequest) error

+ type API_RestoreServer interface

+ Recv func() (*RestoreRequest, error)

+ SendAndClose func(*google_protobuf.Empty) error

+ type ExtractRequest struct

+ NoObjects bool

+ NoPipelines bool

+ NoRepos bool

+ URL string

+ func (*ExtractRequest) Descriptor() ([]byte, []int)

+ func (*ExtractRequest) ProtoMessage()

+ func (m *ExtractRequest) GetNoObjects() bool

+ func (m *ExtractRequest) GetNoPipelines() bool

+ func (m *ExtractRequest) GetNoRepos() bool

+ func (m *ExtractRequest) GetURL() string

+ func (m *ExtractRequest) Marshal() (dAtA []byte, err error)

+ func (m *ExtractRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExtractRequest) Reset()

+ func (m *ExtractRequest) Size() (n int)

+ func (m *ExtractRequest) String() string

+ func (m *ExtractRequest) Unmarshal(dAtA []byte) error

+ type Op struct

+ Op1_7 *Op1_7

+ func (*Op) Descriptor() ([]byte, []int)

+ func (*Op) ProtoMessage()

+ func (m *Op) GetOp1_7() *Op1_7

+ func (m *Op) Marshal() (dAtA []byte, err error)

+ func (m *Op) MarshalTo(dAtA []byte) (int, error)

+ func (m *Op) Reset()

+ func (m *Op) Size() (n int)

+ func (m *Op) String() string

+ func (m *Op) Unmarshal(dAtA []byte) error

+ type Op1_7 struct

+ Branch *pfs.SetBranchRequest

+ Commit *pfs.BuildCommitRequest

+ Object *pfs.PutObjectRequest

+ Pipeline *pps.CreatePipelineRequest

+ Repo *pfs.CreateRepoRequest

+ Tag *pfs.TagObjectRequest

+ func (*Op1_7) Descriptor() ([]byte, []int)

+ func (*Op1_7) ProtoMessage()

+ func (m *Op1_7) GetBranch() *pfs.SetBranchRequest

+ func (m *Op1_7) GetCommit() *pfs.BuildCommitRequest

+ func (m *Op1_7) GetObject() *pfs.PutObjectRequest

+ func (m *Op1_7) GetPipeline() *pps.CreatePipelineRequest

+ func (m *Op1_7) GetRepo() *pfs.CreateRepoRequest

+ func (m *Op1_7) GetTag() *pfs.TagObjectRequest

+ func (m *Op1_7) Marshal() (dAtA []byte, err error)

+ func (m *Op1_7) MarshalTo(dAtA []byte) (int, error)

+ func (m *Op1_7) Reset()

+ func (m *Op1_7) Size() (n int)

+ func (m *Op1_7) String() string

+ func (m *Op1_7) Unmarshal(dAtA []byte) error

+ type RestoreRequest struct

+ Op *Op

+ URL string

+ func (*RestoreRequest) Descriptor() ([]byte, []int)

+ func (*RestoreRequest) ProtoMessage()

+ func (m *RestoreRequest) GetOp() *Op

+ func (m *RestoreRequest) GetURL() string

+ func (m *RestoreRequest) Marshal() (dAtA []byte, err error)

+ func (m *RestoreRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RestoreRequest) Reset()

+ func (m *RestoreRequest) Size() (n int)

+ func (m *RestoreRequest) String() string

+ func (m *RestoreRequest) Unmarshal(dAtA []byte) error