cmavmware

package
v0.0.0-...-e5b634d Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2019 License: Apache-2.0 Imports: 14 Imported by: 1

Documentation

Overview

Package cmavmware is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var ClusterStatus_name = map[int32]string{
	0: "STATUS_UNSPECIFIED",
	1: "PROVISIONING",
	2: "RUNNING",
	3: "RECONCILING",
	4: "STOPPING",
	5: "ERROR",
	6: "DEGRADED",
}
View Source
var ClusterStatus_value = map[string]int32{
	"STATUS_UNSPECIFIED": 0,
	"PROVISIONING":       1,
	"RUNNING":            2,
	"RECONCILING":        3,
	"STOPPING":           4,
	"ERROR":              5,
	"DEGRADED":           6,
}

Functions

func RegisterClusterHandler

func RegisterClusterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterClusterHandler registers the http handlers for service Cluster to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterClusterHandlerClient

func RegisterClusterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClusterClient) error

RegisterClusterHandlerClient registers the http handlers for service Cluster to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ClusterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ClusterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ClusterClient" to call the correct interceptors.

func RegisterClusterHandlerFromEndpoint

func RegisterClusterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterClusterHandlerFromEndpoint is same as RegisterClusterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterClusterServer

func RegisterClusterServer(s *grpc.Server, srv ClusterServer)

Types

type AdjustClusterMsg

