admin

package
v1.7.0-5a590ad9d8e9a09... Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

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
ClusterInfo

Index

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 

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

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

func (m *ExtractRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Op) GetOp1_7 

func (m *Op) GetOp1_7() *Op1_7

func (*Op) Marshal 

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

func (*Op) MarshalTo 

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

func (*Op) ProtoMessage 

func (*Op) ProtoMessage()

func (*Op) Reset 

func (m *Op) Reset()

func (*Op) Size 

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

func (*Op) String 

func (m *Op) String() string

func (*Op) Unmarshal 

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

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) Descriptor() ([]byte, []int)

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

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

func (*Op1_7) MarshalTo 

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

func (*Op1_7) ProtoMessage 

func (*Op1_7) ProtoMessage()

func (*Op1_7) Reset 

func (m *Op1_7) Reset()

func (*Op1_7) Size 

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

func (*Op1_7) String 

func (m *Op1_7) String() string

func (*Op1_7) Unmarshal 

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

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

func (m *RestoreRequest) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.