gce

Documentation

Index

• Constants
• func GenerateInstanceUrl(project, zone, name string) string
• func GenerateMigUrl(project, zone, name string) string
• func ParseInstanceUrl(url string) (project string, zone string, name string, err error)
• func ParseMigUrl(url string) (project string, zone string, name string, err error)
• type GceCloudProvider
  • func BuildGceCloudProvider(gceManager *GceManager, specs []string) (*GceCloudProvider, error)
  • func (gce *GceCloudProvider) Name() string
  • func (gce *GceCloudProvider) NodeGroupForNode(node *apiv1.Node) (cloudprovider.NodeGroup, error)
  • func (gce *GceCloudProvider) NodeGroups() []cloudprovider.NodeGroup
  • func (gce *GceCloudProvider) Pricing() (cloudprovider.PricingModel, error)
• type GceManager
  • func CreateGceManager(configReader io.Reader) (*GceManager, error)
  • func (m *GceManager) DeleteInstances(instances []*GceRef) error
  • func (m *GceManager) GetMigForInstance(instance *GceRef) (*Mig, error)
  • func (m *GceManager) GetMigNodes(mig *Mig) ([]string, error)
  • func (m *GceManager) GetMigSize(mig *Mig) (int64, error)
  • func (m *GceManager) RegisterMig(mig *Mig)
  • func (m *GceManager) SetMigSize(mig *Mig, size int64) error
• type GcePriceModel
  • func (model *GcePriceModel) NodePrice(node *apiv1.Node, startTime time.Time, endTime time.Time) (float64, error)
  • func (model *GcePriceModel) PodPrice(pod *apiv1.Pod, startTime time.Time, endTime time.Time) (float64, error)
• type GceRef
  • func GceRefFromProviderId(id string) (*GceRef, error)
• type Mig
  • func (mig *Mig) Belongs(node *apiv1.Node) (bool, error)
  • func (mig *Mig) Debug() string
  • func (mig *Mig) DecreaseTargetSize(delta int) error
  • func (mig *Mig) DeleteNodes(nodes []*apiv1.Node) error
  • func (mig *Mig) Id() string
  • func (mig *Mig) IncreaseSize(delta int) error
  • func (mig *Mig) MaxSize() int
  • func (mig *Mig) MinSize() int
  • func (mig *Mig) Nodes() ([]string, error)
  • func (mig *Mig) TargetSize() (int, error)
  • func (mig *Mig) TemplateNodeInfo() (*schedulercache.NodeInfo, error)

Constants

const (
	// KubeProxyCpuRequestMillis is the amount of cpu requested by Kubeproxy
	KubeProxyCpuRequestMillis = 100
)

Functions

func GenerateInstanceUrl

func GenerateInstanceUrl(project, zone, name string) string

GenerateInstanceUrl generates url for instance.

func GenerateMigUrl

func GenerateMigUrl(project, zone, name string) string

GenerateMigUrl generates url for instance.

func ParseInstanceUrl

func ParseInstanceUrl(url string) (project string, zone string, name string, err error)

ParseInstanceUrl expects url in format: https://content.googleapis.com/compute/v1/projects/<project-id>/zones/<zone>/instances/<name>

func ParseMigUrl

func ParseMigUrl(url string) (project string, zone string, name string, err error)

ParseMigUrl expects url in format: https://content.googleapis.com/compute/v1/projects/<project-id>/zones/<zone>/instanceGroups/<name>

Types

type GceCloudProvider

type GceCloudProvider struct {
	// contains filtered or unexported fields
}

GceCloudProvider implements CloudProvider interface.

func BuildGceCloudProvider

func BuildGceCloudProvider(gceManager *GceManager, specs []string) (*GceCloudProvider, error)

BuildGceCloudProvider builds CloudProvider implementation for GCE.

func (*GceCloudProvider) Name

func (gce *GceCloudProvider) Name() string

Name returns name of the cloud provider.

func (*GceCloudProvider) NodeGroupForNode

func (gce *GceCloudProvider) NodeGroupForNode(node *apiv1.Node) (cloudprovider.NodeGroup, error)

NodeGroupForNode returns the node group for the given node.

func (*GceCloudProvider) NodeGroups

func (gce *GceCloudProvider) NodeGroups() []cloudprovider.NodeGroup

NodeGroups returns all node groups configured for this cloud provider.

