pachyderm: github.com/pachyderm/pachyderm/src/server/pkg/deploy Index | Files | Directories

package deploy

import "github.com/pachyderm/pachyderm/src/server/pkg/deploy"

Index

Package Files

deploy.go deploy.pb.go

Constants

❖
const DevVersionTag = "local"

DevVersionTag is used to specify and detect that we're using a non-released version of a pachd image

Variables

❖
var (
    ErrInvalidLengthDeploy = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowDeploy   = fmt.Errorf("proto: integer overflow")
)

func RegisterAPIServer Uses

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

type APIClient Uses

❖
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 Uses

❖
func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer Uses

❖
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 Uses

❖
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:"-"`
}

func (*Cluster) Descriptor Uses

❖
func (*Cluster) Descriptor() ([]byte, []int)

func (*Cluster) GetName Uses

❖
func (m *Cluster) GetName() string

func (*Cluster) Marshal Uses

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

func (*Cluster) MarshalTo Uses

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

func (*Cluster) MarshalToSizedBuffer Uses

❖
func (m *Cluster) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Cluster) ProtoMessage Uses

❖
func (*Cluster) ProtoMessage()

func (*Cluster) Reset Uses

❖
func (m *Cluster) Reset()

func (*Cluster) Size Uses

❖
func (m *Cluster) Size() (n int)

func (*Cluster) String Uses

❖
func (m *Cluster) String() string

func (*Cluster) Unmarshal Uses

❖
func (m *Cluster) Unmarshal(dAtA []byte) error

func (*Cluster) XXX_DiscardUnknown Uses

❖
func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal Uses

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

func (*Cluster) XXX_Merge Uses

❖
func (m *Cluster) XXX_Merge(src proto.Message)

func (*Cluster) XXX_Size Uses

❖
func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal Uses

❖
func (m *Cluster) XXX_Unmarshal(b []byte) error

type ClusterInfo Uses

❖
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 Uses

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

func (*ClusterInfo) GetCluster Uses

❖
func (m *ClusterInfo) GetCluster() *Cluster

func (*ClusterInfo) GetShards Uses

❖
func (m *ClusterInfo) GetShards() uint64

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) MarshalToSizedBuffer Uses

❖
func (m *ClusterInfo) MarshalToSizedBuffer(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 ClusterInfos Uses

❖
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 Uses

❖
func (*ClusterInfos) Descriptor() ([]byte, []int)

func (*ClusterInfos) GetClusterInfos Uses

❖
func (m *ClusterInfos) GetClusterInfos() []*ClusterInfo

func (*ClusterInfos) Marshal Uses

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

func (*ClusterInfos) MarshalTo Uses

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

func (*ClusterInfos) MarshalToSizedBuffer Uses

❖
func (m *ClusterInfos) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterInfos) ProtoMessage Uses

❖
func (*ClusterInfos) ProtoMessage()

func (*ClusterInfos) Reset Uses

❖
func (m *ClusterInfos) Reset()

func (*ClusterInfos) Size Uses

❖
func (m *ClusterInfos) Size() (n int)

func (*ClusterInfos) String Uses

❖
func (m *ClusterInfos) String() string

func (*ClusterInfos) Unmarshal Uses

❖
func (m *ClusterInfos) Unmarshal(dAtA []byte) error

func (*ClusterInfos) XXX_DiscardUnknown Uses

❖
func (m *ClusterInfos) XXX_DiscardUnknown()

func (*ClusterInfos) XXX_Marshal Uses

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

func (*ClusterInfos) XXX_Merge Uses

❖
func (m *ClusterInfos) XXX_Merge(src proto.Message)

func (*ClusterInfos) XXX_Size Uses

❖
func (m *ClusterInfos) XXX_Size() int

func (*ClusterInfos) XXX_Unmarshal Uses

❖
func (m *ClusterInfos) XXX_Unmarshal(b []byte) error

type CreateClusterRequest Uses

❖
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 Uses

❖
func (*CreateClusterRequest) Descriptor() ([]byte, []int)

func (*CreateClusterRequest) GetCluster Uses

❖
func (m *CreateClusterRequest) GetCluster() *Cluster

func (*CreateClusterRequest) GetShards Uses

❖
func (m *CreateClusterRequest) GetShards() uint64

func (*CreateClusterRequest) Marshal Uses

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

func (*CreateClusterRequest) MarshalTo Uses

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

func (*CreateClusterRequest) MarshalToSizedBuffer Uses

❖
func (m *CreateClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateClusterRequest) ProtoMessage Uses

❖
func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) Reset Uses

❖
func (m *CreateClusterRequest) Reset()

func (*CreateClusterRequest) Size Uses

❖
func (m *CreateClusterRequest) Size() (n int)

func (*CreateClusterRequest) String Uses

❖
func (m *CreateClusterRequest) String() string

func (*CreateClusterRequest) Unmarshal Uses

❖
func (m *CreateClusterRequest) Unmarshal(dAtA []byte) error

func (*CreateClusterRequest) XXX_DiscardUnknown Uses

❖
func (m *CreateClusterRequest) XXX_DiscardUnknown()

func (*CreateClusterRequest) XXX_Marshal Uses

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

func (*CreateClusterRequest) XXX_Merge Uses

❖
func (m *CreateClusterRequest) XXX_Merge(src proto.Message)

func (*CreateClusterRequest) XXX_Size Uses

❖
func (m *CreateClusterRequest) XXX_Size() int

func (*CreateClusterRequest) XXX_Unmarshal Uses

❖
func (m *CreateClusterRequest) XXX_Unmarshal(b []byte) error

type DeleteClusterRequest Uses

❖
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 Uses

❖
func (*DeleteClusterRequest) Descriptor() ([]byte, []int)

func (*DeleteClusterRequest) GetCluster Uses

❖
func (m *DeleteClusterRequest) GetCluster() *Cluster

func (*DeleteClusterRequest) Marshal Uses

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

func (*DeleteClusterRequest) MarshalTo Uses

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

func (*DeleteClusterRequest) MarshalToSizedBuffer Uses

❖
func (m *DeleteClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteClusterRequest) ProtoMessage Uses

❖
func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) Reset Uses

❖
func (m *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) Size Uses

❖
func (m *DeleteClusterRequest) Size() (n int)

func (*DeleteClusterRequest) String Uses

❖
func (m *DeleteClusterRequest) String() string

func (*DeleteClusterRequest) Unmarshal Uses

❖
func (m *DeleteClusterRequest) Unmarshal(dAtA []byte) error

func (*DeleteClusterRequest) XXX_DiscardUnknown Uses

❖
func (m *DeleteClusterRequest) XXX_DiscardUnknown()

func (*DeleteClusterRequest) XXX_Marshal Uses

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

func (*DeleteClusterRequest) XXX_Merge Uses

❖
func (m *DeleteClusterRequest) XXX_Merge(src proto.Message)

func (*DeleteClusterRequest) XXX_Size Uses

❖
func (m *DeleteClusterRequest) XXX_Size() int

func (*DeleteClusterRequest) XXX_Unmarshal Uses

❖
func (m *DeleteClusterRequest) XXX_Unmarshal(b []byte) error

type InspectClusterRequest Uses

❖
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 Uses

❖
func (*InspectClusterRequest) Descriptor() ([]byte, []int)

func (*InspectClusterRequest) GetCluster Uses

❖
func (m *InspectClusterRequest) GetCluster() *Cluster

func (*InspectClusterRequest) Marshal Uses

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

func (*InspectClusterRequest) MarshalTo Uses

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

func (*InspectClusterRequest) MarshalToSizedBuffer Uses

❖
func (m *InspectClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InspectClusterRequest) ProtoMessage Uses

❖
func (*InspectClusterRequest) ProtoMessage()

func (*InspectClusterRequest) Reset Uses

❖
func (m *InspectClusterRequest) Reset()

func (*InspectClusterRequest) Size Uses

❖
func (m *InspectClusterRequest) Size() (n int)

func (*InspectClusterRequest) String Uses

❖
func (m *InspectClusterRequest) String() string

func (*InspectClusterRequest) Unmarshal Uses

❖
func (m *InspectClusterRequest) Unmarshal(dAtA []byte) error

func (*InspectClusterRequest) XXX_DiscardUnknown Uses

❖
func (m *InspectClusterRequest) XXX_DiscardUnknown()

func (*InspectClusterRequest) XXX_Marshal Uses

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

func (*InspectClusterRequest) XXX_Merge Uses

❖
func (m *InspectClusterRequest) XXX_Merge(src proto.Message)

func (*InspectClusterRequest) XXX_Size Uses

❖
func (m *InspectClusterRequest) XXX_Size() int

func (*InspectClusterRequest) XXX_Unmarshal Uses

❖
func (m *InspectClusterRequest) XXX_Unmarshal(b []byte) error

type KubeEndpoint Uses

❖
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 Uses

❖
func (*KubeEndpoint) Descriptor() ([]byte, []int)

func (*KubeEndpoint) GetHost Uses

❖
func (m *KubeEndpoint) GetHost() string

func (*KubeEndpoint) Marshal Uses

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

func (*KubeEndpoint) MarshalTo Uses

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

func (*KubeEndpoint) MarshalToSizedBuffer Uses

❖
func (m *KubeEndpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KubeEndpoint) ProtoMessage Uses

❖
func (*KubeEndpoint) ProtoMessage()

func (*KubeEndpoint) Reset Uses

❖
func (m *KubeEndpoint) Reset()

func (*KubeEndpoint) Size Uses

❖
func (m *KubeEndpoint) Size() (n int)

func (*KubeEndpoint) String Uses

❖
func (m *KubeEndpoint) String() string

func (*KubeEndpoint) Unmarshal Uses

❖
func (m *KubeEndpoint) Unmarshal(dAtA []byte) error

func (*KubeEndpoint) XXX_DiscardUnknown Uses

❖
func (m *KubeEndpoint) XXX_DiscardUnknown()

func (*KubeEndpoint) XXX_Marshal Uses

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

func (*KubeEndpoint) XXX_Merge Uses

❖
func (m *KubeEndpoint) XXX_Merge(src proto.Message)

func (*KubeEndpoint) XXX_Size Uses

❖
func (m *KubeEndpoint) XXX_Size() int

func (*KubeEndpoint) XXX_Unmarshal Uses

❖
func (m *KubeEndpoint) XXX_Unmarshal(b []byte) error

type ListClusterRequest Uses

❖
type ListClusterRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ListClusterRequest) Descriptor Uses

❖
func (*ListClusterRequest) Descriptor() ([]byte, []int)

func (*ListClusterRequest) Marshal Uses

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

func (*ListClusterRequest) MarshalTo Uses

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

func (*ListClusterRequest) MarshalToSizedBuffer Uses

❖
func (m *ListClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListClusterRequest) ProtoMessage Uses

❖
func (*ListClusterRequest) ProtoMessage()

func (*ListClusterRequest) Reset Uses

❖
func (m *ListClusterRequest) Reset()

func (*ListClusterRequest) Size Uses

❖
func (m *ListClusterRequest) Size() (n int)

func (*ListClusterRequest) String Uses

❖
func (m *ListClusterRequest) String() string

func (*ListClusterRequest) Unmarshal Uses

❖
func (m *ListClusterRequest) Unmarshal(dAtA []byte) error

func (*ListClusterRequest) XXX_DiscardUnknown Uses

❖
func (m *ListClusterRequest) XXX_DiscardUnknown()

func (*ListClusterRequest) XXX_Marshal Uses

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

func (*ListClusterRequest) XXX_Merge Uses

❖
func (m *ListClusterRequest) XXX_Merge(src proto.Message)

func (*ListClusterRequest) XXX_Size Uses

❖
func (m *ListClusterRequest) XXX_Size() int

func (*ListClusterRequest) XXX_Unmarshal Uses

❖
func (m *ListClusterRequest) XXX_Unmarshal(b []byte) error

type UnimplementedAPIServer Uses

❖
type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) CreateCluster Uses

❖
func (*UnimplementedAPIServer) CreateCluster(ctx context.Context, req *CreateClusterRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) DeleteCluster Uses

❖
func (*UnimplementedAPIServer) DeleteCluster(ctx context.Context, req *DeleteClusterRequest) (*types.Empty, error)

func (*UnimplementedAPIServer) InspectCluster Uses

❖
func (*UnimplementedAPIServer) InspectCluster(ctx context.Context, req *InspectClusterRequest) (*ClusterInfo, error)

func (*UnimplementedAPIServer) ListCluster Uses

❖
func (*UnimplementedAPIServer) ListCluster(ctx context.Context, req *ListClusterRequest) (*ClusterInfos, error)

func (*UnimplementedAPIServer) UpdateCluster Uses

❖
func (*UnimplementedAPIServer) UpdateCluster(ctx context.Context, req *UpdateClusterRequest) (*types.Empty, error)

type UpdateClusterRequest Uses

❖
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 Uses

❖
func (*UpdateClusterRequest) Descriptor() ([]byte, []int)

func (*UpdateClusterRequest) GetCluster Uses

❖
func (m *UpdateClusterRequest) GetCluster() *Cluster

func (*UpdateClusterRequest) GetNodes Uses

❖
func (m *UpdateClusterRequest) GetNodes() uint64

func (*UpdateClusterRequest) Marshal Uses

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

func (*UpdateClusterRequest) MarshalTo Uses

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

func (*UpdateClusterRequest) MarshalToSizedBuffer Uses

❖
func (m *UpdateClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateClusterRequest) ProtoMessage Uses

❖
func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) Reset Uses

❖
func (m *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) Size Uses

❖
func (m *UpdateClusterRequest) Size() (n int)

func (*UpdateClusterRequest) String Uses

❖
func (m *UpdateClusterRequest) String() string

func (*UpdateClusterRequest) Unmarshal Uses

❖
func (m *UpdateClusterRequest) Unmarshal(dAtA []byte) error

func (*UpdateClusterRequest) XXX_DiscardUnknown Uses

❖
func (m *UpdateClusterRequest) XXX_DiscardUnknown()

func (*UpdateClusterRequest) XXX_Marshal Uses

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

func (*UpdateClusterRequest) XXX_Merge Uses

❖
func (m *UpdateClusterRequest) XXX_Merge(src proto.Message)

func (*UpdateClusterRequest) XXX_Size Uses

❖
func (m *UpdateClusterRequest) XXX_Size() int

func (*UpdateClusterRequest) XXX_Unmarshal Uses

❖
func (m *UpdateClusterRequest) XXX_Unmarshal(b []byte) error

Directories

PathSynopsis
assets
cmds
images

Package deploy imports 10 packages (graph) and is imported by 1 packages. Updated 2019-08-13. Refresh now. Tools for package owners.