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 ExtractPipelineRequest RestoreRequest ClusterInfo
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 ClusterInfo
- func (*ClusterInfo) Descriptor() ([]byte, []int)
- func (m *ClusterInfo) GetID() string
- func (m *ClusterInfo) Marshal() (dAtA []byte, err error)
- func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterInfo) ProtoMessage()
- func (m *ClusterInfo) Reset()
- func (m *ClusterInfo) Size() (n int)
- func (m *ClusterInfo) String() string
- func (m *ClusterInfo) Unmarshal(dAtA []byte) error
- type ExtractPipelineRequest
- func (*ExtractPipelineRequest) Descriptor() ([]byte, []int)
- func (m *ExtractPipelineRequest) GetPipeline() *pps.Pipeline
- func (m *ExtractPipelineRequest) Marshal() (dAtA []byte, err error)
- func (m *ExtractPipelineRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ExtractPipelineRequest) ProtoMessage()
- func (m *ExtractPipelineRequest) Reset()
- func (m *ExtractPipelineRequest) Size() (n int)
- func (m *ExtractPipelineRequest) String() string
- func (m *ExtractPipelineRequest) Unmarshal(dAtA []byte) error
- 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.CreateBranchRequest
- 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)
ExtractPipeline(ctx context.Context, in *ExtractPipelineRequest, opts ...grpc.CallOption) (*Op, error)
Restore(ctx context.Context, opts ...grpc.CallOption) (API_RestoreClient, error)
InspectCluster(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*ClusterInfo, error)
}
func NewAPIClient ¶
func NewAPIClient(cc *grpc.ClientConn) APIClient
type APIServer ¶
type APIServer interface {
Extract(*ExtractRequest, API_ExtractServer) error
ExtractPipeline(context.Context, *ExtractPipelineRequest) (*Op, error)
Restore(API_RestoreServer) error
InspectCluster(context.Context, *google_protobuf.Empty) (*ClusterInfo, 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 ClusterInfo ¶ added in v1.7.0
type ClusterInfo struct {
ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*ClusterInfo) Descriptor ¶ added in v1.7.0
func (*ClusterInfo) Descriptor() ([]byte, []int)
func (*ClusterInfo) GetID ¶ added in v1.7.0
func (m *ClusterInfo) GetID() string
func (*ClusterInfo) Marshal ¶ added in v1.7.0
func (m *ClusterInfo) Marshal() (dAtA []byte, err error)
func (*ClusterInfo) MarshalTo ¶ added in v1.7.0
func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)
func (*ClusterInfo) ProtoMessage ¶ added in v1.7.0
func (*ClusterInfo) ProtoMessage()
func (*ClusterInfo) Reset ¶ added in v1.7.0
func (m *ClusterInfo) Reset()
func (*ClusterInfo) Size ¶ added in v1.7.0
func (m *ClusterInfo) Size() (n int)
func (*ClusterInfo) String ¶ added in v1.7.0
func (m *ClusterInfo) String() string
func (*ClusterInfo) Unmarshal ¶ added in v1.7.0
func (m *ClusterInfo) Unmarshal(dAtA []byte) error
type ExtractPipelineRequest ¶ added in v1.7.0
type ExtractPipelineRequest struct {
Pipeline *pps.Pipeline `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
}
func (*ExtractPipelineRequest) Descriptor ¶ added in v1.7.0
func (*ExtractPipelineRequest) Descriptor() ([]byte, []int)
func (*ExtractPipelineRequest) GetPipeline ¶ added in v1.7.0
func (m *ExtractPipelineRequest) GetPipeline() *pps.Pipeline
func (*ExtractPipelineRequest) Marshal ¶ added in v1.7.0
func (m *ExtractPipelineRequest) Marshal() (dAtA []byte, err error)
func (*ExtractPipelineRequest) MarshalTo ¶ added in v1.7.0
func (m *ExtractPipelineRequest) MarshalTo(dAtA []byte) (int, error)
func (*ExtractPipelineRequest) ProtoMessage ¶ added in v1.7.0
func (*ExtractPipelineRequest) ProtoMessage()
func (*ExtractPipelineRequest) Reset ¶ added in v1.7.0
func (m *ExtractPipelineRequest) Reset()
func (*ExtractPipelineRequest) Size ¶ added in v1.7.0
func (m *ExtractPipelineRequest) Size() (n int)
func (*ExtractPipelineRequest) String ¶ added in v1.7.0
func (m *ExtractPipelineRequest) String() string
func (*ExtractPipelineRequest) Unmarshal ¶ added in v1.7.0
func (m *ExtractPipelineRequest) Unmarshal(dAtA []byte) error
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.CreateBranchRequest `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.CreateBranchRequest
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.