cmaaks

package
v0.0.0-...-3f274de Latest Latest
Warning

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

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

Documentation

Overview

Package cmaaks is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterClusterHandler 

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

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

func RegisterClusterHandlerClient 

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

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

func RegisterClusterHandlerFromEndpoint 

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

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

func RegisterClusterServer 

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

Types

type AzureClusterServiceAccount 

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 

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

func (*AzureClusterServiceAccount) GetClientId 

func (m *AzureClusterServiceAccount) GetClientId() string

func (*AzureClusterServiceAccount) GetClientSecret 

func (m *AzureClusterServiceAccount) GetClientSecret() string

func (*AzureClusterServiceAccount) ProtoMessage 

func (*AzureClusterServiceAccount) ProtoMessage()

func (*AzureClusterServiceAccount) Reset 

func (m *AzureClusterServiceAccount) Reset()

func (*AzureClusterServiceAccount) String 

func (m *AzureClusterServiceAccount) String() string

func (*AzureClusterServiceAccount) XXX_DiscardUnknown 

func (m *AzureClusterServiceAccount) XXX_DiscardUnknown()

func (*AzureClusterServiceAccount) XXX_Marshal 

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

func (*AzureClusterServiceAccount) XXX_Merge 

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

func (*AzureClusterServiceAccount) XXX_Size 

func (m *AzureClusterServiceAccount) XXX_Size() int

func (*AzureClusterServiceAccount) XXX_Unmarshal 

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

type AzureCredentials 

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 

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

func (*AzureCredentials) GetAppId 

func (m *AzureCredentials) GetAppId() string

func (*AzureCredentials) GetPassword 

func (m *AzureCredentials) GetPassword() string

func (*AzureCredentials) GetSubscriptionId 

func (m *AzureCredentials) GetSubscriptionId() string

func (*AzureCredentials) GetTenant 

func (m *AzureCredentials) GetTenant() string

func (*AzureCredentials) ProtoMessage 

func (*AzureCredentials) ProtoMessage()

func (*AzureCredentials) Reset 

func (m *AzureCredentials) Reset()

func (*AzureCredentials) String 

func (m *AzureCredentials) String() string

func (*AzureCredentials) XXX_DiscardUnknown 

func (m *AzureCredentials) XXX_DiscardUnknown()

func (*AzureCredentials) XXX_Marshal 

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

func (*AzureCredentials) XXX_Merge 

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

func (*AzureCredentials) XXX_Size 

func (m *AzureCredentials) XXX_Size() int

func (*AzureCredentials) XXX_Unmarshal 

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

type ClusterClient 