type AdjustClusterMsg struct {
	// What is the cluster that we are considering for upgrade
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Machines which we want to add to the cluster
	AddNodes []*VMWareMachineSpec `protobuf:"bytes,2,rep,name=add_nodes,json=addNodes,proto3" json:"add_nodes,omitempty"`
	// Machines which we want to remove from the cluster
	RemoveNodes          []*AdjustClusterMsg_VMWareRemoveMachineSpec `protobuf:"bytes,3,rep,name=remove_nodes,json=removeNodes,proto3" json:"remove_nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func (*AdjustClusterMsg) Descriptor

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

func (*AdjustClusterMsg) GetAddNodes

func (m *AdjustClusterMsg) GetAddNodes() []*VMWareMachineSpec

func (*AdjustClusterMsg) GetName

func (m *AdjustClusterMsg) GetName() string

func (*AdjustClusterMsg) GetRemoveNodes

func (*AdjustClusterMsg) ProtoMessage

func (*AdjustClusterMsg) ProtoMessage()

func (*AdjustClusterMsg) Reset

func (m *AdjustClusterMsg) Reset()

func (*AdjustClusterMsg) String

func (m *AdjustClusterMsg) String() string

func (*AdjustClusterMsg) XXX_DiscardUnknown

func (m *AdjustClusterMsg) XXX_DiscardUnknown()

func (*AdjustClusterMsg) XXX_Marshal

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

func (*AdjustClusterMsg) XXX_Merge

func (dst *AdjustClusterMsg) XXX_Merge(src proto.Message)

func (*AdjustClusterMsg) XXX_Size

func (m *AdjustClusterMsg) XXX_Size() int

func (*AdjustClusterMsg) XXX_Unmarshal

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

type AdjustClusterMsg_VMWareRemoveMachineSpec

type AdjustClusterMsg_VMWareRemoveMachineSpec struct {
	// The host for SSH access
	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 (*AdjustClusterMsg_VMWareRemoveMachineSpec) Descriptor

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

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) GetHost

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) ProtoMessage

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) Reset

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) String

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_DiscardUnknown

func (m *AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_DiscardUnknown()

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_Marshal

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

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_Merge

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_Size

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_Unmarshal

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

type AdjustClusterReply

type AdjustClusterReply struct {
	// Was this a successful request
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AdjustClusterReply) Descriptor

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

func (*AdjustClusterReply) GetOk

func (m *AdjustClusterReply) GetOk() bool

func (*AdjustClusterReply) ProtoMessage

func (*AdjustClusterReply) ProtoMessage()

func (*AdjustClusterReply) Reset

func (m *AdjustClusterReply) Reset()

func (*AdjustClusterReply) String

func (m *AdjustClusterReply) String() string

func (*AdjustClusterReply) XXX_DiscardUnknown

func (m *AdjustClusterReply) XXX_DiscardUnknown()

func (*AdjustClusterReply) XXX_Marshal

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

func (*AdjustClusterReply) XXX_Merge

func (dst *AdjustClusterReply) XXX_Merge(src proto.Message)

func (*AdjustClusterReply) XXX_Size

func (m *AdjustClusterReply) XXX_Size() int

func (*AdjustClusterReply) XXX_Unmarshal

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

type ClusterClient

type ClusterClient interface {
	// Will provision a cluster
	CreateCluster(ctx context.Context, in *CreateClusterMsg, opts ...grpc.CallOption) (*CreateClusterReply, error)
	// Will retrieve the status of a cluster and its kubeconfig for connectivity
	GetCluster(ctx context.Context, in *GetClusterMsg, opts ...grpc.CallOption) (*GetClusterReply, error)
	// Will delete a cluster
	DeleteCluster(ctx context.Context, in *DeleteClusterMsg, opts ...grpc.CallOption) (*DeleteClusterReply, error)
	// Will retrieve a list of clusters
	GetClusterList(ctx context.Context, in *GetClusterListMsg, opts ...grpc.CallOption) (*GetClusterListReply, error)
	// Will return version information about api server
	GetVersionInformation(ctx context.Context, in *GetVersionMsg, opts ...grpc.CallOption) (*GetVersionReply, error)
	// Will adjust a provision a cluster
	AdjustClusterNodes(ctx context.Context, in *AdjustClusterMsg, opts ...grpc.CallOption) (*AdjustClusterReply, error)
	// Will return upgrade options for a given cluster
	GetUpgradeClusterInformation(ctx context.Context, in *GetUpgradeClusterInformationMsg, opts ...grpc.CallOption) (*GetUpgradeClusterInformationReply, error)
	// Will attempt to upgrade a cluster
	UpgradeCluster(ctx context.Context, in *UpgradeClusterMsg, opts ...grpc.CallOption) (*UpgradeClusterReply, error)
}

ClusterClient is the client API for Cluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClusterClient

func NewClusterClient(cc *grpc.ClientConn) ClusterClient

type ClusterDetailItem

type ClusterDetailItem struct {
	// ID of the cluster
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the cluster
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Additional information about the status of the cluster
	StatusMessage string `protobuf:"bytes,3,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	// What is the kubeconfig to connect to the cluster
	Kubeconfig string `protobuf:"bytes,4,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
	// The status of the cluster
	Status               ClusterStatus `protobuf:"varint,5,opt,name=status,proto3,enum=cmavmware.ClusterStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ClusterDetailItem) Descriptor

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

func (*ClusterDetailItem) GetId

func (m *ClusterDetailItem) GetId() string

func (*ClusterDetailItem) GetKubeconfig

func (m *ClusterDetailItem) GetKubeconfig() string

func (*ClusterDetailItem) GetName

func (m *ClusterDetailItem) GetName() string

func (*ClusterDetailItem) GetStatus

func (m *ClusterDetailItem) GetStatus() ClusterStatus

func (*ClusterDetailItem) GetStatusMessage

func (m *ClusterDetailItem) GetStatusMessage() string

func (*ClusterDetailItem) ProtoMessage

func (*ClusterDetailItem) ProtoMessage()

func (*ClusterDetailItem) Reset

func (m *ClusterDetailItem) Reset()

func (*ClusterDetailItem) String

func (m *ClusterDetailItem) String() string

func (*ClusterDetailItem) XXX_DiscardUnknown

func (m *ClusterDetailItem) XXX_DiscardUnknown()

func (*ClusterDetailItem) XXX_Marshal

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

func (*ClusterDetailItem) XXX_Merge

func (dst *ClusterDetailItem) XXX_Merge(src proto.Message)

func (*ClusterDetailItem) XXX_Size

func (m *ClusterDetailItem) XXX_Size() int

func (*ClusterDetailItem) XXX_Unmarshal

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

type ClusterItem

type ClusterItem struct {
	// ID of the cluster
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the cluster
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Additional information about the status of the cluster
	StatusMessage string `protobuf:"bytes,3,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	// The status of the cluster
	Status               ClusterStatus `protobuf:"varint,4,opt,name=status,proto3,enum=cmavmware.ClusterStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ClusterItem) Descriptor

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

func (*ClusterItem) GetId

func (m *ClusterItem) GetId() string

func (*ClusterItem) GetName

func (m *ClusterItem) GetName() string

func (*ClusterItem) GetStatus

func (m *ClusterItem) GetStatus() ClusterStatus

func (*ClusterItem) GetStatusMessage

func (m *ClusterItem) GetStatusMessage() string

func (*ClusterItem) ProtoMessage

func (*ClusterItem) ProtoMessage()

func (*ClusterItem) Reset

func (m *ClusterItem) Reset()

func (*ClusterItem) String

func (m *ClusterItem) String() string

func (*ClusterItem) XXX_DiscardUnknown

func (m *ClusterItem) XXX_DiscardUnknown()

func (*ClusterItem) XXX_Marshal

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

func (*ClusterItem) XXX_Merge

func (dst *ClusterItem) XXX_Merge(src proto.Message)

func (*ClusterItem) XXX_Size

func (m *ClusterItem) XXX_Size() int

func (*ClusterItem) XXX_Unmarshal

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

type ClusterServer

type ClusterServer interface {
	// Will provision a cluster
	CreateCluster(context.Context, *CreateClusterMsg) (*CreateClusterReply, error)
	// Will retrieve the status of a cluster and its kubeconfig for connectivity
	GetCluster(context.Context, *GetClusterMsg) (*GetClusterReply, error)
	// Will delete a cluster
	DeleteCluster(context.Context, *DeleteClusterMsg) (*DeleteClusterReply, error)
	// Will retrieve a list of clusters
	GetClusterList(context.Context, *GetClusterListMsg) (*GetClusterListReply, error)
	// Will return version information about api server
	GetVersionInformation(context.Context, *GetVersionMsg) (*GetVersionReply, error)
	// Will adjust a provision a cluster
	AdjustClusterNodes(context.Context, *AdjustClusterMsg) (*AdjustClusterReply, error)
	// Will return upgrade options for a given cluster
	GetUpgradeClusterInformation(context.Context, *GetUpgradeClusterInformationMsg) (*GetUpgradeClusterInformationReply, error)
	// Will attempt to upgrade a cluster
	UpgradeCluster(context.Context, *UpgradeClusterMsg) (*UpgradeClusterReply, error)
}

ClusterServer is the server API for Cluster service.

type ClusterStatus

type ClusterStatus int32
const (
	// Not set
	ClusterStatus_STATUS_UNSPECIFIED ClusterStatus = 0
	// The PROVISIONING state indicates the cluster is being created.
	ClusterStatus_PROVISIONING ClusterStatus = 1
	// The RUNNING state indicates the cluster has been created and is fully usable.
	ClusterStatus_RUNNING ClusterStatus = 2
	// The RECONCILING state indicates that some work is actively being done on the cluster, such as upgrading the master or node software.
	ClusterStatus_RECONCILING ClusterStatus = 3
	// The STOPPING state indicates the cluster is being deleted
	ClusterStatus_STOPPING ClusterStatus = 4
	// The ERROR state indicates the cluster may be unusable
	ClusterStatus_ERROR ClusterStatus = 5
	// The DEGRADED state indicates the cluster requires user action to restore full functionality
	ClusterStatus_DEGRADED ClusterStatus = 6
)

func (ClusterStatus) EnumDescriptor

func (ClusterStatus) EnumDescriptor() ([]byte, []int)

func (ClusterStatus) String

func (x ClusterStatus) String() string

type CreateClusterMsg

type CreateClusterMsg struct {
	// Name of the cluster to be provisioned
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The version of Kubernetes for worker nodes. Control plane versions are determined by the MachineSpec.
	K8SVersion string `protobuf:"bytes,2,opt,name=k8s_version,json=k8sVersion,proto3" json:"k8s_version,omitempty"`
	// Whether or not the cluster is HA
	HighAvailability bool `protobuf:"varint,3,opt,name=high_availability,json=highAvailability,proto3" json:"high_availability,omitempty"`
	// The fabric to be used
	NetworkFabric string `protobuf:"bytes,4,opt,name=network_fabric,json=networkFabric,proto3" json:"network_fabric,omitempty"`
	// Machines which comprise the cluster
	ControlPlaneNodes []*VMWareMachineSpec `protobuf:"bytes,5,rep,name=control_plane_nodes,json=controlPlaneNodes,proto3" json:"control_plane_nodes,omitempty"`
	// Machines which comprise the cluster
	WorkerNodes []*VMWareMachineSpec `protobuf:"bytes,6,rep,name=worker_nodes,json=workerNodes,proto3" json:"worker_nodes,omitempty"`
	// This should be a value like ip:port that will be a virtual IP/port
	// Passed back to external customers to be able to communicate to the cluster
	ApiEndpoint string `protobuf:"bytes,7,opt,name=api_endpoint,json=apiEndpoint,proto3" json:"api_endpoint,omitempty"`
	// Private key used to ssh into machines
	PrivateKey           string   `protobuf:"bytes,8,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateClusterMsg) Descriptor

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

func (*CreateClusterMsg) GetApiEndpoint

func (m *CreateClusterMsg) GetApiEndpoint() string

func (*CreateClusterMsg) GetControlPlaneNodes

func (m *CreateClusterMsg) GetControlPlaneNodes() []*VMWareMachineSpec

func (*CreateClusterMsg) GetHighAvailability

func (m *CreateClusterMsg) GetHighAvailability() bool

func (*CreateClusterMsg) GetK8SVersion

func (m *CreateClusterMsg) GetK8SVersion() string

func (*CreateClusterMsg) GetName

func (m *CreateClusterMsg) GetName() string

func (*CreateClusterMsg) GetNetworkFabric

func (m *CreateClusterMsg) GetNetworkFabric() string

func (*CreateClusterMsg) GetPrivateKey

func (m *CreateClusterMsg) GetPrivateKey() string

func (*CreateClusterMsg) GetWorkerNodes

func (m *CreateClusterMsg) GetWorkerNodes() []*VMWareMachineSpec

func (*CreateClusterMsg) ProtoMessage

func (*CreateClusterMsg) ProtoMessage()

func (*CreateClusterMsg) Reset

func (m *CreateClusterMsg) Reset()

func (*CreateClusterMsg) String

func (m *CreateClusterMsg) String() string

func (*CreateClusterMsg) XXX_DiscardUnknown

func (m *CreateClusterMsg) XXX_DiscardUnknown()

func (*CreateClusterMsg) XXX_Marshal

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

func (*CreateClusterMsg) XXX_Merge

func (dst *CreateClusterMsg) XXX_Merge(src proto.Message)

func (*CreateClusterMsg) XXX_Size

func (m *CreateClusterMsg) XXX_Size() int

func (*CreateClusterMsg) XXX_Unmarshal

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

type CreateClusterReply

type CreateClusterReply struct {
	// Whether or not the cluster was provisioned by this request
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// The details of the cluster request response
	Cluster              *ClusterItem `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CreateClusterReply) Descriptor

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

func (*CreateClusterReply) GetCluster

func (m *CreateClusterReply) GetCluster() *ClusterItem

func (*CreateClusterReply) GetOk

func (m *CreateClusterReply) GetOk() bool

func (*CreateClusterReply) ProtoMessage

func (*CreateClusterReply) ProtoMessage()

func (*CreateClusterReply) Reset

func (m *CreateClusterReply) Reset()

func (*CreateClusterReply) String

func (m *CreateClusterReply) String() string

func (*CreateClusterReply) XXX_DiscardUnknown

func (m *CreateClusterReply) XXX_DiscardUnknown()

func (*CreateClusterReply) XXX_Marshal

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

func (*CreateClusterReply) XXX_Merge

func (dst *CreateClusterReply) XXX_Merge(src proto.Message)

func (*CreateClusterReply) XXX_Size

func (m *CreateClusterReply) XXX_Size() int

func (*CreateClusterReply) XXX_Unmarshal

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

type DeleteClusterMsg

type DeleteClusterMsg struct {
	// What is the cluster's name to destroy
	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 (*DeleteClusterMsg) Descriptor

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

func (*DeleteClusterMsg) GetName

func (m *DeleteClusterMsg) GetName() string

func (*DeleteClusterMsg) ProtoMessage

func (*DeleteClusterMsg) ProtoMessage()

func (*DeleteClusterMsg) Reset

func (m *DeleteClusterMsg) Reset()

func (*DeleteClusterMsg) String

func (m *DeleteClusterMsg) String() string

func (*DeleteClusterMsg) XXX_DiscardUnknown

func (m *DeleteClusterMsg) XXX_DiscardUnknown()

func (*DeleteClusterMsg) XXX_Marshal

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

func (*DeleteClusterMsg) XXX_Merge

func (dst *DeleteClusterMsg) XXX_Merge(src proto.Message)

func (*DeleteClusterMsg) XXX_Size

func (m *DeleteClusterMsg) XXX_Size() int

func (*DeleteClusterMsg) XXX_Unmarshal

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

type DeleteClusterReply

type DeleteClusterReply struct {
	// Could the cluster be destroyed
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// Status of the request
	Status               string   `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteClusterReply) Descriptor

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

func (*DeleteClusterReply) GetOk

func (m *DeleteClusterReply) GetOk() bool

func (*DeleteClusterReply) GetStatus

func (m *DeleteClusterReply) GetStatus() string

func (*DeleteClusterReply) ProtoMessage

func (*DeleteClusterReply) ProtoMessage()

func (*DeleteClusterReply) Reset

func (m *DeleteClusterReply) Reset()

func (*DeleteClusterReply) String

func (m *DeleteClusterReply) String() string

func (*DeleteClusterReply) XXX_DiscardUnknown

func (m *DeleteClusterReply) XXX_DiscardUnknown()

func (*DeleteClusterReply) XXX_Marshal

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

func (*DeleteClusterReply) XXX_Merge

func (dst *DeleteClusterReply) XXX_Merge(src proto.Message)

func (*DeleteClusterReply) XXX_Size

func (m *DeleteClusterReply) XXX_Size() int

func (*DeleteClusterReply) XXX_Unmarshal

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

type GetClusterListMsg

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

func (*GetClusterListMsg) Descriptor

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

func (*GetClusterListMsg) ProtoMessage

func (*GetClusterListMsg) ProtoMessage()

func (*GetClusterListMsg) Reset

func (m *GetClusterListMsg) Reset()

func (*GetClusterListMsg) String

func (m *GetClusterListMsg) String() string

func (*GetClusterListMsg) XXX_DiscardUnknown

func (m *GetClusterListMsg) XXX_DiscardUnknown()

func (*GetClusterListMsg) XXX_Marshal

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

func (*GetClusterListMsg) XXX_Merge

func (dst *GetClusterListMsg) XXX_Merge(src proto.Message)

func (*GetClusterListMsg) XXX_Size

func (m *GetClusterListMsg) XXX_Size() int

func (*GetClusterListMsg) XXX_Unmarshal

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

type GetClusterListReply

type GetClusterListReply struct {
	// Is the cluster in the system
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// List of clusters
	Clusters             []*ClusterItem `protobuf:"bytes,2,rep,name=clusters,proto3" json:"clusters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetClusterListReply) Descriptor

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

func (*GetClusterListReply) GetClusters

func (m *GetClusterListReply) GetClusters() []*ClusterItem

func (*GetClusterListReply) GetOk

func (m *GetClusterListReply) GetOk() bool

func (*GetClusterListReply) ProtoMessage

func (*GetClusterListReply) ProtoMessage()

func (*GetClusterListReply) Reset

func (m *GetClusterListReply) Reset()

func (*GetClusterListReply) String

func (m *GetClusterListReply) String() string

func (*GetClusterListReply) XXX_DiscardUnknown

func (m *GetClusterListReply) XXX_DiscardUnknown()

func (*GetClusterListReply) XXX_Marshal

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

func (*GetClusterListReply) XXX_Merge

func (dst *GetClusterListReply) XXX_Merge(src proto.Message)

func (*GetClusterListReply) XXX_Size

func (m *GetClusterListReply) XXX_Size() int

func (*GetClusterListReply) XXX_Unmarshal

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

type GetClusterMsg

type GetClusterMsg struct {
	// Name of the cluster to be looked up
	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 (*GetClusterMsg) Descriptor

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

func (*GetClusterMsg) GetName

func (m *GetClusterMsg) GetName() string

func (*GetClusterMsg) ProtoMessage

func (*GetClusterMsg) ProtoMessage()

func (*GetClusterMsg) Reset

func (m *GetClusterMsg) Reset()

func (*GetClusterMsg) String

func (m *GetClusterMsg) String() string

func (*GetClusterMsg) XXX_DiscardUnknown

func (m *GetClusterMsg) XXX_DiscardUnknown()

func (*GetClusterMsg) XXX_Marshal

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

func (*GetClusterMsg) XXX_Merge

func (dst *GetClusterMsg) XXX_Merge(src proto.Message)

func (*GetClusterMsg) XXX_Size

func (m *GetClusterMsg) XXX_Size() int

func (*GetClusterMsg) XXX_Unmarshal

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

type GetClusterReply

type GetClusterReply struct {
	// Is the cluster in the system
	Ok                   bool               `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Cluster              *ClusterDetailItem `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetClusterReply) Descriptor

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

func (*GetClusterReply) GetCluster

func (m *GetClusterReply) GetCluster() *ClusterDetailItem

func (*GetClusterReply) GetOk

func (m *GetClusterReply) GetOk() bool

func (*GetClusterReply) ProtoMessage

func (*GetClusterReply) ProtoMessage()

func (*GetClusterReply) Reset

func (m *GetClusterReply) Reset()

func (*GetClusterReply) String

func (m *GetClusterReply) String() string

func (*GetClusterReply) XXX_DiscardUnknown

func (m *GetClusterReply) XXX_DiscardUnknown()

func (*GetClusterReply) XXX_Marshal

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

func (*GetClusterReply) XXX_Merge

func (dst *GetClusterReply) XXX_Merge(src proto.Message)

func (*GetClusterReply) XXX_Size

func (m *GetClusterReply) XXX_Size() int

func (*GetClusterReply) XXX_Unmarshal

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

type GetUpgradeClusterInformationMsg

type GetUpgradeClusterInformationMsg struct {
	// What is the cluster that we are considering for upgrade
	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 (*GetUpgradeClusterInformationMsg) Descriptor

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

func (*GetUpgradeClusterInformationMsg) GetName

func (*GetUpgradeClusterInformationMsg) ProtoMessage

func (*GetUpgradeClusterInformationMsg) ProtoMessage()

func (*GetUpgradeClusterInformationMsg) Reset

func (*GetUpgradeClusterInformationMsg) String

func (*GetUpgradeClusterInformationMsg) XXX_DiscardUnknown

func (m *GetUpgradeClusterInformationMsg) XXX_DiscardUnknown()

func (*GetUpgradeClusterInformationMsg) XXX_Marshal

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

func (*GetUpgradeClusterInformationMsg) XXX_Merge

func (dst *GetUpgradeClusterInformationMsg) XXX_Merge(src proto.Message)

func (*GetUpgradeClusterInformationMsg) XXX_Size

func (m *GetUpgradeClusterInformationMsg) XXX_Size() int

func (*GetUpgradeClusterInformationMsg) XXX_Unmarshal

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

type GetUpgradeClusterInformationReply

type GetUpgradeClusterInformationReply struct {
	// Can the cluster be upgraded
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// What versions are possible right now
	Versions             []string `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetUpgradeClusterInformationReply) Descriptor

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

func (*GetUpgradeClusterInformationReply) GetOk

func (*GetUpgradeClusterInformationReply) GetVersions

func (m *GetUpgradeClusterInformationReply) GetVersions() []string

func (*GetUpgradeClusterInformationReply) ProtoMessage

func (*GetUpgradeClusterInformationReply) ProtoMessage()

func (*GetUpgradeClusterInformationReply) Reset

func (*GetUpgradeClusterInformationReply) String

func (*GetUpgradeClusterInformationReply) XXX_DiscardUnknown

func (m *GetUpgradeClusterInformationReply) XXX_DiscardUnknown()

func (*GetUpgradeClusterInformationReply) XXX_Marshal

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

func (*GetUpgradeClusterInformationReply) XXX_Merge

func (dst *GetUpgradeClusterInformationReply) XXX_Merge(src proto.Message)

func (*GetUpgradeClusterInformationReply) XXX_Size

func (m *GetUpgradeClusterInformationReply) XXX_Size() int

func (*GetUpgradeClusterInformationReply) XXX_Unmarshal

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

type GetVersionMsg

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

Get version of API Server

func (*GetVersionMsg) Descriptor

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

func (*GetVersionMsg) ProtoMessage

func (*GetVersionMsg) ProtoMessage()

func (*GetVersionMsg) Reset

func (m *GetVersionMsg) Reset()

func (*GetVersionMsg) String

func (m *GetVersionMsg) String() string

func (*GetVersionMsg) XXX_DiscardUnknown

func (m *GetVersionMsg) XXX_DiscardUnknown()

func (*GetVersionMsg) XXX_Marshal

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

func (*GetVersionMsg) XXX_Merge

func (dst *GetVersionMsg) XXX_Merge(src proto.Message)

func (*GetVersionMsg) XXX_Size

func (m *GetVersionMsg) XXX_Size() int

func (*GetVersionMsg) XXX_Unmarshal

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

type GetVersionReply

type GetVersionReply struct {
	// If operation was OK
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// Version Information
	VersionInformation   *GetVersionReply_VersionInformation `protobuf:"bytes,2,opt,name=version_information,json=versionInformation,proto3" json:"version_information,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

Reply for version request

func (*GetVersionReply) Descriptor

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

func (*GetVersionReply) GetOk

func (m *GetVersionReply) GetOk() bool

func (*GetVersionReply) GetVersionInformation

func (m *GetVersionReply) GetVersionInformation() *GetVersionReply_VersionInformation

func (*GetVersionReply) ProtoMessage

func (*GetVersionReply) ProtoMessage()

func (*GetVersionReply) Reset

func (m *GetVersionReply) Reset()

func (*GetVersionReply) String

func (m *GetVersionReply) String() string

func (*GetVersionReply) XXX_DiscardUnknown

func (m *GetVersionReply) XXX_DiscardUnknown()

func (*GetVersionReply) XXX_Marshal

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

func (*GetVersionReply) XXX_Merge

func (dst *GetVersionReply) XXX_Merge(src proto.Message)

func (*GetVersionReply) XXX_Size

func (m *GetVersionReply) XXX_Size() int

func (*GetVersionReply) XXX_Unmarshal

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

type GetVersionReply_VersionInformation

type GetVersionReply_VersionInformation struct {
	// The tag on the git repository
	GitVersion string `protobuf:"bytes,1,opt,name=git_version,json=gitVersion,proto3" json:"git_version,omitempty"`
	// The hash of the git commit
	GitCommit string `protobuf:"bytes,2,opt,name=git_commit,json=gitCommit,proto3" json:"git_commit,omitempty"`
	// Whether or not the tree was clean when built
	GitTreeState string `protobuf:"bytes,3,opt,name=git_tree_state,json=gitTreeState,proto3" json:"git_tree_state,omitempty"`
	// Date of build
	BuildDate string `protobuf:"bytes,4,opt,name=build_date,json=buildDate,proto3" json:"build_date,omitempty"`
	// Version of go used to compile
	GoVersion string `protobuf:"bytes,5,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	// Compiler used
	Compiler string `protobuf:"bytes,6,opt,name=compiler,proto3" json:"compiler,omitempty"`
	// Platform it was compiled for / running on
	Platform             string   `protobuf:"bytes,7,opt,name=platform,proto3" json:"platform,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetVersionReply_VersionInformation) Descriptor

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

func (*GetVersionReply_VersionInformation) GetBuildDate

func (m *GetVersionReply_VersionInformation) GetBuildDate() string

func (*GetVersionReply_VersionInformation) GetCompiler

func (m *GetVersionReply_VersionInformation) GetCompiler() string

func (*GetVersionReply_VersionInformation) GetGitCommit

func (m *GetVersionReply_VersionInformation) GetGitCommit() string

func (*GetVersionReply_VersionInformation) GetGitTreeState

func (m *GetVersionReply_VersionInformation) GetGitTreeState() string

func (*GetVersionReply_VersionInformation) GetGitVersion

func (m *GetVersionReply_VersionInformation) GetGitVersion() string

func (*GetVersionReply_VersionInformation) GetGoVersion

func (m *GetVersionReply_VersionInformation) GetGoVersion() string

func (*GetVersionReply_VersionInformation) GetPlatform

func (m *GetVersionReply_VersionInformation) GetPlatform() string

func (*GetVersionReply_VersionInformation) ProtoMessage

func (*GetVersionReply_VersionInformation) ProtoMessage()

func (*GetVersionReply_VersionInformation) Reset

func (*GetVersionReply_VersionInformation) String

func (*GetVersionReply_VersionInformation) XXX_DiscardUnknown

func (m *GetVersionReply_VersionInformation) XXX_DiscardUnknown()

func (*GetVersionReply_VersionInformation) XXX_Marshal

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

func (*GetVersionReply_VersionInformation) XXX_Merge

func (dst *GetVersionReply_VersionInformation) XXX_Merge(src proto.Message)

func (*GetVersionReply_VersionInformation) XXX_Size

func (*GetVersionReply_VersionInformation) XXX_Unmarshal

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

type KubernetesLabel

type KubernetesLabel struct {
	// The name of a label
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The value of a label
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KubernetesLabel) Descriptor

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

func (*KubernetesLabel) GetName

func (m *KubernetesLabel) GetName() string

func (*KubernetesLabel) GetValue

func (m *KubernetesLabel) GetValue() string

func (*KubernetesLabel) ProtoMessage

func (*KubernetesLabel) ProtoMessage()

func (*KubernetesLabel) Reset

func (m *KubernetesLabel) Reset()

func (*KubernetesLabel) String

func (m *KubernetesLabel) String() string

func (*KubernetesLabel) XXX_DiscardUnknown

func (m *KubernetesLabel) XXX_DiscardUnknown()

func (*KubernetesLabel) XXX_Marshal

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

func (*KubernetesLabel) XXX_Merge

func (dst *KubernetesLabel) XXX_Merge(src proto.Message)

func (*KubernetesLabel) XXX_Size

func (m *KubernetesLabel) XXX_Size() int

func (*KubernetesLabel) XXX_Unmarshal

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

type UpgradeClusterMsg

type UpgradeClusterMsg struct {
	// What is the cluster that we are considering for upgrade
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// What version are we upgrading to?
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpgradeClusterMsg) Descriptor

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

func (*UpgradeClusterMsg) GetName

func (m *UpgradeClusterMsg) GetName() string

func (*UpgradeClusterMsg) GetVersion

func (m *UpgradeClusterMsg) GetVersion() string

func (*UpgradeClusterMsg) ProtoMessage

func (*UpgradeClusterMsg) ProtoMessage()

func (*UpgradeClusterMsg) Reset

func (m *UpgradeClusterMsg) Reset()

func (*UpgradeClusterMsg) String

func (m *UpgradeClusterMsg) String() string

func (*UpgradeClusterMsg) XXX_DiscardUnknown

func (m *UpgradeClusterMsg) XXX_DiscardUnknown()

func (*UpgradeClusterMsg) XXX_Marshal

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

func (*UpgradeClusterMsg) XXX_Merge

func (dst *UpgradeClusterMsg) XXX_Merge(src proto.Message)

func (*UpgradeClusterMsg) XXX_Size

func (m *UpgradeClusterMsg) XXX_Size() int

func (*UpgradeClusterMsg) XXX_Unmarshal

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

type UpgradeClusterReply

type UpgradeClusterReply struct {
	// Was this a successful request
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpgradeClusterReply) Descriptor

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

func (*UpgradeClusterReply) GetOk

func (m *UpgradeClusterReply) GetOk() bool

func (*UpgradeClusterReply) ProtoMessage

func (*UpgradeClusterReply) ProtoMessage()

func (*UpgradeClusterReply) Reset

func (m *UpgradeClusterReply) Reset()

func (*UpgradeClusterReply) String

func (m *UpgradeClusterReply) String() string

func (*UpgradeClusterReply) XXX_DiscardUnknown

func (m *UpgradeClusterReply) XXX_DiscardUnknown()

func (*UpgradeClusterReply) XXX_Marshal

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

func (*UpgradeClusterReply) XXX_Merge

func (dst *UpgradeClusterReply) XXX_Merge(src proto.Message)

func (*UpgradeClusterReply) XXX_Size

func (m *UpgradeClusterReply) XXX_Size() int

func (*UpgradeClusterReply) XXX_Unmarshal

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

type VMWareMachineSpec

type VMWareMachineSpec struct {
	// The username for SSH access
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// The host for SSH access
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// The port for SSH access
	Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// The password for SSH access. This is not implemented within the clusterapi
	// because without known_host support a MITM can get the password. A MITM is
	// still a problem for key based authentication; even if they do not get the
	// key they can still impersonate the machine. TODO: implement known_hosts.
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	// The labels for the machines
	Labels               []*KubernetesLabel `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

The specification for a specific node

func (*VMWareMachineSpec) Descriptor

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

func (*VMWareMachineSpec) GetHost

func (m *VMWareMachineSpec) GetHost() string

func (*VMWareMachineSpec) GetLabels

func (m *VMWareMachineSpec) GetLabels() []*KubernetesLabel

func (*VMWareMachineSpec) GetPassword

func (m *VMWareMachineSpec) GetPassword() string

func (*VMWareMachineSpec) GetPort

func (m *VMWareMachineSpec) GetPort() int32

func (*VMWareMachineSpec) GetUsername

func (m *VMWareMachineSpec) GetUsername() string

func (*VMWareMachineSpec) ProtoMessage

func (*VMWareMachineSpec) ProtoMessage()

func (*VMWareMachineSpec) Reset

func (m *VMWareMachineSpec) Reset()

func (*VMWareMachineSpec) String

func (m *VMWareMachineSpec) String() string

func (*VMWareMachineSpec) XXX_DiscardUnknown

func (m *VMWareMachineSpec) XXX_DiscardUnknown()

func (*VMWareMachineSpec) XXX_Marshal

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

func (*VMWareMachineSpec) XXX_Merge

func (dst *VMWareMachineSpec) XXX_Merge(src proto.Message)

func (*VMWareMachineSpec) XXX_Size

func (m *VMWareMachineSpec) XXX_Size() int

func (*VMWareMachineSpec) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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