services

func AddNodesToNB ¶ added in v0.6.1

func AddNodesToNB(ctx context.Context, logger logr.Logger, clusterScope *scope.ClusterScope, linodeMachine v1alpha2.LinodeMachine, nodeBalancerNodes []linodego.NodeBalancerNode) error

AddNodesToNB adds backend Nodes on the Node Balancer configuration.

func CreateDomainRecord ¶ added in v0.4.0

func CreateDomainRecord(ctx context.Context, cscope *scope.ClusterScope, domainID int, dnsEntry DNSOptions) error

func CreateObject ¶ added in v0.8.0

func CreateObject(ctx context.Context, mscope *scope.MachineScope, data []byte) (string, error)

func DeleteAllObjectVersionsAndDeleteMarkers ¶ added in v0.9.2

func DeleteAllObjectVersionsAndDeleteMarkers(ctx context.Context, client clients.S3Client, bucket, prefix string, bypassRetention, ignoreNotFound bool) error

DeleteAllObjectVersionsAndDeleteMarkers deletes all versions of a given object

func DeleteAllObjects ¶ added in v0.9.2

func DeleteAllObjects(
	ctx context.Context,
	s3client clients.S3Client,
	bucketName string,
	bypassRetention bool,
) error

DeleteAllObjects sends delete requests for every object. Versioned objects will get a deletion marker instead of being fully purged.

func DeleteBucket ¶ added in v0.9.2

func DeleteBucket(ctx context.Context, bScope *scope.ObjectStorageBucketScope) error

DeleteBucket deletes the bucket and all its objects.

func DeleteDomainRecord ¶ added in v0.4.0

func DeleteDomainRecord(ctx context.Context, cscope *scope.ClusterScope, domainID int, dnsEntry DNSOptions) error

func DeleteNodesFromNB ¶ added in v0.6.1

func DeleteNodesFromNB(ctx context.Context, logger logr.Logger, clusterScope *scope.ClusterScope) error

DeleteNodesFromNB removes backend Nodes from the Node Balancer configuration

func DeleteObject ¶ added in v0.8.0

func DeleteObject(ctx context.Context, mscope *scope.MachineScope) error

func EnsureAkamaiDNSEntries ¶ added in v0.6.0

func EnsureAkamaiDNSEntries(ctx context.Context, cscope *scope.ClusterScope, operation string, dnsEntry DNSOptions) error

EnsureAkamaiDNSEntries ensures the domainrecord on Akamai EDGE DNS is created, updated, or deleted based on operation passed

func EnsureAndUpdateObjectStorageBucket ¶ added in v0.6.1

func EnsureAndUpdateObjectStorageBucket(ctx context.Context, bScope *scope.ObjectStorageBucketScope) (*linodego.ObjectStorageBucket, error)

EnsureAndUpdateObjectStorageBucket ensures that the bucket exists and updates its access options if necessary.

func EnsureDNSEntries ¶ added in v0.5.0

func EnsureDNSEntries(ctx context.Context, cscope *scope.ClusterScope, operation string) error

EnsureDNSEntries ensures the domainrecord on Linode Cloud Manager is created, updated, or deleted based on operation passed

func EnsureLinodeDNSEntries ¶ added in v0.6.0

func EnsureLinodeDNSEntries(ctx context.Context, cscope *scope.ClusterScope, operation string, dnsEntries []DNSOptions) error

EnsureLinodeDNSEntries ensures the domainrecord on Linode Cloud Manager is created, updated, or deleted based on operation passed

func EnsureNodeBalancer ¶ added in v0.5.0

func EnsureNodeBalancer(ctx context.Context, clusterScope *scope.ClusterScope, logger logr.Logger) (*linodego.NodeBalancer, error)

EnsureNodeBalancer creates a new NodeBalancer if one doesn't exist or returns the existing NodeBalancer

func EnsureNodeBalancerConfigs ¶ added in v0.5.0

func EnsureNodeBalancerConfigs(
	ctx context.Context,
	clusterScope *scope.ClusterScope,
	logger logr.Logger,
) ([]*linodego.NodeBalancerConfig, error)

EnsureNodeBalancerConfigs creates NodeBalancer configs if it does not exist or returns the existing NodeBalancerConfig

func FindSubnet ¶ added in v0.8.7

func FindSubnet(subnetName string, isDirectVPC bool, subnets interface{}) (int, error)

FindSubnet selects a subnet from the provided subnets based on the subnet name It handles both direct VPC subnets and VPCRef subnets If subnet name is provided, it looks for a matching subnet; otherwise, it uses the first subnet Returns the subnet ID and any error encountered

func GetDomainID ¶ added in v0.4.0

func GetDomainID(ctx context.Context, cscope *scope.ClusterScope) (int, error)

GetDomainID gets the domains linode id

func GetObjectStorageKey ¶ added in v0.6.0

func GetObjectStorageKey(ctx context.Context, keyScope *scope.ObjectStorageKeyScope) (*linodego.ObjectStorageKey, error)

func IsAkamaiDomainRecordOwner ¶ added in v0.6.1

func IsAkamaiDomainRecordOwner(ctx context.Context, cscope *scope.ClusterScope) (bool, error)

func IsLinodeDomainRecordOwner ¶ added in v0.6.1

func IsLinodeDomainRecordOwner(ctx context.Context, cscope *scope.ClusterScope, hostname string, domainID int) (bool, error)

func IsObjNotFoundErr ¶ added in v0.9.2

func IsObjNotFoundErr(err error) bool

IsObjNotFoundErr checks if the error is a NotFound or Forbidden error from the S3 API.

func PurgeAllObjects ¶ added in v0.9.2

func PurgeAllObjects(
	ctx context.Context,
	bucket string,
	s3client clients.S3Client,
	bypassRetention,
	ignoreNotFound bool,
) error

PurgeAllObjects wipes out all versions and delete markers for versioned objects.

func RevokeObjectStorageKey ¶ added in v0.6.0

func RevokeObjectStorageKey(ctx context.Context, keyScope *scope.ObjectStorageKeyScope) error

func RotateObjectStorageKey ¶ added in v0.6.0

func RotateObjectStorageKey(ctx context.Context, keyScope *scope.ObjectStorageKeyScope) (*linodego.ObjectStorageKey, error)