cluster_manager_api

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2019 License: Apache-2.0 Imports: 14 Imported by: 2

Documentation

Overview

Package cluster_manager_api 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,
}
View Source
var Provider_name = map[int32]string{
	0: "undefined",
	1: "aws",
	2: "azure",
	3: "vmware",
	4: "ssh",
}
View Source
var Provider_value = map[string]int32{
	"undefined": 0,
	"aws":       1,
	"azure":     2,
	"vmware":    3,
	"ssh":       4,
}

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

RegisterClusterHandler 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 AWSCredentials added in v0.1.1

type AWSCredentials struct {
	// The SecretKeyId for API Access
	SecretKeyId string `protobuf:"bytes,1,opt,name=secret_key_id,json=secretKeyId,proto3" json:"secret_key_id,omitempty"`
	// The SecretAccessKey for API access
	SecretAccessKey string `protobuf:"bytes,2,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	// The Region for API access
	Region               string   `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The credentials to use for creating the cluster

func (*AWSCredentials) Descriptor added in v0.1.1

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

func (*AWSCredentials) GetRegion added in v0.1.1

func (m *AWSCredentials) GetRegion() string

func (*AWSCredentials) GetSecretAccessKey added in v0.1.1

func (m *AWSCredentials) GetSecretAccessKey() string

func (*AWSCredentials) GetSecretKeyId added in v0.1.1

func (m *AWSCredentials) GetSecretKeyId() string

func (*AWSCredentials) ProtoMessage added in v0.1.1

func (*AWSCredentials) ProtoMessage()

func (*AWSCredentials) Reset added in v0.1.1

func (m *AWSCredentials) Reset()

func (*AWSCredentials) String added in v0.1.1

func (m *AWSCredentials) String() string

func (*AWSCredentials) XXX_DiscardUnknown added in v0.1.1

func (m *AWSCredentials) XXX_DiscardUnknown()

func (*AWSCredentials) XXX_Marshal added in v0.1.1

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

func (*AWSCredentials) XXX_Merge added in v0.1.1

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

func (*AWSCredentials) XXX_Size added in v0.1.1

func (m *AWSCredentials) XXX_Size() int

func (*AWSCredentials) XXX_Unmarshal added in v0.1.1

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

type AdjustClusterMsg added in v0.1.1

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"`
	// Name of the providers (aws/azure/vmware/etc)
	Provider Provider `protobuf:"varint,2,opt,name=provider,proto3,enum=cluster_manager_api.Provider" json:"provider,omitempty"`
	// AWS Credentials
	Aws *AWSCredentials `protobuf:"bytes,3,opt,name=aws,proto3" json:"aws,omitempty"`
	// Provider changes
	//
	// Types that are valid to be assigned to ProviderChanges:
	//	*AdjustClusterMsg_Azure
	//	*AdjustClusterMsg_Vmware
	//	*AdjustClusterMsg_Ssh
	ProviderChanges isAdjustClusterMsg_ProviderChanges `protobuf_oneof:"provider_changes"`
	// Callback information
	Callback             *Callback `protobuf:"bytes,8,opt,name=callback,proto3" json:"callback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*AdjustClusterMsg) Descriptor added in v0.1.1

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

func (*AdjustClusterMsg) GetAws added in v0.1.1

func (m *AdjustClusterMsg) GetAws() *AWSCredentials

func (*AdjustClusterMsg) GetAzure added in v0.1.1

func (*AdjustClusterMsg) GetCallback added in v0.1.1

func (m *AdjustClusterMsg) GetCallback() *Callback

func (*AdjustClusterMsg) GetName added in v0.1.1

func (m *AdjustClusterMsg) GetName() string

func (*AdjustClusterMsg) GetProvider added in v0.1.1

func (m *AdjustClusterMsg) GetProvider() Provider

func (*AdjustClusterMsg) GetProviderChanges added in v0.1.1

func (m *AdjustClusterMsg) GetProviderChanges() isAdjustClusterMsg_ProviderChanges

func (*AdjustClusterMsg) GetSsh added in v0.1.1

func (*AdjustClusterMsg) GetVmware added in v0.1.1

func (*AdjustClusterMsg) ProtoMessage added in v0.1.1

func (*AdjustClusterMsg) ProtoMessage()

func (*AdjustClusterMsg) Reset added in v0.1.1

func (m *AdjustClusterMsg) Reset()

func (*AdjustClusterMsg) String added in v0.1.1

func (m *AdjustClusterMsg) String() string

func (*AdjustClusterMsg) XXX_DiscardUnknown added in v0.1.1

func (m *AdjustClusterMsg) XXX_DiscardUnknown()

func (*AdjustClusterMsg) XXX_Marshal added in v0.1.1

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

func (*AdjustClusterMsg) XXX_Merge added in v0.1.1

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

func (*AdjustClusterMsg) XXX_OneofFuncs added in v0.1.1

func (*AdjustClusterMsg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*AdjustClusterMsg) XXX_Size added in v0.1.1

func (m *AdjustClusterMsg) XXX_Size() int

func (*AdjustClusterMsg) XXX_Unmarshal added in v0.1.1

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

type AdjustClusterMsg_AdjustClusterAKSSpec added in v0.1.1

type AdjustClusterMsg_AdjustClusterAKSSpec struct {
	// Credentials to build the cluster
	Credentials *AzureCredentials `protobuf:"bytes,1,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// Node Pool Name
	NodePool string `protobuf:"bytes,2,opt,name=node_pool,json=nodePool,proto3" json:"node_pool,omitempty"`
	// umber to increase by
	AddCount int32 `protobuf:"varint,3,opt,name=add_count,json=addCount,proto3" json:"add_count,omitempty"`
	// number to decrease by
	RemoveCount          int32    `protobuf:"varint,4,opt,name=remove_count,json=removeCount,proto3" json:"remove_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AdjustClusterMsg_AdjustClusterAKSSpec) Descriptor added in v0.1.1

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

func (*AdjustClusterMsg_AdjustClusterAKSSpec) GetAddCount added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterAKSSpec) GetCredentials added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterAKSSpec) GetNodePool added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterAKSSpec) GetRemoveCount added in v0.1.1

func (m *AdjustClusterMsg_AdjustClusterAKSSpec) GetRemoveCount() int32

func (*AdjustClusterMsg_AdjustClusterAKSSpec) ProtoMessage added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterAKSSpec) ProtoMessage()

func (*AdjustClusterMsg_AdjustClusterAKSSpec) Reset added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterAKSSpec) String added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterAKSSpec) XXX_DiscardUnknown added in v0.1.1

func (m *AdjustClusterMsg_AdjustClusterAKSSpec) XXX_DiscardUnknown()

func (*AdjustClusterMsg_AdjustClusterAKSSpec) XXX_Marshal added in v0.1.1

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

func (*AdjustClusterMsg_AdjustClusterAKSSpec) XXX_Merge added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterAKSSpec) XXX_Size added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterAKSSpec) XXX_Unmarshal added in v0.1.1

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

type AdjustClusterMsg_AdjustClusterSshSpec added in v0.1.1

type AdjustClusterMsg_AdjustClusterSshSpec struct {
	// Machines which we want to add to the cluster
	AddNodes []*SshMachineSpec `protobuf:"bytes,1,rep,name=add_nodes,json=addNodes,proto3" json:"add_nodes,omitempty"`
	// Machines which we want to remove from the cluster
	RemoveNodes          []*AdjustClusterMsg_SshRemoveMachineSpec `protobuf:"bytes,2,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_AdjustClusterSshSpec) Descriptor added in v0.1.1

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

func (*AdjustClusterMsg_AdjustClusterSshSpec) GetAddNodes added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterSshSpec) GetRemoveNodes added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterSshSpec) ProtoMessage added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterSshSpec) ProtoMessage()

func (*AdjustClusterMsg_AdjustClusterSshSpec) Reset added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterSshSpec) String added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterSshSpec) XXX_DiscardUnknown added in v0.1.1

func (m *AdjustClusterMsg_AdjustClusterSshSpec) XXX_DiscardUnknown()

func (*AdjustClusterMsg_AdjustClusterSshSpec) XXX_Marshal added in v0.1.1

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

func (*AdjustClusterMsg_AdjustClusterSshSpec) XXX_Merge added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterSshSpec) XXX_Size added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterSshSpec) XXX_Unmarshal added in v0.1.1

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

type AdjustClusterMsg_AdjustClusterVMWareSpec added in v0.1.1

