Documentation
¶
Overview ¶
Package admin is a generated protocol buffer package.
It is generated from these files:
client/admin/admin.proto
It has these top-level messages:
Op1_7 Op ExtractRequest RestoreRequest
Index ¶
- Variables
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- type APIClient
- type APIServer
- type API_ExtractClient
- type API_ExtractServer
- type API_RestoreClient
- type API_RestoreServer
- type ExtractRequest
- func (*ExtractRequest) Descriptor() ([]byte, []int)
- 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 (*ExtractRequest) ProtoMessage()
- func (m *ExtractRequest) Reset()
- func (m *ExtractRequest) Size() (n int)
- func (m *ExtractRequest) String() string
- func (m *ExtractRequest) Unmarshal(dAtA []byte) error
- type Op
- func (*Op) Descriptor() ([]byte, []int)
- func (m *Op) GetOp1_7() *Op1_7
- func (m *Op) Marshal() (dAtA []byte, err error)
- func (m *Op) MarshalTo(dAtA []byte) (int, error)
- func (*Op) ProtoMessage()
- 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
- func (*Op1_7) Descriptor() ([]byte, []int)
- 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 (*Op1_7) ProtoMessage()
- 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
- func (*RestoreRequest) Descriptor() ([]byte, []int)
- 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 (*RestoreRequest) ProtoMessage()
- func (m *RestoreRequest) Reset()
- func (m *RestoreRequest) Size() (n int)
- func (m *RestoreRequest) String() string
- func (m *RestoreRequest) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthAdmin = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAdmin = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterAPIServer ¶
Types ¶
type APIClient ¶
type APIClient interface {
Extract(ctx context.Context, in *ExtractRequest, opts ...grpc.CallOption) (API_ExtractClient, error)
Restore(ctx context.Context, opts ...grpc.CallOption) (API_RestoreClient, error)
}
func NewAPIClient ¶
func NewAPIClient(cc *grpc.ClientConn) APIClient
type APIServer ¶
type APIServer interface {
Extract(*ExtractRequest, API_ExtractServer) error
Restore(API_RestoreServer) error
}
type API_ExtractClient ¶
type API_ExtractClient interface {
Recv() (*Op, error)
grpc.ClientStream
}
type API_ExtractServer ¶
type API_ExtractServer interface {
Send(*Op) error
grpc.ServerStream
}
type API_RestoreClient ¶
type API_RestoreClient interface {
Send(*RestoreRequest) error
CloseAndRecv() (*google_protobuf.Empty, error)
grpc.ClientStream
}
type API_RestoreServer ¶
type API_RestoreServer interface {
SendAndClose(*google_protobuf.Empty) error
Recv() (*RestoreRequest, error)
grpc.ServerStream
}
type ExtractRequest ¶
type ExtractRequest struct {
// URL is an object storage URL, if it's not "" data will be extracted to
// this URL rather than returned.
URL string `protobuf:"bytes,1,opt,name=URL,proto3" json:"URL,omitempty"`
// NoObjects, if true, will cause extract to omit objects (and tags)
NoObjects bool `protobuf:"varint,2,opt,name=no_objects,json=noObjects,proto3" json:"no_objects,omitempty"`
// NoRepos, if true, will cause extract to omit repos, commits and branches.
NoRepos bool `protobuf:"varint,3,opt,name=no_repos,json=noRepos,proto3" json:"no_repos,omitempty"`
// NoPipelines, if true, will cause extract to omit pipelines.
NoPipelines bool `protobuf:"varint,4,opt,name=no_pipelines,json=noPipelines,proto3" json:"no_pipelines,omitempty"`
}
func (*ExtractRequest) Descriptor ¶
func (*ExtractRequest) Descriptor() ([]byte, []int)
func (*ExtractRequest) GetNoObjects ¶
func (m *ExtractRequest) GetNoObjects() bool
func (*ExtractRequest) GetNoPipelines ¶
func (m *ExtractRequest) GetNoPipelines() bool
func (*ExtractRequest) GetNoRepos ¶
func (m *ExtractRequest) GetNoRepos() bool
func (*ExtractRequest) GetURL ¶
func (m *ExtractRequest) GetURL() string
func (*ExtractRequest) Marshal ¶
func (m *ExtractRequest) Marshal() (dAtA []byte, err error)
func (*ExtractRequest) ProtoMessage ¶
func (*ExtractRequest) ProtoMessage()
func (*ExtractRequest) Reset ¶
func (m *ExtractRequest) Reset()
func (*ExtractRequest) Size ¶
func (m *ExtractRequest) Size() (n int)
func (*ExtractRequest) String ¶
func (m *ExtractRequest) String() string
func (*ExtractRequest) Unmarshal ¶
func (m *ExtractRequest) Unmarshal(dAtA []byte) error
type Op ¶
type Op struct {
Op1_7 *Op1_7 `protobuf:"bytes,1,opt,name=op1_7,json=op17" json:"op1_7,omitempty"`
}
func (*Op) Descriptor ¶
func (*Op) ProtoMessage ¶
func (*Op) ProtoMessage()
type Op1_7 ¶
type Op1_7 struct {
Object *pfs.PutObjectRequest `protobuf:"bytes,2,opt,name=object" json:"object,omitempty"`
Tag *pfs.TagObjectRequest `protobuf:"bytes,3,opt,name=tag" json:"tag,omitempty"`
Repo *pfs.CreateRepoRequest `protobuf:"bytes,4,opt,name=repo" json:"repo,omitempty"`
Commit *pfs.BuildCommitRequest `protobuf:"bytes,5,opt,name=commit" json:"commit,omitempty"`
Branch *pfs.SetBranchRequest `protobuf:"bytes,6,opt,name=branch" json:"branch,omitempty"`
Pipeline *pps.CreatePipelineRequest `protobuf:"bytes,7,opt,name=pipeline" json:"pipeline,omitempty"`
}
func (*Op1_7) Descriptor ¶
func (*Op1_7) GetBranch ¶
func (m *Op1_7) GetBranch() *pfs.SetBranchRequest
func (*Op1_7) GetCommit ¶
func (m *Op1_7) GetCommit() *pfs.BuildCommitRequest
func (*Op1_7) GetObject ¶
func (m *Op1_7) GetObject() *pfs.PutObjectRequest
func (*Op1_7) GetPipeline ¶
func (m *Op1_7) GetPipeline() *pps.CreatePipelineRequest
func (*Op1_7) GetRepo ¶
func (m *Op1_7) GetRepo() *pfs.CreateRepoRequest
func (*Op1_7) GetTag ¶
func (m *Op1_7) GetTag() *pfs.TagObjectRequest
func (*Op1_7) ProtoMessage ¶
func (*Op1_7) ProtoMessage()
type RestoreRequest ¶
type RestoreRequest struct {
Op *Op `protobuf:"bytes,1,opt,name=op" json:"op,omitempty"`
// URL is an object storage URL, if it's not "" data will be restored from
// this URL.
URL string `protobuf:"bytes,2,opt,name=URL,proto3" json:"URL,omitempty"`
}
func (*RestoreRequest) Descriptor ¶
func (*RestoreRequest) Descriptor() ([]byte, []int)
func (*RestoreRequest) GetOp ¶
func (m *RestoreRequest) GetOp() *Op
func (*RestoreRequest) GetURL ¶
func (m *RestoreRequest) GetURL() string
func (*RestoreRequest) Marshal ¶
func (m *RestoreRequest) Marshal() (dAtA []byte, err error)
func (*RestoreRequest) ProtoMessage ¶
func (*RestoreRequest) ProtoMessage()
func (*RestoreRequest) Reset ¶
func (m *RestoreRequest) Reset()
func (*RestoreRequest) Size ¶
func (m *RestoreRequest) Size() (n int)
func (*RestoreRequest) String ¶
func (m *RestoreRequest) String() string
func (*RestoreRequest) Unmarshal ¶
func (m *RestoreRequest) Unmarshal(dAtA []byte) error
Click to show internal directories.
Click to hide internal directories.