func (*GceCloudProvider) Pricing

func (gce *GceCloudProvider) Pricing() (cloudprovider.PricingModel, error)

Pricing returns pricing model for this cloud provider or error if not available.

type GceManager

type GceManager struct {
	// contains filtered or unexported fields
}

GceManager is handles gce communication and data caching.

func CreateGceManager

func CreateGceManager(configReader io.Reader) (*GceManager, error)

CreateGceManager constructs gceManager object.

func (*GceManager) DeleteInstances

func (m *GceManager) DeleteInstances(instances []*GceRef) error

DeleteInstances deletes the given instances. All instances must be controlled by the same MIG.

func (*GceManager) GetMigForInstance

func (m *GceManager) GetMigForInstance(instance *GceRef) (*Mig, error)

GetMigForInstance returns MigConfig of the given Instance

func (*GceManager) GetMigNodes

func (m *GceManager) GetMigNodes(mig *Mig) ([]string, error)

GetMigNodes returns mig nodes.

func (*GceManager) GetMigSize

func (m *GceManager) GetMigSize(mig *Mig) (int64, error)

GetMigSize gets MIG size.

func (*GceManager) RegisterMig

func (m *GceManager) RegisterMig(mig *Mig)

RegisterMig registers mig in Gce Manager.

func (*GceManager) SetMigSize

func (m *GceManager) SetMigSize(mig *Mig, size int64) error

SetMigSize sets MIG size.

type GcePriceModel

type GcePriceModel struct {
}

GcePriceModel implements PriceModel interface for GCE.

func (*GcePriceModel) NodePrice

func (model *GcePriceModel) NodePrice(node *apiv1.Node, startTime time.Time, endTime time.Time) (float64, error)

NodePrice returns a price of running the given node for a given period of time. All prices are in USD.

func (*GcePriceModel) PodPrice

func (model *GcePriceModel) PodPrice(pod *apiv1.Pod, startTime time.Time, endTime time.Time) (float64, error)

PodPrice returns a theoretical minimum priece of running a pod for a given period of time on a perfectly matching machine.

type GceRef

type GceRef struct {
	Project string
	Zone    string
	Name    string
}

GceRef contains s reference to some entity in GCE/GKE world.

func GceRefFromProviderId

func GceRefFromProviderId(id string) (*GceRef, error)

GceRefFromProviderId creates InstanceConfig object from provider id which must be in format: gce://<project-id>/<zone>/<name> TODO(piosz): add better check whether the id is correct

type Mig

type Mig struct {
	GceRef
	// contains filtered or unexported fields
}

Mig implements NodeGroup interfrace.

func (*Mig) Belongs

func (mig *Mig) Belongs(node *apiv1.Node) (bool, error)

Belongs returns true if the given node belongs to the NodeGroup.

func (*Mig) Debug

func (mig *Mig) Debug() string

Debug returns a debug string for the Mig.

func (*Mig) DecreaseTargetSize

func (mig *Mig) DecreaseTargetSize(delta int) error

DecreaseTargetSize decreases the target size of the node group. This function doesn't permit to delete any existing node and can be used only to reduce the request for new nodes that have not been yet fulfilled. Delta should be negative.

func (*Mig) DeleteNodes

func (mig *Mig) DeleteNodes(nodes []*apiv1.Node) error

DeleteNodes deletes the nodes from the group.

func (*Mig) Id

func (mig *Mig) Id() string

Id returns mig url.

func (*Mig) IncreaseSize

func (mig *Mig) IncreaseSize(delta int) error

IncreaseSize increases Mig size

func (*Mig) MaxSize

func (mig *Mig) MaxSize() int

MaxSize returns maximum size of the node group.

func (*Mig) MinSize

func (mig *Mig) MinSize() int

MinSize returns minimum size of the node group.

func (*Mig) Nodes

func (mig *Mig) Nodes() ([]string, error)

Nodes returns a list of all nodes that belong to this node group.

func (*Mig) TargetSize

func (mig *Mig) TargetSize() (int, error)

TargetSize returns the current TARGET size of the node group. It is possible that the number is different from the number of nodes registered in Kuberentes.

func (*Mig) TemplateNodeInfo

func (mig *Mig) TemplateNodeInfo() (*schedulercache.NodeInfo, error)

TemplateNodeInfo returns a node template for this node group.