package openstack

import "k8s.io/kubernetes/pkg/cloudprovider/providers/openstack"

Index ¶

• Constants
• Variables
• type Config
• type Instances
• func (i *Instances) AddSSHKeyToAllInstances(user string, keyData []byte) error
• func (i *Instances) CurrentNodeName(hostname string) (string, error)
• func (i *Instances) ExternalID(name string) (string, error)
• func (i *Instances) InstanceID(name string) (string, error)
• func (i *Instances) List(name_filter string) ([]string, error)
• func (i *Instances) NodeAddresses(name string) ([]api.NodeAddress, error)
• type LoadBalancer
• func (lb *LoadBalancer) EnsureTCPLoadBalancer(name, region string, loadBalancerIP net.IP, ports []*api.ServicePort, hosts []string, affinity api.ServiceAffinity) (*api.LoadBalancerStatus, error)
• func (lb *LoadBalancer) EnsureTCPLoadBalancerDeleted(name, region string) error
• func (lb *LoadBalancer) GetTCPLoadBalancer(name, region string) (*api.LoadBalancerStatus, bool, error)
• func (lb *LoadBalancer) UpdateTCPLoadBalancer(name, region string, hosts []string) error
• type LoadBalancerOpts
• type MyDuration
• func (d *MyDuration) UnmarshalText(text []byte) error
• type OpenStack
• func (os *OpenStack) AttachDisk(diskName string) (string, error)
• func (os *OpenStack) Clusters() (cloudprovider.Clusters, bool)
• func (os *OpenStack) DetachDisk(partialDiskId string) error
• func (os *OpenStack) GetZone() (cloudprovider.Zone, error)
• func (os *OpenStack) Instances() (cloudprovider.Instances, bool)
• func (os *OpenStack) ProviderName() string
• func (os *OpenStack) Routes() (cloudprovider.Routes, bool)
• func (os *OpenStack) ScrubDNS(nameservers, searches []string) (nsOut, srchOut []string)
• func (os *OpenStack) TCPLoadBalancer() (cloudprovider.TCPLoadBalancer, bool)
• func (os *OpenStack) Zones() (cloudprovider.Zones, bool)

Constants ¶

const (
	MiB = 1024 * 1024
	GB  = 1000 * 1000 * 1000
)

const ProviderName = "openstack"

Variables ¶

var ErrAttrNotFound = errors.New("Expected attribute not found")

var ErrMultipleResults = errors.New("Multiple results where only one expected")

var ErrNoAddressFound = errors.New("No address found for host")

var ErrNotFound = errors.New("Failed to find object")

Types ¶

type Config ¶

type Config struct {
	Global struct {
		AuthUrl    string `gcfg:"auth-url"`
		Username   string
		UserId     string `gcfg:"user-id"`
		Password   string
		ApiKey     string `gcfg:"api-key"`
		TenantId   string `gcfg:"tenant-id"`
		TenantName string `gcfg:"tenant-name"`
		DomainId   string `gcfg:"domain-id"`
		DomainName string `gcfg:"domain-name"`
		Region     string
	}
	LoadBalancer LoadBalancerOpts
}

type Instances ¶

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

func (*Instances) AddSSHKeyToAllInstances ¶

func (i *Instances) AddSSHKeyToAllInstances(user string, keyData []byte) error

func (*Instances) CurrentNodeName ¶

func (i *Instances) CurrentNodeName(hostname string) (string, error)

Implementation of Instances.CurrentNodeName

func (*Instances) ExternalID ¶

func (i *Instances) ExternalID(name string) (string, error)

ExternalID returns the cloud provider ID of the specified instance (deprecated).

func (*Instances) InstanceID ¶

func (i *Instances) InstanceID(name string) (string, error)

InstanceID returns the cloud provider ID of the specified instance.

func (*Instances) List ¶

func (i *Instances) List(name_filter string) ([]string, error)

func (*Instances) NodeAddresses ¶

func (i *Instances) NodeAddresses(name string) ([]api.NodeAddress, error)

type LoadBalancer ¶

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

func (*LoadBalancer) EnsureTCPLoadBalancer ¶

func (lb *LoadBalancer) EnsureTCPLoadBalancer(name, region string, loadBalancerIP net.IP, ports []*api.ServicePort, hosts []string, affinity api.ServiceAffinity) (*api.LoadBalancerStatus, error)

func (*LoadBalancer) EnsureTCPLoadBalancerDeleted ¶

func (lb *LoadBalancer) EnsureTCPLoadBalancerDeleted(name, region string) error

func (*LoadBalancer) GetTCPLoadBalancer ¶

func (lb *LoadBalancer) GetTCPLoadBalancer(name, region string) (*api.LoadBalancerStatus, bool, error)

func (*LoadBalancer) UpdateTCPLoadBalancer ¶

func (lb *LoadBalancer) UpdateTCPLoadBalancer(name, region string, hosts []string) error

type LoadBalancerOpts ¶

type LoadBalancerOpts struct {
	SubnetId          string     `gcfg:"subnet-id"` // required
	LBMethod          string     `gfcg:"lb-method"`
	CreateMonitor     bool       `gcfg:"create-monitor"`
	MonitorDelay      MyDuration `gcfg:"monitor-delay"`
	MonitorTimeout    MyDuration `gcfg:"monitor-timeout"`
	MonitorMaxRetries uint       `gcfg:"monitor-max-retries"`
}

type MyDuration ¶

type MyDuration struct {
	time.Duration
}

encoding.TextUnmarshaler interface for time.Duration

func (*MyDuration) UnmarshalText ¶

func (d *MyDuration) UnmarshalText(text []byte) error

type OpenStack ¶

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

OpenStack is an implementation of cloud provider Interface for OpenStack.

func (*OpenStack) AttachDisk ¶

func (os *OpenStack) AttachDisk(diskName string) (string, error)

Attaches given cinder volume to the compute running kubelet

func (*OpenStack) Clusters ¶

func (os *OpenStack) Clusters() (cloudprovider.Clusters, bool)

func (*OpenStack) DetachDisk ¶

func (os *OpenStack) DetachDisk(partialDiskId string) error

Detaches given cinder volume from the compute running kubelet

func (*OpenStack) GetZone ¶

func (os *OpenStack) GetZone() (cloudprovider.Zone, error)

func (*OpenStack) Instances ¶

func (os *OpenStack) Instances() (cloudprovider.Instances, bool)

Instances returns an implementation of Instances for OpenStack.

func (*OpenStack) ProviderName ¶

func (os *OpenStack) ProviderName() string

ProviderName returns the cloud provider ID.

func (*OpenStack) Routes ¶

func (os *OpenStack) Routes() (cloudprovider.Routes, bool)

func (*OpenStack) ScrubDNS ¶

func (os *OpenStack) ScrubDNS(nameservers, searches []string) (nsOut, srchOut []string)

ScrubDNS filters DNS settings for pods.

func (*OpenStack) TCPLoadBalancer ¶

func (os *OpenStack) TCPLoadBalancer() (cloudprovider.TCPLoadBalancer, bool)

func (*OpenStack) Zones ¶

func (os *OpenStack) Zones() (cloudprovider.Zones, bool)

Source Files ¶

openstack.go