protokube

package
v1.24.0 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2022 License: Apache-2.0 Imports: 44 Imported by: 94

Documentation

Index

Constants

View Source 
const MetadataLatest string = "http://169.254.169.254/openstack/latest/meta_data.json"

Variables

View Source 
var RootFS = "/"

RootFS is the root fs path

Functions

func GetClusterID added in v1.16.0 

func GetClusterID() (string, error)

func NewDOCloud added in v1.21.3 

func NewDOCloud() (*godo.Client, error)

Types

type AWSCloudProvider added in v1.24.0 

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

AWSCloudProvider defines the AWS cloud provider implementation

func NewAWSCloudProvider added in v1.24.0 

func NewAWSCloudProvider() (*AWSCloudProvider, error)

NewAWSCloudProvider returns a new aws volume provider

func (*AWSCloudProvider) GossipSeeds added in v1.24.0 

func (a *AWSCloudProvider) GossipSeeds() (gossip.SeedProvider, error)

func (*AWSCloudProvider) InstanceID added in v1.24.0 

func (a *AWSCloudProvider) InstanceID() string

func (*AWSCloudProvider) InstanceInternalIP added in v1.24.0 

func (a *AWSCloudProvider) InstanceInternalIP() net.IP

type AzureCloudProvider added in v1.24.0 

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

AzureCloudProvider implements the CloudProvider interface for Azure.

func NewAzureCloudProvider added in v1.24.0 

func NewAzureCloudProvider() (*AzureCloudProvider, error)

NewAzureCloudProvider returns a new AzureCloudProvider.

func (*AzureCloudProvider) GossipSeeds added in v1.24.0 

func (a *AzureCloudProvider) GossipSeeds() (gossip.SeedProvider, error)

GossipSeeds implements CloudProvider GossipSeeds.

func (*AzureCloudProvider) InstanceID added in v1.24.0 

func (a *AzureCloudProvider) InstanceID() string

InstanceID implements CloudProvider InstanceID.

func (*AzureCloudProvider) InstanceInternalIP added in v1.24.0 

func (a *AzureCloudProvider) InstanceInternalIP() net.IP

InstanceInternalIP implements CloudProvider InstanceInternalIP.

type CloudProvider added in v1.24.0 

type CloudProvider interface {
	InstanceID() string
	InstanceInternalIP() net.IP
	GossipSeeds() (gossip.SeedProvider, error)
}

type DOCloudProvider added in v1.24.0 

type DOCloudProvider struct {
	ClusterID string
	// contains filtered or unexported fields
}

func NewDOCloudProvider added in v1.24.0 

func NewDOCloudProvider() (*DOCloudProvider, error)

func (*DOCloudProvider) GossipSeeds added in v1.24.0 

func (d *DOCloudProvider) GossipSeeds() (gossip.SeedProvider, error)

func (*DOCloudProvider) InstanceID added in v1.24.0 

func (d *DOCloudProvider) InstanceID() string

func (*DOCloudProvider) InstanceInternalIP added in v1.24.0 

func (d *DOCloudProvider) InstanceInternalIP() net.IP

type GCECloudProvider added in v1.24.0 

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

GCECloudProvider is the CloudProvider implementation for GCE

func NewGCECloudProvider added in v1.24.0 

func NewGCECloudProvider() (*GCECloudProvider, error)

NewGCECloudProvider builds a GCECloudProvider

func (*GCECloudProvider) GossipSeeds added in v1.24.0 

func (g *GCECloudProvider) GossipSeeds() (gossip.SeedProvider, error)

func (*GCECloudProvider) InstanceID added in v1.24.0 

func (g *GCECloudProvider) InstanceID() string

func (*GCECloudProvider) InstanceInternalIP added in v1.24.0 

func (a *GCECloudProvider) InstanceInternalIP() net.IP

InstanceInternalIP implements CloudProvider InstanceInternalIP

func (*GCECloudProvider) Project added in v1.24.0 

func (a *GCECloudProvider) Project() string

