import "github.com/pachyderm/pachyderm/src/server/pkg/deploy"
const DevVersionTag = "local"
DevVersionTag is used to specify and detect that we're using a non-released version of a pachd image
var ( ErrInvalidLengthDeploy = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDeploy = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupDeploy = fmt.Errorf("proto: unexpected end of group") )
type APIClient interface { CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*types.Empty, error) UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*types.Empty, error) InspectCluster(ctx context.Context, in *InspectClusterRequest, opts ...grpc.CallOption) (*ClusterInfo, error) ListCluster(ctx context.Context, in *ListClusterRequest, opts ...grpc.CallOption) (*ClusterInfos, error) DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*types.Empty, 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(cc *grpc.ClientConn) APIClient
type APIServer interface { CreateCluster(context.Context, *CreateClusterRequest) (*types.Empty, error) UpdateCluster(context.Context, *UpdateClusterRequest) (*types.Empty, error) InspectCluster(context.Context, *InspectClusterRequest) (*ClusterInfo, error) ListCluster(context.Context, *ListClusterRequest) (*ClusterInfos, error) DeleteCluster(context.Context, *DeleteClusterRequest) (*types.Empty, error) }
APIServer is the server API for API service.
type Cluster struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
type ClusterInfo struct { Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` Shards uint64 `protobuf:"varint,2,opt,name=shards,proto3" json:"shards,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterInfo) Descriptor() ([]byte, []int)
func (m *ClusterInfo) GetCluster() *Cluster
func (m *ClusterInfo) GetShards() uint64
func (m *ClusterInfo) Marshal() (dAtA []byte, err error)
func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)
func (m *ClusterInfo) MarshalToSizedBuffer(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
func (m *ClusterInfo) XXX_DiscardUnknown()
func (m *ClusterInfo) XXX_Merge(src proto.Message)
func (m *ClusterInfo) XXX_Size() int
func (m *ClusterInfo) XXX_Unmarshal(b []byte) error
type ClusterInfos struct { ClusterInfos []*ClusterInfo `protobuf:"bytes,1,rep,name=cluster_infos,json=clusterInfos,proto3" json:"cluster_infos,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterInfos) Descriptor() ([]byte, []int)
func (m *ClusterInfos) GetClusterInfos() []*ClusterInfo
func (m *ClusterInfos) Marshal() (dAtA []byte, err error)
func (m *ClusterInfos) MarshalTo(dAtA []byte) (int, error)
func (m *ClusterInfos) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterInfos) ProtoMessage()
func (m *ClusterInfos) Reset()
func (m *ClusterInfos) Size() (n int)
func (m *ClusterInfos) String() string
func (m *ClusterInfos) Unmarshal(dAtA []byte) error
func (m *ClusterInfos) XXX_DiscardUnknown()
func (m *ClusterInfos) XXX_Merge(src proto.Message)
func (m *ClusterInfos) XXX_Size() int
func (m *ClusterInfos) XXX_Unmarshal(b []byte) error
type CreateClusterRequest struct { Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` Shards uint64 `protobuf:"varint,2,opt,name=shards,proto3" json:"shards,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateClusterRequest) Descriptor() ([]byte, []int)
func (m *CreateClusterRequest) GetCluster() *Cluster
func (m *CreateClusterRequest) GetShards() uint64
func (m *CreateClusterRequest) Marshal() (dAtA []byte, err error)
func (m *CreateClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (m *CreateClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateClusterRequest) ProtoMessage()
func (m *CreateClusterRequest) Reset()
func (m *CreateClusterRequest) Size() (n int)
func (m *CreateClusterRequest) String() string
func (m *CreateClusterRequest) Unmarshal(dAtA []byte) error
func (m *CreateClusterRequest) XXX_DiscardUnknown()
func (m *CreateClusterRequest) XXX_Merge(src proto.Message)
func (m *CreateClusterRequest) XXX_Size() int
func (m *CreateClusterRequest) XXX_Unmarshal(b []byte) error
type DeleteClusterRequest struct { Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteClusterRequest) Descriptor() ([]byte, []int)
func (m *DeleteClusterRequest) GetCluster() *Cluster
func (m *DeleteClusterRequest) Marshal() (dAtA []byte, err error)
func (m *DeleteClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (m *DeleteClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeleteClusterRequest) ProtoMessage()
func (m *DeleteClusterRequest) Reset()
func (m *DeleteClusterRequest) Size() (n int)
func (m *DeleteClusterRequest) String() string
func (m *DeleteClusterRequest) Unmarshal(dAtA []byte) error
func (m *DeleteClusterRequest) XXX_DiscardUnknown()
func (m *DeleteClusterRequest) XXX_Merge(src proto.Message)
func (m *DeleteClusterRequest) XXX_Size() int
func (m *DeleteClusterRequest) XXX_Unmarshal(b []byte) error
type InspectClusterRequest struct { Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InspectClusterRequest) Descriptor() ([]byte, []int)
func (m *InspectClusterRequest) GetCluster() *Cluster
func (m *InspectClusterRequest) Marshal() (dAtA []byte, err error)
func (m *InspectClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (m *InspectClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InspectClusterRequest) ProtoMessage()
func (m *InspectClusterRequest) Reset()
func (m *InspectClusterRequest) Size() (n int)
func (m *InspectClusterRequest) String() string
func (m *InspectClusterRequest) Unmarshal(dAtA []byte) error
func (m *InspectClusterRequest) XXX_DiscardUnknown()
func (m *InspectClusterRequest) XXX_Merge(src proto.Message)
func (m *InspectClusterRequest) XXX_Size() int
func (m *InspectClusterRequest) XXX_Unmarshal(b []byte) error
type KubeEndpoint struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*KubeEndpoint) Descriptor() ([]byte, []int)
func (m *KubeEndpoint) GetHost() string
func (m *KubeEndpoint) Marshal() (dAtA []byte, err error)
func (m *KubeEndpoint) MarshalTo(dAtA []byte) (int, error)
func (m *KubeEndpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubeEndpoint) ProtoMessage()
func (m *KubeEndpoint) Reset()
func (m *KubeEndpoint) Size() (n int)
func (m *KubeEndpoint) String() string
func (m *KubeEndpoint) Unmarshal(dAtA []byte) error
func (m *KubeEndpoint) XXX_DiscardUnknown()
func (m *KubeEndpoint) XXX_Merge(src proto.Message)
func (m *KubeEndpoint) XXX_Size() int
func (m *KubeEndpoint) XXX_Unmarshal(b []byte) error
type ListClusterRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListClusterRequest) Descriptor() ([]byte, []int)
func (m *ListClusterRequest) Marshal() (dAtA []byte, err error)
func (m *ListClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (m *ListClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListClusterRequest) ProtoMessage()
func (m *ListClusterRequest) Reset()
func (m *ListClusterRequest) Size() (n int)
func (m *ListClusterRequest) String() string
func (m *ListClusterRequest) Unmarshal(dAtA []byte) error
func (m *ListClusterRequest) XXX_DiscardUnknown()
func (m *ListClusterRequest) XXX_Merge(src proto.Message)
func (m *ListClusterRequest) XXX_Size() int
func (m *ListClusterRequest) XXX_Unmarshal(b []byte) error
type UnimplementedAPIServer struct { }
UnimplementedAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedAPIServer) CreateCluster(ctx context.Context, req *CreateClusterRequest) (*types.Empty, error)
func (*UnimplementedAPIServer) DeleteCluster(ctx context.Context, req *DeleteClusterRequest) (*types.Empty, error)
func (*UnimplementedAPIServer) InspectCluster(ctx context.Context, req *InspectClusterRequest) (*ClusterInfo, error)
func (*UnimplementedAPIServer) ListCluster(ctx context.Context, req *ListClusterRequest) (*ClusterInfos, error)
func (*UnimplementedAPIServer) UpdateCluster(ctx context.Context, req *UpdateClusterRequest) (*types.Empty, error)
type UpdateClusterRequest struct { Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"` Nodes uint64 `protobuf:"varint,2,opt,name=nodes,proto3" json:"nodes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateClusterRequest) Descriptor() ([]byte, []int)
func (m *UpdateClusterRequest) GetCluster() *Cluster
func (m *UpdateClusterRequest) GetNodes() uint64
func (m *UpdateClusterRequest) Marshal() (dAtA []byte, err error)
func (m *UpdateClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (m *UpdateClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateClusterRequest) ProtoMessage()
func (m *UpdateClusterRequest) Reset()
func (m *UpdateClusterRequest) Size() (n int)
func (m *UpdateClusterRequest) String() string
func (m *UpdateClusterRequest) Unmarshal(dAtA []byte) error
func (m *UpdateClusterRequest) XXX_DiscardUnknown()
func (m *UpdateClusterRequest) XXX_Merge(src proto.Message)
func (m *UpdateClusterRequest) XXX_Size() int
func (m *UpdateClusterRequest) XXX_Unmarshal(b []byte) error
Path | Synopsis |
---|---|
assets | |
cmds | |
images |
Package deploy imports 10 packages (graph) and is imported by 1 packages. Updated 2021-01-21. Refresh now. Tools for package owners.