infracluster

Documentation

Index

• Constants
• func GetResourceTagsFromInfraClusterAnnotations(annotations map[string]string) map[string]*string
• type ClusterZoneAzureConfig
• type CommonPatcher
  • func NewCommonPatcher(ctx context.Context, params CommonPatcherParams) (*CommonPatcher, error)
  • func (s *CommonPatcher) APIServerPrivateIP() string
  • func (s *CommonPatcher) APIServerPublicIP() *infrav1.PublicIPSpec
  • func (s *CommonPatcher) ClientID() string
  • func (s *CommonPatcher) Close(ctx context.Context) error
  • func (s *CommonPatcher) ClusterName() string
  • func (s *CommonPatcher) IsAPIServerPrivate() bool
  • func (s *CommonPatcher) PatchObject(ctx context.Context) error
  • func (s *CommonPatcher) SubscriptionID() string
  • func (s *CommonPatcher) TenantID() string
• type CommonPatcherParams
• type ManagementClusterConfig
• type Patcher
• type PublicIPService
  • func NewPublicIPService(cluster *capi.Cluster) *PublicIPService
  • func (s *PublicIPService) Get(ctx context.Context, spec azure.ResourceSpecGetter) (result interface{}, err error)
• type Scope
  • func NewScope(ctx context.Context, params ScopeParams) (*Scope, error)
  • func (s *Scope) AzureClusterSpec() *infrav1.AzureClusterSpec
  • func (s *Scope) AzureClusterStatus() *infrav1.AzureClusterStatus
  • func (s *Scope) ClusterK8sClient(ctx context.Context) (client.Client, error)
  • func (s *Scope) InfraClusterAnnotations() map[string]string
  • func (s *Scope) InfraClusterIdentity(ctx context.Context) (*infrav1.AzureClusterIdentity, error)
  • func (s *Scope) IsAzureCluster() bool
  • func (s *Scope) ManagementCluster(ctx context.Context) (*infrav1.AzureCluster, error)
  • func (s *Scope) ManagementClusterIdentity(ctx context.Context) (*infrav1.AzureClusterIdentity, error)
  • func (s *Scope) PublicIPsService() async.Getter
• type ScopeParams

Constants

const (
	ResourceTagNamePrefix = "azure-resourcegroup-tag."
)

Functions

func GetResourceTagsFromInfraClusterAnnotations

func GetResourceTagsFromInfraClusterAnnotations(annotations map[string]string) map[string]*string

Types

type ClusterZoneAzureConfig

type ClusterZoneAzureConfig struct {
	SubscriptionID string
	ClientID       string
	TenantID       string
	ClientSecret   string
	Location       string
}

type CommonPatcher

type CommonPatcher struct {
	Cluster      *capi.Cluster
	InfraCluster *unstructured.Unstructured
	// contains filtered or unexported fields
}

func NewCommonPatcher

func NewCommonPatcher(ctx context.Context, params CommonPatcherParams) (*CommonPatcher, error)

func (*CommonPatcher) APIServerPrivateIP

func (s *CommonPatcher) APIServerPrivateIP() string

func (*CommonPatcher) APIServerPublicIP

func (s *CommonPatcher) APIServerPublicIP() *infrav1.PublicIPSpec

func (*CommonPatcher) ClientID

func (s *CommonPatcher) ClientID() string

func (*CommonPatcher) Close

func (s *CommonPatcher) Close(ctx context.Context) error

func (*CommonPatcher) ClusterName

func (s *CommonPatcher) ClusterName() string

func (*CommonPatcher) IsAPIServerPrivate

func (s *CommonPatcher) IsAPIServerPrivate() bool

func (*CommonPatcher) PatchObject

func (s *CommonPatcher) PatchObject(ctx context.Context) error

func (*CommonPatcher) SubscriptionID

func (s *CommonPatcher) SubscriptionID() string

func (*CommonPatcher) TenantID

func (s *CommonPatcher) TenantID() string

type CommonPatcherParams

type CommonPatcherParams struct {
	ClientID       string
	SubscriptionID string
	TenantID       string
	Cluster        *capi.Cluster
	InfraCluster   *unstructured.Unstructured
	K8sClient      client.Client
}

type ManagementClusterConfig

type ManagementClusterConfig struct {
	Name      string
	Namespace string
}

type Patcher

type Patcher interface {
	ClientID() string
	SubscriptionID() string
	TenantID() string
	ClusterName() string
	PatchObject(ctx context.Context) error
	IsAPIServerPrivate() bool
	APIServerPrivateIP() string
	APIServerPublicIP() *infrav1.PublicIPSpec
	Close(ctx context.Context) error
}

type PublicIPService

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

func NewPublicIPService

func NewPublicIPService(cluster *capi.Cluster) *PublicIPService

func (*PublicIPService) Get

func (s *PublicIPService) Get(ctx context.Context, spec azure.ResourceSpecGetter) (result interface{}, err error)

type Scope

type Scope struct {
	Client       client.Client
	Cluster      *capi.Cluster
	InfraCluster *unstructured.Unstructured

	Patcher Patcher

	AzureLocation string
	// contains filtered or unexported fields
}

func NewScope

func NewScope(ctx context.Context, params ScopeParams) (*Scope, error)

func (*Scope) AzureClusterSpec

func (s *Scope) AzureClusterSpec() *infrav1.AzureClusterSpec

func (*Scope) AzureClusterStatus

func (s *Scope) AzureClusterStatus() *infrav1.AzureClusterStatus

func (*Scope) ClusterK8sClient

func (s *Scope) ClusterK8sClient(ctx context.Context) (client.Client, error)

func (*Scope) InfraClusterAnnotations

func (s *Scope) InfraClusterAnnotations() map[string]string

func (*Scope) InfraClusterIdentity

func (s *Scope) InfraClusterIdentity(ctx context.Context) (*infrav1.AzureClusterIdentity, error)

func (*Scope) IsAzureCluster

func (s *Scope) IsAzureCluster() bool

func (*Scope) ManagementCluster

func (s *Scope) ManagementCluster(ctx context.Context) (*infrav1.AzureCluster, error)

func (*Scope) ManagementClusterIdentity

func (s *Scope) ManagementClusterIdentity(ctx context.Context) (*infrav1.AzureClusterIdentity, error)

func (*Scope) PublicIPsService

func (s *Scope) PublicIPsService() async.Getter

type ScopeParams

type ScopeParams struct {
	Client                  client.Client
	Cluster                 *capi.Cluster
	InfraCluster            *unstructured.Unstructured
	Cache                   *capzscope.ClusterCache
	ManagementClusterConfig ManagementClusterConfig
	ClusterIdentityRef      *corev1.ObjectReference
	ClusterZoneAzureConfig  ClusterZoneAzureConfig
}