server

package

Go to main page

Versions in this module

v1

v1.29.0-rke2

Dec 26, 2023

v1.29.0-dev

Dec 28, 2023

v1.27.3

Jul 10, 2023

v1.27.1

Jan 28, 2023

v1.26.6

Jul 10, 2023

v1.26.4

May 4, 2023

v1.26.2

Jan 28, 2023

v1.26.1

Jan 23, 2023

v1.26.0

Dec 28, 2022

Changes in this version

type AutoScalerServerApp

+ func (s *AutoScalerServerApp) HasInstance(ctx context.Context, request *apigrpc.HasInstanceRequest) (*apigrpc.HasInstanceReply, error)

v1.25.11

Jul 10, 2023

v1.25.9

May 4, 2023

v1.25.7

Jan 28, 2023

v1.25.6

Jan 23, 2023

Changes in this version

+ const AutoScalerServerNodeStateCreating

+ func NewExternalgrpcServerApp(appServer *AutoScalerServerApp) (*externalgrpcServerApp, error)

type AutoScalerServerApp

+ func (s *AutoScalerServerApp) GetOptions(ctx context.Context, request *apigrpc.GetOptionsRequest) (*apigrpc.GetOptionsReply, error)

type AutoScalerServerNode

+ func (vm *AutoScalerServerNode) WaitSSHReady(nodename, address string) error

type AutoScalerServerNodeGroup

+ func (g *AutoScalerServerNodeGroup) AllNodes() []*AutoScalerServerNode

+ func (g *AutoScalerServerNodeGroup) GetOptions(defaults *types.NodeGroupAutoscalingOptions) (*types.NodeGroupAutoscalingOptions, error)

v1.25.5

Dec 27, 2022

v1.25.2

Sep 27, 2022

v1.25.1

Sep 17, 2022

v1.24.9

Dec 27, 2022

Changes in this version

type AutoScalerServerNode

+ CRDUID uid.UID

+ func (vm *AutoScalerServerNode) WaitForIP() (*string, error)

v1.24.5

Sep 27, 2022

v1.24.2

Jul 3, 2022

v1.24.0

Jul 3, 2022

v1.23.11

Sep 17, 2022

v1.23.8

Jul 3, 2022

v1.23.4

Mar 12, 2022

v1.23.1

Dec 21, 2021

v1.22.14

Sep 17, 2022

v1.22.7

Mar 12, 2022

v1.22.5

Dec 21, 2021

v1.21.10

Mar 12, 2022

v1.21.8

Dec 21, 2021

v1.21.2

Jul 14, 2021

v1.21.0

May 8, 2021

v1.21.0-dev

May 3, 2021

v1.20.15

Mar 12, 2022

Changes in this version

+ const AutoScalerServerNodeAutoscaled

+ const AutoScalerServerNodeExternal

+ const AutoScalerServerNodeManaged

+ const ErrorEvent

+ const FailedEvent

+ const SuccessEvent

+ const WarningEvent

type AutoScalerServerNode

+ AllowDeployment bool

+ CPU int

+ ControlPlaneNode bool

+ ExtraAnnotations KubernetesLabel

+ ExtraLabels KubernetesLabel

+ IPAddress string

+ Memory int

+ NodeType AutoScalerServerNodeType

+ UID uid.UID

type AutoScalerServerNodeGroup

+ ControlPlaneNamePrefix string

+ ManagedNodeNamePrefix string

+ ProvisionnedNodeNamePrefix string

+ type AutoScalerServerNodeType int32

+ type Controller struct

+ func NewController(application applicationInterface, stopCh <-chan struct{}) (*Controller, error)

+ func (c *Controller) CreateCRD() error

+ func (c *Controller) Run() error

type KubernetesLabel

+ func CreateLabelOrAnnotation(values []string) KubernetesLabel

v1.20.14

Dec 21, 2021

Changes in this version

type AutoScalerServerNode

+ DiskSize int

+ DiskType string

type AutoScalerServerNodeGroup

+ DiskType string

+ LastNodeIndex int

+ NodeNamePrefix string

+ NotOwnedNodes int

+ RunningNodes map[int]ServerNodeState

+ type ServerNodeState int

+ const ServerNodeStateCreating

+ const ServerNodeStateDeleted

+ const ServerNodeStateNotRunning

+ const ServerNodeStateRunning

v1.20.5

May 8, 2021

v1.18.6

Aug 21, 2020

v1.18.2

Jul 4, 2020

v1.17.5

Aug 21, 2020

v1.16.9

Aug 21, 2020

v1.15.11

Aug 21, 2020

Changes in this version

+ func StartServer(kubeConfig, saveState, configFileName string)

+ type AutoScalerServerApp struct

+ AutoProvision bool

+ Configuration *types.AutoScalerServerConfig

+ Groups map[string]*AutoScalerServerNodeGroup

+ KubeAdmConfiguration *apigrpc.KubeAdmConfig

+ NodesDefinition []*apigrpc.NodeGroupDef

+ ResourceLimiter *types.ResourceLimiter

+ func (s *AutoScalerServerApp) Autoprovisioned(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.AutoprovisionedReply, error)

+ func (s *AutoScalerServerApp) Belongs(ctx context.Context, request *apigrpc.BelongsRequest) (*apigrpc.BelongsReply, error)

+ func (s *AutoScalerServerApp) Cleanup(ctx context.Context, request *apigrpc.CloudProviderServiceRequest) (*apigrpc.CleanupReply, error)

