admin

package
v1.8.8 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

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)
	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 *types.Empty, opts ...grpc.CallOption) (*ClusterInfo, error)
}

APIClient is the client API for API service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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, *types.Empty) (*ClusterInfo, error)
}

APIServer is the server API for API service.

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() (*types.Empty, error)
	grpc.ClientStream
}

type API_RestoreServer 

type API_RestoreServer interface {
	SendAndClose(*types.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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ClusterInfo) XXX_DiscardUnknown added in v1.7.12 

func (m *ClusterInfo) XXX_DiscardUnknown()

func (*ClusterInfo) XXX_Marshal added in v1.7.12 

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

func (*ClusterInfo) XXX_Merge added in v1.7.12 

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

func (*ClusterInfo) XXX_Size added in v1.7.12 

func (m *ClusterInfo) XXX_Size() int

func (*ClusterInfo) XXX_Unmarshal added in v1.7.12 

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

type ExtractPipelineRequest added in v1.7.0 

type ExtractPipelineRequest struct {
	Pipeline             *pps1.Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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() *pps1.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

func (*ExtractPipelineRequest) XXX_DiscardUnknown added in v1.7.12 

func (m *ExtractPipelineRequest) XXX_DiscardUnknown()

func (*ExtractPipelineRequest) XXX_Marshal added in v1.7.12 

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

func (*ExtractPipelineRequest) XXX_Merge added in v1.7.12 

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

func (*ExtractPipelineRequest) XXX_Size added in v1.7.12 

func (m *ExtractPipelineRequest) XXX_Size() int

func (*ExtractPipelineRequest) XXX_Unmarshal added in v1.7.12 

func (m *ExtractPipelineRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ExtractRequest) XXX_DiscardUnknown added in v1.7.12 

func (m *ExtractRequest) XXX_DiscardUnknown()

func (*ExtractRequest) XXX_Marshal added in v1.7.12 

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

func (*ExtractRequest) XXX_Merge added in v1.7.12 

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

func (*ExtractRequest) XXX_Size added in v1.7.12 

func (m *ExtractRequest) XXX_Size() int

func (*ExtractRequest) XXX_Unmarshal added in v1.7.12 

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

type Op 

type Op struct {
	Op1_7                *Op1_7   `protobuf:"bytes,1,opt,name=op1_7,json=op17,proto3" json:"op1_7,omitempty"`
	Op1_8                *Op1_8   `protobuf:"bytes,2,opt,name=op1_8,json=op18,proto3" json:"op1_8,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Op) Descriptor 

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

func (*Op) GetOp1_7 

func (m *Op) GetOp1_7() *Op1_7

func (*Op) GetOp1_8 added in v1.8.1 

func (m *Op) GetOp1_8() *Op1_8

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

func (*Op) XXX_DiscardUnknown added in v1.7.12 

func (m *Op) XXX_DiscardUnknown()

func (*Op) XXX_Marshal added in v1.7.12 

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

func (*Op) XXX_Merge added in v1.7.12 

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

func (*Op) XXX_Size added in v1.7.12 

func (m *Op) XXX_Size() int

func (*Op) XXX_Unmarshal added in v1.7.12 

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

type Op1_7 

type Op1_7 struct {
	Object               *pfs.PutObjectRequest      `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	Tag                  *pfs.TagObjectRequest      `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
	Repo                 *pfs.CreateRepoRequest     `protobuf:"bytes,4,opt,name=repo,proto3" json:"repo,omitempty"`
	Commit               *pfs.BuildCommitRequest    `protobuf:"bytes,5,opt,name=commit,proto3" json:"commit,omitempty"`
	Branch               *pfs.CreateBranchRequest   `protobuf:"bytes,6,opt,name=branch,proto3" json:"branch,omitempty"`
	Pipeline             *pps.CreatePipelineRequest `protobuf:"bytes,7,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

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

func (*Op1_7) XXX_DiscardUnknown added in v1.7.12 

func (m *Op1_7) XXX_DiscardUnknown()

func (*Op1_7) XXX_Marshal added in v1.7.12 

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

func (*Op1_7) XXX_Merge added in v1.7.12 

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

func (*Op1_7) XXX_Size added in v1.7.12 

func (m *Op1_7) XXX_Size() int

func (*Op1_7) XXX_Unmarshal added in v1.7.12 

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

type Op1_8 added in v1.8.1 

type Op1_8 struct {
	Object               *pfs1.PutObjectRequest      `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	Tag                  *pfs1.TagObjectRequest      `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
	Repo                 *pfs1.CreateRepoRequest     `protobuf:"bytes,4,opt,name=repo,proto3" json:"repo,omitempty"`
	Commit               *pfs1.BuildCommitRequest    `protobuf:"bytes,5,opt,name=commit,proto3" json:"commit,omitempty"`
	Branch               *pfs1.CreateBranchRequest   `protobuf:"bytes,6,opt,name=branch,proto3" json:"branch,omitempty"`
	Pipeline             *pps1.CreatePipelineRequest `protobuf:"bytes,7,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*Op1_8) Descriptor added in v1.8.1 

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

func (*Op1_8) GetBranch added in v1.8.1 

func (m *Op1_8) GetBranch() *pfs1.CreateBranchRequest

func (*Op1_8) GetCommit added in v1.8.1 

func (m *Op1_8) GetCommit() *pfs1.BuildCommitRequest

func (*Op1_8) GetObject added in v1.8.1 

func (m *Op1_8) GetObject() *pfs1.PutObjectRequest

func (*Op1_8) GetPipeline added in v1.8.1 

func (m *Op1_8) GetPipeline() *pps1.CreatePipelineRequest

func (*Op1_8) GetRepo added in v1.8.1 

func (m *Op1_8) GetRepo() *pfs1.CreateRepoRequest

func (*Op1_8) GetTag added in v1.8.1 

func (m *Op1_8) GetTag() *pfs1.TagObjectRequest

func (*Op1_8) Marshal added in v1.8.1 

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

func (*Op1_8) MarshalTo added in v1.8.1 

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

func (*Op1_8) ProtoMessage added in v1.8.1 

func (*Op1_8) ProtoMessage()

func (*Op1_8) Reset added in v1.8.1 

func (m *Op1_8) Reset()

func (*Op1_8) Size added in v1.8.1 

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

func (*Op1_8) String added in v1.8.1 

func (m *Op1_8) String() string

func (*Op1_8) Unmarshal added in v1.8.1 

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

func (*Op1_8) XXX_DiscardUnknown added in v1.8.1 

func (m *Op1_8) XXX_DiscardUnknown()

func (*Op1_8) XXX_Marshal added in v1.8.1 

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

func (*Op1_8) XXX_Merge added in v1.8.1 

func (m *Op1_8) XXX_Merge(src proto.Message)

func (*Op1_8) XXX_Size added in v1.8.1 

func (m *Op1_8) XXX_Size() int

func (*Op1_8) XXX_Unmarshal added in v1.8.1 

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

type RestoreRequest 

type RestoreRequest struct {
	Op *Op `protobuf:"bytes,1,opt,name=op,proto3" 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*RestoreRequest) XXX_DiscardUnknown added in v1.7.12 

func (m *RestoreRequest) XXX_DiscardUnknown()

func (*RestoreRequest) XXX_Marshal added in v1.7.12 

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

func (*RestoreRequest) XXX_Merge added in v1.7.12 

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

func (*RestoreRequest) XXX_Size added in v1.7.12 

func (m *RestoreRequest) XXX_Size() int

func (*RestoreRequest) XXX_Unmarshal added in v1.7.12 

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

type UnimplementedAPIServer added in v1.8.7 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) Extract added in v1.8.7 

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

func (*UnimplementedAPIServer) ExtractPipeline added in v1.8.7 

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

func (*UnimplementedAPIServer) InspectCluster added in v1.8.7 

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

func (*UnimplementedAPIServer) Restore added in v1.8.7 

func (*UnimplementedAPIServer) Restore(srv API_RestoreServer) error

Source Files

View all Source files

Directories

Path Synopsis
1_7
auth
enterprise
hashtree
pfs
pps

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.