scaleway

Documentation

Index

• Constants
• func CreateValidScalewayProfile() (*scw.Profile, error)
• func NewScalewayAuthenticator() (bootstrap.Authenticator, error)
• func NewScalewayVerifier(ctx context.Context, opt *ScalewayVerifierOptions) (bootstrap.Verifier, error)
• func ParseRegionFromZone(zone scw.Zone) (region scw.Region, err error)
• func ParseZoneFromClusterSpec(clusterSpec kops.ClusterSpec) (scw.Zone, error)
• type ScalewayVerifierOptions
• type ScwAPITarget
  • func NewScwAPITarget(cloud ScwCloud) *ScwAPITarget
  • func (t *ScwAPITarget) DefaultCheckExisting() bool
  • func (s ScwAPITarget) Finish(taskMap map[string]fi.CloudupTask) error
  • func (s ScwAPITarget) ProcessDeletions() bool
• type ScwCloud
  • func NewScwCloud(tags map[string]string) (ScwCloud, error)

Constants

const (
	TagClusterName           = "noprefix=kops.k8s.io/cluster"
	TagInstanceGroup         = "noprefix=kops.k8s.io/instance-group"
	TagNameRolePrefix        = "noprefix=kops.k8s.io/role"
	TagNameEtcdClusterPrefix = "noprefix=kops.k8s.io/etcd"
	TagRoleControlPlane      = "ControlPlane"
	TagRoleWorker            = "Node"
	KopsUserAgentPrefix      = "kubernetes-kops/"
)

const ScalewayAuthenticationTokenPrefix = "x-scaleway-instance-server-id "

Functions

func CreateValidScalewayProfile

func CreateValidScalewayProfile() (*scw.Profile, error)

func NewScalewayAuthenticator

func NewScalewayAuthenticator() (bootstrap.Authenticator, error)

func NewScalewayVerifier

func NewScalewayVerifier(ctx context.Context, opt *ScalewayVerifierOptions) (bootstrap.Verifier, error)

func ParseRegionFromZone

func ParseRegionFromZone(zone scw.Zone) (region scw.Region, err error)

func ParseZoneFromClusterSpec

func ParseZoneFromClusterSpec(clusterSpec kops.ClusterSpec) (scw.Zone, error)

Types

type ScalewayVerifierOptions

type ScalewayVerifierOptions struct{}

type ScwAPITarget

type ScwAPITarget struct {
	Cloud ScwCloud
}

func NewScwAPITarget

func NewScwAPITarget(cloud ScwCloud) *ScwAPITarget

func (*ScwAPITarget) DefaultCheckExisting

func (t *ScwAPITarget) DefaultCheckExisting() bool

func (ScwAPITarget) Finish

func (s ScwAPITarget) Finish(taskMap map[string]fi.CloudupTask) error

func (ScwAPITarget) ProcessDeletions

func (s ScwAPITarget) ProcessDeletions() bool

type ScwCloud

type ScwCloud interface {
	fi.Cloud

	ClusterName(tags []string) string
	DNS() (dnsprovider.Interface, error)
	ProviderID() kops.CloudProviderID
	Region() string
	Zone() string

	DomainService() *domain.API
	IamService() *iam.API
	InstanceService() *instance.API
	LBService() *lb.ZonedAPI

	DeleteGroup(group *cloudinstances.CloudInstanceGroup) error
	DeleteInstance(i *cloudinstances.CloudInstance) error
	DeregisterInstance(instance *cloudinstances.CloudInstance) error
	DetachInstance(instance *cloudinstances.CloudInstance) error
	FindClusterStatus(cluster *kops.Cluster) (*kops.ClusterStatus, error)
	FindVPCInfo(id string) (*fi.VPCInfo, error)
	GetApiIngressStatus(cluster *kops.Cluster) ([]fi.ApiIngressStatus, error)
	GetCloudGroups(cluster *kops.Cluster, instancegroups []*kops.InstanceGroup, warnUnmatched bool, nodes []v1.Node) (map[string]*cloudinstances.CloudInstanceGroup, error)

	GetClusterDNSRecords(clusterName string) ([]*domain.Record, error)
	GetClusterLoadBalancers(clusterName string) ([]*lb.LB, error)
	GetClusterServers(clusterName string, instanceGroupName *string) ([]*instance.Server, error)
	GetClusterSSHKeys(clusterName string) ([]*iam.SSHKey, error)
	GetClusterVolumes(clusterName string) ([]*instance.Volume, error)

	DeleteDNSRecord(record *domain.Record, clusterName string) error
	DeleteLoadBalancer(loadBalancer *lb.LB) error
	DeleteServer(server *instance.Server) error
	DeleteSSHKey(sshkey *iam.SSHKey) error
	DeleteVolume(volume *instance.Volume) error
}

ScwCloud exposes all the interfaces required to operate on Scaleway resources

func NewScwCloud

func NewScwCloud(tags map[string]string) (ScwCloud, error)

NewScwCloud returns a Cloud with a Scaleway Client using the env vars SCW_PROFILE or SCW_ACCESS_KEY, SCW_SECRET_KEY and SCW_DEFAULT_PROJECT_ID