Project returns the current GCE project

type HetznerCloudProvider added in v1.24.0 

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

HetznerCloudProvider defines the Hetzner Cloud volume implementation.

func NewHetznerCloudProvider added in v1.24.0 

func NewHetznerCloudProvider() (*HetznerCloudProvider, error)

NewHetznerCloudProvider returns a new Hetzner Cloud provider.

func (*HetznerCloudProvider) GossipSeeds added in v1.24.0 

func (h *HetznerCloudProvider) GossipSeeds() (gossip.SeedProvider, error)

func (*HetznerCloudProvider) InstanceID added in v1.24.0 

func (h *HetznerCloudProvider) InstanceID() string

func (HetznerCloudProvider) InstanceInternalIP added in v1.24.0 

func (h HetznerCloudProvider) InstanceInternalIP() net.IP

type InstanceMetadata added in v1.15.1 

type InstanceMetadata struct {
	Name             string    `json:"name"`
	UserMeta         *Metadata `json:"meta"`
	ProjectID        string    `json:"project_id"`
	AvailabilityZone string    `json:"availability_zone"`
	Hostname         string    `json:"hostname"`
	ServerID         string    `json:"uuid"`
}

type KubeBoot 

type KubeBoot struct {
	// Channels is a list of channel to apply
	Channels []string
	// InternalDNSSuffix is the dns zone we are living in
	InternalDNSSuffix string
	// InternalIP is the internal ip address of the node
	InternalIP net.IP
	// Kubernetes holds a kubernetes client
	Kubernetes *KubernetesContext
	// Master indicates we are a master node
	Master bool

	// BootstrapMasterNodeLabels controls the initial application of node labels to our node
	// The node is found by matching NodeName
	BootstrapMasterNodeLabels bool

	// NodeName is the name of our node as it will be registered in k8s.
	// Used by BootstrapMasterNodeLabels
	NodeName string
}

KubeBoot is the options for the protokube service

func (*KubeBoot) RunSyncLoop 

func (k *KubeBoot) RunSyncLoop()

RunSyncLoop is responsible for provision the cluster

type KubernetesContext 

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

KubernetesContext is the kubernetes context

func NewKubernetesContext 

func NewKubernetesContext() *KubernetesContext

NewKubernetesContext returns a new KubernetesContext

func (*KubernetesContext) KubernetesClient 

func (c *KubernetesContext) KubernetesClient() (kubernetes.Interface, error)

KubernetesClient returns a new kubernetes api client

type Metadata added in v1.15.1 

type Metadata struct {
	// Matches openstack.TagClusterName
	ClusterName string `json:"KubernetesCluster"`
}

type OpenStackCloudProvider added in v1.24.0 

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

OpenStackCloudProvider is the CloudProvider implementation for OpenStack

func NewOpenStackCloudProvider added in v1.24.0 

func NewOpenStackCloudProvider() (*OpenStackCloudProvider, error)

NewOpenStackCloudProvider builds a OpenstackVolume

func (*OpenStackCloudProvider) GossipSeeds added in v1.24.0 

func (g *OpenStackCloudProvider) GossipSeeds() (gossip.SeedProvider, error)

func (*OpenStackCloudProvider) InstanceID added in v1.24.0 

func (g *OpenStackCloudProvider) InstanceID() string

func (*OpenStackCloudProvider) InstanceInternalIP added in v1.24.0 

func (a *OpenStackCloudProvider) InstanceInternalIP() net.IP

InstanceInternalIP implements CloudProvider InstanceInternalIP

func (*OpenStackCloudProvider) Project added in v1.24.0 

func (a *OpenStackCloudProvider) Project() string

Project returns the current OpenStack project

type TokenSource added in v1.21.3 

type TokenSource struct {
	AccessToken string
}

TokenSource implements oauth2.TokenSource

func (*TokenSource) Token added in v1.21.3 

func (t *TokenSource) Token() (*oauth2.Token, error)

Token() returns oauth2.Token

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.