admin

package
Version: v1.7.12 Latest Latest
Warning

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

Go to latest
Published: May 2, 2019 License: Apache-2.0 Imports: 10 Imported by: 9

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

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"`
	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) 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 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

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL