pachyderm: github.com/pachyderm/pachyderm/src/client/admin Index | Files | Directories

package admin

import "github.com/pachyderm/pachyderm/src/client/admin"

Index

Package Files

admin.pb.go

Variables

var (
    ErrInvalidLengthAdmin = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowAdmin   = fmt.Errorf("proto: integer overflow")
)

func RegisterAPIServer Uses

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

type APIClient Uses

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 Uses

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer Uses

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 Uses

type API_ExtractClient interface {
    Recv() (*Op, error)
    grpc.ClientStream
}

type API_ExtractServer Uses

type API_ExtractServer interface {
    Send(*Op) error
    grpc.ServerStream
}

type API_RestoreClient Uses

type API_RestoreClient interface {
    Send(*RestoreRequest) error
    CloseAndRecv() (*types.Empty, error)
    grpc.ClientStream
}

type API_RestoreServer Uses

type API_RestoreServer interface {
    SendAndClose(*types.Empty) error
    Recv() (*RestoreRequest, error)
    grpc.ServerStream
}

type ClusterInfo Uses

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 Uses

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

func (*ClusterInfo) GetID Uses

func (m *ClusterInfo) GetID() string

func (*ClusterInfo) Marshal Uses

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

func (*ClusterInfo) MarshalTo Uses

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

func (*ClusterInfo) ProtoMessage Uses

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) Reset Uses

func (m *ClusterInfo) Reset()

func (*ClusterInfo) Size Uses

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

func (*ClusterInfo) String Uses

func (m *ClusterInfo) String() string

func (*ClusterInfo) Unmarshal Uses

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

func (*ClusterInfo) XXX_DiscardUnknown Uses

func (m *ClusterInfo) XXX_DiscardUnknown()

func (*ClusterInfo) XXX_Marshal Uses

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

func (*ClusterInfo) XXX_Merge Uses

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

func (*ClusterInfo) XXX_Size Uses

func (m *ClusterInfo) XXX_Size() int

func (*ClusterInfo) XXX_Unmarshal Uses

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

type ExtractPipelineRequest Uses

type ExtractPipelineRequest struct {
    Pipeline             *pps2.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 Uses

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

func (*ExtractPipelineRequest) GetPipeline Uses

func (m *ExtractPipelineRequest) GetPipeline() *pps2.Pipeline

func (*ExtractPipelineRequest) Marshal Uses

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

func (*ExtractPipelineRequest) MarshalTo Uses

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

func (*ExtractPipelineRequest) ProtoMessage Uses

func (*ExtractPipelineRequest) ProtoMessage()

func (*ExtractPipelineRequest) Reset Uses

func (m *ExtractPipelineRequest) Reset()

func (*ExtractPipelineRequest) Size Uses

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

func (*ExtractPipelineRequest) String Uses

func (m *ExtractPipelineRequest) String() string

func (*ExtractPipelineRequest) Unmarshal Uses

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

func (*ExtractPipelineRequest) XXX_DiscardUnknown Uses

func (m *ExtractPipelineRequest) XXX_DiscardUnknown()

func (*ExtractPipelineRequest) XXX_Marshal Uses

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

func (*ExtractPipelineRequest) XXX_Merge Uses

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

func (*ExtractPipelineRequest) XXX_Size Uses

func (m *ExtractPipelineRequest) XXX_Size() int

func (*ExtractPipelineRequest) XXX_Unmarshal Uses

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

type ExtractRequest Uses

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 Uses

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

func (*ExtractRequest) GetNoObjects Uses

func (m *ExtractRequest) GetNoObjects() bool

func (*ExtractRequest) GetNoPipelines Uses

func (m *ExtractRequest) GetNoPipelines() bool

func (*ExtractRequest) GetNoRepos Uses

func (m *ExtractRequest) GetNoRepos() bool

func (*ExtractRequest) GetURL Uses

func (m *ExtractRequest) GetURL() string

func (*ExtractRequest) Marshal Uses

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

func (*ExtractRequest) MarshalTo Uses

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

func (*ExtractRequest) ProtoMessage Uses

func (*ExtractRequest) ProtoMessage()

func (*ExtractRequest) Reset Uses

func (m *ExtractRequest) Reset()

func (*ExtractRequest) Size Uses

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

func (*ExtractRequest) String Uses

func (m *ExtractRequest) String() string

func (*ExtractRequest) Unmarshal Uses

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

func (*ExtractRequest) XXX_DiscardUnknown Uses

func (m *ExtractRequest) XXX_DiscardUnknown()

func (*ExtractRequest) XXX_Marshal Uses

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

func (*ExtractRequest) XXX_Merge Uses

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

func (*ExtractRequest) XXX_Size Uses

func (m *ExtractRequest) XXX_Size() int

func (*ExtractRequest) XXX_Unmarshal Uses

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

type Op Uses

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"`
    Op1_9                *Op1_9   `protobuf:"bytes,3,opt,name=op1_9,json=op19,proto3" json:"op1_9,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Op) Descriptor Uses

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

func (*Op) GetOp1_7 Uses

func (m *Op) GetOp1_7() *Op1_7

func (*Op) GetOp1_8 Uses

func (m *Op) GetOp1_8() *Op1_8

func (*Op) GetOp1_9 Uses

func (m *Op) GetOp1_9() *Op1_9

func (*Op) Marshal Uses

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

func (*Op) MarshalTo Uses

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

func (*Op) ProtoMessage Uses

func (*Op) ProtoMessage()

func (*Op) Reset Uses

func (m *Op) Reset()

func (*Op) Size Uses

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

func (*Op) String Uses

func (m *Op) String() string

func (*Op) Unmarshal Uses

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

func (*Op) XXX_DiscardUnknown Uses

func (m *Op) XXX_DiscardUnknown()

func (*Op) XXX_Marshal Uses

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

func (*Op) XXX_Merge Uses

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

func (*Op) XXX_Size Uses

func (m *Op) XXX_Size() int

func (*Op) XXX_Unmarshal Uses

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

type Op1_7 Uses

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 Uses

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

func (*Op1_7) GetBranch Uses

func (m *Op1_7) GetBranch() *pfs.CreateBranchRequest

func (*Op1_7) GetCommit Uses

func (m *Op1_7) GetCommit() *pfs.BuildCommitRequest

func (*Op1_7) GetObject Uses

func (m *Op1_7) GetObject() *pfs.PutObjectRequest

func (*Op1_7) GetPipeline Uses

func (m *Op1_7) GetPipeline() *pps.CreatePipelineRequest

func (*Op1_7) GetRepo Uses

func (m *Op1_7) GetRepo() *pfs.CreateRepoRequest

func (*Op1_7) GetTag Uses

func (m *Op1_7) GetTag() *pfs.TagObjectRequest

func (*Op1_7) Marshal Uses

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

func (*Op1_7) MarshalTo Uses

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

func (*Op1_7) ProtoMessage Uses

func (*Op1_7) ProtoMessage()

func (*Op1_7) Reset Uses

func (m *Op1_7) Reset()

func (*Op1_7) Size Uses

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

func (*Op1_7) String Uses

func (m *Op1_7) String() string

func (*Op1_7) Unmarshal Uses

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

func (*Op1_7) XXX_DiscardUnknown Uses

func (m *Op1_7) XXX_DiscardUnknown()

func (*Op1_7) XXX_Marshal Uses

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

func (*Op1_7) XXX_Merge Uses

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

func (*Op1_7) XXX_Size Uses

func (m *Op1_7) XXX_Size() int

func (*Op1_7) XXX_Unmarshal Uses

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

type Op1_8 Uses

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 Uses

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

func (*Op1_8) GetBranch Uses

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

func (*Op1_8) GetCommit Uses

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

func (*Op1_8) GetObject Uses

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

func (*Op1_8) GetPipeline Uses

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

func (*Op1_8) GetRepo Uses

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

func (*Op1_8) GetTag Uses

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

func (*Op1_8) Marshal Uses

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

func (*Op1_8) MarshalTo Uses

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

func (*Op1_8) ProtoMessage Uses

func (*Op1_8) ProtoMessage()

func (*Op1_8) Reset Uses

func (m *Op1_8) Reset()

func (*Op1_8) Size Uses

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

func (*Op1_8) String Uses

func (m *Op1_8) String() string

func (*Op1_8) Unmarshal Uses

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

func (*Op1_8) XXX_DiscardUnknown Uses

func (m *Op1_8) XXX_DiscardUnknown()

func (*Op1_8) XXX_Marshal Uses

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

func (*Op1_8) XXX_Merge Uses

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

func (*Op1_8) XXX_Size Uses

func (m *Op1_8) XXX_Size() int

func (*Op1_8) XXX_Unmarshal Uses

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

type Op1_9 Uses

type Op1_9 struct {
    Object               *pfs2.PutObjectRequest      `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
    Tag                  *pfs2.TagObjectRequest      `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
    Repo                 *pfs2.CreateRepoRequest     `protobuf:"bytes,4,opt,name=repo,proto3" json:"repo,omitempty"`
    Commit               *pfs2.BuildCommitRequest    `protobuf:"bytes,5,opt,name=commit,proto3" json:"commit,omitempty"`
    Branch               *pfs2.CreateBranchRequest   `protobuf:"bytes,6,opt,name=branch,proto3" json:"branch,omitempty"`
    Pipeline             *pps2.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_9) Descriptor Uses

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

func (*Op1_9) GetBranch Uses

func (m *Op1_9) GetBranch() *pfs2.CreateBranchRequest

func (*Op1_9) GetCommit Uses

func (m *Op1_9) GetCommit() *pfs2.BuildCommitRequest

func (*Op1_9) GetObject Uses

func (m *Op1_9) GetObject() *pfs2.PutObjectRequest

func (*Op1_9) GetPipeline Uses

func (m *Op1_9) GetPipeline() *pps2.CreatePipelineRequest

func (*Op1_9) GetRepo Uses

func (m *Op1_9) GetRepo() *pfs2.CreateRepoRequest

func (*Op1_9) GetTag Uses

func (m *Op1_9) GetTag() *pfs2.TagObjectRequest

func (*Op1_9) Marshal Uses

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

func (*Op1_9) MarshalTo Uses

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

func (*Op1_9) ProtoMessage Uses

func (*Op1_9) ProtoMessage()

func (*Op1_9) Reset Uses

func (m *Op1_9) Reset()

func (*Op1_9) Size Uses

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

func (*Op1_9) String Uses

func (m *Op1_9) String() string

func (*Op1_9) Unmarshal Uses

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

func (*Op1_9) XXX_DiscardUnknown Uses

func (m *Op1_9) XXX_DiscardUnknown()

func (*Op1_9) XXX_Marshal Uses

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

func (*Op1_9) XXX_Merge Uses

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

func (*Op1_9) XXX_Size Uses

func (m *Op1_9) XXX_Size() int

func (*Op1_9) XXX_Unmarshal Uses

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

type RestoreRequest Uses

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 Uses

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

func (*RestoreRequest) GetOp Uses

func (m *RestoreRequest) GetOp() *Op

func (*RestoreRequest) GetURL Uses

func (m *RestoreRequest) GetURL() string

func (*RestoreRequest) Marshal Uses

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

func (*RestoreRequest) MarshalTo Uses

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

func (*RestoreRequest) ProtoMessage Uses

func (*RestoreRequest) ProtoMessage()

func (*RestoreRequest) Reset Uses

func (m *RestoreRequest) Reset()

func (*RestoreRequest) Size Uses

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

func (*RestoreRequest) String Uses

func (m *RestoreRequest) String() string

func (*RestoreRequest) Unmarshal Uses

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

func (*RestoreRequest) XXX_DiscardUnknown Uses

func (m *RestoreRequest) XXX_DiscardUnknown()

func (*RestoreRequest) XXX_Marshal Uses

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

func (*RestoreRequest) XXX_Merge Uses

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

func (*RestoreRequest) XXX_Size Uses

func (m *RestoreRequest) XXX_Size() int

func (*RestoreRequest) XXX_Unmarshal Uses

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

type UnimplementedAPIServer Uses

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) Extract Uses

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

func (*UnimplementedAPIServer) ExtractPipeline Uses

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

func (*UnimplementedAPIServer) InspectCluster Uses

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

func (*UnimplementedAPIServer) Restore Uses

func (*UnimplementedAPIServer) Restore(srv API_RestoreServer) error

Directories

PathSynopsis
1_7/auth
1_7/enterprise
1_7/hashtree
1_7/pfs
1_7/pps
1_8/auth
1_8/enterprise
1_8/pfs
1_8/pps

Package admin imports 17 packages (graph) and is imported by 5 packages. Updated 2019-06-14. Refresh now. Tools for package owners.