Documentation ¶
Index ¶
- Constants
- Variables
- func ConvertMachineDefinedTags(machineDefinedTags map[string]map[string]string) map[string]map[string]interface{}
- func GetNsgNamesFromId(ids []string, nsgs []*infrastructurev1beta2.NSG) []string
- func GetRegionCodeFromRegion(ctx context.Context, identityClient identityClient.Client, region string) (string, error)
- func GetSubnetNameFromId(id *string, subnets []*infrastructurev1beta2.Subnet) string
- func GetSubnetNamesFromId(ids []string, subnets []*infrastructurev1beta2.Subnet) []string
- func MockAuthConfig() (config.AuthConfig, error)
- type ClientProvider
- type ClientProviderParams
- type ClusterScope
- func (s *ClusterScope) APIServerPort() int32
- func (s *ClusterScope) AddNSGSecurityRules(ctx context.Context, nsgId *string, ...) error
- func (s *ClusterScope) CreateInternetGateway(ctx context.Context) (*string, error)
- func (s *ClusterScope) CreateLB(ctx context.Context, lb infrastructurev1beta2.LoadBalancer) (*string, *string, error)
- func (s *ClusterScope) CreateNLB(ctx context.Context, lb infrastructurev1beta2.LoadBalancer) (*string, *string, error)
- func (s *ClusterScope) CreateNSG(ctx context.Context, nsg infrastructurev1beta2.NSG) (*string, error)
- func (s *ClusterScope) CreateNatGateway(ctx context.Context) (*string, error)
- func (s *ClusterScope) CreateRouteTable(ctx context.Context, routeTableType string) (*string, error)
- func (s *ClusterScope) CreateSecurityList(ctx context.Context, secList infrastructurev1beta2.SecurityList) (*string, error)
- func (s *ClusterScope) CreateServiceGateway(ctx context.Context) (*string, error)
- func (s *ClusterScope) CreateSubnet(ctx context.Context, spec infrastructurev1beta2.Subnet) (*string, error)
- func (s *ClusterScope) CreateVCN(ctx context.Context, spec infrastructurev1beta2.VCN) (*string, error)
- func (s *ClusterScope) DeleteApiServerLB(ctx context.Context) error
- func (s *ClusterScope) DeleteApiServerNLB(ctx context.Context) error
- func (s *ClusterScope) DeleteDRG(ctx context.Context) error
- func (s *ClusterScope) DeleteDRGRPCAttachment(ctx context.Context) error
- func (s *ClusterScope) DeleteDRGVCNAttachment(ctx context.Context) error
- func (s *ClusterScope) DeleteInternetGateway(ctx context.Context) error
- func (s *ClusterScope) DeleteNSGs(ctx context.Context) error
- func (s *ClusterScope) DeleteNatGateway(ctx context.Context) error
- func (s *ClusterScope) DeleteRouteTables(ctx context.Context) error
- func (s *ClusterScope) DeleteSecurityLists(ctx context.Context) error
- func (s *ClusterScope) DeleteServiceGateway(ctx context.Context) error
- func (s *ClusterScope) DeleteSubnets(ctx context.Context) error
- func (s *ClusterScope) DeleteVCN(ctx context.Context) error
- func (s *ClusterScope) GetCompartmentId() string
- func (s *ClusterScope) GetControlPlaneEndpointSubnet() *infrastructurev1beta2.Subnet
- func (s *ClusterScope) GetControlPlaneEndpointSubnetCidr() string
- func (s *ClusterScope) GetControlPlaneLbsLoadBalancerName() string
- func (s *ClusterScope) GetControlPlaneLoadBalancerName() string
- func (s *ClusterScope) GetControlPlaneMachineSubnet() *infrastructurev1beta2.Subnet
- func (s *ClusterScope) GetControlPlaneMachineSubnetCidr() string
- func (s *ClusterScope) GetDRG(ctx context.Context) (*core.Drg, error)
- func (s *ClusterScope) GetDRGAttachment(ctx context.Context) (*core.DrgAttachment, error)
- func (s *ClusterScope) GetDRGName() string
- func (s *ClusterScope) GetDefinedTags() map[string]map[string]interface{}
- func (s *ClusterScope) GetDesiredRouteTables() []string
- func (s *ClusterScope) GetFreeFormTags() map[string]string
- func (s *ClusterScope) GetInternetGateway(ctx context.Context) (*core.InternetGateway, error)
- func (s *ClusterScope) GetLoadBalancers(ctx context.Context) (*loadbalancer.LoadBalancer, error)
- func (s *ClusterScope) GetNSG(ctx context.Context, spec infrastructurev1beta2.NSG) (*core.NetworkSecurityGroup, error)
- func (s *ClusterScope) GetNSGSpec() []*infrastructurev1beta2.NSG
- func (s *ClusterScope) GetNatGateway(ctx context.Context) (*core.NatGateway, error)
- func (s *ClusterScope) GetNetworkLoadBalancers(ctx context.Context) (*networkloadbalancer.NetworkLoadBalancer, error)
- func (s *ClusterScope) GetNodeSubnet() []*infrastructurev1beta2.Subnet
- func (s *ClusterScope) GetOCIClusterAccessor() OCIClusterAccessor
- func (s *ClusterScope) GetSecurityList(ctx context.Context, spec infrastructurev1beta2.SecurityList) (*core.SecurityList, error)
- func (s *ClusterScope) GetServiceGateway(ctx context.Context) (*core.ServiceGateway, error)
- func (s *ClusterScope) GetServiceLoadBalancerSubnet() *infrastructurev1beta2.Subnet
- func (s *ClusterScope) GetServiceLoadBalancerSubnetCidr() string
- func (s *ClusterScope) GetSubnet(ctx context.Context, spec infrastructurev1beta2.Subnet) (*core.Subnet, error)
- func (s *ClusterScope) GetSubnetsSpec() []*infrastructurev1beta2.Subnet
- func (s *ClusterScope) GetVCN(ctx context.Context) (*core.Vcn, error)
- func (s *ClusterScope) GetVcnCidr() string
- func (s *ClusterScope) GetVcnName() string
- func (s *ClusterScope) IsAllSubnetsPrivate() bool
- func (s *ClusterScope) IsAllSubnetsPublic() bool
- func (s *ClusterScope) IsLBEqual(actual *loadbalancer.LoadBalancer, desired infrastructurev1beta2.LoadBalancer) bool
- func (s *ClusterScope) IsNLBEqual(actual *networkloadbalancer.NetworkLoadBalancer, ...) bool
- func (s *ClusterScope) IsNSGEqual(actual *core.NetworkSecurityGroup, desired infrastructurev1beta2.NSG) bool
- func (s *ClusterScope) IsNSGExitsByRole(role infrastructurev1beta2.Role) bool
- func (s *ClusterScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
- func (s *ClusterScope) IsSecurityListEqual(actual core.SecurityList, desired infrastructurev1beta2.SecurityList) bool
- func (s *ClusterScope) IsSecurityListExitsByRole(role infrastructurev1beta2.Role) bool
- func (s *ClusterScope) IsSubnetsEqual(actual *core.Subnet, desired infrastructurev1beta2.Subnet) bool
- func (s *ClusterScope) IsVcnEquals(actual *core.Vcn, desired infrastructurev1beta2.VCN) bool
- func (s *ClusterScope) LBSpec() infrastructurev1beta2.LoadBalancer
- func (s *ClusterScope) NLBSpec() infrastructurev1beta2.LoadBalancer
- func (s *ClusterScope) NodeSubnetCidr() []string
- func (s *ClusterScope) ReconcileApiServerLB(ctx context.Context) error
- func (s *ClusterScope) ReconcileApiServerNLB(ctx context.Context) error
- func (s *ClusterScope) ReconcileDRG(ctx context.Context) error
- func (s *ClusterScope) ReconcileDRGRPCAttachment(ctx context.Context) error
- func (s *ClusterScope) ReconcileDRGVCNAttachment(ctx context.Context) error
- func (s *ClusterScope) ReconcileFailureDomains(ctx context.Context) error
- func (s *ClusterScope) ReconcileInternetGateway(ctx context.Context) error
- func (s *ClusterScope) ReconcileNSG(ctx context.Context) error
- func (s *ClusterScope) ReconcileNatGateway(ctx context.Context) error
- func (s *ClusterScope) ReconcileRouteTable(ctx context.Context) error
- func (s *ClusterScope) ReconcileServiceGateway(ctx context.Context) error
- func (s *ClusterScope) ReconcileSubnet(ctx context.Context) error
- func (s *ClusterScope) ReconcileVCN(ctx context.Context) error
- func (s *ClusterScope) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
- func (s *ClusterScope) SetRegionKey(ctx context.Context) error
- func (s *ClusterScope) UpdateDRGAttachment(ctx context.Context) (*core.DrgAttachment, error)
- func (s *ClusterScope) UpdateLB(ctx context.Context, lb infrastructurev1beta2.LoadBalancer) error
- func (s *ClusterScope) UpdateNLB(ctx context.Context, nlb infrastructurev1beta2.LoadBalancer) error
- func (s *ClusterScope) UpdateNSG(ctx context.Context, nsgSpec infrastructurev1beta2.NSG) error
- func (s *ClusterScope) UpdateNSGSecurityRulesIfNeeded(ctx context.Context, desired infrastructurev1beta2.NSG, ...) (bool, error)
- func (s *ClusterScope) UpdateNatGateway(ctx context.Context) error
- func (s *ClusterScope) UpdateSecurityList(ctx context.Context, securityListSpec infrastructurev1beta2.SecurityList) error
- func (s *ClusterScope) UpdateSubnet(ctx context.Context, spec infrastructurev1beta2.Subnet) error
- func (s *ClusterScope) UpdateVCN(ctx context.Context, vcn infrastructurev1beta2.VCN) error
- func (s *ClusterScope) VCNSpec() infrastructurev1beta2.VCN
- type ClusterScopeClient
- type ClusterScopeParams
- type MachinePoolScope
- func (s *MachinePoolScope) BuildInstancePoolPlacement() ([]core.CreateInstancePoolPlacementConfigurationDetails, error)
- func (m *MachinePoolScope) CleanupInstanceConfiguration(ctx context.Context, instancePool *core.InstancePool) error
- func (m *MachinePoolScope) Close(ctx context.Context) error
- func (m *MachinePoolScope) CreateInstancePool(ctx context.Context) (*core.InstancePool, error)
- func (m *MachinePoolScope) FindInstancePool(ctx context.Context) (*core.InstancePool, error)
- func (m *MachinePoolScope) GetBootstrapData() (string, error)
- func (m *MachinePoolScope) GetFreeFormTags() map[string]string
- func (m *MachinePoolScope) GetInstanceConfiguration(ctx context.Context) (*core.InstanceConfiguration, error)
- func (m *MachinePoolScope) GetInstanceConfigurationId() *string
- func (m *MachinePoolScope) GetWorkerMachineNSG() *string
- func (m *MachinePoolScope) GetWorkerMachineSubnet() *string
- func (m *MachinePoolScope) HasFailed() bool
- func (s *MachinePoolScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
- func (m *MachinePoolScope) ListInstancePoolSummaries(ctx context.Context, req core.ListInstancePoolsRequest) ([]core.InstancePoolSummary, error)
- func (m *MachinePoolScope) ListMachinePoolInstances(ctx context.Context) ([]core.InstanceSummary, error)
- func (m *MachinePoolScope) PatchObject(ctx context.Context) error
- func (m *MachinePoolScope) ReconcileInstanceConfiguration(ctx context.Context) error
- func (m *MachinePoolScope) SetFailureMessage(v error)
- func (m *MachinePoolScope) SetFailureReason(v capierrors.MachineStatusError)
- func (m *MachinePoolScope) SetInstanceConfigurationIdStatus(id string)
- func (m *MachinePoolScope) SetListandSetMachinePoolInstances(ctx context.Context) (int32, error)
- func (m *MachinePoolScope) SetReady()
- func (m *MachinePoolScope) SetReplicaCount(count int32)
- func (m *MachinePoolScope) TerminateInstancePool(ctx context.Context, instancePool *core.InstancePool) error
- func (m *MachinePoolScope) UpdatePool(ctx context.Context, instancePool *core.InstancePool) (*core.InstancePool, error)
- type MachinePoolScopeParams
- type MachineScope
- func (m *MachineScope) Close(ctx context.Context) error
- func (m *MachineScope) DeleteMachine(ctx context.Context, instance *core.Instance) error
- func (m *MachineScope) GetBootstrapData() (string, error)
- func (m *MachineScope) GetInstanceId() *string
- func (m *MachineScope) GetInstanceIp(ctx context.Context) (*string, error)
- func (m *MachineScope) GetMachine(ctx context.Context) (*core.Instance, error)
- func (m *MachineScope) GetMachineByDisplayName(ctx context.Context, name string) (*core.Instance, error)
- func (m *MachineScope) GetMachineIPFromStatus() (string, error)
- func (m *MachineScope) GetOrCreateMachine(ctx context.Context) (*core.Instance, error)
- func (m *MachineScope) IsControlPlane() bool
- func (m *MachineScope) IsReady() bool
- func (m *MachineScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
- func (m *MachineScope) Name() string
- func (m *MachineScope) PatchObject(ctx context.Context) error
- func (m *MachineScope) ReconcileCreateInstanceOnLB(ctx context.Context) error
- func (m *MachineScope) ReconcileDeleteInstanceOnLB(ctx context.Context) error
- func (m *MachineScope) ReconcileVnicAttachments(ctx context.Context) error
- func (m *MachineScope) SetFailureMessage(v error)
- func (m *MachineScope) SetFailureReason(v capierrors.MachineStatusError)
- func (m *MachineScope) SetNotReady()
- func (m *MachineScope) SetReady()
- type MachineScopeParams
- type ManagedControlPlaneScope
- func (s *ManagedControlPlaneScope) DeleteOKECluster(ctx context.Context, cluster *oke.Cluster) error
- func (s *ManagedControlPlaneScope) GetClusterName() string
- func (s *ManagedControlPlaneScope) GetOKECluster(ctx context.Context) (*oke.Cluster, error)
- func (s *ManagedControlPlaneScope) GetOrCreateControlPlane(ctx context.Context) (*oke.Cluster, error)
- func (s *ManagedControlPlaneScope) IsControlPlaneEndpointSubnetPublic() bool
- func (s *ManagedControlPlaneScope) ReconcileAddons(ctx context.Context, okeCluster *oke.Cluster) error
- func (s *ManagedControlPlaneScope) ReconcileKubeconfig(ctx context.Context, okeCluster *oke.Cluster) error
- func (s *ManagedControlPlaneScope) UpdateControlPlane(ctx context.Context, okeCluster *oke.Cluster) (bool, error)
- type ManagedControlPlaneScopeParams
- type ManagedMachinePoolScope
- func (m *ManagedMachinePoolScope) Close(ctx context.Context) error
- func (m *ManagedMachinePoolScope) CreateNodePool(ctx context.Context) (*oke.NodePool, error)
- func (m *ManagedMachinePoolScope) DeleteNodePool(ctx context.Context, nodePool *oke.NodePool) error
- func (m *ManagedMachinePoolScope) FindNodePool(ctx context.Context) (*oke.NodePool, error)
- func (m *ManagedMachinePoolScope) GetWorkerMachineSubnet() *string
- func (m *ManagedMachinePoolScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
- func (m *ManagedMachinePoolScope) PatchObject(ctx context.Context) error
- func (m *ManagedMachinePoolScope) SetFailureReason(v capierrors.MachineStatusError)
- func (m *ManagedMachinePoolScope) SetListandSetMachinePoolInstances(ctx context.Context, nodePool *oke.NodePool) (int32, error)
- func (m *ManagedMachinePoolScope) SetReplicaCount(count int32)
- func (m *ManagedMachinePoolScope) UpdateNodePool(ctx context.Context, pool *oke.NodePool) (bool, error)
- type ManagedMachinePoolScopeParams
- type MockOCIClients
- type OCIClients
- type OCIClusterAccessor
- type OCIManagedCluster
- func (c OCIManagedCluster) GetAvailabilityDomains() map[string]infrastructurev1beta2.OCIAvailabilityDomain
- func (c OCIManagedCluster) GetClientOverrides() *infrastructurev1beta2.ClientOverrides
- func (c OCIManagedCluster) GetCompartmentId() string
- func (c OCIManagedCluster) GetDRG() *infrastructurev1beta2.DRG
- func (c OCIManagedCluster) GetDefinedTags() map[string]map[string]string
- func (c OCIManagedCluster) GetFailureDomains() clusterv1.FailureDomains
- func (c OCIManagedCluster) GetFreeformTags() map[string]string
- func (c OCIManagedCluster) GetIdentityRef() *corev1.ObjectReference
- func (c OCIManagedCluster) GetName() string
- func (c OCIManagedCluster) GetNameSpace() string
- func (c OCIManagedCluster) GetNetworkSpec() *infrastructurev1beta2.NetworkSpec
- func (c OCIManagedCluster) GetOCIResourceIdentifier() string
- func (c OCIManagedCluster) GetRegion() string
- func (c OCIManagedCluster) GetVCNPeering() *infrastructurev1beta2.VCNPeering
- func (c OCIManagedCluster) MarkConditionFalse(t clusterv1.ConditionType, reason string, severity clusterv1.ConditionSeverity, ...)
- func (c OCIManagedCluster) SetAvailabilityDomains(ads map[string]infrastructurev1beta2.OCIAvailabilityDomain)
- func (c OCIManagedCluster) SetControlPlaneEndpoint(endpoint clusterv1.APIEndpoint)
- func (c OCIManagedCluster) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
- type OCISelfManagedCluster
- func (c OCISelfManagedCluster) GetAvailabilityDomains() map[string]infrastructurev1beta2.OCIAvailabilityDomain
- func (c OCISelfManagedCluster) GetClientOverrides() *infrastructurev1beta2.ClientOverrides
- func (c OCISelfManagedCluster) GetCompartmentId() string
- func (c OCISelfManagedCluster) GetDRG() *infrastructurev1beta2.DRG
- func (c OCISelfManagedCluster) GetDefinedTags() map[string]map[string]string
- func (c OCISelfManagedCluster) GetFailureDomains() clusterv1.FailureDomains
- func (c OCISelfManagedCluster) GetFreeformTags() map[string]string
- func (c OCISelfManagedCluster) GetIdentityRef() *corev1.ObjectReference
- func (c OCISelfManagedCluster) GetName() string
- func (c OCISelfManagedCluster) GetNameSpace() string
- func (c OCISelfManagedCluster) GetNetworkSpec() *infrastructurev1beta2.NetworkSpec
- func (c OCISelfManagedCluster) GetOCIResourceIdentifier() string
- func (c OCISelfManagedCluster) GetRegion() string
- func (c OCISelfManagedCluster) GetVCNPeering() *infrastructurev1beta2.VCNPeering
- func (c OCISelfManagedCluster) MarkConditionFalse(t clusterv1.ConditionType, reason string, severity clusterv1.ConditionSeverity, ...)
- func (c OCISelfManagedCluster) SetAvailabilityDomains(ads map[string]infrastructurev1beta2.OCIAvailabilityDomain)
- func (c OCISelfManagedCluster) SetControlPlaneEndpoint(endpoint clusterv1.APIEndpoint)
- func (c OCISelfManagedCluster) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
- type VirtualMachinePoolScope
- func (m *VirtualMachinePoolScope) Close(ctx context.Context) error
- func (m *VirtualMachinePoolScope) CreateVirtualNodePool(ctx context.Context) (*oke.VirtualNodePool, error)
- func (m *VirtualMachinePoolScope) DeleteVirtualNodePool(ctx context.Context, nodePool *oke.VirtualNodePool) error
- func (m *VirtualMachinePoolScope) FindVirtualNodePool(ctx context.Context) (*oke.VirtualNodePool, error)
- func (m *VirtualMachinePoolScope) GetWorkerMachineSubnet() *string
- func (m *VirtualMachinePoolScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
- func (m *VirtualMachinePoolScope) ListandSetMachinePoolInstances(ctx context.Context, nodePool *oke.VirtualNodePool) (int32, error)
- func (m *VirtualMachinePoolScope) PatchObject(ctx context.Context) error
- func (m *VirtualMachinePoolScope) SetFailureReason(v capierrors.MachinePoolStatusFailure)
- func (m *VirtualMachinePoolScope) SetReplicaCount(count int32)
- func (m *VirtualMachinePoolScope) UpdateVirtualNodePool(ctx context.Context, pool *oke.VirtualNodePool) (bool, error)
- type VirtualMachinePoolScopeParams
Constants ¶
const ( AvailabilityDomain = "AvailabilityDomain" FaultDomain = "FaultDomain" OCIClusterKind = "OCICluster" OCIManagedClusterKind = "OCIManagedCluster" OCIManagedClusterControlPlaneKind = "OCIManagedClusterControlPlane" )
const ( VcnDefaultCidr = "10.0.0.0/16" ControlPlaneEndpointSubnetDefaultCIDR = "10.0.0.8/29" ControlPlaneMachineSubnetDefaultCIDR = "10.0.0.0/29" WorkerSubnetDefaultCIDR = "10.0.64.0/20" ServiceLoadBalancerDefaultCIDR = "10.0.0.32/27" ApiServerPort = 6443 APIServerLBBackendSetName = "apiserver-lb-backendset" APIServerLBListener = "apiserver-lb-listener" SGWServiceSuffix = "-services-in-oracle-services-network" ServiceGatewayName = "service-gateway" PublicRouteTableName = "public-route-table" PrivateRouteTableName = "private-route-table" NatGatewayName = "nat-gateway" InternetGatewayName = "internet-gateway" ControlPlaneEndpointDefaultName = "control-plane-endpoint" ControlPlaneDefaultName = "control-plane" WorkerDefaultName = "worker" ServiceLBDefaultName = "service-lb" )
const ( PollInterval = 5 * time.Second RequestTimeout = 2 * time.Minute )
const (
LogLevelWarn = 3
)
const OCIMachineKind = "OCIMachine"
const OCIMachinePoolKind = "OCIMachinePool"
const (
OCIManagedMachinePoolKind = "OCIManagedMachinePool"
)
const (
OCIVirtualMachinePoolKind = "OCIVirtualMachinePool"
)
Variables ¶
var (
LoadBalancerPolicy = networkloadbalancer.NetworkLoadBalancingPolicyFiveTuple
)
var (
MockTestRegion = "us-lexington-1"
)
Functions ¶
func ConvertMachineDefinedTags ¶ added in v0.7.0
func ConvertMachineDefinedTags(machineDefinedTags map[string]map[string]string) map[string]map[string]interface{}
ConvertMachineDefinedTags passes in the OCIMachineSpec DefinedTags and returns a converted map of defined tags to be used when creating API requests.
func GetNsgNamesFromId ¶ added in v0.6.0
func GetNsgNamesFromId(ids []string, nsgs []*infrastructurev1beta2.NSG) []string
GetNsgNamesFromId returns the names of the NSGs with the provided IDs
func GetRegionCodeFromRegion ¶ added in v0.6.0
func GetRegionCodeFromRegion(ctx context.Context, identityClient identityClient.Client, region string) (string, error)
GetRegionCodeFromRegion pulls all OCI regions available and returns the passed in region's code if contained in the list.
example: "ca-toronto-1" -> "YYZ"
func GetSubnetNameFromId ¶ added in v0.6.0
func GetSubnetNameFromId(id *string, subnets []*infrastructurev1beta2.Subnet) string
GetSubnetNameFromId returns the name of the Subnet with the provided ID
func GetSubnetNamesFromId ¶ added in v0.6.0
func GetSubnetNamesFromId(ids []string, subnets []*infrastructurev1beta2.Subnet) []string
GetSubnetNamesFromId returns the names of the Subnets with the provided IDs
func MockAuthConfig ¶ added in v0.2.0
func MockAuthConfig() (config.AuthConfig, error)
Types ¶
type ClientProvider ¶ added in v0.2.0
ClientProvider defines the regional clients
func MockNewClientProvider ¶ added in v0.2.0
func MockNewClientProvider(mockClients MockOCIClients) (*ClientProvider, error)
func NewClientProvider ¶ added in v0.2.0
func NewClientProvider(params ClientProviderParams) (*ClientProvider, error)
NewClientProvider builds the ClientProvider with a client for the given region
func (*ClientProvider) GetAuthProvider ¶ added in v0.9.0
func (c *ClientProvider) GetAuthProvider() common.ConfigurationProvider
GetAuthProvider returns the client provider auth config
func (*ClientProvider) GetOrBuildClient ¶ added in v0.2.0
func (c *ClientProvider) GetOrBuildClient(region string) (OCIClients, error)
GetOrBuildClient if the OCIClients exist for the region they are returned, if not clients will build them
func (*ClientProvider) GetRegion ¶ added in v0.7.0
func (c *ClientProvider) GetRegion() (string, error)
GetRegion returns the region from the authentication config provider
type ClientProviderParams ¶ added in v0.9.0
type ClientProviderParams struct { // OciAuthConfigProvider wraps information about the account owner OciAuthConfigProvider common.ConfigurationProvider // ClientOverrides contains information about client host url overrides. ClientOverrides *v1beta2.ClientOverrides // CertOverride a x509 CertPool to use as an override for client TLSClientConfig CertOverride *x509.CertPool }
ClientProviderParams is the params struct for NewClientProvider
type ClusterScope ¶
type ClusterScope struct { *logr.Logger Cluster *clusterv1.Cluster VCNClient vcn.Client NetworkLoadBalancerClient nlb.NetworkLoadBalancerClient LoadBalancerClient lb.LoadBalancerClient IdentityClient identityClient.Client // RegionIdentifier Identifier as specified here https://docs.oracle.com/en-us/iaas/Content/General/Concepts/regions.htm RegionIdentifier string ClientProvider *ClientProvider OCIClusterAccessor OCIClusterAccessor // RegionIdentifier Key as specified here https://docs.oracle.com/en-us/iaas/Content/General/Concepts/regions.htm RegionKey string // contains filtered or unexported fields }
func NewClusterScope ¶
func NewClusterScope(params ClusterScopeParams) (*ClusterScope, error)
NewClusterScope creates a ClusterScope given the ClusterScopeParams
func (*ClusterScope) APIServerPort ¶
func (s *ClusterScope) APIServerPort() int32
APIServerPort returns the APIServerPort to use when creating the load balancer.
func (*ClusterScope) AddNSGSecurityRules ¶
func (s *ClusterScope) AddNSGSecurityRules(ctx context.Context, nsgId *string, ingress []infrastructurev1beta2.IngressSecurityRuleForNSG, egress []infrastructurev1beta2.EgressSecurityRuleForNSG) error
func (*ClusterScope) CreateInternetGateway ¶
func (s *ClusterScope) CreateInternetGateway(ctx context.Context) (*string, error)
CreateInternetGateway creates the Internet Gateway for the cluster based on the ClusterScope
func (*ClusterScope) CreateLB ¶
func (s *ClusterScope) CreateLB(ctx context.Context, lb infrastructurev1beta2.LoadBalancer) (*string, *string, error)
CreateLB configures and creates the Load Balancer for the cluster based on the ClusterScope. This configures the LB Listeners and Backend Sets in order to create the Load Balancer. It will await the Work Request completion before returning
See https://docs.oracle.com/en-us/iaas/Content/LoadBalancer/overview.htm for more details on the Network Load Balancer
func (*ClusterScope) CreateNLB ¶ added in v0.9.0
func (s *ClusterScope) CreateNLB(ctx context.Context, lb infrastructurev1beta2.LoadBalancer) (*string, *string, error)
CreateNLB configures and creates the Network Load Balancer for the cluster based on the ClusterScope. This configures the LB Listeners and Backend Sets in order to create the Network Load Balancer. It will await the Work Request completion before returning
See https://docs.oracle.com/en-us/iaas/Content/NetworkLoadBalancer/overview.htm for more details on the Network Load Balancer
func (*ClusterScope) CreateNSG ¶
func (s *ClusterScope) CreateNSG(ctx context.Context, nsg infrastructurev1beta2.NSG) (*string, error)
func (*ClusterScope) CreateNatGateway ¶
func (s *ClusterScope) CreateNatGateway(ctx context.Context) (*string, error)
CreateNatGateway creates the NAT Gateway for the cluster based on the ClusterScope
func (*ClusterScope) CreateRouteTable ¶
func (*ClusterScope) CreateSecurityList ¶
func (s *ClusterScope) CreateSecurityList(ctx context.Context, secList infrastructurev1beta2.SecurityList) (*string, error)
func (*ClusterScope) CreateServiceGateway ¶
func (s *ClusterScope) CreateServiceGateway(ctx context.Context) (*string, error)
func (*ClusterScope) CreateSubnet ¶
func (s *ClusterScope) CreateSubnet(ctx context.Context, spec infrastructurev1beta2.Subnet) (*string, error)
func (*ClusterScope) CreateVCN ¶
func (s *ClusterScope) CreateVCN(ctx context.Context, spec infrastructurev1beta2.VCN) (*string, error)
func (*ClusterScope) DeleteApiServerLB ¶
func (s *ClusterScope) DeleteApiServerLB(ctx context.Context) error
DeleteApiServerLB retrieves and attempts to delete the Load Balancer if found. It will await the Work Request completion before returning
func (*ClusterScope) DeleteApiServerNLB ¶ added in v0.9.0
func (s *ClusterScope) DeleteApiServerNLB(ctx context.Context) error
DeleteApiServerNLB retrieves and attempts to delete the Network Load Balancer if found. It will await the Work Request completion before returning
func (*ClusterScope) DeleteDRG ¶ added in v0.3.0
func (s *ClusterScope) DeleteDRG(ctx context.Context) error
DeleteDRG tries to delete the DRG
func (*ClusterScope) DeleteDRGRPCAttachment ¶ added in v0.3.0
func (s *ClusterScope) DeleteDRGRPCAttachment(ctx context.Context) error
DeleteDRGRPCAttachment deletes DRG RPC attachments
func (*ClusterScope) DeleteDRGVCNAttachment ¶ added in v0.3.0
func (s *ClusterScope) DeleteDRGVCNAttachment(ctx context.Context) error
func (*ClusterScope) DeleteInternetGateway ¶
func (s *ClusterScope) DeleteInternetGateway(ctx context.Context) error
DeleteInternetGateway retrieves and attempts to delete the Internet Gateway if found.
func (*ClusterScope) DeleteNSGs ¶
func (s *ClusterScope) DeleteNSGs(ctx context.Context) error
func (*ClusterScope) DeleteNatGateway ¶
func (s *ClusterScope) DeleteNatGateway(ctx context.Context) error
DeleteNatGateway retrieves and attempts to delete the NAT Gateway if found.
func (*ClusterScope) DeleteRouteTables ¶
func (s *ClusterScope) DeleteRouteTables(ctx context.Context) error
func (*ClusterScope) DeleteSecurityLists ¶
func (s *ClusterScope) DeleteSecurityLists(ctx context.Context) error
func (*ClusterScope) DeleteServiceGateway ¶
func (s *ClusterScope) DeleteServiceGateway(ctx context.Context) error
func (*ClusterScope) DeleteSubnets ¶
func (s *ClusterScope) DeleteSubnets(ctx context.Context) error
func (*ClusterScope) GetCompartmentId ¶
func (s *ClusterScope) GetCompartmentId() string
GetCompartmentId returns the CompartmentId defined in OCICluster's spec
func (*ClusterScope) GetControlPlaneEndpointSubnet ¶
func (s *ClusterScope) GetControlPlaneEndpointSubnet() *infrastructurev1beta2.Subnet
func (*ClusterScope) GetControlPlaneEndpointSubnetCidr ¶
func (s *ClusterScope) GetControlPlaneEndpointSubnetCidr() string
func (*ClusterScope) GetControlPlaneLbsLoadBalancerName ¶ added in v0.9.0
func (s *ClusterScope) GetControlPlaneLbsLoadBalancerName() string
GetControlPlaneLoadBalancerName returns the user defined APIServerLB name from the spec or assigns the name based on the OCICluster's name
func (*ClusterScope) GetControlPlaneLoadBalancerName ¶
func (s *ClusterScope) GetControlPlaneLoadBalancerName() string
GetControlPlaneLoadBalancerName returns the user defined APIServerLB name from the spec or assigns the name based on the OCICluster's name
func (*ClusterScope) GetControlPlaneMachineSubnet ¶
func (s *ClusterScope) GetControlPlaneMachineSubnet() *infrastructurev1beta2.Subnet
func (*ClusterScope) GetControlPlaneMachineSubnetCidr ¶
func (s *ClusterScope) GetControlPlaneMachineSubnetCidr() string
func (*ClusterScope) GetDRG ¶ added in v0.3.0
GetDRG retrieves the Cluster's core.Drg using the one of the following methods
1. the OCICluster's spec Drg
2. Listing the Drgs for the Compartment (by ID) and filtering by tag
func (*ClusterScope) GetDRGAttachment ¶ added in v0.3.0
func (s *ClusterScope) GetDRGAttachment(ctx context.Context) (*core.DrgAttachment, error)
func (*ClusterScope) GetDRGName ¶ added in v0.3.0
func (s *ClusterScope) GetDRGName() string
func (*ClusterScope) GetDefinedTags ¶
func (s *ClusterScope) GetDefinedTags() map[string]map[string]interface{}
GetDefinedTags returns a map of DefinedTags defined in the OCICluster's spec
func (*ClusterScope) GetDesiredRouteTables ¶
func (s *ClusterScope) GetDesiredRouteTables() []string
func (*ClusterScope) GetFreeFormTags ¶
func (s *ClusterScope) GetFreeFormTags() map[string]string
GetFreeFormTags returns a map of FreeformTags defined in the OCICluster's spec
func (*ClusterScope) GetInternetGateway ¶
func (s *ClusterScope) GetInternetGateway(ctx context.Context) (*core.InternetGateway, error)
GetInternetGateway retrieves the Cluster's core.InternetGateway using the one of the following methods
1. the OCICluster's spec InternetGatewayId
2. Listing the Internet Gateways for the Compartment (by ID) and filtering by tag
func (*ClusterScope) GetLoadBalancers ¶ added in v0.9.0
func (s *ClusterScope) GetLoadBalancers(ctx context.Context) (*loadbalancer.LoadBalancer, error)
GetLoadBalancers retrieves the Cluster's loadbalancer.LoadBalancer using the one of the following methods
1. the OCICluster's spec LoadBalancerId
2. Listing the LoadBalancers for the Compartment (by ID) and DisplayName then filtering by tag
func (*ClusterScope) GetNSG ¶
func (s *ClusterScope) GetNSG(ctx context.Context, spec infrastructurev1beta2.NSG) (*core.NetworkSecurityGroup, error)
func (*ClusterScope) GetNSGSpec ¶
func (s *ClusterScope) GetNSGSpec() []*infrastructurev1beta2.NSG
func (*ClusterScope) GetNatGateway ¶
func (s *ClusterScope) GetNatGateway(ctx context.Context) (*core.NatGateway, error)
GetNatGateway retrieves the Cluster's core.NatGateway using the one of the following methods
1. the OCICluster's spec NatGatewayId
2. Listing the NAT Gateways for the Compartment (by ID), VCN and DisplayName and filtering by tag
func (*ClusterScope) GetNetworkLoadBalancers ¶ added in v0.9.0
func (s *ClusterScope) GetNetworkLoadBalancers(ctx context.Context) (*networkloadbalancer.NetworkLoadBalancer, error)
GetNetworkLoadBalancers retrieves the Cluster's networkloadbalancer.NetworkLoadBalancer using the one of the following methods
1. the OCICluster's spec LoadBalancerId
2. Listing the NetworkLoadBalancers for the Compartment (by ID) and DisplayName then filtering by tag
func (*ClusterScope) GetNodeSubnet ¶
func (s *ClusterScope) GetNodeSubnet() []*infrastructurev1beta2.Subnet
func (*ClusterScope) GetOCIClusterAccessor ¶ added in v0.6.0
func (s *ClusterScope) GetOCIClusterAccessor() OCIClusterAccessor
func (*ClusterScope) GetSecurityList ¶
func (s *ClusterScope) GetSecurityList(ctx context.Context, spec infrastructurev1beta2.SecurityList) (*core.SecurityList, error)
func (*ClusterScope) GetServiceGateway ¶
func (s *ClusterScope) GetServiceGateway(ctx context.Context) (*core.ServiceGateway, error)
func (*ClusterScope) GetServiceLoadBalancerSubnet ¶
func (s *ClusterScope) GetServiceLoadBalancerSubnet() *infrastructurev1beta2.Subnet
func (*ClusterScope) GetServiceLoadBalancerSubnetCidr ¶
func (s *ClusterScope) GetServiceLoadBalancerSubnetCidr() string
func (*ClusterScope) GetSubnet ¶
func (s *ClusterScope) GetSubnet(ctx context.Context, spec infrastructurev1beta2.Subnet) (*core.Subnet, error)
func (*ClusterScope) GetSubnetsSpec ¶
func (s *ClusterScope) GetSubnetsSpec() []*infrastructurev1beta2.Subnet
func (*ClusterScope) GetVcnCidr ¶
func (s *ClusterScope) GetVcnCidr() string
func (*ClusterScope) GetVcnName ¶
func (s *ClusterScope) GetVcnName() string
func (*ClusterScope) IsAllSubnetsPrivate ¶
func (s *ClusterScope) IsAllSubnetsPrivate() bool
IsAllSubnetsPrivate determines if all the ClusterScope's subnets are private
func (*ClusterScope) IsAllSubnetsPublic ¶
func (s *ClusterScope) IsAllSubnetsPublic() bool
IsAllSubnetsPublic determines if all the ClusterScope's subnets are public
func (*ClusterScope) IsLBEqual ¶
func (s *ClusterScope) IsLBEqual(actual *loadbalancer.LoadBalancer, desired infrastructurev1beta2.LoadBalancer) bool
IsLBEqual determines if the actual loadbalancer.LoadBalancer is equal to the desired. Equality is determined by DisplayName, FreeformTags and DefinedTags matching.
func (*ClusterScope) IsNLBEqual ¶ added in v0.9.0
func (s *ClusterScope) IsNLBEqual(actual *networkloadbalancer.NetworkLoadBalancer, desired infrastructurev1beta2.LoadBalancer) bool
IsNLBEqual determines if the actual networkloadbalancer.NetworkLoadBalancer is equal to the desired. Equality is determined by DisplayName
func (*ClusterScope) IsNSGEqual ¶
func (s *ClusterScope) IsNSGEqual(actual *core.NetworkSecurityGroup, desired infrastructurev1beta2.NSG) bool
IsNSGEqual compares the actual and desired NSG using name.
func (*ClusterScope) IsNSGExitsByRole ¶
func (s *ClusterScope) IsNSGExitsByRole(role infrastructurev1beta2.Role) bool
func (*ClusterScope) IsResourceCreatedByClusterAPI ¶
func (s *ClusterScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
func (*ClusterScope) IsSecurityListEqual ¶
func (s *ClusterScope) IsSecurityListEqual(actual core.SecurityList, desired infrastructurev1beta2.SecurityList) bool
func (*ClusterScope) IsSecurityListExitsByRole ¶
func (s *ClusterScope) IsSecurityListExitsByRole(role infrastructurev1beta2.Role) bool
func (*ClusterScope) IsSubnetsEqual ¶
func (s *ClusterScope) IsSubnetsEqual(actual *core.Subnet, desired infrastructurev1beta2.Subnet) bool
func (*ClusterScope) IsVcnEquals ¶
func (s *ClusterScope) IsVcnEquals(actual *core.Vcn, desired infrastructurev1beta2.VCN) bool
func (*ClusterScope) LBSpec ¶
func (s *ClusterScope) LBSpec() infrastructurev1beta2.LoadBalancer
LBSpec builds the LoadBalancer from the ClusterScope and returns it
func (*ClusterScope) NLBSpec ¶ added in v0.9.0
func (s *ClusterScope) NLBSpec() infrastructurev1beta2.LoadBalancer
NLBSpec builds the Network LoadBalancer from the ClusterScope and returns it
func (*ClusterScope) NodeSubnetCidr ¶
func (s *ClusterScope) NodeSubnetCidr() []string
func (*ClusterScope) ReconcileApiServerLB ¶
func (s *ClusterScope) ReconcileApiServerLB(ctx context.Context) error
ReconcileApiServerLB tries to move the Load Balancer to the desired OCICluster Spec
func (*ClusterScope) ReconcileApiServerNLB ¶ added in v0.9.0
func (s *ClusterScope) ReconcileApiServerNLB(ctx context.Context) error
ReconcileApiServerNLB tries to move the Network Load Balancer to the desired OCICluster Spec
func (*ClusterScope) ReconcileDRG ¶ added in v0.3.0
func (s *ClusterScope) ReconcileDRG(ctx context.Context) error
ReconcileDRG tries to move the DRG to the desired OCICluster Spec
func (*ClusterScope) ReconcileDRGRPCAttachment ¶ added in v0.3.0
func (s *ClusterScope) ReconcileDRGRPCAttachment(ctx context.Context) error
ReconcileDRGRPCAttachment reconciles DRG RPC attachments
func (*ClusterScope) ReconcileDRGVCNAttachment ¶ added in v0.3.0
func (s *ClusterScope) ReconcileDRGVCNAttachment(ctx context.Context) error
ReconcileDRGVCNAttachment tries to attach the DRG to the VCN
func (*ClusterScope) ReconcileFailureDomains ¶
func (s *ClusterScope) ReconcileFailureDomains(ctx context.Context) error
func (*ClusterScope) ReconcileInternetGateway ¶
func (s *ClusterScope) ReconcileInternetGateway(ctx context.Context) error
ReconcileInternetGateway tries to move the Internet Gateway to the desired OCICluster Spec
func (*ClusterScope) ReconcileNSG ¶
func (s *ClusterScope) ReconcileNSG(ctx context.Context) error
func (*ClusterScope) ReconcileNatGateway ¶
func (s *ClusterScope) ReconcileNatGateway(ctx context.Context) error
ReconcileNatGateway tries to move the NAT Gateway to the desired OCICluster Spec
func (*ClusterScope) ReconcileRouteTable ¶
func (s *ClusterScope) ReconcileRouteTable(ctx context.Context) error
func (*ClusterScope) ReconcileServiceGateway ¶
func (s *ClusterScope) ReconcileServiceGateway(ctx context.Context) error
func (*ClusterScope) ReconcileSubnet ¶
func (s *ClusterScope) ReconcileSubnet(ctx context.Context) error
func (*ClusterScope) ReconcileVCN ¶
func (s *ClusterScope) ReconcileVCN(ctx context.Context) error
func (*ClusterScope) SetFailureDomain ¶
func (s *ClusterScope) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
SetFailureDomain sets the cluster's failure domain in the status
func (*ClusterScope) SetRegionKey ¶ added in v0.6.0
func (s *ClusterScope) SetRegionKey(ctx context.Context) error
SetRegionKey sets the region key in the scope
func (*ClusterScope) UpdateDRGAttachment ¶ added in v0.3.0
func (s *ClusterScope) UpdateDRGAttachment(ctx context.Context) (*core.DrgAttachment, error)
func (*ClusterScope) UpdateLB ¶
func (s *ClusterScope) UpdateLB(ctx context.Context, lb infrastructurev1beta2.LoadBalancer) error
UpdateLB updates existing Load Balancer's DisplayName, FreeformTags and DefinedTags
func (*ClusterScope) UpdateNLB ¶ added in v0.9.0
func (s *ClusterScope) UpdateNLB(ctx context.Context, nlb infrastructurev1beta2.LoadBalancer) error
UpdateLB updates existing Load Balancer's DisplayName, FreeformTags and DefinedTags
func (*ClusterScope) UpdateNSG ¶
func (s *ClusterScope) UpdateNSG(ctx context.Context, nsgSpec infrastructurev1beta2.NSG) error
func (*ClusterScope) UpdateNSGSecurityRulesIfNeeded ¶
func (s *ClusterScope) UpdateNSGSecurityRulesIfNeeded(ctx context.Context, desired infrastructurev1beta2.NSG, actual *core.NetworkSecurityGroup) (bool, error)
UpdateNSGSecurityRulesIfNeeded updates NSG rules if required by comparing actual and desired.
func (*ClusterScope) UpdateNatGateway ¶
func (s *ClusterScope) UpdateNatGateway(ctx context.Context) error
UpdateNatGateway updates the FreeFormTags and DefinedTags
func (*ClusterScope) UpdateSecurityList ¶
func (s *ClusterScope) UpdateSecurityList(ctx context.Context, securityListSpec infrastructurev1beta2.SecurityList) error
func (*ClusterScope) UpdateSubnet ¶
func (s *ClusterScope) UpdateSubnet(ctx context.Context, spec infrastructurev1beta2.Subnet) error
func (*ClusterScope) UpdateVCN ¶
func (s *ClusterScope) UpdateVCN(ctx context.Context, vcn infrastructurev1beta2.VCN) error
func (*ClusterScope) VCNSpec ¶
func (s *ClusterScope) VCNSpec() infrastructurev1beta2.VCN
type ClusterScopeClient ¶
type ClusterScopeClient interface { ReconcileVCN(ctx context.Context) error ReconcileInternetGateway(ctx context.Context) error ReconcileNatGateway(ctx context.Context) error ReconcileServiceGateway(ctx context.Context) error ReconcileNSG(ctx context.Context) error ReconcileRouteTable(ctx context.Context) error ReconcileSubnet(ctx context.Context) error ReconcileApiServerNLB(ctx context.Context) error ReconcileApiServerLB(ctx context.Context) error ReconcileFailureDomains(ctx context.Context) error ReconcileDRG(ctx context.Context) error DeleteDRG(ctx context.Context) error ReconcileDRGVCNAttachment(ctx context.Context) error ReconcileDRGRPCAttachment(ctx context.Context) error DeleteApiServerNLB(ctx context.Context) error DeleteApiServerLB(ctx context.Context) error DeleteNSGs(ctx context.Context) error DeleteSubnets(ctx context.Context) error DeleteRouteTables(ctx context.Context) error DeleteSecurityLists(ctx context.Context) error DeleteServiceGateway(ctx context.Context) error DeleteNatGateway(ctx context.Context) error DeleteInternetGateway(ctx context.Context) error DeleteVCN(ctx context.Context) error DeleteDRGVCNAttachment(ctx context.Context) error DeleteDRGRPCAttachment(ctx context.Context) error GetOCIClusterAccessor() OCIClusterAccessor SetRegionKey(ctx context.Context) error }
type ClusterScopeParams ¶
type ClusterScopeParams struct { Client client.Client Logger *logr.Logger Cluster *clusterv1.Cluster VCNClient vcn.Client NetworkLoadBalancerClient nlb.NetworkLoadBalancerClient LoadBalancerClient lb.LoadBalancerClient IdentityClient identityClient.Client // RegionIdentifier Identifier as specified here https://docs.oracle.com/en-us/iaas/Content/General/Concepts/regions.htm RegionIdentifier string OCIAuthConfigProvider common.ConfigurationProvider ClientProvider *ClientProvider OCIClusterAccessor OCIClusterAccessor // RegionIdentifier Key as specified here https://docs.oracle.com/en-us/iaas/Content/General/Concepts/regions.htm RegionKey string }
ClusterScopeParams defines the params need to create a new ClusterScope
type MachinePoolScope ¶ added in v0.4.0
type MachinePoolScope struct { *logr.Logger Client client.Client Cluster *clusterv1.Cluster MachinePool *expclusterv1.MachinePool ComputeManagementClient computemanagement.Client OCICluster *infrastructurev1beta2.OCICluster OCIMachinePool *expinfra1.OCIMachinePool // contains filtered or unexported fields }
func NewMachinePoolScope ¶ added in v0.4.0
func NewMachinePoolScope(params MachinePoolScopeParams) (*MachinePoolScope, error)
NewMachinePoolScope creates a MachinePoolScope given the MachinePoolScopeParams
func (*MachinePoolScope) BuildInstancePoolPlacement ¶ added in v0.4.0
func (s *MachinePoolScope) BuildInstancePoolPlacement() ([]core.CreateInstancePoolPlacementConfigurationDetails, error)
func (*MachinePoolScope) CleanupInstanceConfiguration ¶ added in v0.7.0
func (m *MachinePoolScope) CleanupInstanceConfiguration(ctx context.Context, instancePool *core.InstancePool) error
func (*MachinePoolScope) Close ¶ added in v0.4.0
func (m *MachinePoolScope) Close(ctx context.Context) error
Close closes the current scope persisting the cluster configuration and status.
func (*MachinePoolScope) CreateInstancePool ¶ added in v0.4.0
func (m *MachinePoolScope) CreateInstancePool(ctx context.Context) (*core.InstancePool, error)
CreateInstancePool attempts to create an instance pool
func (*MachinePoolScope) FindInstancePool ¶ added in v0.4.0
func (m *MachinePoolScope) FindInstancePool(ctx context.Context) (*core.InstancePool, error)
FindInstancePool attempts to find the instance pool by name and checks to make sure the instance pool was created by the cluster before returning the correct pool
func (*MachinePoolScope) GetBootstrapData ¶ added in v0.4.0
func (m *MachinePoolScope) GetBootstrapData() (string, error)
GetBootstrapData returns the bootstrap data from the secret in the Machine's bootstrap.dataSecretName.
func (*MachinePoolScope) GetFreeFormTags ¶ added in v0.4.0
func (m *MachinePoolScope) GetFreeFormTags() map[string]string
GetFreeFormTags gets the free form tags for the MachinePoolScope cluster and returns them
func (*MachinePoolScope) GetInstanceConfiguration ¶ added in v0.7.0
func (m *MachinePoolScope) GetInstanceConfiguration(ctx context.Context) (*core.InstanceConfiguration, error)
GetInstanceConfiguration returns the instance configuration associated with the instance pool
func (*MachinePoolScope) GetInstanceConfigurationId ¶ added in v0.4.0
func (m *MachinePoolScope) GetInstanceConfigurationId() *string
GetInstanceConfigurationId returns the MachinePoolScope instance configuration id.
func (*MachinePoolScope) GetWorkerMachineNSG ¶ added in v0.4.0
func (m *MachinePoolScope) GetWorkerMachineNSG() *string
GetWorkerMachineNSG returns the worker role core.NetworkSecurityGroup id for the cluster
func (*MachinePoolScope) GetWorkerMachineSubnet ¶ added in v0.4.0
func (m *MachinePoolScope) GetWorkerMachineSubnet() *string
GetWorkerMachineSubnet returns the WorkerRole core.Subnet id for the cluster
func (*MachinePoolScope) HasFailed ¶ added in v0.4.0
func (m *MachinePoolScope) HasFailed() bool
HasFailed returns true when the OCIMachinePool's Failure reason or Failure message is populated.
func (*MachinePoolScope) IsResourceCreatedByClusterAPI ¶ added in v0.4.0
func (s *MachinePoolScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
IsResourceCreatedByClusterAPI determines if the instance was created by the cluster using the tags created at instance launch.
func (*MachinePoolScope) ListInstancePoolSummaries ¶ added in v0.4.0
func (m *MachinePoolScope) ListInstancePoolSummaries(ctx context.Context, req core.ListInstancePoolsRequest) ([]core.InstancePoolSummary, error)
ListInstancePoolSummaries list the core.InstancePoolSummary for the given core.ListInstancePoolsRequest
func (*MachinePoolScope) ListMachinePoolInstances ¶ added in v0.4.0
func (m *MachinePoolScope) ListMachinePoolInstances(ctx context.Context) ([]core.InstanceSummary, error)
ListMachinePoolInstances returns the WorkerRole core.Subnet id for the cluster
func (*MachinePoolScope) PatchObject ¶ added in v0.4.0
func (m *MachinePoolScope) PatchObject(ctx context.Context) error
PatchObject persists the cluster configuration and status.
func (*MachinePoolScope) ReconcileInstanceConfiguration ¶ added in v0.4.0
func (m *MachinePoolScope) ReconcileInstanceConfiguration(ctx context.Context) error
ReconcileInstanceConfiguration works to try to reconcile the state of the instance configuration for the cluster
func (*MachinePoolScope) SetFailureMessage ¶ added in v0.4.0
func (m *MachinePoolScope) SetFailureMessage(v error)
SetFailureMessage sets the OCIMachine status error message.
func (*MachinePoolScope) SetFailureReason ¶ added in v0.4.0
func (m *MachinePoolScope) SetFailureReason(v capierrors.MachineStatusError)
SetFailureReason sets the OCIMachine status error reason.
func (*MachinePoolScope) SetInstanceConfigurationIdStatus ¶ added in v0.4.0
func (m *MachinePoolScope) SetInstanceConfigurationIdStatus(id string)
SetInstanceConfigurationIdStatus sets the MachinePool InstanceConfigurationId status.
func (*MachinePoolScope) SetListandSetMachinePoolInstances ¶ added in v0.4.0
func (m *MachinePoolScope) SetListandSetMachinePoolInstances(ctx context.Context) (int32, error)
SetListandSetMachinePoolInstances retrieves a machine pools instances and sets them in the ProviderIDList
func (*MachinePoolScope) SetReady ¶ added in v0.4.0
func (m *MachinePoolScope) SetReady()
SetReady sets the OCIMachine Ready Status.
func (*MachinePoolScope) SetReplicaCount ¶ added in v0.4.0
func (m *MachinePoolScope) SetReplicaCount(count int32)
func (*MachinePoolScope) TerminateInstancePool ¶ added in v0.4.0
func (m *MachinePoolScope) TerminateInstancePool(ctx context.Context, instancePool *core.InstancePool) error
func (*MachinePoolScope) UpdatePool ¶ added in v0.4.0
func (m *MachinePoolScope) UpdatePool(ctx context.Context, instancePool *core.InstancePool) (*core.InstancePool, error)
UpdatePool attempts to update the instance pool
type MachinePoolScopeParams ¶ added in v0.4.0
type MachinePoolScopeParams struct { Logger *logr.Logger Cluster *clusterv1.Cluster MachinePool *expclusterv1.MachinePool Client client.Client ComputeManagementClient computemanagement.Client OCICluster *infrastructurev1beta2.OCICluster OCIMachinePool *expinfra1.OCIMachinePool }
MachinePoolScopeParams defines the params need to create a new MachineScope
type MachineScope ¶
type MachineScope struct { *logr.Logger Client client.Client Cluster *clusterv1.Cluster Machine *clusterv1.Machine ComputeClient compute.ComputeClient OCICluster *infrastructurev1beta2.OCICluster OCIMachine *infrastructurev1beta2.OCIMachine VCNClient vcn.Client NetworkLoadBalancerClient nlb.NetworkLoadBalancerClient LoadBalancerClient lb.LoadBalancerClient // contains filtered or unexported fields }
func NewMachineScope ¶
func NewMachineScope(params MachineScopeParams) (*MachineScope, error)
NewMachineScope creates a MachineScope given the MachineScopeParams
func (*MachineScope) Close ¶
func (m *MachineScope) Close(ctx context.Context) error
Close closes the current scope persisting the cluster configuration and status.
func (*MachineScope) DeleteMachine ¶
DeleteMachine terminates the instance using InstanceId from the OCIMachine spec and deletes the boot volume
func (*MachineScope) GetBootstrapData ¶
func (m *MachineScope) GetBootstrapData() (string, error)
GetBootstrapData returns the bootstrap data from the secret in the Machine's bootstrap.dataSecretName.
func (*MachineScope) GetInstanceId ¶
func (m *MachineScope) GetInstanceId() *string
GetInstanceId returns the OCIMachine instance id.
func (*MachineScope) GetInstanceIp ¶
func (m *MachineScope) GetInstanceIp(ctx context.Context) (*string, error)
GetInstanceIp returns the OCIMachine's instance IP from its primary VNIC attachment.
See https://docs.oracle.com/en-us/iaas/Content/Network/Tasks/managingVNICs.htm for more on VNICs
func (*MachineScope) GetMachine ¶
GetMachine will attempt to get the machine instance by instance id, or display name if not instance id
func (*MachineScope) GetMachineByDisplayName ¶
func (m *MachineScope) GetMachineByDisplayName(ctx context.Context, name string) (*core.Instance, error)
GetMachineByDisplayName returns the machine from the compartment if there is a matching DisplayName, and it was created by the cluster
func (*MachineScope) GetMachineIPFromStatus ¶
func (m *MachineScope) GetMachineIPFromStatus() (string, error)
GetMachineIPFromStatus returns the IP address from the OCIMachine's status if it is the Internal IP
func (*MachineScope) GetOrCreateMachine ¶
GetOrCreateMachine will get machine instance or create if the instances doesn't exist
func (*MachineScope) IsControlPlane ¶
func (m *MachineScope) IsControlPlane() bool
IsControlPlane returns true if the machine is a control plane.
func (*MachineScope) IsReady ¶
func (m *MachineScope) IsReady() bool
IsReady returns the ready status of the machine.
func (*MachineScope) IsResourceCreatedByClusterAPI ¶
func (m *MachineScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
IsResourceCreatedByClusterAPI determines if the instance was created by the cluster using the tags created at instance launch.
func (*MachineScope) PatchObject ¶
func (m *MachineScope) PatchObject(ctx context.Context) error
PatchObject persists the cluster configuration and status.
func (*MachineScope) ReconcileCreateInstanceOnLB ¶
func (m *MachineScope) ReconcileCreateInstanceOnLB(ctx context.Context) error
ReconcileCreateInstanceOnLB sets up backend sets for the load balancer
func (*MachineScope) ReconcileDeleteInstanceOnLB ¶
func (m *MachineScope) ReconcileDeleteInstanceOnLB(ctx context.Context) error
ReconcileDeleteInstanceOnLB checks to make sure the instance is part of a backend set then deletes the backend on the NetworkLoadBalancer
It will await the Work Request completion before returning ¶
See https://docs.oracle.com/en-us/iaas/Content/NetworkLoadBalancer/BackendServers/backend_server_management.htm#BackendServerManagement for more info on Backend Server Management
func (*MachineScope) ReconcileVnicAttachments ¶ added in v0.7.0
func (m *MachineScope) ReconcileVnicAttachments(ctx context.Context) error
func (*MachineScope) SetFailureMessage ¶
func (m *MachineScope) SetFailureMessage(v error)
SetFailureMessage sets the OCIMachine status error message.
func (*MachineScope) SetFailureReason ¶
func (m *MachineScope) SetFailureReason(v capierrors.MachineStatusError)
SetFailureReason sets the OCIMachine status error reason.
func (*MachineScope) SetNotReady ¶ added in v0.11.3
func (m *MachineScope) SetNotReady()
SetNotReady sets the OCIMachine Ready Status to false.
func (*MachineScope) SetReady ¶
func (m *MachineScope) SetReady()
SetReady sets the OCIMachine Ready Status.
type MachineScopeParams ¶
type MachineScopeParams struct { Logger *logr.Logger Cluster *clusterv1.Cluster Machine *clusterv1.Machine Client client.Client ComputeClient compute.ComputeClient OCICluster *infrastructurev1beta2.OCICluster OCIMachine *infrastructurev1beta2.OCIMachine VCNClient vcn.Client NetworkLoadBalancerClient nlb.NetworkLoadBalancerClient LoadBalancerClient lb.LoadBalancerClient }
MachineScopeParams defines the params need to create a new MachineScope
type ManagedControlPlaneScope ¶ added in v0.6.0
type ManagedControlPlaneScope struct { *logr.Logger Cluster *clusterv1.Cluster ContainerEngineClient containerengine.Client BaseClient baseclient.BaseClient ClientProvider *ClientProvider OCIManagedControlPlane *infrav2exp.OCIManagedControlPlane OCIClusterAccessor OCIClusterAccessor RegionIdentifier string // contains filtered or unexported fields }
func NewManagedControlPlaneScope ¶ added in v0.6.0
func NewManagedControlPlaneScope(params ManagedControlPlaneScopeParams) (*ManagedControlPlaneScope, error)
NewManagedControlPlaneScope creates a ManagedControlPlaneScope given the ManagedControlPlaneScopeParams
func (*ManagedControlPlaneScope) DeleteOKECluster ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) DeleteOKECluster(ctx context.Context, cluster *oke.Cluster) error
DeleteOKECluster deletes an OKE cluster
func (*ManagedControlPlaneScope) GetClusterName ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) GetClusterName() string
GetClusterName returns the name of the cluster
func (*ManagedControlPlaneScope) GetOKECluster ¶ added in v0.6.0
GetOKECluster tries to lookup a control plane(OKE cluster) based on ID/Name and returns the cluster if it exists,
func (*ManagedControlPlaneScope) GetOrCreateControlPlane ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) GetOrCreateControlPlane(ctx context.Context) (*oke.Cluster, error)
GetOrCreateControlPlane tries to lookup a control plane(OKE cluster) based on ID/Name and returns the cluster if it exists, else creates an OKE cluster with the provided parameters in spec.
func (*ManagedControlPlaneScope) IsControlPlaneEndpointSubnetPublic ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) IsControlPlaneEndpointSubnetPublic() bool
IsControlPlaneEndpointSubnetPublic returns true if the control plane endpoint subnet is public
func (*ManagedControlPlaneScope) ReconcileAddons ¶ added in v0.11.0
func (s *ManagedControlPlaneScope) ReconcileAddons(ctx context.Context, okeCluster *oke.Cluster) error
ReconcileAddons reconciles addons which have been specified in the spec on the OKE cluster
func (*ManagedControlPlaneScope) ReconcileKubeconfig ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) ReconcileKubeconfig(ctx context.Context, okeCluster *oke.Cluster) error
ReconcileKubeconfig reconciles the kubeconfig secret which will be used by core CAPI components to talk to the OKE cluster
func (*ManagedControlPlaneScope) UpdateControlPlane ¶ added in v0.6.0
func (s *ManagedControlPlaneScope) UpdateControlPlane(ctx context.Context, okeCluster *oke.Cluster) (bool, error)
UpdateControlPlane updates the control plane(OKE cluster) if necessary based on spec changes
type ManagedControlPlaneScopeParams ¶ added in v0.6.0
type ManagedControlPlaneScopeParams struct { Logger *logr.Logger Client client.Client Cluster *clusterv1.Cluster ContainerEngineClient containerengine.Client BaseClient baseclient.BaseClient ClientProvider *ClientProvider OCIManagedControlPlane *infrav2exp.OCIManagedControlPlane OCIClusterAccessor OCIClusterAccessor RegionIdentifier string }
ManagedControlPlaneScopeParams defines the params need to create a new ManagedControlPlaneScope
type ManagedMachinePoolScope ¶ added in v0.6.0
type ManagedMachinePoolScope struct { *logr.Logger Client client.Client Cluster *clusterv1.Cluster MachinePool *expclusterv1.MachinePool ComputeManagementClient computemanagement.Client OCIManagedCluster *infrav2exp.OCIManagedCluster OCIManagedMachinePool *expinfra1.OCIManagedMachinePool ContainerEngineClient containerengine.Client OCIManagedControlPlane *infrav2exp.OCIManagedControlPlane // contains filtered or unexported fields }
func NewManagedMachinePoolScope ¶ added in v0.6.0
func NewManagedMachinePoolScope(params ManagedMachinePoolScopeParams) (*ManagedMachinePoolScope, error)
NewManagedMachinePoolScope creates a ManagedMachinePoolScope given the ManagedMachinePoolScopeParams
func (*ManagedMachinePoolScope) Close ¶ added in v0.6.0
func (m *ManagedMachinePoolScope) Close(ctx context.Context) error
Close closes the current scope persisting the cluster configuration and status.
func (*ManagedMachinePoolScope) CreateNodePool ¶ added in v0.6.0
CreateNodePool attempts to create a node pool
func (*ManagedMachinePoolScope) DeleteNodePool ¶ added in v0.6.0
DeleteNodePool terminates a nodepool
func (*ManagedMachinePoolScope) FindNodePool ¶ added in v0.6.0
FindNodePool attempts to find the node pool by id if the id exists or by name. It checks to make sure the node pool was created by the cluster before returning the correct pool
func (*ManagedMachinePoolScope) GetWorkerMachineSubnet ¶ added in v0.6.0
func (m *ManagedMachinePoolScope) GetWorkerMachineSubnet() *string
GetWorkerMachineSubnet returns the WorkerRole core.Subnet id for the cluster
func (*ManagedMachinePoolScope) IsResourceCreatedByClusterAPI ¶ added in v0.6.0
func (m *ManagedMachinePoolScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
IsResourceCreatedByClusterAPI determines if the instance was created by the cluster using the tags created at instance launch.
func (*ManagedMachinePoolScope) PatchObject ¶ added in v0.6.0
func (m *ManagedMachinePoolScope) PatchObject(ctx context.Context) error
PatchObject persists the cluster configuration and status.
func (*ManagedMachinePoolScope) SetFailureReason ¶ added in v0.6.0
func (m *ManagedMachinePoolScope) SetFailureReason(v capierrors.MachineStatusError)
SetFailureReason sets the OCIMachine status error reason.
func (*ManagedMachinePoolScope) SetListandSetMachinePoolInstances ¶ added in v0.6.0
func (m *ManagedMachinePoolScope) SetListandSetMachinePoolInstances(ctx context.Context, nodePool *oke.NodePool) (int32, error)
SetListandSetMachinePoolInstances retrieves a machine pools instances and sets them in the ProviderIDList
func (*ManagedMachinePoolScope) SetReplicaCount ¶ added in v0.6.0
func (m *ManagedMachinePoolScope) SetReplicaCount(count int32)
func (*ManagedMachinePoolScope) UpdateNodePool ¶ added in v0.6.0
func (m *ManagedMachinePoolScope) UpdateNodePool(ctx context.Context, pool *oke.NodePool) (bool, error)
UpdateNodePool updates a node pool, if needed, based on updated spec
type ManagedMachinePoolScopeParams ¶ added in v0.6.0
type ManagedMachinePoolScopeParams struct { Logger *logr.Logger Cluster *clusterv1.Cluster MachinePool *expclusterv1.MachinePool Client client.Client ComputeManagementClient computemanagement.Client OCIManagedCluster *infrav2exp.OCIManagedCluster OCIManagedControlPlane *infrav2exp.OCIManagedControlPlane OCIManagedMachinePool *expinfra1.OCIManagedMachinePool ContainerEngineClient containerengine.Client }
ManagedMachinePoolScopeParams defines the params need to create a new ManagedMachinePoolScope
type MockOCIClients ¶ added in v0.2.0
type MockOCIClients struct { VCNClient vcn.Client ComputeClient compute.ComputeClient NetworkLoadBalancerClient *networkloadbalancer.NetworkLoadBalancerClient LoadBalancerClient *loadbalancer.LoadBalancerClient IdentityClient identity.Client }
type OCIClients ¶ added in v0.2.0
type OCIClients struct { ComputeClient compute.ComputeClient ComputeManagementClient computemanagement.Client VCNClient vcn.Client NetworkLoadBalancerClient nlb.NetworkLoadBalancerClient LoadBalancerClient lb.LoadBalancerClient IdentityClient identityClient.Client ContainerEngineClient containerEngineClient.Client BaseClient base.BaseClient }
OCIClients is the struct of all the needed OCI clients
type OCIClusterAccessor ¶ added in v0.6.0
type OCIClusterAccessor interface { // GetOCIResourceIdentifier returns the OCI resource identifier of the cluster. GetOCIResourceIdentifier() string // GetDefinedTags returns the defined tags of the cluster. GetDefinedTags() map[string]map[string]string // GetCompartmentId returns the compartment id of the cluster. GetCompartmentId() string // GetFreeformTags returns the free form tags of the cluster. GetFreeformTags() map[string]string // GetName returns the name of the cluster. GetName() string // GetNameSpace returns the namespace of the cluster. GetNameSpace() string // GetRegion returns the region of the cluster, if specified in the spec. GetRegion() string // GetClientOverrides returns the client host url overrides for the cluster GetClientOverrides() *infrastructurev1beta2.ClientOverrides // GetNetworkSpec returns the NetworkSpec of the cluster. GetNetworkSpec() *infrastructurev1beta2.NetworkSpec // SetControlPlaneEndpoint sets the control plane endpoint of the cluster. SetControlPlaneEndpoint(endpoint clusterv1.APIEndpoint) // GetFailureDomains returns the failure domains of the cluster. GetFailureDomains() clusterv1.FailureDomains // SetFailureDomain sets the failure domain. SetFailureDomain(id string, spec clusterv1.FailureDomainSpec) // GetAvailabilityDomains get the availability domain. GetAvailabilityDomains() map[string]infrastructurev1beta2.OCIAvailabilityDomain // SetAvailabilityDomains sets the availability domain. SetAvailabilityDomains(ads map[string]infrastructurev1beta2.OCIAvailabilityDomain) // MarkConditionFalse marks the provided condition as false in the cluster object MarkConditionFalse(t clusterv1.ConditionType, reason string, severity clusterv1.ConditionSeverity, messageFormat string, messageArgs ...interface{}) // GetIdentityRef returns the Identity reference of the cluster GetIdentityRef() *corev1.ObjectReference }
OCIClusterAccessor interface defines the methods needed to access or modify member variables in Cluster object. This interface is required because there are 2 different cluster objects in OCI provider, OCiCluster(which is self managed) and OCIManagedCluster(which is a managed cluster - OKE). But both these clusters needs to share the same code for Network reconciliation. Hence this wrapper interface,
type OCIManagedCluster ¶ added in v0.6.0
type OCIManagedCluster struct {
OCIManagedCluster *infrav2exp.OCIManagedCluster
}
OCIManagedCluster is the ClusterAccessor implementation for managed clusters(OKE)
func (OCIManagedCluster) GetAvailabilityDomains ¶ added in v0.9.0
func (c OCIManagedCluster) GetAvailabilityDomains() map[string]infrastructurev1beta2.OCIAvailabilityDomain
func (OCIManagedCluster) GetClientOverrides ¶ added in v0.9.0
func (c OCIManagedCluster) GetClientOverrides() *infrastructurev1beta2.ClientOverrides
func (OCIManagedCluster) GetCompartmentId ¶ added in v0.6.0
func (c OCIManagedCluster) GetCompartmentId() string
func (OCIManagedCluster) GetDRG ¶ added in v0.6.0
func (c OCIManagedCluster) GetDRG() *infrastructurev1beta2.DRG
func (OCIManagedCluster) GetDefinedTags ¶ added in v0.6.0
func (c OCIManagedCluster) GetDefinedTags() map[string]map[string]string
func (OCIManagedCluster) GetFailureDomains ¶ added in v0.6.0
func (c OCIManagedCluster) GetFailureDomains() clusterv1.FailureDomains
func (OCIManagedCluster) GetFreeformTags ¶ added in v0.6.0
func (c OCIManagedCluster) GetFreeformTags() map[string]string
func (OCIManagedCluster) GetIdentityRef ¶ added in v0.7.0
func (c OCIManagedCluster) GetIdentityRef() *corev1.ObjectReference
func (OCIManagedCluster) GetName ¶ added in v0.6.0
func (c OCIManagedCluster) GetName() string
func (OCIManagedCluster) GetNameSpace ¶ added in v0.7.0
func (c OCIManagedCluster) GetNameSpace() string
func (OCIManagedCluster) GetNetworkSpec ¶ added in v0.6.0
func (c OCIManagedCluster) GetNetworkSpec() *infrastructurev1beta2.NetworkSpec
func (OCIManagedCluster) GetOCIResourceIdentifier ¶ added in v0.6.0
func (c OCIManagedCluster) GetOCIResourceIdentifier() string
func (OCIManagedCluster) GetRegion ¶ added in v0.7.0
func (c OCIManagedCluster) GetRegion() string
func (OCIManagedCluster) GetVCNPeering ¶ added in v0.6.0
func (c OCIManagedCluster) GetVCNPeering() *infrastructurev1beta2.VCNPeering
func (OCIManagedCluster) MarkConditionFalse ¶ added in v0.7.0
func (c OCIManagedCluster) MarkConditionFalse(t clusterv1.ConditionType, reason string, severity clusterv1.ConditionSeverity, messageFormat string, messageArgs ...interface{})
func (OCIManagedCluster) SetAvailabilityDomains ¶ added in v0.6.0
func (c OCIManagedCluster) SetAvailabilityDomains(ads map[string]infrastructurev1beta2.OCIAvailabilityDomain)
func (OCIManagedCluster) SetControlPlaneEndpoint ¶ added in v0.6.0
func (c OCIManagedCluster) SetControlPlaneEndpoint(endpoint clusterv1.APIEndpoint)
func (OCIManagedCluster) SetFailureDomain ¶ added in v0.6.0
func (c OCIManagedCluster) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
type OCISelfManagedCluster ¶ added in v0.6.0
type OCISelfManagedCluster struct {
OCICluster *infrastructurev1beta2.OCICluster
}
OCISelfManagedCluster is the ClusterAccessor implementation for self managed clusters
func (OCISelfManagedCluster) GetAvailabilityDomains ¶ added in v0.9.0
func (c OCISelfManagedCluster) GetAvailabilityDomains() map[string]infrastructurev1beta2.OCIAvailabilityDomain
func (OCISelfManagedCluster) GetClientOverrides ¶ added in v0.9.0
func (c OCISelfManagedCluster) GetClientOverrides() *infrastructurev1beta2.ClientOverrides
func (OCISelfManagedCluster) GetCompartmentId ¶ added in v0.6.0
func (c OCISelfManagedCluster) GetCompartmentId() string
func (OCISelfManagedCluster) GetDRG ¶ added in v0.6.0
func (c OCISelfManagedCluster) GetDRG() *infrastructurev1beta2.DRG
func (OCISelfManagedCluster) GetDefinedTags ¶ added in v0.6.0
func (c OCISelfManagedCluster) GetDefinedTags() map[string]map[string]string
func (OCISelfManagedCluster) GetFailureDomains ¶ added in v0.6.0
func (c OCISelfManagedCluster) GetFailureDomains() clusterv1.FailureDomains
func (OCISelfManagedCluster) GetFreeformTags ¶ added in v0.6.0
func (c OCISelfManagedCluster) GetFreeformTags() map[string]string
func (OCISelfManagedCluster) GetIdentityRef ¶ added in v0.7.0
func (c OCISelfManagedCluster) GetIdentityRef() *corev1.ObjectReference
func (OCISelfManagedCluster) GetName ¶ added in v0.6.0
func (c OCISelfManagedCluster) GetName() string
func (OCISelfManagedCluster) GetNameSpace ¶ added in v0.7.0
func (c OCISelfManagedCluster) GetNameSpace() string
func (OCISelfManagedCluster) GetNetworkSpec ¶ added in v0.6.0
func (c OCISelfManagedCluster) GetNetworkSpec() *infrastructurev1beta2.NetworkSpec
func (OCISelfManagedCluster) GetOCIResourceIdentifier ¶ added in v0.6.0
func (c OCISelfManagedCluster) GetOCIResourceIdentifier() string
func (OCISelfManagedCluster) GetRegion ¶ added in v0.7.0
func (c OCISelfManagedCluster) GetRegion() string
func (OCISelfManagedCluster) GetVCNPeering ¶ added in v0.6.0
func (c OCISelfManagedCluster) GetVCNPeering() *infrastructurev1beta2.VCNPeering
func (OCISelfManagedCluster) MarkConditionFalse ¶ added in v0.7.0
func (c OCISelfManagedCluster) MarkConditionFalse(t clusterv1.ConditionType, reason string, severity clusterv1.ConditionSeverity, messageFormat string, messageArgs ...interface{})
func (OCISelfManagedCluster) SetAvailabilityDomains ¶ added in v0.6.0
func (c OCISelfManagedCluster) SetAvailabilityDomains(ads map[string]infrastructurev1beta2.OCIAvailabilityDomain)
func (OCISelfManagedCluster) SetControlPlaneEndpoint ¶ added in v0.6.0
func (c OCISelfManagedCluster) SetControlPlaneEndpoint(endpoint clusterv1.APIEndpoint)
func (OCISelfManagedCluster) SetFailureDomain ¶ added in v0.6.0
func (c OCISelfManagedCluster) SetFailureDomain(id string, spec clusterv1.FailureDomainSpec)
type VirtualMachinePoolScope ¶ added in v0.10.0
type VirtualMachinePoolScope struct { *logr.Logger Client client.Client Cluster *clusterv1.Cluster MachinePool *expclusterv1.MachinePool ComputeManagementClient computemanagement.Client OCIManagedCluster *infrav2exp.OCIManagedCluster OCIVirtualMachinePool *expinfra1.OCIVirtualMachinePool ContainerEngineClient containerengine.Client OCIManagedControlPlane *infrav2exp.OCIManagedControlPlane // contains filtered or unexported fields }
func NewVirtualMachinePoolScope ¶ added in v0.10.0
func NewVirtualMachinePoolScope(params VirtualMachinePoolScopeParams) (*VirtualMachinePoolScope, error)
NewVirtualMachinePoolScope creates a VirtualMachinePoolScope given the VirtualMachinePoolScopeParams
func (*VirtualMachinePoolScope) Close ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) Close(ctx context.Context) error
Close closes the current scope persisting the cluster configuration and status.
func (*VirtualMachinePoolScope) CreateVirtualNodePool ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) CreateVirtualNodePool(ctx context.Context) (*oke.VirtualNodePool, error)
CreateVirtualNodePool attempts to create a virtual node pool
func (*VirtualMachinePoolScope) DeleteVirtualNodePool ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) DeleteVirtualNodePool(ctx context.Context, nodePool *oke.VirtualNodePool) error
DeleteVirtualNodePool terminates a virtual nodepool
func (*VirtualMachinePoolScope) FindVirtualNodePool ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) FindVirtualNodePool(ctx context.Context) (*oke.VirtualNodePool, error)
FindVirtualNodePool attempts to find the node pool by id if the id exists or by name. It checks to make sure the node pool was created by the cluster before returning the correct pool
func (*VirtualMachinePoolScope) GetWorkerMachineSubnet ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) GetWorkerMachineSubnet() *string
GetWorkerMachineSubnet returns the WorkerRole core.Subnet id for the cluster
func (*VirtualMachinePoolScope) IsResourceCreatedByClusterAPI ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) IsResourceCreatedByClusterAPI(resourceFreeFormTags map[string]string) bool
IsResourceCreatedByClusterAPI determines if the virtual node pool was created by the cluster using the tags created at virtual node pool launch.
func (*VirtualMachinePoolScope) ListandSetMachinePoolInstances ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) ListandSetMachinePoolInstances(ctx context.Context, nodePool *oke.VirtualNodePool) (int32, error)
ListandSetMachinePoolInstances retrieves a virtual node pools instances and sets them in the ProviderIDList
func (*VirtualMachinePoolScope) PatchObject ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) PatchObject(ctx context.Context) error
PatchObject persists the cluster configuration and status.
func (*VirtualMachinePoolScope) SetFailureReason ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) SetFailureReason(v capierrors.MachinePoolStatusFailure)
SetFailureReason sets the OCIMachine status error reason.
func (*VirtualMachinePoolScope) SetReplicaCount ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) SetReplicaCount(count int32)
func (*VirtualMachinePoolScope) UpdateVirtualNodePool ¶ added in v0.10.0
func (m *VirtualMachinePoolScope) UpdateVirtualNodePool(ctx context.Context, pool *oke.VirtualNodePool) (bool, error)
UpdateVirtualNodePool updates a virtual node pool, if needed, based on updated spec
type VirtualMachinePoolScopeParams ¶ added in v0.10.0
type VirtualMachinePoolScopeParams struct { Logger *logr.Logger Cluster *clusterv1.Cluster MachinePool *expclusterv1.MachinePool Client client.Client ComputeManagementClient computemanagement.Client OCIManagedCluster *infrav2exp.OCIManagedCluster OCIManagedControlPlane *infrav2exp.OCIManagedControlPlane OCIVirtualMachinePool *expinfra1.OCIVirtualMachinePool ContainerEngineClient containerengine.Client }
VirtualMachinePoolScopeParams defines the params need to create a new VirtualMachinePoolScope
Source Files ¶
- clients.go
- clients_mock.go
- cluster.go
- cluster_accessor.go
- cluster_client.go
- defaults.go
- drg_reconciler.go
- drg_rpc_attachment_reconciler.go
- drg_vcn_attachment_reconciler.go
- internet_gateway_reconciler.go
- load_balancer_reconciler.go
- machine.go
- machine_pool.go
- managed_control_plane.go
- managed_machine_pool.go
- nat_gateway_reconciler.go
- network_load_balancer_reconciler.go
- nsg_reconciler.go
- oci_managed_cluster.go
- oci_selfmanaged_cluster.go
- route_table_reconciler.go
- security_list_reconciler.go
- service_gateway_reconciler.go
- subnet_reconciler.go
- util.go
- vcn_reconciler.go
- virtual_machine_pool.go
- vnic_reconciler.go