type ClusterClient interface {
	// Will provision a cluster
	CreateCluster(ctx context.Context, in *CreateClusterMsg, opts ...grpc.CallOption) (*CreateClusterReply, error)
	// Will retrieve the status of a cluster and its kubeconfig for connectivity
	GetCluster(ctx context.Context, in *GetClusterMsg, opts ...grpc.CallOption) (*GetClusterReply, error)
	// Will delete a cluster
	DeleteCluster(ctx context.Context, in *DeleteClusterMsg, opts ...grpc.CallOption) (*DeleteClusterReply, error)
	// Will retrieve a list of clusters
	GetClusterList(ctx context.Context, in *GetClusterListMsg, opts ...grpc.CallOption) (*GetClusterListReply, error)
	// Will return version information about api server
	GetVersionInformation(ctx context.Context, in *GetVersionMsg, opts ...grpc.CallOption) (*GetVersionReply, error)
	// Will retrieve available upgrades of a cluster
	GetClusterUpgrades(ctx context.Context, in *GetClusterUpgradesMsg, opts ...grpc.CallOption) (*GetClusterUpgradesReply, error)
	// Will upgrade a cluster
	UpgradeCluster(ctx context.Context, in *UpgradeClusterMsg, opts ...grpc.CallOption) (*UpgradeClusterReply, error)
	// Will retrieve node count
	GetClusterNodeCount(ctx context.Context, in *GetClusterNodeCountMsg, opts ...grpc.CallOption) (*GetClusterNodeCountReply, error)
	// Will scale a clusters node count
	ScaleCluster(ctx context.Context, in *ScaleClusterMsg, opts ...grpc.CallOption) (*ScaleClusterReply, error)
	// Will enable cluster autoscaling
	EnableClusterAutoscaling(ctx context.Context, in *EnableClusterAutoscalingMsg, opts ...grpc.CallOption) (*EnableClusterAutoscalingReply, 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=cmaaks.ClusterStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ClusterDetailItem) Descriptor 

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

func (*ClusterDetailItem) GetId 

func (m *ClusterDetailItem) GetId() string

func (*ClusterDetailItem) GetKubeconfig 

func (m *ClusterDetailItem) GetKubeconfig() string

func (*ClusterDetailItem) GetName 

func (m *ClusterDetailItem) GetName() string

func (*ClusterDetailItem) GetStatus 

func (m *ClusterDetailItem) GetStatus() ClusterStatus

func (*ClusterDetailItem) GetStatusMessage 

func (m *ClusterDetailItem) GetStatusMessage() string

func (*ClusterDetailItem) ProtoMessage 

func (*ClusterDetailItem) ProtoMessage()

func (*ClusterDetailItem) Reset 

func (m *ClusterDetailItem) Reset()

func (*ClusterDetailItem) String 

func (m *ClusterDetailItem) String() string

func (*ClusterDetailItem) XXX_DiscardUnknown 

func (m *ClusterDetailItem) XXX_DiscardUnknown()

func (*ClusterDetailItem) XXX_Marshal 

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

func (*ClusterDetailItem) XXX_Merge 

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

func (*ClusterDetailItem) XXX_Size 

func (m *ClusterDetailItem) XXX_Size() int

func (*ClusterDetailItem) XXX_Unmarshal 

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

type ClusterItem 

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

func (*ClusterItem) Descriptor 

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

func (*ClusterItem) GetId 

func (m *ClusterItem) GetId() string

func (*ClusterItem) GetName 

func (m *ClusterItem) GetName() string

func (*ClusterItem) GetStatus 

func (m *ClusterItem) GetStatus() ClusterStatus

func (*ClusterItem) GetStatusMessage 

func (m *ClusterItem) GetStatusMessage() string

func (*ClusterItem) ProtoMessage 

func (*ClusterItem) ProtoMessage()

func (*ClusterItem) Reset 

func (m *ClusterItem) Reset()

func (*ClusterItem) String 

func (m *ClusterItem) String() string

func (*ClusterItem) XXX_DiscardUnknown 

func (m *ClusterItem) XXX_DiscardUnknown()

func (*ClusterItem) XXX_Marshal 

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

func (*ClusterItem) XXX_Merge 

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

func (*ClusterItem) XXX_Size 

func (m *ClusterItem) XXX_Size() int

func (*ClusterItem) XXX_Unmarshal 

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

type ClusterServer 

type ClusterServer interface {
	// Will provision a cluster
	CreateCluster(context.Context, *CreateClusterMsg) (*CreateClusterReply, error)
	// Will retrieve the status of a cluster and its kubeconfig for connectivity
	GetCluster(context.Context, *GetClusterMsg) (*GetClusterReply, error)
	// Will delete a cluster
	DeleteCluster(context.Context, *DeleteClusterMsg) (*DeleteClusterReply, error)
	// Will retrieve a list of clusters
	GetClusterList(context.Context, *GetClusterListMsg) (*GetClusterListReply, error)
	// Will return version information about api server
	GetVersionInformation(context.Context, *GetVersionMsg) (*GetVersionReply, error)
	// Will retrieve available upgrades of a cluster
	GetClusterUpgrades(context.Context, *GetClusterUpgradesMsg) (*GetClusterUpgradesReply, error)
	// Will upgrade a cluster
	UpgradeCluster(context.Context, *UpgradeClusterMsg) (*UpgradeClusterReply, error)
	// Will retrieve node count
	GetClusterNodeCount(context.Context, *GetClusterNodeCountMsg) (*GetClusterNodeCountReply, error)
	// Will scale a clusters node count
	ScaleCluster(context.Context, *ScaleClusterMsg) (*ScaleClusterReply, error)
	// Will enable cluster autoscaling
	EnableClusterAutoscaling(context.Context, *EnableClusterAutoscalingMsg) (*EnableClusterAutoscalingReply, error)
}

ClusterServer is the server API for Cluster service.

type ClusterStatus 

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

func (ClusterStatus) EnumDescriptor 

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

func (ClusterStatus) String 

func (x ClusterStatus) String() string

type CreateClusterAKSSpec 

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"`
	// Cluster service account used to talk to azure (ex: creating load balancer)
	ClusterAccount *AzureClusterServiceAccount `protobuf:"bytes,3,opt,name=clusterAccount,proto3" json:"clusterAccount,omitempty"`
	// Instance groups
	InstanceGroups []*CreateClusterAKSSpec_AKSInstanceGroup `protobuf:"bytes,4,rep,name=instance_groups,json=instanceGroups,proto3" json:"instance_groups,omitempty"`
	// Tags
	Tags                 []*CreateClusterAKSSpec_Tags `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*CreateClusterAKSSpec) Descriptor 

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

func (*CreateClusterAKSSpec) GetClusterAccount 

func (m *CreateClusterAKSSpec) GetClusterAccount() *AzureClusterServiceAccount

func (*CreateClusterAKSSpec) GetCredentials 

func (m *CreateClusterAKSSpec) GetCredentials() *AzureCredentials

func (*CreateClusterAKSSpec) GetInstanceGroups 

func (m *CreateClusterAKSSpec) GetInstanceGroups() []*CreateClusterAKSSpec_AKSInstanceGroup

func (*CreateClusterAKSSpec) GetLocation 

func (m *CreateClusterAKSSpec) GetLocation() string

func (*CreateClusterAKSSpec) GetTags 

func (m *CreateClusterAKSSpec) GetTags() []*CreateClusterAKSSpec_Tags

func (*CreateClusterAKSSpec) ProtoMessage 

func (*CreateClusterAKSSpec) ProtoMessage()

func (*CreateClusterAKSSpec) Reset 

func (m *CreateClusterAKSSpec) Reset()

func (*CreateClusterAKSSpec) String 

func (m *CreateClusterAKSSpec) String() string

func (*CreateClusterAKSSpec) XXX_DiscardUnknown 

func (m *CreateClusterAKSSpec) XXX_DiscardUnknown()

func (*CreateClusterAKSSpec) XXX_Marshal 

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

func (*CreateClusterAKSSpec) XXX_Merge 

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

func (*CreateClusterAKSSpec) XXX_Size 

func (m *CreateClusterAKSSpec) XXX_Size() int

func (*CreateClusterAKSSpec) XXX_Unmarshal 

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

type CreateClusterAKSSpec_AKSInstanceGroup 

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"`
	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 

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

func (*CreateClusterAKSSpec_AKSInstanceGroup) GetMinQuantity 

func (m *CreateClusterAKSSpec_AKSInstanceGroup) GetMinQuantity() int32

func (*CreateClusterAKSSpec_AKSInstanceGroup) GetName 

func (m *CreateClusterAKSSpec_AKSInstanceGroup) GetName() string

func (*CreateClusterAKSSpec_AKSInstanceGroup) GetType 

func (m *CreateClusterAKSSpec_AKSInstanceGroup) GetType() string

func (*CreateClusterAKSSpec_AKSInstanceGroup) ProtoMessage 

func (*CreateClusterAKSSpec_AKSInstanceGroup) ProtoMessage()

func (*CreateClusterAKSSpec_AKSInstanceGroup) Reset 

func (m *CreateClusterAKSSpec_AKSInstanceGroup) Reset()

func (*CreateClusterAKSSpec_AKSInstanceGroup) String 

func (m *CreateClusterAKSSpec_AKSInstanceGroup) String() string

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_DiscardUnknown 

func (m *CreateClusterAKSSpec_AKSInstanceGroup) XXX_DiscardUnknown()

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_Marshal 

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

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_Merge 

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

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_Size 

func (m *CreateClusterAKSSpec_AKSInstanceGroup) XXX_Size() int

func (*CreateClusterAKSSpec_AKSInstanceGroup) XXX_Unmarshal 

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

type CreateClusterAKSSpec_Tags 

type CreateClusterAKSSpec_Tags struct {
	// Tag key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Tag value
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Tags are name/value pairs that enable you to categorize resources and view consolidated billing

func (*CreateClusterAKSSpec_Tags) Descriptor 

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

func (*CreateClusterAKSSpec_Tags) GetKey 

func (m *CreateClusterAKSSpec_Tags) GetKey() string

func (*CreateClusterAKSSpec_Tags) GetValue 

func (m *CreateClusterAKSSpec_Tags) GetValue() string

func (*CreateClusterAKSSpec_Tags) ProtoMessage 

func (*CreateClusterAKSSpec_Tags) ProtoMessage()

func (*CreateClusterAKSSpec_Tags) Reset 

func (m *CreateClusterAKSSpec_Tags) Reset()

func (*CreateClusterAKSSpec_Tags) String 

func (m *CreateClusterAKSSpec_Tags) String() string

func (*CreateClusterAKSSpec_Tags) XXX_DiscardUnknown 

func (m *CreateClusterAKSSpec_Tags) XXX_DiscardUnknown()

func (*CreateClusterAKSSpec_Tags) XXX_Marshal 

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

func (*CreateClusterAKSSpec_Tags) XXX_Merge 

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

func (*CreateClusterAKSSpec_Tags) XXX_Size 

func (m *CreateClusterAKSSpec_Tags) XXX_Size() int

func (*CreateClusterAKSSpec_Tags) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*CreateClusterMsg) Descriptor 

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

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 - like aks
	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"`
	// The AKS specification
	Azure *CreateClusterAKSSpec `protobuf:"bytes,3,opt,name=azure,proto3" json:"azure,omitempty"`
	// Whether or not the cluster is HA
	HighAvailability bool `protobuf:"varint,4,opt,name=high_availability,json=highAvailability,proto3" json:"high_availability,omitempty"`
	// The fabric to be used
	NetworkFabric        string   `protobuf:"bytes,5,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) GetAzure 

func (m *CreateClusterProviderSpec) GetAzure() *CreateClusterAKSSpec

func (*CreateClusterProviderSpec) GetHighAvailability 

func (m *CreateClusterProviderSpec) GetHighAvailability() bool

func (*CreateClusterProviderSpec) GetK8SVersion 

func (m *CreateClusterProviderSpec) GetK8SVersion() string

func (*CreateClusterProviderSpec) GetName 

func (m *CreateClusterProviderSpec) GetName() string

func (*CreateClusterProviderSpec) GetNetworkFabric 

func (m *CreateClusterProviderSpec) GetNetworkFabric() string

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_Size 

func (m *CreateClusterProviderSpec) XXX_Size() int

func (*CreateClusterProviderSpec) XXX_Unmarshal 

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

type CreateClusterReply 

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

func (*CreateClusterReply) Descriptor 

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

func (*CreateClusterReply) GetCluster 

func (m *CreateClusterReply) GetCluster() *ClusterItem

func (*CreateClusterReply) GetOk 

func (m *CreateClusterReply) GetOk() bool

func (*CreateClusterReply) ProtoMessage 

func (*CreateClusterReply) ProtoMessage()

func (*CreateClusterReply) Reset 

func (m *CreateClusterReply) Reset()

func (*CreateClusterReply) String 

func (m *CreateClusterReply) String() string

func (*CreateClusterReply) XXX_DiscardUnknown 

func (m *CreateClusterReply) XXX_DiscardUnknown()

func (*CreateClusterReply) XXX_Marshal 

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

func (*CreateClusterReply) XXX_Merge 

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

func (*CreateClusterReply) XXX_Size 

func (m *CreateClusterReply) XXX_Size() int

func (*CreateClusterReply) XXX_Unmarshal 

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

type DeleteClusterMsg 

type DeleteClusterMsg struct {
	// What is the cluster's name to destroy
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Credentials to delete 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 (*DeleteClusterMsg) Descriptor 

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

func (*DeleteClusterMsg) GetCredentials 

func (m *DeleteClusterMsg) GetCredentials() *AzureCredentials

func (*DeleteClusterMsg) GetName 

func (m *DeleteClusterMsg) GetName() string

func (*DeleteClusterMsg) ProtoMessage 

func (*DeleteClusterMsg) ProtoMessage()

func (*DeleteClusterMsg) Reset 

func (m *DeleteClusterMsg) Reset()

func (*DeleteClusterMsg) String 

func (m *DeleteClusterMsg) String() string

func (*DeleteClusterMsg) XXX_DiscardUnknown 

func (m *DeleteClusterMsg) XXX_DiscardUnknown()

func (*DeleteClusterMsg) XXX_Marshal 

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

func (*DeleteClusterMsg) XXX_Merge 

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

func (*DeleteClusterMsg) XXX_Size 

func (m *DeleteClusterMsg) XXX_Size() int

func (*DeleteClusterMsg) XXX_Unmarshal 

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

type DeleteClusterReply 

type DeleteClusterReply struct {
	// Could the cluster be destroyed
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// Additional information about the status of the cluster
	StatusMessage string `protobuf:"bytes,2,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	// Status of the request
	Status               ClusterStatus `protobuf:"varint,3,opt,name=status,proto3,enum=cmaaks.ClusterStatus" 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() ClusterStatus

func (*DeleteClusterReply) GetStatusMessage 

func (m *DeleteClusterReply) GetStatusMessage() 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 EnableClusterAutoscalingMsg 

type EnableClusterAutoscalingMsg struct {
	// Name of the cluster
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Groups to add autoscaling on
	// Currently only one node group is allowed in AKS, will work with more than 1 entry later
	Nodegroups []*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup `protobuf:"bytes,2,rep,name=nodegroups,proto3" json:"nodegroups,omitempty"`
	// Credentials to access the cluster
	Credentials          *AzureCredentials `protobuf:"bytes,4,opt,name=credentials,proto3" json:"credentials,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*EnableClusterAutoscalingMsg) Descriptor 

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

func (*EnableClusterAutoscalingMsg) GetCredentials 

func (m *EnableClusterAutoscalingMsg) GetCredentials() *AzureCredentials

func (*EnableClusterAutoscalingMsg) GetName 

func (m *EnableClusterAutoscalingMsg) GetName() string

func (*EnableClusterAutoscalingMsg) GetNodegroups 

func (m *EnableClusterAutoscalingMsg) GetNodegroups() []*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup

func (*EnableClusterAutoscalingMsg) ProtoMessage 

func (*EnableClusterAutoscalingMsg) ProtoMessage()

func (*EnableClusterAutoscalingMsg) Reset 

func (m *EnableClusterAutoscalingMsg) Reset()

func (*EnableClusterAutoscalingMsg) String 

func (m *EnableClusterAutoscalingMsg) String() string

func (*EnableClusterAutoscalingMsg) XXX_DiscardUnknown 

func (m *EnableClusterAutoscalingMsg) XXX_DiscardUnknown()

func (*EnableClusterAutoscalingMsg) XXX_Marshal 

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

func (*EnableClusterAutoscalingMsg) XXX_Merge 

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

func (*EnableClusterAutoscalingMsg) XXX_Size 

func (m *EnableClusterAutoscalingMsg) XXX_Size() int

func (*EnableClusterAutoscalingMsg) XXX_Unmarshal 

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

type EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup 

type EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup struct {
	// Name of node group
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Minimum number of nodes for autoscaling
	MinQuantity int32 `protobuf:"varint,2,opt,name=min_quantity,json=minQuantity,proto3" json:"min_quantity,omitempty"`
	// Maximum number of nodes for autoscaling
	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:"-"`
}

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) Descriptor 

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

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) GetMaxQuantity 

func (m *EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) GetMaxQuantity() int32

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) GetMinQuantity 

func (m *EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) GetMinQuantity() int32

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) GetName 

func (m *EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) GetName() string

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) ProtoMessage 

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) ProtoMessage()

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) Reset 

func (m *EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) Reset()

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) String 

func (m *EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) String() string

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) XXX_DiscardUnknown 

func (m *EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) XXX_DiscardUnknown()

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) XXX_Marshal 

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

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) XXX_Merge 

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

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) XXX_Size 

func (m *EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) XXX_Size() int

func (*EnableClusterAutoscalingMsg_AzureAutoscalingNodeGroup) XXX_Unmarshal 

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

type EnableClusterAutoscalingReply 

type EnableClusterAutoscalingReply struct {
	// Whether or not cluster autoscaling was enabled by this 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 (*EnableClusterAutoscalingReply) Descriptor 

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

func (*EnableClusterAutoscalingReply) GetOk 

func (m *EnableClusterAutoscalingReply) GetOk() bool

func (*EnableClusterAutoscalingReply) ProtoMessage 

func (*EnableClusterAutoscalingReply) ProtoMessage()

func (*EnableClusterAutoscalingReply) Reset 

func (m *EnableClusterAutoscalingReply) Reset()

func (*EnableClusterAutoscalingReply) String 

func (m *EnableClusterAutoscalingReply) String() string

func (*EnableClusterAutoscalingReply) XXX_DiscardUnknown 

func (m *EnableClusterAutoscalingReply) XXX_DiscardUnknown()

func (*EnableClusterAutoscalingReply) XXX_Marshal 

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

func (*EnableClusterAutoscalingReply) XXX_Merge 

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

func (*EnableClusterAutoscalingReply) XXX_Size 

func (m *EnableClusterAutoscalingReply) XXX_Size() int

func (*EnableClusterAutoscalingReply) XXX_Unmarshal 

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

type GetClusterListMsg 

type GetClusterListMsg struct {
	// Credentials to search subscription for clusters
	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 (*GetClusterListMsg) Descriptor 

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

func (*GetClusterListMsg) GetCredentials 

func (m *GetClusterListMsg) GetCredentials() *AzureCredentials

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"`
	// Credentials to query for 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 (*GetClusterMsg) Descriptor 

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

func (*GetClusterMsg) GetCredentials 

func (m *GetClusterMsg) GetCredentials() *AzureCredentials

func (*GetClusterMsg) GetName 

func (m *GetClusterMsg) GetName() string

func (*GetClusterMsg) ProtoMessage 

func (*GetClusterMsg) ProtoMessage()

func (*GetClusterMsg) Reset 

func (m *GetClusterMsg) Reset()

func (*GetClusterMsg) String 

func (m *GetClusterMsg) String() string

func (*GetClusterMsg) XXX_DiscardUnknown 

func (m *GetClusterMsg) XXX_DiscardUnknown()

func (*GetClusterMsg) XXX_Marshal 

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

func (*GetClusterMsg) XXX_Merge 

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

func (*GetClusterMsg) XXX_Size 

func (m *GetClusterMsg) XXX_Size() int

func (*GetClusterMsg) XXX_Unmarshal 

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

type GetClusterNodeCountMsg 

type GetClusterNodeCountMsg struct {
	// Name of the cluster to be looked up
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Credentials to query for 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:"-"`
}

Get available node count

func (*GetClusterNodeCountMsg) Descriptor 

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

func (*GetClusterNodeCountMsg) GetCredentials 

func (m *GetClusterNodeCountMsg) GetCredentials() *AzureCredentials

func (*GetClusterNodeCountMsg) GetName 

func (m *GetClusterNodeCountMsg) GetName() string

func (*GetClusterNodeCountMsg) ProtoMessage 

func (*GetClusterNodeCountMsg) ProtoMessage()

func (*GetClusterNodeCountMsg) Reset 

func (m *GetClusterNodeCountMsg) Reset()

func (*GetClusterNodeCountMsg) String 

func (m *GetClusterNodeCountMsg) String() string

func (*GetClusterNodeCountMsg) XXX_DiscardUnknown 

func (m *GetClusterNodeCountMsg) XXX_DiscardUnknown()

func (*GetClusterNodeCountMsg) XXX_Marshal 

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

func (*GetClusterNodeCountMsg) XXX_Merge 

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

func (*GetClusterNodeCountMsg) XXX_Size 

func (m *GetClusterNodeCountMsg) XXX_Size() int

func (*GetClusterNodeCountMsg) XXX_Unmarshal 

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

type GetClusterNodeCountReply 

type GetClusterNodeCountReply struct {
	// Is the cluster in the system
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// the available node pool name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The available node count
	Count                int32    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Reply with available node count

func (*GetClusterNodeCountReply) Descriptor 

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

func (*GetClusterNodeCountReply) GetCount 

func (m *GetClusterNodeCountReply) GetCount() int32

func (*GetClusterNodeCountReply) GetName 

func (m *GetClusterNodeCountReply) GetName() string

func (*GetClusterNodeCountReply) GetOk 

func (m *GetClusterNodeCountReply) GetOk() bool

func (*GetClusterNodeCountReply) ProtoMessage 

func (*GetClusterNodeCountReply) ProtoMessage()

func (*GetClusterNodeCountReply) Reset 

func (m *GetClusterNodeCountReply) Reset()

func (*GetClusterNodeCountReply) String 

func (m *GetClusterNodeCountReply) String() string

func (*GetClusterNodeCountReply) XXX_DiscardUnknown 

func (m *GetClusterNodeCountReply) XXX_DiscardUnknown()

func (*GetClusterNodeCountReply) XXX_Marshal 

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

func (*GetClusterNodeCountReply) XXX_Merge 

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

func (*GetClusterNodeCountReply) XXX_Size 

func (m *GetClusterNodeCountReply) XXX_Size() int

func (*GetClusterNodeCountReply) XXX_Unmarshal 

func (m *GetClusterNodeCountReply) 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 GetClusterUpgradesMsg 

type GetClusterUpgradesMsg struct {
	// Name of the cluster to be looked up
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Credentials to query for 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:"-"`
}

Get available cluster upgrades

func (*GetClusterUpgradesMsg) Descriptor 

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

func (*GetClusterUpgradesMsg) GetCredentials 

func (m *GetClusterUpgradesMsg) GetCredentials() *AzureCredentials

func (*GetClusterUpgradesMsg) GetName 

func (m *GetClusterUpgradesMsg) GetName() string

func (*GetClusterUpgradesMsg) ProtoMessage 

func (*GetClusterUpgradesMsg) ProtoMessage()

func (*GetClusterUpgradesMsg) Reset 

func (m *GetClusterUpgradesMsg) Reset()

func (*GetClusterUpgradesMsg) String 

func (m *GetClusterUpgradesMsg) String() string

func (*GetClusterUpgradesMsg) XXX_DiscardUnknown 

func (m *GetClusterUpgradesMsg) XXX_DiscardUnknown()

func (*GetClusterUpgradesMsg) XXX_Marshal 

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

func (*GetClusterUpgradesMsg) XXX_Merge 

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

func (*GetClusterUpgradesMsg) XXX_Size 

func (m *GetClusterUpgradesMsg) XXX_Size() int

func (*GetClusterUpgradesMsg) XXX_Unmarshal 

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

type GetClusterUpgradesReply 

type GetClusterUpgradesReply struct {
	// Is the cluster in the system
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// The available upgrades
	Upgrades             []*Upgrade `protobuf:"bytes,2,rep,name=upgrades,proto3" json:"upgrades,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Reply with available upgrades

func (*GetClusterUpgradesReply) Descriptor 

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

func (*GetClusterUpgradesReply) GetOk 

func (m *GetClusterUpgradesReply) GetOk() bool

func (*GetClusterUpgradesReply) GetUpgrades 

func (m *GetClusterUpgradesReply) GetUpgrades() []*Upgrade

func (*GetClusterUpgradesReply) ProtoMessage 

func (*GetClusterUpgradesReply) ProtoMessage()

func (*GetClusterUpgradesReply) Reset 

func (m *GetClusterUpgradesReply) Reset()

func (*GetClusterUpgradesReply) String 

func (m *GetClusterUpgradesReply) String() string

func (*GetClusterUpgradesReply) XXX_DiscardUnknown 

func (m *GetClusterUpgradesReply) XXX_DiscardUnknown()

func (*GetClusterUpgradesReply) XXX_Marshal 

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

func (*GetClusterUpgradesReply) XXX_Merge 

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

func (*GetClusterUpgradesReply) XXX_Size 

func (m *GetClusterUpgradesReply) XXX_Size() int

func (*GetClusterUpgradesReply) XXX_Unmarshal 

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

type GetVersionMsg 

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

Get version of API Server

func (*GetVersionMsg) Descriptor 

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

func (*GetVersionMsg) ProtoMessage 

func (*GetVersionMsg) ProtoMessage()

func (*GetVersionMsg) Reset 

func (m *GetVersionMsg) Reset()

func (*GetVersionMsg) String 

func (m *GetVersionMsg) String() string

func (*GetVersionMsg) XXX_DiscardUnknown 

func (m *GetVersionMsg) XXX_DiscardUnknown()

func (*GetVersionMsg) XXX_Marshal 

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

func (*GetVersionMsg) XXX_Merge 

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

func (*GetVersionMsg) XXX_Size 

func (m *GetVersionMsg) XXX_Size() int

func (*GetVersionMsg) XXX_Unmarshal 

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

type GetVersionReply 

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

Reply for version request

func (*GetVersionReply) Descriptor 

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

func (*GetVersionReply) GetOk 

func (m *GetVersionReply) GetOk() bool

func (*GetVersionReply) GetVersionInformation 

func (m *GetVersionReply) GetVersionInformation() *GetVersionReply_VersionInformation

func (*GetVersionReply) ProtoMessage 

func (*GetVersionReply) ProtoMessage()

func (*GetVersionReply) Reset 

func (m *GetVersionReply) Reset()

func (*GetVersionReply) String 

func (m *GetVersionReply) String() string

func (*GetVersionReply) XXX_DiscardUnknown 

func (m *GetVersionReply) XXX_DiscardUnknown()

func (*GetVersionReply) XXX_Marshal 

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

func (*GetVersionReply) XXX_Merge 

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

func (*GetVersionReply) XXX_Size 

func (m *GetVersionReply) XXX_Size() int

func (*GetVersionReply) XXX_Unmarshal 

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

type GetVersionReply_VersionInformation 

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

func (*GetVersionReply_VersionInformation) Descriptor 

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

func (*GetVersionReply_VersionInformation) GetBuildDate 

func (m *GetVersionReply_VersionInformation) GetBuildDate() string

func (*GetVersionReply_VersionInformation) GetCompiler 

func (m *GetVersionReply_VersionInformation) GetCompiler() string

func (*GetVersionReply_VersionInformation) GetGitCommit 

func (m *GetVersionReply_VersionInformation) GetGitCommit() string

func (*GetVersionReply_VersionInformation) GetGitTreeState 

func (m *GetVersionReply_VersionInformation) GetGitTreeState() string

func (*GetVersionReply_VersionInformation) GetGitVersion 

func (m *GetVersionReply_VersionInformation) GetGitVersion() string

func (*GetVersionReply_VersionInformation) GetGoVersion 

func (m *GetVersionReply_VersionInformation) GetGoVersion() string

func (*GetVersionReply_VersionInformation) GetPlatform 

func (m *GetVersionReply_VersionInformation) GetPlatform() string

func (*GetVersionReply_VersionInformation) ProtoMessage 

func (*GetVersionReply_VersionInformation) ProtoMessage()

func (*GetVersionReply_VersionInformation) Reset 

func (m *GetVersionReply_VersionInformation) Reset()

func (*GetVersionReply_VersionInformation) String 

func (m *GetVersionReply_VersionInformation) String() string

func (*GetVersionReply_VersionInformation) XXX_DiscardUnknown 

func (m *GetVersionReply_VersionInformation) XXX_DiscardUnknown()

func (*GetVersionReply_VersionInformation) XXX_Marshal 

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

func (*GetVersionReply_VersionInformation) XXX_Merge 

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

func (*GetVersionReply_VersionInformation) XXX_Size 

func (m *GetVersionReply_VersionInformation) XXX_Size() int

func (*GetVersionReply_VersionInformation) XXX_Unmarshal 

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

type ScaleClusterMsg 

type ScaleClusterMsg struct {
	// Name of cluster
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Credentials to search subscription for clusters
	Credentials *AzureCredentials `protobuf:"bytes,2,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// name of node pool
	NodePool string `protobuf:"bytes,3,opt,name=node_pool,json=nodePool,proto3" json:"node_pool,omitempty"`
	// total desired nodes
	Count                int32    `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScaleClusterMsg) Descriptor 

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

func (*ScaleClusterMsg) GetCount 

func (m *ScaleClusterMsg) GetCount() int32

func (*ScaleClusterMsg) GetCredentials 

func (m *ScaleClusterMsg) GetCredentials() *AzureCredentials

func (*ScaleClusterMsg) GetName 

func (m *ScaleClusterMsg) GetName() string

func (*ScaleClusterMsg) GetNodePool 

func (m *ScaleClusterMsg) GetNodePool() string

func (*ScaleClusterMsg) ProtoMessage 

func (*ScaleClusterMsg) ProtoMessage()

func (*ScaleClusterMsg) Reset 

func (m *ScaleClusterMsg) Reset()

func (*ScaleClusterMsg) String 

func (m *ScaleClusterMsg) String() string

func (*ScaleClusterMsg) XXX_DiscardUnknown 

func (m *ScaleClusterMsg) XXX_DiscardUnknown()

func (*ScaleClusterMsg) XXX_Marshal 

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

func (*ScaleClusterMsg) XXX_Merge 

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

func (*ScaleClusterMsg) XXX_Size 

func (m *ScaleClusterMsg) XXX_Size() int

func (*ScaleClusterMsg) XXX_Unmarshal 

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

type ScaleClusterReply 

type ScaleClusterReply struct {
	// wheather or not the cluster was scaled
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// Status of the request
	Status               ClusterStatus `protobuf:"varint,2,opt,name=status,proto3,enum=cmaaks.ClusterStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ScaleClusterReply) Descriptor 

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

func (*ScaleClusterReply) GetOk 

func (m *ScaleClusterReply) GetOk() bool

func (*ScaleClusterReply) GetStatus 

func (m *ScaleClusterReply) GetStatus() ClusterStatus

func (*ScaleClusterReply) ProtoMessage 

func (*ScaleClusterReply) ProtoMessage()

func (*ScaleClusterReply) Reset 

func (m *ScaleClusterReply) Reset()

func (*ScaleClusterReply) String 

func (m *ScaleClusterReply) String() string

func (*ScaleClusterReply) XXX_DiscardUnknown 

func (m *ScaleClusterReply) XXX_DiscardUnknown()

func (*ScaleClusterReply) XXX_Marshal 

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

func (*ScaleClusterReply) XXX_Merge 

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

func (*ScaleClusterReply) XXX_Size 

func (m *ScaleClusterReply) XXX_Size() int

func (*ScaleClusterReply) XXX_Unmarshal 

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

type Upgrade 

type Upgrade struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

available upgrade version

func (*Upgrade) Descriptor 

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

func (*Upgrade) GetVersion 

func (m *Upgrade) GetVersion() string

func (*Upgrade) ProtoMessage 

func (*Upgrade) ProtoMessage()

func (*Upgrade) Reset 

func (m *Upgrade) Reset()

func (*Upgrade) String 

func (m *Upgrade) String() string

func (*Upgrade) XXX_DiscardUnknown 

func (m *Upgrade) XXX_DiscardUnknown()

func (*Upgrade) XXX_Marshal 

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

func (*Upgrade) XXX_Merge 

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

func (*Upgrade) XXX_Size 

func (m *Upgrade) XXX_Size() int

func (*Upgrade) XXX_Unmarshal 

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

type UpgradeClusterAKSSpec 

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

func (*UpgradeClusterAKSSpec) Descriptor 

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

func (*UpgradeClusterAKSSpec) GetCredentials 

func (m *UpgradeClusterAKSSpec) GetCredentials() *AzureCredentials

func (*UpgradeClusterAKSSpec) ProtoMessage 

func (*UpgradeClusterAKSSpec) ProtoMessage()

func (*UpgradeClusterAKSSpec) Reset 

func (m *UpgradeClusterAKSSpec) Reset()

func (*UpgradeClusterAKSSpec) String 

func (m *UpgradeClusterAKSSpec) String() string

func (*UpgradeClusterAKSSpec) XXX_DiscardUnknown 

func (m *UpgradeClusterAKSSpec) XXX_DiscardUnknown()

func (*UpgradeClusterAKSSpec) XXX_Marshal 

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

func (*UpgradeClusterAKSSpec) XXX_Merge 

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

func (*UpgradeClusterAKSSpec) XXX_Size 

func (m *UpgradeClusterAKSSpec) XXX_Size() int

func (*UpgradeClusterAKSSpec) XXX_Unmarshal 

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

type UpgradeClusterMsg 

type UpgradeClusterMsg struct {
	// Name of the cluster to be upgraded
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The provider specification
	Provider             *UpgradeClusterProviderSpec `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*UpgradeClusterMsg) Descriptor 

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

func (*UpgradeClusterMsg) GetName 

func (m *UpgradeClusterMsg) GetName() string

func (*UpgradeClusterMsg) GetProvider 

func (m *UpgradeClusterMsg) GetProvider() *UpgradeClusterProviderSpec

func (*UpgradeClusterMsg) ProtoMessage 

func (*UpgradeClusterMsg) ProtoMessage()

func (*UpgradeClusterMsg) Reset 

func (m *UpgradeClusterMsg) Reset()

func (*UpgradeClusterMsg) String 

func (m *UpgradeClusterMsg) String() string

func (*UpgradeClusterMsg) XXX_DiscardUnknown 

func (m *UpgradeClusterMsg) XXX_DiscardUnknown()

func (*UpgradeClusterMsg) XXX_Marshal 

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

func (*UpgradeClusterMsg) XXX_Merge 

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

func (*UpgradeClusterMsg) XXX_Size 

func (m *UpgradeClusterMsg) XXX_Size() int

func (*UpgradeClusterMsg) XXX_Unmarshal 

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

type UpgradeClusterProviderSpec 

type UpgradeClusterProviderSpec struct {
	// What is the provider - like aks
	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"`
	// The AKS specification
	Azure                *UpgradeClusterAKSSpec `protobuf:"bytes,3,opt,name=azure,proto3" json:"azure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*UpgradeClusterProviderSpec) Descriptor 

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

func (*UpgradeClusterProviderSpec) GetAzure 

func (m *UpgradeClusterProviderSpec) GetAzure() *UpgradeClusterAKSSpec

func (*UpgradeClusterProviderSpec) GetK8SVersion 

func (m *UpgradeClusterProviderSpec) GetK8SVersion() string

func (*UpgradeClusterProviderSpec) GetName 

func (m *UpgradeClusterProviderSpec) GetName() string

func (*UpgradeClusterProviderSpec) ProtoMessage 

func (*UpgradeClusterProviderSpec) ProtoMessage()

func (*UpgradeClusterProviderSpec) Reset 

func (m *UpgradeClusterProviderSpec) Reset()

func (*UpgradeClusterProviderSpec) String 

func (m *UpgradeClusterProviderSpec) String() string

func (*UpgradeClusterProviderSpec) XXX_DiscardUnknown 

func (m *UpgradeClusterProviderSpec) XXX_DiscardUnknown()

func (*UpgradeClusterProviderSpec) XXX_Marshal 

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

func (*UpgradeClusterProviderSpec) XXX_Merge 

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

func (*UpgradeClusterProviderSpec) XXX_Size 

func (m *UpgradeClusterProviderSpec) XXX_Size() int

func (*UpgradeClusterProviderSpec) XXX_Unmarshal 

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

type UpgradeClusterReply 

type UpgradeClusterReply struct {
	// Whether or not the cluster was upgrade 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 (*UpgradeClusterReply) Descriptor 

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

func (*UpgradeClusterReply) GetCluster 

func (m *UpgradeClusterReply) GetCluster() *ClusterItem

func (*UpgradeClusterReply) GetOk 

func (m *UpgradeClusterReply) GetOk() bool

func (*UpgradeClusterReply) ProtoMessage 

func (*UpgradeClusterReply) ProtoMessage()

func (*UpgradeClusterReply) Reset 

func (m *UpgradeClusterReply) Reset()

func (*UpgradeClusterReply) String 

func (m *UpgradeClusterReply) String() string

func (*UpgradeClusterReply) XXX_DiscardUnknown 

func (m *UpgradeClusterReply) XXX_DiscardUnknown()

func (*UpgradeClusterReply) XXX_Marshal 

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

func (*UpgradeClusterReply) XXX_Merge 

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

func (*UpgradeClusterReply) XXX_Size 

func (m *UpgradeClusterReply) XXX_Size() int

func (*UpgradeClusterReply) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.