type AdjustClusterMsg_AdjustClusterVMWareSpec struct {
	// Machines which we want to add to the cluster
	AddNodes []*VMWareMachineSpec `protobuf:"bytes,1,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,2,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_AdjustClusterVMWareSpec) Descriptor added in v0.1.1

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

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) GetAddNodes added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) GetRemoveNodes added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) ProtoMessage added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) Reset added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) String added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) XXX_DiscardUnknown added in v0.1.1

func (m *AdjustClusterMsg_AdjustClusterVMWareSpec) XXX_DiscardUnknown()

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) XXX_Marshal added in v0.1.1

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

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) XXX_Merge added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) XXX_Size added in v0.1.1

func (*AdjustClusterMsg_AdjustClusterVMWareSpec) XXX_Unmarshal added in v0.1.1

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

type AdjustClusterMsg_Azure added in v0.1.1

type AdjustClusterMsg_Azure struct {
	Azure *AdjustClusterMsg_AdjustClusterAKSSpec `protobuf:"bytes,6,opt,name=azure,proto3,oneof"`
}

type AdjustClusterMsg_Ssh added in v0.1.1

type AdjustClusterMsg_Ssh struct {
	Ssh *AdjustClusterMsg_AdjustClusterSshSpec `protobuf:"bytes,9,opt,name=ssh,proto3,oneof"`
}

type AdjustClusterMsg_SshRemoveMachineSpec added in v0.1.1

type AdjustClusterMsg_SshRemoveMachineSpec 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 (*AdjustClusterMsg_SshRemoveMachineSpec) Descriptor added in v0.1.1

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

func (*AdjustClusterMsg_SshRemoveMachineSpec) GetHost added in v0.1.1

func (*AdjustClusterMsg_SshRemoveMachineSpec) ProtoMessage added in v0.1.1

func (*AdjustClusterMsg_SshRemoveMachineSpec) ProtoMessage()

func (*AdjustClusterMsg_SshRemoveMachineSpec) Reset added in v0.1.1

func (*AdjustClusterMsg_SshRemoveMachineSpec) String added in v0.1.1

func (*AdjustClusterMsg_SshRemoveMachineSpec) XXX_DiscardUnknown added in v0.1.1

func (m *AdjustClusterMsg_SshRemoveMachineSpec) XXX_DiscardUnknown()

func (*AdjustClusterMsg_SshRemoveMachineSpec) XXX_Marshal added in v0.1.1

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

func (*AdjustClusterMsg_SshRemoveMachineSpec) XXX_Merge added in v0.1.1

func (*AdjustClusterMsg_SshRemoveMachineSpec) XXX_Size added in v0.1.1

func (*AdjustClusterMsg_SshRemoveMachineSpec) XXX_Unmarshal added in v0.1.1

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

type AdjustClusterMsg_VMWareRemoveMachineSpec added in v0.1.1

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 added in v0.1.1

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

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) GetHost added in v0.1.1

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) ProtoMessage added in v0.1.1

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) Reset added in v0.1.1

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) String added in v0.1.1

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_DiscardUnknown added in v0.1.1

func (m *AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_DiscardUnknown()

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_Marshal added in v0.1.1

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

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_Merge added in v0.1.1

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_Size added in v0.1.1

func (*AdjustClusterMsg_VMWareRemoveMachineSpec) XXX_Unmarshal added in v0.1.1

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

type AdjustClusterMsg_Vmware added in v0.1.1

type AdjustClusterMsg_Vmware struct {
	Vmware *AdjustClusterMsg_AdjustClusterVMWareSpec `protobuf:"bytes,7,opt,name=vmware,proto3,oneof"`
}

type AdjustClusterReply added in v0.1.1

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 added in v0.1.1

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

func (*AdjustClusterReply) GetOk added in v0.1.1

func (m *AdjustClusterReply) GetOk() bool

func (*AdjustClusterReply) ProtoMessage added in v0.1.1

func (*AdjustClusterReply) ProtoMessage()

func (*AdjustClusterReply) Reset added in v0.1.1

func (m *AdjustClusterReply) Reset()

func (*AdjustClusterReply) String added in v0.1.1

func (m *AdjustClusterReply) String() string

func (*AdjustClusterReply) XXX_DiscardUnknown added in v0.1.1

func (m *AdjustClusterReply) XXX_DiscardUnknown()

func (*AdjustClusterReply) XXX_Marshal added in v0.1.1

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

func (*AdjustClusterReply) XXX_Merge added in v0.1.1

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

func (*AdjustClusterReply) XXX_Size added in v0.1.1

func (m *AdjustClusterReply) XXX_Size() int

func (*AdjustClusterReply) XXX_Unmarshal added in v0.1.1

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

type AzureClusterServiceAccount added in v0.1.1

type AzureClusterServiceAccount struct {
	// The ClientId (aka: AppID)
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The ClientSecret (aka: password)
	ClientSecret         string   `protobuf:"bytes,2,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

the account used by the cluster to create azure resources (ex: load balancer)

func (*AzureClusterServiceAccount) Descriptor added in v0.1.1

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

func (*AzureClusterServiceAccount) GetClientId added in v0.1.1

func (m *AzureClusterServiceAccount) GetClientId() string

func (*AzureClusterServiceAccount) GetClientSecret added in v0.1.1

func (m *AzureClusterServiceAccount) GetClientSecret() string

func (*AzureClusterServiceAccount) ProtoMessage added in v0.1.1

func (*AzureClusterServiceAccount) ProtoMessage()

func (*AzureClusterServiceAccount) Reset added in v0.1.1

func (m *AzureClusterServiceAccount) Reset()

func (*AzureClusterServiceAccount) String added in v0.1.1

func (m *AzureClusterServiceAccount) String() string

func (*AzureClusterServiceAccount) XXX_DiscardUnknown added in v0.1.1

func (m *AzureClusterServiceAccount) XXX_DiscardUnknown()

func (*AzureClusterServiceAccount) XXX_Marshal added in v0.1.1

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

func (*AzureClusterServiceAccount) XXX_Merge added in v0.1.1

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

func (*AzureClusterServiceAccount) XXX_Size added in v0.1.1

func (m *AzureClusterServiceAccount) XXX_Size() int

func (*AzureClusterServiceAccount) XXX_Unmarshal added in v0.1.1

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

type AzureCredentials added in v0.1.1

type AzureCredentials struct {
	// The AppId for API Access
	AppId string `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// The Tenant for API access
	Tenant string `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	// The Password for API access
	Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// The Subscription for API access
	SubscriptionId       string   `protobuf:"bytes,4,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The credentials to use for creating the cluster

func (*AzureCredentials) Descriptor added in v0.1.1

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

func (*AzureCredentials) GetAppId added in v0.1.1

func (m *AzureCredentials) GetAppId() string

func (*AzureCredentials) GetPassword added in v0.1.1

func (m *AzureCredentials) GetPassword() string

func (*AzureCredentials) GetSubscriptionId added in v0.1.1

func (m *AzureCredentials) GetSubscriptionId() string

func (*AzureCredentials) GetTenant added in v0.1.1

func (m *AzureCredentials) GetTenant() string

func (*AzureCredentials) ProtoMessage added in v0.1.1

func (*AzureCredentials) ProtoMessage()

func (*AzureCredentials) Reset added in v0.1.1

func (m *AzureCredentials) Reset()

func (*AzureCredentials) String added in v0.1.1

func (m *AzureCredentials) String() string

func (*AzureCredentials) XXX_DiscardUnknown added in v0.1.1

func (m *AzureCredentials) XXX_DiscardUnknown()

func (*AzureCredentials) XXX_Marshal added in v0.1.1

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

func (*AzureCredentials) XXX_Merge added in v0.1.1

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

func (*AzureCredentials) XXX_Size added in v0.1.1

func (m *AzureCredentials) XXX_Size() int

func (*AzureCredentials) XXX_Unmarshal added in v0.1.1

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

type Callback added in v0.1.1

type Callback struct {
	// The URL to call back to
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// The ID of the request
	RequestId            string   `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Callback) Descriptor added in v0.1.1

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

func (*Callback) GetRequestId added in v0.1.1

func (m *Callback) GetRequestId() string

func (*Callback) GetUrl added in v0.1.1

func (m *Callback) GetUrl() string

func (*Callback) ProtoMessage added in v0.1.1

func (*Callback) ProtoMessage()

func (*Callback) Reset added in v0.1.1

func (m *Callback) Reset()

func (*Callback) String added in v0.1.1

func (m *Callback) String() string

func (*Callback) XXX_DiscardUnknown added in v0.1.1

func (m *Callback) XXX_DiscardUnknown()

func (*Callback) XXX_Marshal added in v0.1.1

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

func (*Callback) XXX_Merge added in v0.1.1

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

func (*Callback) XXX_Size added in v0.1.1

func (m *Callback) XXX_Size() int

func (*Callback) XXX_Unmarshal added in v0.1.1

func (m *Callback) 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 adjust a provision a cluster
	AdjustClusterNodes(ctx context.Context, in *AdjustClusterMsg, opts ...grpc.CallOption) (*AdjustClusterReply, error)
	// Will retrieve a list of clusters
	GetClusterList(ctx context.Context, in *GetClusterListMsg, opts ...grpc.CallOption) (*GetClusterListReply, error)
	// Will install (or reinstall) tiller
	ProvisionTiller(ctx context.Context, in *ProvisionTillerMsg, opts ...grpc.CallOption) (*ProvisionTillerReply, error)
	// Will install (or reinstall) helm chart
	// This will be destructive if a chart has already been deployed with the same name
	InstallHelmChart(ctx context.Context, in *InstallHelmChartMsg, opts ...grpc.CallOption) (*InstallHelmChartReply, error)
	// Will delete deployed helm chart
	DeleteHelmChart(ctx context.Context, in *DeleteHelmChartMsg, opts ...grpc.CallOption) (*DeleteHelmChartReply, error)
	// Will return version information about api server
	GetVersionInformation(ctx context.Context, in *GetVersionMsg, opts ...grpc.CallOption) (*GetVersionReply, 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)
	// Will update aws credentials used for a cluster
	UpdateAWSCredentials(ctx context.Context, in *UpdateAWSCredentialsMsg, opts ...grpc.CallOption) (*UpdateAWSCredentialsReply, error)
	// Will update azure credentials used for a cluster
	UpdateAzureCredentials(ctx context.Context, in *UpdateAzureCredentialsMsg, opts ...grpc.CallOption) (*UpdateAzureCredentialsReply, 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=cluster_manager_api.ClusterStatus" json:"status,omitempty"`
	// What is the admin bearer token
	Bearertoken          string   `protobuf:"bytes,6,opt,name=bearertoken,proto3" json:"bearertoken,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterDetailItem) Descriptor

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

func (*ClusterDetailItem) GetBearertoken added in v0.1.1

func (m *ClusterDetailItem) GetBearertoken() string

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 added in v0.1.1

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=cluster_manager_api.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 added in v0.1.1

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 adjust a provision a cluster
	AdjustClusterNodes(context.Context, *AdjustClusterMsg) (*AdjustClusterReply, error)
	// Will retrieve a list of clusters
	GetClusterList(context.Context, *GetClusterListMsg) (*GetClusterListReply, error)
	// Will install (or reinstall) tiller
	ProvisionTiller(context.Context, *ProvisionTillerMsg) (*ProvisionTillerReply, error)
	// Will install (or reinstall) helm chart
	// This will be destructive if a chart has already been deployed with the same name
	InstallHelmChart(context.Context, *InstallHelmChartMsg) (*InstallHelmChartReply, error)
	// Will delete deployed helm chart
	DeleteHelmChart(context.Context, *DeleteHelmChartMsg) (*DeleteHelmChartReply, error)
	// Will return version information about api server
	GetVersionInformation(context.Context, *GetVersionMsg) (*GetVersionReply, 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)
	// Will update aws credentials used for a cluster
	UpdateAWSCredentials(context.Context, *UpdateAWSCredentialsMsg) (*UpdateAWSCredentialsReply, error)
	// Will update azure credentials used for a cluster
	UpdateAzureCredentials(context.Context, *UpdateAzureCredentialsMsg) (*UpdateAzureCredentialsReply, error)
}

ClusterServer is the server API for Cluster service.

type ClusterStatus added in v0.1.1

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 added in v0.1.1

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

func (ClusterStatus) String added in v0.1.1

func (x ClusterStatus) String() string

type CreateClusterAKSSpec added in v0.1.1

type CreateClusterAKSSpec struct {
	// The Azure Data Center
	Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// Credentials to build the cluster
	Credentials *AzureCredentials `protobuf:"bytes,2,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// Instance groups
	InstanceGroups       []*CreateClusterAKSSpec_AKSInstanceGroup `protobuf:"bytes,4,rep,name=instance_groups,json=instanceGroups,proto3" json:"instance_groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

func (*CreateClusterAKSSpec) Descriptor added in v0.1.1

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

func (*CreateClusterAKSSpec) GetCredentials added in v0.1.1

func (m *CreateClusterAKSSpec) GetCredentials() *AzureCredentials

func (*CreateClusterAKSSpec) GetInstanceGroups added in v0.1.1

func (*CreateClusterAKSSpec) GetLocation added in v0.1.1

func (m *CreateClusterAKSSpec) GetLocation() string

func (*CreateClusterAKSSpec) ProtoMessage added in v0.1.1

func (*CreateClusterAKSSpec) ProtoMessage()

func (*CreateClusterAKSSpec) Reset added in v0.1.1

func (m *CreateClusterAKSSpec) Reset()

func (*CreateClusterAKSSpec) String added in v0.1.1

func (m *CreateClusterAKSSpec) String() string

func (*CreateClusterAKSSpec) XXX_DiscardUnknown added in v0.1.1

func (m *CreateClusterAKSSpec) XXX_DiscardUnknown()

func (*CreateClusterAKSSpec) XXX_Marshal added in v0.1.1

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

func (*CreateClusterAKSSpec) XXX_Merge added in v0.1.1

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

func (*CreateClusterAKSSpec) XXX_Size added in v0.1.1

func (m *CreateClusterAKSSpec) XXX_Size() int

func (*CreateClusterAKSSpec) XXX_Unmarshal added in v0.1.1

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

type CreateClusterAKSSpec_AKSInstanceGroup added in v0.1.1

type CreateClusterAKSSpec_AKSInstanceGroup struct {
	// The name of the group
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Instance type (Standard_D2_v2, etc.)
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Minimum number of instances (defaults to zero)
	MinQuantity int32 `protobuf:"varint,3,opt,name=min_quantity,json=minQuantity,proto3" json:"min_quantity,omitempty"`
	// Maximum number of instances (defaults to zero)
	MaxQuantity          int32    `protobuf:"varint,4,opt,name=max_quantity,json=maxQuantity,proto3" json:"max_quantity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Instance groups define a type and number of instances

func (*CreateClusterAKSSpec_AKSInstanceGroup) Descriptor added in v0.1.1

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

func (*CreateClusterAKSSpec_AKSInstanceGroup) GetMaxQuantity added in v0.1.1

func (m *CreateClusterAKSSpec_AKSInstanceGroup) GetMaxQuantity() int32

func (*CreateClusterAKSSpec_AKSInstanceGroup) GetMinQuantity added in v0.1.1

func (m *CreateClusterAKSSpec_AKSInstanceGroup) GetMinQuantity() int32

func (*CreateClusterAKSSpec_AKSInstanceGroup) GetName added in v0.1.1

func (*CreateClusterAKSSpec_AKSInstanceGroup) GetType added in v0.1.1

func (*CreateClusterAKSSpec_AKSInstanceGroup) ProtoMessage added in v0.1.1

func (*CreateClusterAKSSpec_AKSInstanceGroup) ProtoMessage()

func (*CreateClusterAKSSpec_AKSInstanceGroup) Reset added in v0.1.1

func (*CreateClusterAKSSpec_AKSInstanceGroup) String added in v0.1.1

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_DiscardUnknown added in v0.1.1

func (m *CreateClusterAKSSpec_AKSInstanceGroup) XXX_DiscardUnknown()

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_Marshal added in v0.1.1

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

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_Merge added in v0.1.1

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_Size added in v0.1.1

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_Unmarshal added in v0.1.1

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

type CreateClusterAWSSpec

type CreateClusterAWSSpec struct {
	// The AWS Data Center
	DataCenter *CreateClusterAWSSpec_AWSDataCenter `protobuf:"bytes,1,opt,name=data_center,json=dataCenter,proto3" json:"data_center,omitempty"`
	// Credentials to build the cluster
	Credentials *AWSCredentials `protobuf:"bytes,2,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// BYO items
	Resources *CreateClusterAWSSpec_AWSPreconfiguredItems `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"`
	// Instance groups
	InstanceGroups       []*CreateClusterAWSSpec_AWSInstanceGroup `protobuf:"bytes,4,rep,name=instance_groups,json=instanceGroups,proto3" json:"instance_groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

func (*CreateClusterAWSSpec) Descriptor

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

func (*CreateClusterAWSSpec) GetCredentials added in v0.1.1

func (m *CreateClusterAWSSpec) GetCredentials() *AWSCredentials

func (*CreateClusterAWSSpec) GetDataCenter added in v0.1.1

func (*CreateClusterAWSSpec) GetInstanceGroups added in v0.1.1

func (*CreateClusterAWSSpec) GetResources added in v0.1.1

func (*CreateClusterAWSSpec) ProtoMessage

func (*CreateClusterAWSSpec) ProtoMessage()

func (*CreateClusterAWSSpec) Reset

func (m *CreateClusterAWSSpec) Reset()

func (*CreateClusterAWSSpec) String

func (m *CreateClusterAWSSpec) String() string

func (*CreateClusterAWSSpec) XXX_DiscardUnknown

func (m *CreateClusterAWSSpec) XXX_DiscardUnknown()

func (*CreateClusterAWSSpec) XXX_Marshal

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

func (*CreateClusterAWSSpec) XXX_Merge

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

func (*CreateClusterAWSSpec) XXX_Size

func (m *CreateClusterAWSSpec) XXX_Size() int

func (*CreateClusterAWSSpec) XXX_Unmarshal

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

type CreateClusterAWSSpec_AWSDataCenter added in v0.1.1

type CreateClusterAWSSpec_AWSDataCenter struct {
	// Which region (us-east-1, etc.)
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// Which availability zones (us-east-1b, us-east-2c, us-west-2d, etc.)
	AvailabilityZones    []string `protobuf:"bytes,2,rep,name=availability_zones,json=availabilityZones,proto3" json:"availability_zones,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Which Data Center

func (*CreateClusterAWSSpec_AWSDataCenter) Descriptor added in v0.1.1

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

func (*CreateClusterAWSSpec_AWSDataCenter) GetAvailabilityZones added in v0.1.1

func (m *CreateClusterAWSSpec_AWSDataCenter) GetAvailabilityZones() []string

func (*CreateClusterAWSSpec_AWSDataCenter) GetRegion added in v0.1.1

func (*CreateClusterAWSSpec_AWSDataCenter) ProtoMessage added in v0.1.1

func (*CreateClusterAWSSpec_AWSDataCenter) ProtoMessage()

func (*CreateClusterAWSSpec_AWSDataCenter) Reset added in v0.1.1

func (*CreateClusterAWSSpec_AWSDataCenter) String added in v0.1.1

func (*CreateClusterAWSSpec_AWSDataCenter) XXX_DiscardUnknown added in v0.1.1

func (m *CreateClusterAWSSpec_AWSDataCenter) XXX_DiscardUnknown()

func (*CreateClusterAWSSpec_AWSDataCenter) XXX_Marshal added in v0.1.1

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

func (*CreateClusterAWSSpec_AWSDataCenter) XXX_Merge added in v0.1.1

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

func (*CreateClusterAWSSpec_AWSDataCenter) XXX_Size added in v0.1.1

func (*CreateClusterAWSSpec_AWSDataCenter) XXX_Unmarshal added in v0.1.1

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

type CreateClusterAWSSpec_AWSInstanceGroup added in v0.1.1

type CreateClusterAWSSpec_AWSInstanceGroup struct {
	// Instance type (m5.large, etc.)
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Minimum number of instances (defaults to zero)
	MinQuantity int32 `protobuf:"varint,2,opt,name=min_quantity,json=minQuantity,proto3" json:"min_quantity,omitempty"`
	// Maximum number of instances (defaults to zero)
	MaxQuantity          int32    `protobuf:"varint,3,opt,name=max_quantity,json=maxQuantity,proto3" json:"max_quantity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Instance groups define a type and number of instances

func (*CreateClusterAWSSpec_AWSInstanceGroup) Descriptor added in v0.1.1

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

func (*CreateClusterAWSSpec_AWSInstanceGroup) GetMaxQuantity added in v0.1.1

func (m *CreateClusterAWSSpec_AWSInstanceGroup) GetMaxQuantity() int32

func (*CreateClusterAWSSpec_AWSInstanceGroup) GetMinQuantity added in v0.1.1

func (m *CreateClusterAWSSpec_AWSInstanceGroup) GetMinQuantity() int32

func (*CreateClusterAWSSpec_AWSInstanceGroup) GetType added in v0.1.1

func (*CreateClusterAWSSpec_AWSInstanceGroup) ProtoMessage added in v0.1.1

func (*CreateClusterAWSSpec_AWSInstanceGroup) ProtoMessage()

func (*CreateClusterAWSSpec_AWSInstanceGroup) Reset added in v0.1.1

func (*CreateClusterAWSSpec_AWSInstanceGroup) String added in v0.1.1

func (*CreateClusterAWSSpec_AWSInstanceGroup) XXX_DiscardUnknown added in v0.1.1

func (m *CreateClusterAWSSpec_AWSInstanceGroup) XXX_DiscardUnknown()

func (*CreateClusterAWSSpec_AWSInstanceGroup) XXX_Marshal added in v0.1.1

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

func (*CreateClusterAWSSpec_AWSInstanceGroup) XXX_Merge added in v0.1.1

func (*CreateClusterAWSSpec_AWSInstanceGroup) XXX_Size added in v0.1.1

func (*CreateClusterAWSSpec_AWSInstanceGroup) XXX_Unmarshal added in v0.1.1

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

type CreateClusterAWSSpec_AWSPreconfiguredItems added in v0.1.1

type CreateClusterAWSSpec_AWSPreconfiguredItems struct {
	// The VPC id, blank for for "create one for you", filled if you are BYO VPC
	VpcId string `protobuf:"bytes,1,opt,name=vpc_id,json=vpcId,proto3" json:"vpc_id,omitempty"`
	// Security group
	SecurityGroupId string `protobuf:"bytes,2,opt,name=security_group_id,json=securityGroupId,proto3" json:"security_group_id,omitempty"`
	// The IAM role for the cluster (arn)ClusterAssociationdd
	IamRoleArn           string   `protobuf:"bytes,3,opt,name=iam_role_arn,json=iamRoleArn,proto3" json:"iam_role_arn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

For when some things are already created

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) Descriptor added in v0.1.1

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) GetIamRoleArn added in v0.1.1

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) GetSecurityGroupId added in v0.1.1

func (m *CreateClusterAWSSpec_AWSPreconfiguredItems) GetSecurityGroupId() string

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) GetVpcId added in v0.1.1

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) ProtoMessage added in v0.1.1

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) Reset added in v0.1.1

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) String added in v0.1.1

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) XXX_DiscardUnknown added in v0.1.1

