Documentation ¶
Overview ¶
Package deploy is a generated protocol buffer package.
It is generated from these files:
server/pkg/deploy/deploy.proto
It has these top-level messages:
KubeEndpoint Cluster ClusterInfo ClusterInfos CreateClusterRequest UpdateClusterRequest InspectClusterRequest ListClusterRequest DeleteClusterRequest
Index ¶
- Constants
- Variables
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- type APIClient
- type APIServer
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)
- func (m *Cluster) GetName() string
- func (m *Cluster) Marshal() (dAtA []byte, err error)
- func (m *Cluster) MarshalTo(dAtA []byte) (int, error)
- func (*Cluster) ProtoMessage()
- func (m *Cluster) Reset()
- func (m *Cluster) Size() (n int)
- func (m *Cluster) String() string
- func (m *Cluster) Unmarshal(dAtA []byte) error
- type ClusterInfo
- 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 (*ClusterInfo) ProtoMessage()
- func (m *ClusterInfo) Reset()
- func (m *ClusterInfo) Size() (n int)
- func (m *ClusterInfo) String() string
- func (m *ClusterInfo) Unmarshal(dAtA []byte) error
- type ClusterInfos
- 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 (*ClusterInfos) ProtoMessage()
- func (m *ClusterInfos) Reset()
- func (m *ClusterInfos) Size() (n int)
- func (m *ClusterInfos) String() string
- func (m *ClusterInfos) Unmarshal(dAtA []byte) error
- type CreateClusterRequest
- 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 (*CreateClusterRequest) ProtoMessage()
- func (m *CreateClusterRequest) Reset()
- func (m *CreateClusterRequest) Size() (n int)
- func (m *CreateClusterRequest) String() string
- func (m *CreateClusterRequest) Unmarshal(dAtA []byte) error
- type DeleteClusterRequest
- 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 (*DeleteClusterRequest) ProtoMessage()
- func (m *DeleteClusterRequest) Reset()
- func (m *DeleteClusterRequest) Size() (n int)
- func (m *DeleteClusterRequest) String() string
- func (m *DeleteClusterRequest) Unmarshal(dAtA []byte) error
- type InspectClusterRequest
- 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 (*InspectClusterRequest) ProtoMessage()
- func (m *InspectClusterRequest) Reset()
- func (m *InspectClusterRequest) Size() (n int)
- func (m *InspectClusterRequest) String() string
- func (m *InspectClusterRequest) Unmarshal(dAtA []byte) error
- type KubeEndpoint
- 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 (*KubeEndpoint) ProtoMessage()
- func (m *KubeEndpoint) Reset()
- func (m *KubeEndpoint) Size() (n int)
- func (m *KubeEndpoint) String() string
- func (m *KubeEndpoint) Unmarshal(dAtA []byte) error
- type ListClusterRequest
- func (*ListClusterRequest) Descriptor() ([]byte, []int)
- func (m *ListClusterRequest) Marshal() (dAtA []byte, err error)
- func (m *ListClusterRequest) MarshalTo(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
- type UpdateClusterRequest
- 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 (*UpdateClusterRequest) ProtoMessage()
- func (m *UpdateClusterRequest) Reset()
- func (m *UpdateClusterRequest) Size() (n int)
- func (m *UpdateClusterRequest) String() string
- func (m *UpdateClusterRequest) Unmarshal(dAtA []byte) error
Constants ¶
View Source
const DevVersionTag = "local"
DevVersionTag is used to specify and detect that we're using a non-released version of a pachd image
Variables ¶
View Source
var ( ErrInvalidLengthDeploy = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDeploy = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterAPIServer ¶
Types ¶
type APIClient ¶
type APIClient interface { CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*google_protobuf.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) (*google_protobuf.Empty, error) }
func NewAPIClient ¶
func NewAPIClient(cc *grpc.ClientConn) APIClient
type APIServer ¶
type APIServer interface { CreateCluster(context.Context, *CreateClusterRequest) (*google_protobuf.Empty, error) UpdateCluster(context.Context, *UpdateClusterRequest) (*google_protobuf.Empty, error) InspectCluster(context.Context, *InspectClusterRequest) (*ClusterInfo, error) ListCluster(context.Context, *ListClusterRequest) (*ClusterInfos, error) DeleteCluster(context.Context, *DeleteClusterRequest) (*google_protobuf.Empty, error) }
type Cluster ¶
type Cluster struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*Cluster) Descriptor ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
type ClusterInfo ¶
type ClusterInfo struct { Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"` Shards uint64 `protobuf:"varint,2,opt,name=shards,proto3" json:"shards,omitempty"` }
func (*ClusterInfo) Descriptor ¶
func (*ClusterInfo) Descriptor() ([]byte, []int)
func (*ClusterInfo) GetCluster ¶
func (m *ClusterInfo) GetCluster() *Cluster
func (*ClusterInfo) GetShards ¶ added in v1.3.5
func (m *ClusterInfo) GetShards() uint64
func (*ClusterInfo) Marshal ¶ added in v1.5.0
func (m *ClusterInfo) Marshal() (dAtA []byte, err error)
func (*ClusterInfo) MarshalTo ¶ added in v1.5.0
func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)
func (*ClusterInfo) ProtoMessage ¶
func (*ClusterInfo) ProtoMessage()
func (*ClusterInfo) Reset ¶
func (m *ClusterInfo) Reset()
func (*ClusterInfo) Size ¶ added in v1.5.0
func (m *ClusterInfo) Size() (n int)
func (*ClusterInfo) String ¶
func (m *ClusterInfo) String() string
func (*ClusterInfo) Unmarshal ¶ added in v1.5.0
func (m *ClusterInfo) Unmarshal(dAtA []byte) error
type ClusterInfos ¶
type ClusterInfos struct {
ClusterInfos []*ClusterInfo `protobuf:"bytes,1,rep,name=cluster_infos,json=clusterInfos" json:"cluster_infos,omitempty"`
}
func (*ClusterInfos) Descriptor ¶
func (*ClusterInfos) Descriptor() ([]byte, []int)
func (*ClusterInfos) GetClusterInfos ¶
func (m *ClusterInfos) GetClusterInfos() []*ClusterInfo
func (*ClusterInfos) Marshal ¶ added in v1.5.0
func (m *ClusterInfos) Marshal() (dAtA []byte, err error)
func (*ClusterInfos) MarshalTo ¶ added in v1.5.0
func (m *ClusterInfos) MarshalTo(dAtA []byte) (int, error)
func (*ClusterInfos) ProtoMessage ¶
func (*ClusterInfos) ProtoMessage()
func (*ClusterInfos) Reset ¶
func (m *ClusterInfos) Reset()
func (*ClusterInfos) Size ¶ added in v1.5.0
func (m *ClusterInfos) Size() (n int)
func (*ClusterInfos) String ¶
func (m *ClusterInfos) String() string
func (*ClusterInfos) Unmarshal ¶ added in v1.5.0
func (m *ClusterInfos) Unmarshal(dAtA []byte) error
type CreateClusterRequest ¶
type CreateClusterRequest struct { Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"` Shards uint64 `protobuf:"varint,2,opt,name=shards,proto3" json:"shards,omitempty"` }
func (*CreateClusterRequest) Descriptor ¶
func (*CreateClusterRequest) Descriptor() ([]byte, []int)
func (*CreateClusterRequest) GetCluster ¶
func (m *CreateClusterRequest) GetCluster() *Cluster
func (*CreateClusterRequest) GetShards ¶ added in v1.3.5
func (m *CreateClusterRequest) GetShards() uint64
func (*CreateClusterRequest) Marshal ¶ added in v1.5.0
func (m *CreateClusterRequest) Marshal() (dAtA []byte, err error)
func (*CreateClusterRequest) MarshalTo ¶ added in v1.5.0
func (m *CreateClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateClusterRequest) ProtoMessage ¶
func (*CreateClusterRequest) ProtoMessage()
func (*CreateClusterRequest) Reset ¶
func (m *CreateClusterRequest) Reset()
func (*CreateClusterRequest) Size ¶ added in v1.5.0
func (m *CreateClusterRequest) Size() (n int)
func (*CreateClusterRequest) String ¶
func (m *CreateClusterRequest) String() string
func (*CreateClusterRequest) Unmarshal ¶ added in v1.5.0
func (m *CreateClusterRequest) Unmarshal(dAtA []byte) error
type DeleteClusterRequest ¶
type DeleteClusterRequest struct {
Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`
}
func (*DeleteClusterRequest) Descriptor ¶
func (*DeleteClusterRequest) Descriptor() ([]byte, []int)
func (*DeleteClusterRequest) GetCluster ¶
func (m *DeleteClusterRequest) GetCluster() *Cluster
func (*DeleteClusterRequest) Marshal ¶ added in v1.5.0
func (m *DeleteClusterRequest) Marshal() (dAtA []byte, err error)
func (*DeleteClusterRequest) MarshalTo ¶ added in v1.5.0
func (m *DeleteClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (*DeleteClusterRequest) ProtoMessage ¶
func (*DeleteClusterRequest) ProtoMessage()
func (*DeleteClusterRequest) Reset ¶
func (m *DeleteClusterRequest) Reset()
func (*DeleteClusterRequest) Size ¶ added in v1.5.0
func (m *DeleteClusterRequest) Size() (n int)
func (*DeleteClusterRequest) String ¶
func (m *DeleteClusterRequest) String() string
func (*DeleteClusterRequest) Unmarshal ¶ added in v1.5.0
func (m *DeleteClusterRequest) Unmarshal(dAtA []byte) error
type InspectClusterRequest ¶
type InspectClusterRequest struct {
Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"`
}
func (*InspectClusterRequest) Descriptor ¶
func (*InspectClusterRequest) Descriptor() ([]byte, []int)
func (*InspectClusterRequest) GetCluster ¶
func (m *InspectClusterRequest) GetCluster() *Cluster
func (*InspectClusterRequest) Marshal ¶ added in v1.5.0
func (m *InspectClusterRequest) Marshal() (dAtA []byte, err error)
func (*InspectClusterRequest) MarshalTo ¶ added in v1.5.0
func (m *InspectClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (*InspectClusterRequest) ProtoMessage ¶
func (*InspectClusterRequest) ProtoMessage()
func (*InspectClusterRequest) Reset ¶
func (m *InspectClusterRequest) Reset()
func (*InspectClusterRequest) Size ¶ added in v1.5.0
func (m *InspectClusterRequest) Size() (n int)
func (*InspectClusterRequest) String ¶
func (m *InspectClusterRequest) String() string
func (*InspectClusterRequest) Unmarshal ¶ added in v1.5.0
func (m *InspectClusterRequest) Unmarshal(dAtA []byte) error
type KubeEndpoint ¶
type KubeEndpoint struct {
Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
}
func (*KubeEndpoint) Descriptor ¶
func (*KubeEndpoint) Descriptor() ([]byte, []int)
func (*KubeEndpoint) GetHost ¶ added in v1.3.5
func (m *KubeEndpoint) GetHost() string
func (*KubeEndpoint) Marshal ¶ added in v1.5.0
func (m *KubeEndpoint) Marshal() (dAtA []byte, err error)
func (*KubeEndpoint) MarshalTo ¶ added in v1.5.0
func (m *KubeEndpoint) MarshalTo(dAtA []byte) (int, error)
func (*KubeEndpoint) ProtoMessage ¶
func (*KubeEndpoint) ProtoMessage()
func (*KubeEndpoint) Reset ¶
func (m *KubeEndpoint) Reset()
func (*KubeEndpoint) Size ¶ added in v1.5.0
func (m *KubeEndpoint) Size() (n int)
func (*KubeEndpoint) String ¶
func (m *KubeEndpoint) String() string
func (*KubeEndpoint) Unmarshal ¶ added in v1.5.0
func (m *KubeEndpoint) Unmarshal(dAtA []byte) error
type ListClusterRequest ¶
type ListClusterRequest struct { }
func (*ListClusterRequest) Descriptor ¶
func (*ListClusterRequest) Descriptor() ([]byte, []int)
func (*ListClusterRequest) Marshal ¶ added in v1.5.0
func (m *ListClusterRequest) Marshal() (dAtA []byte, err error)
func (*ListClusterRequest) MarshalTo ¶ added in v1.5.0
func (m *ListClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListClusterRequest) ProtoMessage ¶
func (*ListClusterRequest) ProtoMessage()
func (*ListClusterRequest) Reset ¶
func (m *ListClusterRequest) Reset()
func (*ListClusterRequest) Size ¶ added in v1.5.0
func (m *ListClusterRequest) Size() (n int)
func (*ListClusterRequest) String ¶
func (m *ListClusterRequest) String() string
func (*ListClusterRequest) Unmarshal ¶ added in v1.5.0
func (m *ListClusterRequest) Unmarshal(dAtA []byte) error
type UpdateClusterRequest ¶
type UpdateClusterRequest struct { Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"` Nodes uint64 `protobuf:"varint,2,opt,name=nodes,proto3" json:"nodes,omitempty"` }
func (*UpdateClusterRequest) Descriptor ¶
func (*UpdateClusterRequest) Descriptor() ([]byte, []int)
func (*UpdateClusterRequest) GetCluster ¶
func (m *UpdateClusterRequest) GetCluster() *Cluster
func (*UpdateClusterRequest) GetNodes ¶ added in v1.3.5
func (m *UpdateClusterRequest) GetNodes() uint64
func (*UpdateClusterRequest) Marshal ¶ added in v1.5.0
func (m *UpdateClusterRequest) Marshal() (dAtA []byte, err error)
func (*UpdateClusterRequest) MarshalTo ¶ added in v1.5.0
func (m *UpdateClusterRequest) MarshalTo(dAtA []byte) (int, error)
func (*UpdateClusterRequest) ProtoMessage ¶
func (*UpdateClusterRequest) ProtoMessage()
func (*UpdateClusterRequest) Reset ¶
func (m *UpdateClusterRequest) Reset()
func (*UpdateClusterRequest) Size ¶ added in v1.5.0
func (m *UpdateClusterRequest) Size() (n int)
func (*UpdateClusterRequest) String ¶
func (m *UpdateClusterRequest) String() string
func (*UpdateClusterRequest) Unmarshal ¶ added in v1.5.0
func (m *UpdateClusterRequest) Unmarshal(dAtA []byte) error
Click to show internal directories.
Click to hide internal directories.