Documentation ¶
Index ¶
- Variables
- func CloudProviders() []string
- func GetInstanceProviderID(cloud Interface, nodeName types.NodeName) (string, error)
- func GetLoadBalancerName(service *v1.Service) string
- func IsCloudProvider(name string) bool
- func IsExternal(name string) bool
- func RegisterCloudProvider(name string, cloud Factory)
- type Clusters
- type Factory
- type Instances
- type Interface
- type LoadBalancer
- type Route
- type Routes
- type Zone
- type Zones
Constants ¶
This section is empty.
Variables ¶
var ( InstanceNotFound = errors.New("instance not found") DiskNotFound = errors.New("disk is not found") )
Functions ¶
func CloudProviders ¶
func CloudProviders() []string
CloudProviders returns the name of all registered cloud providers in a string slice
func GetInstanceProviderID ¶
func GetLoadBalancerName ¶
TODO(#6812): Use a shorter name that's less likely to be longer than cloud providers' name length limits.
func IsCloudProvider ¶
IsCloudProvider returns true if name corresponds to an already registered cloud provider.
func IsExternal ¶
Detects if the string is an external cloud provider
func RegisterCloudProvider ¶
RegisterCloudProvider registers a cloudprovider.Factory by name. This is expected to happen during app startup.
Types ¶
type Clusters ¶
type Clusters interface { // ListClusters lists the names of the available clusters. ListClusters() ([]string, error) // Master gets back the address (either DNS name or IP address) of the master node for the cluster. Master(clusterName string) (string, error) }
Clusters is an abstract, pluggable interface for clusters of containers.
type Factory ¶
Factory is a function that returns a cloudprovider.Interface. The config parameter provides an io.Reader handler to the factory in order to load specific configurations. If no configuration is provided the parameter is nil.
type Instances ¶
type Instances interface { // NodeAddresses returns the addresses of the specified instance. // TODO(roberthbailey): This currently is only used in such a way that it // returns the address of the calling instance. We should do a rename to // make this clearer. NodeAddresses(name types.NodeName) ([]v1.NodeAddress, error) // ExternalID returns the cloud provider ID of the node with the specified NodeName. // Note that if the instance does not exist or is no longer running, we must return ("", cloudprovider.InstanceNotFound) ExternalID(nodeName types.NodeName) (string, error) // InstanceID returns the cloud provider ID of the node with the specified NodeName. InstanceID(nodeName types.NodeName) (string, error) // InstanceType returns the type of the specified instance. InstanceType(name types.NodeName) (string, error) // AddSSHKeyToAllInstances adds an SSH public key as a legal identity for all instances // expected format for the key is standard ssh-keygen format: <protocol> <blob> AddSSHKeyToAllInstances(user string, keyData []byte) error // CurrentNodeName returns the name of the node we are currently running on // On most clouds (e.g. GCE) this is the hostname, so we provide the hostname CurrentNodeName(hostname string) (types.NodeName, error) }
Instances is an abstract, pluggable interface for sets of instances.
type Interface ¶
type Interface interface { // LoadBalancer returns a balancer interface. Also returns true if the interface is supported, false otherwise. LoadBalancer() (LoadBalancer, bool) // Instances returns an instances interface. Also returns true if the interface is supported, false otherwise. Instances() (Instances, bool) // Zones returns a zones interface. Also returns true if the interface is supported, false otherwise. Zones() (Zones, bool) // Clusters returns a clusters interface. Also returns true if the interface is supported, false otherwise. Clusters() (Clusters, bool) // Routes returns a routes interface along with whether the interface is supported. Routes() (Routes, bool) // ProviderName returns the cloud provider ID. ProviderName() string // ScrubDNS provides an opportunity for cloud-provider-specific code to process DNS settings for pods. ScrubDNS(nameservers, searches []string) (nsOut, srchOut []string) }
Interface is an abstract, pluggable interface for cloud providers.
func GetCloudProvider ¶
GetCloudProvider creates an instance of the named cloud provider, or nil if the name is unknown. The error return is only used if the named provider was known but failed to initialize. The config parameter specifies the io.Reader handler of the configuration file for the cloud provider, or nil for no configuation.
type LoadBalancer ¶
type LoadBalancer interface { // TODO: Break this up into different interfaces (LB, etc) when we have more than one type of service // GetLoadBalancer returns whether the specified load balancer exists, and // if so, what its status is. // Implementations must treat the *v1.Service parameter as read-only and not modify it. // Parameter 'clusterName' is the name of the cluster as presented to kube-controller-manager GetLoadBalancer(clusterName string, service *v1.Service) (status *v1.LoadBalancerStatus, exists bool, err error) // EnsureLoadBalancer creates a new load balancer 'name', or updates the existing one. Returns the status of the balancer // Implementations must treat the *v1.Service and *v1.Node // parameters as read-only and not modify them. // Parameter 'clusterName' is the name of the cluster as presented to kube-controller-manager EnsureLoadBalancer(clusterName string, service *v1.Service, nodes []*v1.Node) (*v1.LoadBalancerStatus, error) // UpdateLoadBalancer updates hosts under the specified load balancer. // Implementations must treat the *v1.Service and *v1.Node // parameters as read-only and not modify them. // Parameter 'clusterName' is the name of the cluster as presented to kube-controller-manager UpdateLoadBalancer(clusterName string, service *v1.Service, nodes []*v1.Node) error // EnsureLoadBalancerDeleted deletes the specified load balancer if it // exists, returning nil if the load balancer specified either didn't exist or // was successfully deleted. // This construction is useful because many cloud providers' load balancers // have multiple underlying components, meaning a Get could say that the LB // doesn't exist even if some part of it is still laying around. // Implementations must treat the *v1.Service parameter as read-only and not modify it. // Parameter 'clusterName' is the name of the cluster as presented to kube-controller-manager EnsureLoadBalancerDeleted(clusterName string, service *v1.Service) error }
LoadBalancer is an abstract, pluggable interface for load balancers.
type Route ¶
type Route struct { // Name is the name of the routing rule in the cloud-provider. // It will be ignored in a Create (although nameHint may influence it) Name string // TargetNode is the NodeName of the target instance. TargetNode types.NodeName // DestinationCIDR is the CIDR format IP range that this routing rule // applies to. DestinationCIDR string }
Route is a representation of an advanced routing rule.
type Routes ¶
type Routes interface { // ListRoutes lists all managed routes that belong to the specified clusterName ListRoutes(clusterName string) ([]*Route, error) // CreateRoute creates the described managed route // route.Name will be ignored, although the cloud-provider may use nameHint // to create a more user-meaningful name. CreateRoute(clusterName string, nameHint string, route *Route) error // DeleteRoute deletes the specified managed route // Route should be as returned by ListRoutes DeleteRoute(clusterName string, route *Route) error }
Routes is an abstract, pluggable interface for advanced routing rules.