func (m *CreateClusterAWSSpec_AWSPreconfiguredItems) XXX_DiscardUnknown()

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) XXX_Marshal added in v0.1.1

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

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) XXX_Merge added in v0.1.1

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) XXX_Size added in v0.1.1

func (*CreateClusterAWSSpec_AWSPreconfiguredItems) XXX_Unmarshal added in v0.1.1

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 provider specification
	Provider *CreateClusterProviderSpec `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	// Callback information
	Callback             *Callback `protobuf:"bytes,3,opt,name=callback,proto3" json:"callback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CreateClusterMsg) Descriptor

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

func (*CreateClusterMsg) GetCallback added in v0.1.1

func (m *CreateClusterMsg) GetCallback() *Callback

func (*CreateClusterMsg) GetName

func (m *CreateClusterMsg) GetName() string

func (*CreateClusterMsg) GetProvider

func (m *CreateClusterMsg) GetProvider() *CreateClusterProviderSpec

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 CreateClusterProviderSpec

type CreateClusterProviderSpec struct {
	// What is the provider - currently this is aws or maas
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The version of Kubernetes
	K8SVersion string `protobuf:"bytes,2,opt,name=k8s_version,json=k8sVersion,proto3" json:"k8s_version,omitempty"`
	// Types that are valid to be assigned to ProviderInformation:
	//	*CreateClusterProviderSpec_Aws
	//	*CreateClusterProviderSpec_Azure
	//	*CreateClusterProviderSpec_Vmware
	//	*CreateClusterProviderSpec_Ssh
	ProviderInformation isCreateClusterProviderSpec_ProviderInformation `protobuf_oneof:"provider_information"`
	// Whether or not the cluster is HA
	HighAvailability bool `protobuf:"varint,5,opt,name=high_availability,json=highAvailability,proto3" json:"high_availability,omitempty"`
	// The fabric to be used
	NetworkFabric        string   `protobuf:"bytes,6,opt,name=network_fabric,json=networkFabric,proto3" json:"network_fabric,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateClusterProviderSpec) Descriptor

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

func (*CreateClusterProviderSpec) GetAws

func (*CreateClusterProviderSpec) GetAzure added in v0.1.1

func (*CreateClusterProviderSpec) GetHighAvailability added in v0.1.1

func (m *CreateClusterProviderSpec) GetHighAvailability() bool

func (*CreateClusterProviderSpec) GetK8SVersion added in v0.1.1

func (m *CreateClusterProviderSpec) GetK8SVersion() string

func (*CreateClusterProviderSpec) GetName

func (m *CreateClusterProviderSpec) GetName() string

func (*CreateClusterProviderSpec) GetNetworkFabric added in v0.1.1

func (m *CreateClusterProviderSpec) GetNetworkFabric() string

func (*CreateClusterProviderSpec) GetProviderInformation added in v0.1.1

func (m *CreateClusterProviderSpec) GetProviderInformation() isCreateClusterProviderSpec_ProviderInformation

func (*CreateClusterProviderSpec) GetSsh added in v0.1.1

func (*CreateClusterProviderSpec) GetVmware added in v0.1.1

func (*CreateClusterProviderSpec) ProtoMessage

func (*CreateClusterProviderSpec) ProtoMessage()

func (*CreateClusterProviderSpec) Reset

func (m *CreateClusterProviderSpec) Reset()

func (*CreateClusterProviderSpec) String

func (m *CreateClusterProviderSpec) String() string

func (*CreateClusterProviderSpec) XXX_DiscardUnknown

func (m *CreateClusterProviderSpec) XXX_DiscardUnknown()

func (*CreateClusterProviderSpec) XXX_Marshal

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

func (*CreateClusterProviderSpec) XXX_Merge

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

func (*CreateClusterProviderSpec) XXX_OneofFuncs added in v0.1.1

func (*CreateClusterProviderSpec) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*CreateClusterProviderSpec) XXX_Size

func (m *CreateClusterProviderSpec) XXX_Size() int

func (*CreateClusterProviderSpec) XXX_Unmarshal

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

type CreateClusterProviderSpec_Aws added in v0.1.1

type CreateClusterProviderSpec_Aws struct {
	Aws *CreateClusterAWSSpec `protobuf:"bytes,3,opt,name=aws,proto3,oneof"`
}

type CreateClusterProviderSpec_Azure added in v0.1.1

type CreateClusterProviderSpec_Azure struct {
	Azure *CreateClusterAKSSpec `protobuf:"bytes,4,opt,name=azure,proto3,oneof"`
}

type CreateClusterProviderSpec_Ssh added in v0.1.1

type CreateClusterProviderSpec_Ssh struct {
	Ssh *CreateClusterSshSpec `protobuf:"bytes,8,opt,name=ssh,proto3,oneof"`
}

type CreateClusterProviderSpec_Vmware added in v0.1.1

type CreateClusterProviderSpec_Vmware struct {
	Vmware *CreateClusterVMWareSpec `protobuf:"bytes,7,opt,name=vmware,proto3,oneof"`
}

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 CreateClusterSshSpec added in v0.1.1

type CreateClusterSshSpec struct {
	// Machines which comprise the cluster
	ControlPlaneNodes []*SshMachineSpec `protobuf:"bytes,3,rep,name=control_plane_nodes,json=controlPlaneNodes,proto3" json:"control_plane_nodes,omitempty"`
	// Machines which comprise the cluster
	WorkerNodes []*SshMachineSpec `protobuf:"bytes,4,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,5,opt,name=api_endpoint,json=apiEndpoint,proto3" json:"api_endpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateClusterSshSpec) Descriptor added in v0.1.1

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

func (*CreateClusterSshSpec) GetApiEndpoint added in v0.1.1

func (m *CreateClusterSshSpec) GetApiEndpoint() string

func (*CreateClusterSshSpec) GetControlPlaneNodes added in v0.1.1

func (m *CreateClusterSshSpec) GetControlPlaneNodes() []*SshMachineSpec

func (*CreateClusterSshSpec) GetWorkerNodes added in v0.1.1

func (m *CreateClusterSshSpec) GetWorkerNodes() []*SshMachineSpec

func (*CreateClusterSshSpec) ProtoMessage added in v0.1.1

func (*CreateClusterSshSpec) ProtoMessage()

func (*CreateClusterSshSpec) Reset added in v0.1.1

func (m *CreateClusterSshSpec) Reset()

func (*CreateClusterSshSpec) String added in v0.1.1

func (m *CreateClusterSshSpec) String() string

func (*CreateClusterSshSpec) XXX_DiscardUnknown added in v0.1.1

func (m *CreateClusterSshSpec) XXX_DiscardUnknown()

func (*CreateClusterSshSpec) XXX_Marshal added in v0.1.1

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

func (*CreateClusterSshSpec) XXX_Merge added in v0.1.1

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

func (*CreateClusterSshSpec) XXX_Size added in v0.1.1

func (m *CreateClusterSshSpec) XXX_Size() int

func (*CreateClusterSshSpec) XXX_Unmarshal added in v0.1.1

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

type CreateClusterVMWareSpec added in v0.1.1

type CreateClusterVMWareSpec struct {
	// Machines which comprise the cluster
	ControlPlaneNodes []*VMWareMachineSpec `protobuf:"bytes,3,rep,name=control_plane_nodes,json=controlPlaneNodes,proto3" json:"control_plane_nodes,omitempty"`
	// Machines which comprise the cluster
	WorkerNodes []*VMWareMachineSpec `protobuf:"bytes,4,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,5,opt,name=api_endpoint,json=apiEndpoint,proto3" json:"api_endpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateClusterVMWareSpec) Descriptor added in v0.1.1

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

func (*CreateClusterVMWareSpec) GetApiEndpoint added in v0.1.1

func (m *CreateClusterVMWareSpec) GetApiEndpoint() string

func (*CreateClusterVMWareSpec) GetControlPlaneNodes added in v0.1.1

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

func (*CreateClusterVMWareSpec) GetWorkerNodes added in v0.1.1

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

func (*CreateClusterVMWareSpec) ProtoMessage added in v0.1.1

func (*CreateClusterVMWareSpec) ProtoMessage()

func (*CreateClusterVMWareSpec) Reset added in v0.1.1

func (m *CreateClusterVMWareSpec) Reset()

func (*CreateClusterVMWareSpec) String added in v0.1.1

func (m *CreateClusterVMWareSpec) String() string

func (*CreateClusterVMWareSpec) XXX_DiscardUnknown added in v0.1.1

func (m *CreateClusterVMWareSpec) XXX_DiscardUnknown()

func (*CreateClusterVMWareSpec) XXX_Marshal added in v0.1.1

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

func (*CreateClusterVMWareSpec) XXX_Merge added in v0.1.1

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

func (*CreateClusterVMWareSpec) XXX_Size added in v0.1.1

func (m *CreateClusterVMWareSpec) XXX_Size() int

func (*CreateClusterVMWareSpec) XXX_Unmarshal added in v0.1.1

func (m *CreateClusterVMWareSpec) 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"`
	// AWS Credentials
	Aws *AWSCredentials `protobuf:"bytes,2,opt,name=aws,proto3" json:"aws,omitempty"`
	// Azure Credentials
	Azure *AzureCredentials `protobuf:"bytes,3,opt,name=azure,proto3" json:"azure,omitempty"`
	// Name of the providers (aws/azure/vmware/etc)
	Provider Provider `protobuf:"varint,4,opt,name=provider,proto3,enum=cluster_manager_api.Provider" json:"provider,omitempty"`
	// Callback information
	Callback             *Callback `protobuf:"bytes,5,opt,name=callback,proto3" json:"callback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeleteClusterMsg) Descriptor

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

func (*DeleteClusterMsg) GetAws added in v0.1.1

func (m *DeleteClusterMsg) GetAws() *AWSCredentials

func (*DeleteClusterMsg) GetAzure added in v0.1.1

func (m *DeleteClusterMsg) GetAzure() *AzureCredentials

func (*DeleteClusterMsg) GetCallback added in v0.1.1

func (m *DeleteClusterMsg) GetCallback() *Callback

func (*DeleteClusterMsg) GetName

func (m *DeleteClusterMsg) GetName() string

func (*DeleteClusterMsg) GetProvider added in v0.1.1

func (m *DeleteClusterMsg) GetProvider() Provider

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 DeleteHelmChartMsg

type DeleteHelmChartMsg struct {
	// Cluster tiller should be installed on
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// What tiller should be used
	PackageManager string `protobuf:"bytes,2,opt,name=package_manager,json=packageManager,proto3" json:"package_manager,omitempty"`
	// Chart Name
	Chart string `protobuf:"bytes,3,opt,name=chart,proto3" json:"chart,omitempty"`
	// AWS Credentials
	Aws *AWSCredentials `protobuf:"bytes,4,opt,name=aws,proto3" json:"aws,omitempty"`
	// Azure Credentials
	Azure *AzureCredentials `protobuf:"bytes,5,opt,name=azure,proto3" json:"azure,omitempty"`
	// Name of the providers (aws/azure/vmware/etc)
	Provider Provider `protobuf:"varint,6,opt,name=provider,proto3,enum=cluster_manager_api.Provider" json:"provider,omitempty"`
	// A unique id to indicate this request
	RequestId string `protobuf:"bytes,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Callback information
	Callback             *Callback `protobuf:"bytes,8,opt,name=callback,proto3" json:"callback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeleteHelmChartMsg) Descriptor

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

func (*DeleteHelmChartMsg) GetAws added in v0.1.1

func (m *DeleteHelmChartMsg) GetAws() *AWSCredentials

func (*DeleteHelmChartMsg) GetAzure added in v0.1.1

func (m *DeleteHelmChartMsg) GetAzure() *AzureCredentials

func (*DeleteHelmChartMsg) GetCallback added in v0.1.1

func (m *DeleteHelmChartMsg) GetCallback() *Callback

func (*DeleteHelmChartMsg) GetChart

func (m *DeleteHelmChartMsg) GetChart() string

func (*DeleteHelmChartMsg) GetCluster

func (m *DeleteHelmChartMsg) GetCluster() string

func (*DeleteHelmChartMsg) GetPackageManager added in v0.1.1

func (m *DeleteHelmChartMsg) GetPackageManager() string

func (*DeleteHelmChartMsg) GetProvider added in v0.1.1

func (m *DeleteHelmChartMsg) GetProvider() Provider

func (*DeleteHelmChartMsg) GetRequestId added in v0.1.1

func (m *DeleteHelmChartMsg) GetRequestId() string

func (*DeleteHelmChartMsg) ProtoMessage

func (*DeleteHelmChartMsg) ProtoMessage()

func (*DeleteHelmChartMsg) Reset

func (m *DeleteHelmChartMsg) Reset()

func (*DeleteHelmChartMsg) String

func (m *DeleteHelmChartMsg) String() string

func (*DeleteHelmChartMsg) XXX_DiscardUnknown

func (m *DeleteHelmChartMsg) XXX_DiscardUnknown()

func (*DeleteHelmChartMsg) XXX_Marshal

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

func (*DeleteHelmChartMsg) XXX_Merge

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

func (*DeleteHelmChartMsg) XXX_Size

func (m *DeleteHelmChartMsg) XXX_Size() int

func (*DeleteHelmChartMsg) XXX_Unmarshal

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

type DeleteHelmChartReply

type DeleteHelmChartReply struct {
	// Was the operation successful
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// What messages were given
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteHelmChartReply) Descriptor

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

func (*DeleteHelmChartReply) GetMessage

func (m *DeleteHelmChartReply) GetMessage() string

func (*DeleteHelmChartReply) GetOk

func (m *DeleteHelmChartReply) GetOk() bool

func (*DeleteHelmChartReply) ProtoMessage

func (*DeleteHelmChartReply) ProtoMessage()

func (*DeleteHelmChartReply) Reset

func (m *DeleteHelmChartReply) Reset()

func (*DeleteHelmChartReply) String

func (m *DeleteHelmChartReply) String() string

func (*DeleteHelmChartReply) XXX_DiscardUnknown

func (m *DeleteHelmChartReply) XXX_DiscardUnknown()

func (*DeleteHelmChartReply) XXX_Marshal

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

func (*DeleteHelmChartReply) XXX_Merge

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

func (*DeleteHelmChartReply) XXX_Size

func (m *DeleteHelmChartReply) XXX_Size() int

func (*DeleteHelmChartReply) XXX_Unmarshal

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

type GenericHelmChart

type GenericHelmChart struct {
	// What is the name of the deployment
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// What is the namespace to deploy the application to
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// What is the chart repository
	Repo *GenericHelmChart_ChartRepository `protobuf:"bytes,3,opt,name=repo,proto3" json:"repo,omitempty"`
	// What is the chart name
	Chart string `protobuf:"bytes,4,opt,name=chart,proto3" json:"chart,omitempty"`
	// What is the chart version
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// What are the options (nested yaml - the Values.yaml contents)
	Values string `protobuf:"bytes,6,opt,name=values,proto3" json:"values,omitempty"`
	// The payload of a chart (for airgapped solutions, etc)
	ChartPayload         []byte   `protobuf:"bytes,7,opt,name=chart_payload,json=chartPayload,proto3" json:"chart_payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GenericHelmChart) Descriptor

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

func (*GenericHelmChart) GetChart

func (m *GenericHelmChart) GetChart() string

func (*GenericHelmChart) GetChartPayload added in v0.1.1

func (m *GenericHelmChart) GetChartPayload() []byte

func (*GenericHelmChart) GetName

func (m *GenericHelmChart) GetName() string

func (*GenericHelmChart) GetNamespace

func (m *GenericHelmChart) GetNamespace() string

func (*GenericHelmChart) GetRepo

func (*GenericHelmChart) GetValues

func (m *GenericHelmChart) GetValues() string

func (*GenericHelmChart) GetVersion added in v0.1.1

func (m *GenericHelmChart) GetVersion() string

func (*GenericHelmChart) ProtoMessage

func (*GenericHelmChart) ProtoMessage()

func (*GenericHelmChart) Reset

func (m *GenericHelmChart) Reset()

func (*GenericHelmChart) String

func (m *GenericHelmChart) String() string

func (*GenericHelmChart) XXX_DiscardUnknown

func (m *GenericHelmChart) XXX_DiscardUnknown()

func (*GenericHelmChart) XXX_Marshal

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

func (*GenericHelmChart) XXX_Merge

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

func (*GenericHelmChart) XXX_Size

func (m *GenericHelmChart) XXX_Size() int

func (*GenericHelmChart) XXX_Unmarshal

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

type GenericHelmChart_ChartRepository added in v0.1.1

type GenericHelmChart_ChartRepository struct {
	// What is the URL for the chart repo
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// What is the repo name
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GenericHelmChart_ChartRepository) Descriptor added in v0.1.1

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

func (*GenericHelmChart_ChartRepository) GetName added in v0.1.1

func (*GenericHelmChart_ChartRepository) GetUrl added in v0.1.1

func (*GenericHelmChart_ChartRepository) ProtoMessage added in v0.1.1

func (*GenericHelmChart_ChartRepository) ProtoMessage()

func (*GenericHelmChart_ChartRepository) Reset added in v0.1.1

func (*GenericHelmChart_ChartRepository) String added in v0.1.1

func (*GenericHelmChart_ChartRepository) XXX_DiscardUnknown added in v0.1.1

func (m *GenericHelmChart_ChartRepository) XXX_DiscardUnknown()

func (*GenericHelmChart_ChartRepository) XXX_Marshal added in v0.1.1

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

func (*GenericHelmChart_ChartRepository) XXX_Merge added in v0.1.1

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

func (*GenericHelmChart_ChartRepository) XXX_Size added in v0.1.1

func (m *GenericHelmChart_ChartRepository) XXX_Size() int

func (*GenericHelmChart_ChartRepository) XXX_Unmarshal added in v0.1.1

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

type GetClusterListMsg

type GetClusterListMsg struct {
	// AWS Credentials
	Aws *AWSCredentials `protobuf:"bytes,1,opt,name=aws,proto3" json:"aws,omitempty"`
	// Azure Credentials
	Azure *AzureCredentials `protobuf:"bytes,2,opt,name=azure,proto3" json:"azure,omitempty"`
	// Name of the providers (aws/azure/vmware/etc)
	Provider             Provider `protobuf:"varint,4,opt,name=provider,proto3,enum=cluster_manager_api.Provider" json:"provider,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClusterListMsg) Descriptor

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

func (*GetClusterListMsg) GetAws added in v0.1.1

func (m *GetClusterListMsg) GetAws() *AWSCredentials

func (*GetClusterListMsg) GetAzure added in v0.1.1

func (m *GetClusterListMsg) GetAzure() *AzureCredentials

func (*GetClusterListMsg) GetProvider added in v0.1.1

func (m *GetClusterListMsg) GetProvider() Provider

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"`
	// AWS Credentials
	Aws *AWSCredentials `protobuf:"bytes,2,opt,name=aws,proto3" json:"aws,omitempty"`
	// Azure Credentials
	Azure *AzureCredentials `protobuf:"bytes,3,opt,name=azure,proto3" json:"azure,omitempty"`
	// Name of the providers (aws/azure/vmware/etc)
	Provider             Provider `protobuf:"varint,4,opt,name=provider,proto3,enum=cluster_manager_api.Provider" json:"provider,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetClusterMsg) Descriptor

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

func (*GetClusterMsg) GetAws added in v0.1.1

func (m *GetClusterMsg) GetAws() *AWSCredentials

func (*GetClusterMsg) GetAzure added in v0.1.1

func (m *GetClusterMsg) GetAzure() *AzureCredentials

func (*GetClusterMsg) GetName

func (m *GetClusterMsg) GetName() string

func (*GetClusterMsg) GetProvider added in v0.1.1

func (m *GetClusterMsg) GetProvider() Provider

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 added in v0.1.1

type GetUpgradeClusterInformationMsg struct {
	// Name of the providers (aws/azure/vmware/etc)
	Provider Provider `protobuf:"varint,1,opt,name=provider,proto3,enum=cluster_manager_api.Provider" json:"provider,omitempty"`
	// AWS Credentials
	Aws *AWSCredentials `protobuf:"bytes,2,opt,name=aws,proto3" json:"aws,omitempty"`
	// Azure Credentials
	Azure *AzureCredentials `protobuf:"bytes,3,opt,name=azure,proto3" json:"azure,omitempty"`
	// What is the cluster that we are considering for upgrade
	Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetUpgradeClusterInformationMsg) Descriptor added in v0.1.1

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

func (*GetUpgradeClusterInformationMsg) GetAws added in v0.1.1

func (*GetUpgradeClusterInformationMsg) GetAzure added in v0.1.1

func (*GetUpgradeClusterInformationMsg) GetName added in v0.1.1

func (*GetUpgradeClusterInformationMsg) GetProvider added in v0.1.1

func (m *GetUpgradeClusterInformationMsg) GetProvider() Provider

func (*GetUpgradeClusterInformationMsg) ProtoMessage added in v0.1.1

func (*GetUpgradeClusterInformationMsg) ProtoMessage()

func (*GetUpgradeClusterInformationMsg) Reset added in v0.1.1

func (*GetUpgradeClusterInformationMsg) String added in v0.1.1

func (*GetUpgradeClusterInformationMsg) XXX_DiscardUnknown added in v0.1.1

func (m *GetUpgradeClusterInformationMsg) XXX_DiscardUnknown()

func (*GetUpgradeClusterInformationMsg) XXX_Marshal added in v0.1.1

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

func (*GetUpgradeClusterInformationMsg) XXX_Merge added in v0.1.1

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

func (*GetUpgradeClusterInformationMsg) XXX_Size added in v0.1.1

func (m *GetUpgradeClusterInformationMsg) XXX_Size() int

func (*GetUpgradeClusterInformationMsg) XXX_Unmarshal added in v0.1.1

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

type GetUpgradeClusterInformationReply added in v0.1.1

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 added in v0.1.1

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

func (*GetUpgradeClusterInformationReply) GetOk added in v0.1.1

func (*GetUpgradeClusterInformationReply) GetVersions added in v0.1.1

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

func (*GetUpgradeClusterInformationReply) ProtoMessage added in v0.1.1

func (*GetUpgradeClusterInformationReply) ProtoMessage()

func (*GetUpgradeClusterInformationReply) Reset added in v0.1.1

func (*GetUpgradeClusterInformationReply) String added in v0.1.1

func (*GetUpgradeClusterInformationReply) XXX_DiscardUnknown added in v0.1.1

func (m *GetUpgradeClusterInformationReply) XXX_DiscardUnknown()

func (*GetUpgradeClusterInformationReply) XXX_Marshal added in v0.1.1

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

func (*GetUpgradeClusterInformationReply) XXX_Merge added in v0.1.1

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

func (*GetUpgradeClusterInformationReply) XXX_Size added in v0.1.1

func (m *GetUpgradeClusterInformationReply) XXX_Size() int

func (*GetUpgradeClusterInformationReply) XXX_Unmarshal added in v0.1.1

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

type GetVersionMsg added in v0.1.1

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

Get version of API Server

func (*GetVersionMsg) Descriptor added in v0.1.1

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

func (*GetVersionMsg) ProtoMessage added in v0.1.1

func (*GetVersionMsg) ProtoMessage()

func (*GetVersionMsg) Reset added in v0.1.1

func (m *GetVersionMsg) Reset()

func (*GetVersionMsg) String added in v0.1.1

func (m *GetVersionMsg) String() string

func (*GetVersionMsg) XXX_DiscardUnknown added in v0.1.1

func (m *GetVersionMsg) XXX_DiscardUnknown()

func (*GetVersionMsg) XXX_Marshal added in v0.1.1

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

func (*GetVersionMsg) XXX_Merge added in v0.1.1

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

func (*GetVersionMsg) XXX_Size added in v0.1.1

func (m *GetVersionMsg) XXX_Size() int

func (*GetVersionMsg) XXX_Unmarshal added in v0.1.1

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

type GetVersionReply added in v0.1.1

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 added in v0.1.1

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

func (*GetVersionReply) GetOk added in v0.1.1

func (m *GetVersionReply) GetOk() bool

func (*GetVersionReply) GetVersionInformation added in v0.1.1

func (m *GetVersionReply) GetVersionInformation() *GetVersionReply_VersionInformation

func (*GetVersionReply) ProtoMessage added in v0.1.1

func (*GetVersionReply) ProtoMessage()

func (*GetVersionReply) Reset added in v0.1.1

func (m *GetVersionReply) Reset()

func (*GetVersionReply) String added in v0.1.1

func (m *GetVersionReply) String() string

func (*GetVersionReply) XXX_DiscardUnknown added in v0.1.1

func (m *GetVersionReply) XXX_DiscardUnknown()

func (*GetVersionReply) XXX_Marshal added in v0.1.1

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

func (*GetVersionReply) XXX_Merge added in v0.1.1

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

func (*GetVersionReply) XXX_Size added in v0.1.1

func (m *GetVersionReply) XXX_Size() int

func (*GetVersionReply) XXX_Unmarshal added in v0.1.1

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

type GetVersionReply_VersionInformation added in v0.1.1

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 added in v0.1.1

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

func (*GetVersionReply_VersionInformation) GetBuildDate added in v0.1.1

func (m *GetVersionReply_VersionInformation) GetBuildDate() string

func (*GetVersionReply_VersionInformation) GetCompiler added in v0.1.1

func (m *GetVersionReply_VersionInformation) GetCompiler() string

func (*GetVersionReply_VersionInformation) GetGitCommit added in v0.1.1

func (m *GetVersionReply_VersionInformation) GetGitCommit() string

func (*GetVersionReply_VersionInformation) GetGitTreeState added in v0.1.1

func (m *GetVersionReply_VersionInformation) GetGitTreeState() string

func (*GetVersionReply_VersionInformation) GetGitVersion added in v0.1.1

func (m *GetVersionReply_VersionInformation) GetGitVersion() string

func (*GetVersionReply_VersionInformation) GetGoVersion added in v0.1.1

func (m *GetVersionReply_VersionInformation) GetGoVersion() string

func (*GetVersionReply_VersionInformation) GetPlatform added in v0.1.1

func (m *GetVersionReply_VersionInformation) GetPlatform() string

func (*GetVersionReply_VersionInformation) ProtoMessage added in v0.1.1

func (*GetVersionReply_VersionInformation) ProtoMessage()

func (*GetVersionReply_VersionInformation) Reset added in v0.1.1

func (*GetVersionReply_VersionInformation) String added in v0.1.1

func (*GetVersionReply_VersionInformation) XXX_DiscardUnknown added in v0.1.1

func (m *GetVersionReply_VersionInformation) XXX_DiscardUnknown()

func (*GetVersionReply_VersionInformation) XXX_Marshal added in v0.1.1

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

func (*GetVersionReply_VersionInformation) XXX_Merge added in v0.1.1

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

func (*GetVersionReply_VersionInformation) XXX_Size added in v0.1.1

func (*GetVersionReply_VersionInformation) XXX_Unmarshal added in v0.1.1

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

type InstallHelmChartMsg

type InstallHelmChartMsg struct {
	// Cluster tiller should be installed on
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// What tiller should be used
	PackageManger string `protobuf:"bytes,2,opt,name=package_manger,json=packageManger,proto3" json:"package_manger,omitempty"`
	// Chart Settings
	Chart *GenericHelmChart `protobuf:"bytes,3,opt,name=chart,proto3" json:"chart,omitempty"`
	// AWS Credentials
	Aws *AWSCredentials `protobuf:"bytes,4,opt,name=aws,proto3" json:"aws,omitempty"`
	// Azure Credentials
	Azure *AzureCredentials `protobuf:"bytes,5,opt,name=azure,proto3" json:"azure,omitempty"`
	// Name of the providers (aws/azure/vmware/etc)
	Provider Provider `protobuf:"varint,6,opt,name=provider,proto3,enum=cluster_manager_api.Provider" json:"provider,omitempty"`
	// Callback information
	Callback             *Callback `protobuf:"bytes,7,opt,name=callback,proto3" json:"callback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*InstallHelmChartMsg) Descriptor

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

func (*InstallHelmChartMsg) GetAws added in v0.1.1

func (m *InstallHelmChartMsg) GetAws() *AWSCredentials

func (*InstallHelmChartMsg) GetAzure added in v0.1.1

func (m *InstallHelmChartMsg) GetAzure() *AzureCredentials

func (*InstallHelmChartMsg) GetCallback added in v0.1.1

func (m *InstallHelmChartMsg) GetCallback() *Callback

func (*InstallHelmChartMsg) GetChart

func (m *InstallHelmChartMsg) GetChart() *GenericHelmChart

func (*InstallHelmChartMsg) GetCluster

func (m *InstallHelmChartMsg) GetCluster() string

func (*InstallHelmChartMsg) GetPackageManger added in v0.1.1

func (m *InstallHelmChartMsg) GetPackageManger() string

func (*InstallHelmChartMsg) GetProvider added in v0.1.1

func (m *InstallHelmChartMsg) GetProvider() Provider

func (*InstallHelmChartMsg) ProtoMessage

func (*InstallHelmChartMsg) ProtoMessage()

func (*InstallHelmChartMsg) Reset

func (m *InstallHelmChartMsg) Reset()

func (*InstallHelmChartMsg) String

func (m *InstallHelmChartMsg) String() string

func (*InstallHelmChartMsg) XXX_DiscardUnknown

func (m *InstallHelmChartMsg) XXX_DiscardUnknown()

func (*InstallHelmChartMsg) XXX_Marshal

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

func (*InstallHelmChartMsg) XXX_Merge

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

func (*InstallHelmChartMsg) XXX_Size

func (m *InstallHelmChartMsg) XXX_Size() int

func (*InstallHelmChartMsg) XXX_Unmarshal

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

type InstallHelmChartReply

type InstallHelmChartReply struct {
	// Was the operation successful
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// What messages were given
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InstallHelmChartReply) Descriptor

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

func (*InstallHelmChartReply) GetMessage

func (m *InstallHelmChartReply) GetMessage() string

func (*InstallHelmChartReply) GetOk

func (m *InstallHelmChartReply) GetOk() bool

func (*InstallHelmChartReply) ProtoMessage

func (*InstallHelmChartReply) ProtoMessage()

func (*InstallHelmChartReply) Reset

func (m *InstallHelmChartReply) Reset()

func (*InstallHelmChartReply) String

func (m *InstallHelmChartReply) String() string

func (*InstallHelmChartReply) XXX_DiscardUnknown

func (m *InstallHelmChartReply) XXX_DiscardUnknown()

func (*InstallHelmChartReply) XXX_Marshal

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

func (*InstallHelmChartReply) XXX_Merge

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

func (*InstallHelmChartReply) XXX_Size

func (m *InstallHelmChartReply) XXX_Size() int

func (*InstallHelmChartReply) XXX_Unmarshal

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

type KubernetesLabel added in v0.1.1

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 added in v0.1.1

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

func (*KubernetesLabel) GetName added in v0.1.1

func (m *KubernetesLabel) GetName() string

func (*KubernetesLabel) GetValue added in v0.1.1

func (m *KubernetesLabel) GetValue() string

func (*KubernetesLabel) ProtoMessage added in v0.1.1

func (*KubernetesLabel) ProtoMessage()

func (*KubernetesLabel) Reset added in v0.1.1

func (m *KubernetesLabel) Reset()

func (*KubernetesLabel) String added in v0.1.1

func (m *KubernetesLabel) String() string

func (*KubernetesLabel) XXX_DiscardUnknown added in v0.1.1

func (m *KubernetesLabel) XXX_DiscardUnknown()

func (*KubernetesLabel) XXX_Marshal added in v0.1.1

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

func (*KubernetesLabel) XXX_Merge added in v0.1.1

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

func (*KubernetesLabel) XXX_Size added in v0.1.1

func (m *KubernetesLabel) XXX_Size() int

func (*KubernetesLabel) XXX_Unmarshal added in v0.1.1

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

type Provider added in v0.1.1

type Provider int32
const (
	Provider_undefined Provider = 0
	Provider_aws       Provider = 1
	Provider_azure     Provider = 2
	Provider_vmware    Provider = 3
	Provider_ssh       Provider = 4
)

func (Provider) EnumDescriptor added in v0.1.1

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

func (Provider) String added in v0.1.1

func (x Provider) String() string

type ProvisionTillerMsg

type ProvisionTillerMsg struct {
	// Name of the tiller / package manager
	Name string `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster tiller should be installed on
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Namespace tiller should be installed in
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// image (if not the default) for tiller (quay.io/someguy/tiller)
	Image string `protobuf:"bytes,11,opt,name=image,proto3" json:"image,omitempty"`
	// Version of tiller/helm to install / upgrade to (v2.11.0, etc)
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// Is the tiller a cluster-wide tiller?
	// Should it have cluster-wide admin privileges?
	ClusterWide bool `protobuf:"varint,4,opt,name=cluster_wide,json=clusterWide,proto3" json:"cluster_wide,omitempty"`
	// Namespaces that it should be able to admin on
	AdminNamespaces []string `protobuf:"bytes,5,rep,name=admin_namespaces,json=adminNamespaces,proto3" json:"admin_namespaces,omitempty"`
	// AWS Credentials
	Aws *AWSCredentials `protobuf:"bytes,6,opt,name=aws,proto3" json:"aws,omitempty"`
	// Azure Credentials
	Azure *AzureCredentials `protobuf:"bytes,7,opt,name=azure,proto3" json:"azure,omitempty"`
	// Name of the providers (aws/azure/vmware/etc)
	Provider Provider `protobuf:"varint,8,opt,name=provider,proto3,enum=cluster_manager_api.Provider" json:"provider,omitempty"`
	// Callback information
	Callback             *Callback `protobuf:"bytes,9,opt,name=callback,proto3" json:"callback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ProvisionTillerMsg) Descriptor

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

func (*ProvisionTillerMsg) GetAdminNamespaces

func (m *ProvisionTillerMsg) GetAdminNamespaces() []string

func (*ProvisionTillerMsg) GetAws added in v0.1.1

func (m *ProvisionTillerMsg) GetAws() *AWSCredentials

func (*ProvisionTillerMsg) GetAzure added in v0.1.1

func (m *ProvisionTillerMsg) GetAzure() *AzureCredentials

func (*ProvisionTillerMsg) GetCallback added in v0.1.1

func (m *ProvisionTillerMsg) GetCallback() *Callback

func (*ProvisionTillerMsg) GetCluster

func (m *ProvisionTillerMsg) GetCluster() string

func (*ProvisionTillerMsg) GetClusterWide

func (m *ProvisionTillerMsg) GetClusterWide() bool

func (*ProvisionTillerMsg) GetImage added in v0.1.1

func (m *ProvisionTillerMsg) GetImage() string

func (*ProvisionTillerMsg) GetName added in v0.1.1

func (m *ProvisionTillerMsg) GetName() string

func (*ProvisionTillerMsg) GetNamespace

func (m *ProvisionTillerMsg) GetNamespace() string

func (*ProvisionTillerMsg) GetProvider added in v0.1.1

func (m *ProvisionTillerMsg) GetProvider() Provider

func (*ProvisionTillerMsg) GetVersion

func (m *ProvisionTillerMsg) GetVersion() string

func (*ProvisionTillerMsg) ProtoMessage

func (*ProvisionTillerMsg) ProtoMessage()

func (*ProvisionTillerMsg) Reset

func (m *ProvisionTillerMsg) Reset()

func (*ProvisionTillerMsg) String

func (m *ProvisionTillerMsg) String() string

func (*ProvisionTillerMsg) XXX_DiscardUnknown

func (m *ProvisionTillerMsg) XXX_DiscardUnknown()

func (*ProvisionTillerMsg) XXX_Marshal

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

func (*ProvisionTillerMsg) XXX_Merge

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

func (*ProvisionTillerMsg) XXX_Size

func (m *ProvisionTillerMsg) XXX_Size() int

func (*ProvisionTillerMsg) XXX_Unmarshal

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

type ProvisionTillerReply

type ProvisionTillerReply struct {
	// Was the operation successful
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// What messages were given
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProvisionTillerReply) Descriptor

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

func (*ProvisionTillerReply) GetMessage

func (m *ProvisionTillerReply) GetMessage() string

func (*ProvisionTillerReply) GetOk

func (m *ProvisionTillerReply) GetOk() bool

func (*ProvisionTillerReply) ProtoMessage

func (*ProvisionTillerReply) ProtoMessage()

func (*ProvisionTillerReply) Reset

func (m *ProvisionTillerReply) Reset()

func (*ProvisionTillerReply) String

func (m *ProvisionTillerReply) String() string

func (*ProvisionTillerReply) XXX_DiscardUnknown

func (m *ProvisionTillerReply) XXX_DiscardUnknown()

func (*ProvisionTillerReply) XXX_Marshal

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

func (*ProvisionTillerReply) XXX_Merge

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

func (*ProvisionTillerReply) XXX_Size

func (m *ProvisionTillerReply) XXX_Size() int

func (*ProvisionTillerReply) XXX_Unmarshal

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

type SshMachineSpec added in v0.1.1

type SshMachineSpec 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 k8s version for the control plane. This node is only a master if this field is defined.
	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 (*SshMachineSpec) Descriptor added in v0.1.1

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

func (*SshMachineSpec) GetHost added in v0.1.1

func (m *SshMachineSpec) GetHost() string

func (*SshMachineSpec) GetLabels added in v0.1.1

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

func (*SshMachineSpec) GetPassword added in v0.1.1

func (m *SshMachineSpec) GetPassword() string

func (*SshMachineSpec) GetPort added in v0.1.1

func (m *SshMachineSpec) GetPort() int32

func (*SshMachineSpec) GetUsername added in v0.1.1

func (m *SshMachineSpec) GetUsername() string

func (*SshMachineSpec) ProtoMessage added in v0.1.1

func (*SshMachineSpec) ProtoMessage()

func (*SshMachineSpec) Reset added in v0.1.1

func (m *SshMachineSpec) Reset()

func (*SshMachineSpec) String added in v0.1.1

func (m *SshMachineSpec) String() string

func (*SshMachineSpec) XXX_DiscardUnknown added in v0.1.1

func (m *SshMachineSpec) XXX_DiscardUnknown()

func (*SshMachineSpec) XXX_Marshal added in v0.1.1

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

func (*SshMachineSpec) XXX_Merge added in v0.1.1

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

func (*SshMachineSpec) XXX_Size added in v0.1.1

func (m *SshMachineSpec) XXX_Size() int

func (*SshMachineSpec) XXX_Unmarshal added in v0.1.1

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

type UpdateAWSCredentialsMsg added in v0.1.1

type UpdateAWSCredentialsMsg struct {
	// Cluster name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Credentials to build the cluster
	Credentials          *AWSCredentials `protobuf:"bytes,2,opt,name=credentials,proto3" json:"credentials,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*UpdateAWSCredentialsMsg) Descriptor added in v0.1.1

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

func (*UpdateAWSCredentialsMsg) GetCredentials added in v0.1.1

func (m *UpdateAWSCredentialsMsg) GetCredentials() *AWSCredentials

func (*UpdateAWSCredentialsMsg) GetName added in v0.1.1

func (m *UpdateAWSCredentialsMsg) GetName() string

func (*UpdateAWSCredentialsMsg) ProtoMessage added in v0.1.1

func (*UpdateAWSCredentialsMsg) ProtoMessage()

func (*UpdateAWSCredentialsMsg) Reset added in v0.1.1

func (m *UpdateAWSCredentialsMsg) Reset()

func (*UpdateAWSCredentialsMsg) String added in v0.1.1

func (m *UpdateAWSCredentialsMsg) String() string

func (*UpdateAWSCredentialsMsg) XXX_DiscardUnknown added in v0.1.1

func (m *UpdateAWSCredentialsMsg) XXX_DiscardUnknown()

func (*UpdateAWSCredentialsMsg) XXX_Marshal added in v0.1.1

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

func (*UpdateAWSCredentialsMsg) XXX_Merge added in v0.1.1

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

func (*UpdateAWSCredentialsMsg) XXX_Size added in v0.1.1

func (m *UpdateAWSCredentialsMsg) XXX_Size() int

func (*UpdateAWSCredentialsMsg) XXX_Unmarshal added in v0.1.1

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

type UpdateAWSCredentialsReply added in v0.1.1

type UpdateAWSCredentialsReply 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 (*UpdateAWSCredentialsReply) Descriptor added in v0.1.1

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

func (*UpdateAWSCredentialsReply) GetOk added in v0.1.1

func (m *UpdateAWSCredentialsReply) GetOk() bool

func (*UpdateAWSCredentialsReply) ProtoMessage added in v0.1.1

func (*UpdateAWSCredentialsReply) ProtoMessage()

func (*UpdateAWSCredentialsReply) Reset added in v0.1.1

func (m *UpdateAWSCredentialsReply) Reset()

func (*UpdateAWSCredentialsReply) String added in v0.1.1

func (m *UpdateAWSCredentialsReply) String() string

func (*UpdateAWSCredentialsReply) XXX_DiscardUnknown added in v0.1.1

func (m *UpdateAWSCredentialsReply) XXX_DiscardUnknown()

func (*UpdateAWSCredentialsReply) XXX_Marshal added in v0.1.1

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

func (*UpdateAWSCredentialsReply) XXX_Merge added in v0.1.1

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

func (*UpdateAWSCredentialsReply) XXX_Size added in v0.1.1

func (m *UpdateAWSCredentialsReply) XXX_Size() int

func (*UpdateAWSCredentialsReply) XXX_Unmarshal added in v0.1.1

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

type UpdateAzureCredentialsMsg added in v0.1.1

type UpdateAzureCredentialsMsg struct {
	// Cluster name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Credentials to build the cluster
	Credentials          *AzureCredentials `protobuf:"bytes,2,opt,name=credentials,proto3" json:"credentials,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UpdateAzureCredentialsMsg) Descriptor added in v0.1.1

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

func (*UpdateAzureCredentialsMsg) GetCredentials added in v0.1.1

func (m *UpdateAzureCredentialsMsg) GetCredentials() *AzureCredentials

func (*UpdateAzureCredentialsMsg) GetName added in v0.1.1

func (m *UpdateAzureCredentialsMsg) GetName() string

func (*UpdateAzureCredentialsMsg) ProtoMessage added in v0.1.1

func (*UpdateAzureCredentialsMsg) ProtoMessage()

func (*UpdateAzureCredentialsMsg) Reset added in v0.1.1

func (m *UpdateAzureCredentialsMsg) Reset()

func (*UpdateAzureCredentialsMsg) String added in v0.1.1

func (m *UpdateAzureCredentialsMsg) String() string

func (*UpdateAzureCredentialsMsg) XXX_DiscardUnknown added in v0.1.1

func (m *UpdateAzureCredentialsMsg) XXX_DiscardUnknown()

func (*UpdateAzureCredentialsMsg) XXX_Marshal added in v0.1.1

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

func (*UpdateAzureCredentialsMsg) XXX_Merge added in v0.1.1

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

func (*UpdateAzureCredentialsMsg) XXX_Size added in v0.1.1

func (m *UpdateAzureCredentialsMsg) XXX_Size() int

func (*UpdateAzureCredentialsMsg) XXX_Unmarshal added in v0.1.1

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

type UpdateAzureCredentialsReply added in v0.1.1

type UpdateAzureCredentialsReply 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 (*UpdateAzureCredentialsReply) Descriptor added in v0.1.1

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

func (*UpdateAzureCredentialsReply) GetOk added in v0.1.1

func (m *UpdateAzureCredentialsReply) GetOk() bool

func (*UpdateAzureCredentialsReply) ProtoMessage added in v0.1.1

func (*UpdateAzureCredentialsReply) ProtoMessage()

func (*UpdateAzureCredentialsReply) Reset added in v0.1.1

func (m *UpdateAzureCredentialsReply) Reset()

func (*UpdateAzureCredentialsReply) String added in v0.1.1

func (m *UpdateAzureCredentialsReply) String() string

func (*UpdateAzureCredentialsReply) XXX_DiscardUnknown added in v0.1.1

func (m *UpdateAzureCredentialsReply) XXX_DiscardUnknown()

func (*UpdateAzureCredentialsReply) XXX_Marshal added in v0.1.1

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

func (*UpdateAzureCredentialsReply) XXX_Merge added in v0.1.1

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

func (*UpdateAzureCredentialsReply) XXX_Size added in v0.1.1

func (m *UpdateAzureCredentialsReply) XXX_Size() int

func (*UpdateAzureCredentialsReply) XXX_Unmarshal added in v0.1.1

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

type UpgradeClusterMsg added in v0.1.1

type UpgradeClusterMsg struct {
	// Name of the providers (aws/azure/vmware/etc)
	Provider Provider `protobuf:"varint,1,opt,name=provider,proto3,enum=cluster_manager_api.Provider" json:"provider,omitempty"`
	// AWS Credentials
	Aws *AWSCredentials `protobuf:"bytes,2,opt,name=aws,proto3" json:"aws,omitempty"`
	// Azure Credentials
	Azure *AzureCredentials `protobuf:"bytes,3,opt,name=azure,proto3" json:"azure,omitempty"`
	// What is the cluster that we are considering for upgrade
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// What version are we upgrading to?
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// Callback information
	Callback             *Callback `protobuf:"bytes,6,opt,name=callback,proto3" json:"callback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*UpgradeClusterMsg) Descriptor added in v0.1.1

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

func (*UpgradeClusterMsg) GetAws added in v0.1.1

func (m *UpgradeClusterMsg) GetAws() *AWSCredentials

func (*UpgradeClusterMsg) GetAzure added in v0.1.1

func (m *UpgradeClusterMsg) GetAzure() *AzureCredentials

func (*UpgradeClusterMsg) GetCallback added in v0.1.1

func (m *UpgradeClusterMsg) GetCallback() *Callback

func (*UpgradeClusterMsg) GetName added in v0.1.1

func (m *UpgradeClusterMsg) GetName() string

func (*UpgradeClusterMsg) GetProvider added in v0.1.1

func (m *UpgradeClusterMsg) GetProvider() Provider

func (*UpgradeClusterMsg) GetVersion added in v0.1.1

func (m *UpgradeClusterMsg) GetVersion() string

func (*UpgradeClusterMsg) ProtoMessage added in v0.1.1

func (*UpgradeClusterMsg) ProtoMessage()

func (*UpgradeClusterMsg) Reset added in v0.1.1

func (m *UpgradeClusterMsg) Reset()

func (*UpgradeClusterMsg) String added in v0.1.1

func (m *UpgradeClusterMsg) String() string

func (*UpgradeClusterMsg) XXX_DiscardUnknown added in v0.1.1

func (m *UpgradeClusterMsg) XXX_DiscardUnknown()

func (*UpgradeClusterMsg) XXX_Marshal added in v0.1.1

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

func (*UpgradeClusterMsg) XXX_Merge added in v0.1.1

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

func (*UpgradeClusterMsg) XXX_Size added in v0.1.1

func (m *UpgradeClusterMsg) XXX_Size() int

func (*UpgradeClusterMsg) XXX_Unmarshal added in v0.1.1

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

type UpgradeClusterReply added in v0.1.1

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 added in v0.1.1

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

func (*UpgradeClusterReply) GetOk added in v0.1.1

func (m *UpgradeClusterReply) GetOk() bool

func (*UpgradeClusterReply) ProtoMessage added in v0.1.1

func (*UpgradeClusterReply) ProtoMessage()

func (*UpgradeClusterReply) Reset added in v0.1.1

func (m *UpgradeClusterReply) Reset()

func (*UpgradeClusterReply) String added in v0.1.1

func (m *UpgradeClusterReply) String() string

func (*UpgradeClusterReply) XXX_DiscardUnknown added in v0.1.1

func (m *UpgradeClusterReply) XXX_DiscardUnknown()

func (*UpgradeClusterReply) XXX_Marshal added in v0.1.1

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

func (*UpgradeClusterReply) XXX_Merge added in v0.1.1

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

func (*UpgradeClusterReply) XXX_Size added in v0.1.1

func (m *UpgradeClusterReply) XXX_Size() int

func (*UpgradeClusterReply) XXX_Unmarshal added in v0.1.1

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

type VMWareMachineSpec added in v0.1.1

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 k8s version for the control plane. This node is only a master if this field is defined.
	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 added in v0.1.1

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

func (*VMWareMachineSpec) GetHost added in v0.1.1

func (m *VMWareMachineSpec) GetHost() string

func (*VMWareMachineSpec) GetLabels added in v0.1.1

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

func (*VMWareMachineSpec) GetPassword added in v0.1.1

func (m *VMWareMachineSpec) GetPassword() string

func (*VMWareMachineSpec) GetPort added in v0.1.1

func (m *VMWareMachineSpec) GetPort() int32

func (*VMWareMachineSpec) GetUsername added in v0.1.1

func (m *VMWareMachineSpec) GetUsername() string

func (*VMWareMachineSpec) ProtoMessage added in v0.1.1

func (*VMWareMachineSpec) ProtoMessage()

func (*VMWareMachineSpec) Reset added in v0.1.1

func (m *VMWareMachineSpec) Reset()

func (*VMWareMachineSpec) String added in v0.1.1

func (m *VMWareMachineSpec) String() string

func (*VMWareMachineSpec) XXX_DiscardUnknown added in v0.1.1

func (m *VMWareMachineSpec) XXX_DiscardUnknown()

func (*VMWareMachineSpec) XXX_Marshal added in v0.1.1

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

func (*VMWareMachineSpec) XXX_Merge added in v0.1.1

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

func (*VMWareMachineSpec) XXX_Size added in v0.1.1

func (m *VMWareMachineSpec) XXX_Size() int

func (*VMWareMachineSpec) XXX_Unmarshal added in v0.1.1

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