+ func (s *AutoScalerServerApp) Connect(ctx context.Context, request *apigrpc.ConnectRequest) (*apigrpc.ConnectReply, error)

+ func (s *AutoScalerServerApp) Create(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.CreateReply, error)

+ func (s *AutoScalerServerApp) Debug(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.DebugReply, error)

+ func (s *AutoScalerServerApp) DecreaseTargetSize(ctx context.Context, request *apigrpc.DecreaseTargetSizeRequest) (*apigrpc.DecreaseTargetSizeReply, error)

+ func (s *AutoScalerServerApp) Delete(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.DeleteReply, error)

+ func (s *AutoScalerServerApp) DeleteNodes(ctx context.Context, request *apigrpc.DeleteNodesRequest) (*apigrpc.DeleteNodesReply, error)

+ func (s *AutoScalerServerApp) Exist(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.ExistReply, error)

+ func (s *AutoScalerServerApp) GPULabel(ctx context.Context, request *apigrpc.CloudProviderServiceRequest) (*apigrpc.GPULabelReply, error)

+ func (s *AutoScalerServerApp) GetAvailableGPUTypes(ctx context.Context, request *apigrpc.CloudProviderServiceRequest) (*apigrpc.GetAvailableGPUTypesReply, error)

+ func (s *AutoScalerServerApp) GetAvailableMachineTypes(ctx context.Context, request *apigrpc.CloudProviderServiceRequest) (*apigrpc.AvailableMachineTypesReply, error)

+ func (s *AutoScalerServerApp) GetResourceLimiter(ctx context.Context, request *apigrpc.CloudProviderServiceRequest) (*apigrpc.ResourceLimiterReply, error)

+ func (s *AutoScalerServerApp) Id(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.IdReply, error)

+ func (s *AutoScalerServerApp) IncreaseSize(ctx context.Context, request *apigrpc.IncreaseSizeRequest) (*apigrpc.IncreaseSizeReply, error)

+ func (s *AutoScalerServerApp) Load(fileName string) error

+ func (s *AutoScalerServerApp) MaxSize(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.MaxSizeReply, error)

+ func (s *AutoScalerServerApp) MinSize(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.MinSizeReply, error)

+ func (s *AutoScalerServerApp) Name(ctx context.Context, request *apigrpc.CloudProviderServiceRequest) (*apigrpc.NameReply, error)

+ func (s *AutoScalerServerApp) NewNodeGroup(ctx context.Context, request *apigrpc.NewNodeGroupRequest) (*apigrpc.NewNodeGroupReply, error)

+ func (s *AutoScalerServerApp) NodeGroupForNode(ctx context.Context, request *apigrpc.NodeGroupForNodeRequest) (*apigrpc.NodeGroupForNodeReply, error)

+ func (s *AutoScalerServerApp) NodeGroups(ctx context.Context, request *apigrpc.CloudProviderServiceRequest) (*apigrpc.NodeGroupsReply, error)

+ func (s *AutoScalerServerApp) NodePrice(ctx context.Context, request *apigrpc.NodePriceRequest) (*apigrpc.NodePriceReply, error)

+ func (s *AutoScalerServerApp) Nodes(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.NodesReply, error)

+ func (s *AutoScalerServerApp) PodPrice(ctx context.Context, request *apigrpc.PodPriceRequest) (*apigrpc.PodPriceReply, error)

+ func (s *AutoScalerServerApp) Pricing(ctx context.Context, request *apigrpc.CloudProviderServiceRequest) (*apigrpc.PricingModelReply, error)

+ func (s *AutoScalerServerApp) Refresh(ctx context.Context, request *apigrpc.CloudProviderServiceRequest) (*apigrpc.RefreshReply, error)

+ func (s *AutoScalerServerApp) Save(fileName string) error

+ func (s *AutoScalerServerApp) TargetSize(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.TargetSizeReply, error)

+ func (s *AutoScalerServerApp) TemplateNodeInfo(ctx context.Context, request *apigrpc.NodeGroupServiceRequest) (*apigrpc.TemplateNodeInfoReply, error)

+ type AutoScalerServerNode struct

+ Addresses []string

+ AutoProvisionned bool

+ AwsConfig *aws.Configuration

+ Disk int

+ InstanceName string

+ InstanceType string

+ NodeGroupID string

+ NodeIndex int

+ NodeName string

+ ProviderID string

+ RunningInstance *aws.Ec2Instance

+ State AutoScalerServerNodeState

+ func (vm *AutoScalerServerNode) CheckIfIPIsReady(nodename, address string) error

+ type AutoScalerServerNodeGroup struct

+ AutoProvision bool

+ DiskSize int

+ InstanceType string

+ LastCreatedNodeIndex int

+ MaxNodeSize int

+ MinNodeSize int

+ NodeGroupIdentifier string

+ NodeLabels KubernetesLabel

+ Nodes map[string]*AutoScalerServerNode

+ ServiceIdentifier string

+ Status NodeGroupState

+ SystemLabels KubernetesLabel

+ type AutoScalerServerNodeState int32

+ const AutoScalerServerNodeStateDeleted

+ const AutoScalerServerNodeStateNotCreated

+ const AutoScalerServerNodeStateRunning

+ const AutoScalerServerNodeStateStopped

+ const AutoScalerServerNodeStateUndefined

+ func (s AutoScalerServerNodeState) String() string

+ type KubernetesLabel map[string]string

+ type NodeGroupState int32

+ const NodegroupCreated

+ const NodegroupDeleted

+ const NodegroupDeleting

+ const NodegroupNotCreated

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