dataplatformcluster

Documentation

Index

• func GenerateCreateInput(cr *v1alpha1.DataplatformCluster) *sdkgo.CreateClusterRequest
• func GenerateUpdateInput(cr *v1alpha1.DataplatformCluster) *sdkgo.PatchClusterRequest
• func IsUpToDate(cr *v1alpha1.DataplatformCluster, cluster sdkgo.ClusterResponseData) bool
• func LateInitializer(in *v1alpha1.DataplatformClusterParameters, sg *sdkgo.ClusterResponseData)
• func LateStatusInitializer(in *v1alpha1.DataplatformClusterObservation, sg *sdkgo.ClusterResponseData)
• type APIClient
  • func (dp *APIClient) CreateDataplatformCluster(ctx context.Context, cluster sdkgo.CreateClusterRequest) (sdkgo.ClusterResponseData, *sdkgo.APIResponse, error)
  • func (dp *APIClient) DeleteDataPlatformCluster(ctx context.Context, clusterID string) (*sdkgo.APIResponse, error)
  • func (dp *APIClient) GetAPIClient() *sdkgo.APIClient
  • func (dp *APIClient) GetDataplatformClusterByID(ctx context.Context, clusterID string) (sdkgo.ClusterResponseData, *sdkgo.APIResponse, error)
  • func (dp *APIClient) GetKubeConfig(ctx context.Context, clusterID string) (map[string]any, *sdkgo.APIResponse, error)
  • func (dp *APIClient) IsDataplatformDeleted(ctx context.Context, ids ...string) (bool, error)
  • func (dp *APIClient) PatchDataPlatformCluster(ctx context.Context, clusterID string, cluster sdkgo.PatchClusterRequest) (sdkgo.ClusterResponseData, *sdkgo.APIResponse, error)
• type Client

Functions

func GenerateCreateInput

func GenerateCreateInput(cr *v1alpha1.DataplatformCluster) *sdkgo.CreateClusterRequest

GenerateCreateInput returns sdkgo.KubernetesClusterForPost based on the CR spec

func GenerateUpdateInput

func GenerateUpdateInput(cr *v1alpha1.DataplatformCluster) *sdkgo.PatchClusterRequest

GenerateUpdateInput returns sdkgo.KubernetesClusterForPut based on the CR spec modifications

func IsUpToDate

func IsUpToDate(cr *v1alpha1.DataplatformCluster, cluster sdkgo.ClusterResponseData) bool

IsUpToDate returns true if the dataplatform cluster is up-to-date or false if it does not

func LateInitializer

func LateInitializer(in *v1alpha1.DataplatformClusterParameters, sg *sdkgo.ClusterResponseData)

LateInitializer fills the empty fields in *v1alpha1.ClusterParameters with the values seen in sdkgo.KubernetesCluster.

func LateStatusInitializer

func LateStatusInitializer(in *v1alpha1.DataplatformClusterObservation, sg *sdkgo.ClusterResponseData)

LateStatusInitializer fills the empty fields in *v1alpha1.ClusterObservation with the values seen in sdkgo.KubernetesCluster.

Types

type APIClient

type APIClient struct {
	*clients.IonosServices
}

APIClient is a wrapper around IONOS Service

func (*APIClient) CreateDataplatformCluster

func (dp *APIClient) CreateDataplatformCluster(ctx context.Context, cluster sdkgo.CreateClusterRequest) (sdkgo.ClusterResponseData, *sdkgo.APIResponse, error)

CreateDataplatformCluster based on ClustersPost

func (*APIClient) DeleteDataPlatformCluster

func (dp *APIClient) DeleteDataPlatformCluster(ctx context.Context, clusterID string) (*sdkgo.APIResponse, error)

DeleteDataPlatformCluster based on clusterID

func (*APIClient) GetAPIClient

func (dp *APIClient) GetAPIClient() *sdkgo.APIClient

GetAPIClient gets the APIClient

func (*APIClient) GetDataplatformClusterByID

func (dp *APIClient) GetDataplatformClusterByID(ctx context.Context, clusterID string) (sdkgo.ClusterResponseData, *sdkgo.APIResponse, error)

GetDataplatformClusterByID based on clusterID

func (*APIClient) GetKubeConfig

func (dp *APIClient) GetKubeConfig(ctx context.Context, clusterID string) (map[string]any, *sdkgo.APIResponse, error)

GetKubeConfig based on clusterID

func (*APIClient) IsDataplatformDeleted

func (dp *APIClient) IsDataplatformDeleted(ctx context.Context, ids ...string) (bool, error)

IsDataplatformDeleted returns true if the dataplatform cluster is deleted

func (*APIClient) PatchDataPlatformCluster

func (dp *APIClient) PatchDataPlatformCluster(ctx context.Context, clusterID string, cluster sdkgo.PatchClusterRequest) (sdkgo.ClusterResponseData, *sdkgo.APIResponse, error)

PatchDataPlatformCluster based on clusterID and ClustersPatch

type Client

type Client interface {
	GetDataplatformClusterByID(ctx context.Context, clusterID string) (sdkgo.ClusterResponseData, *sdkgo.APIResponse, error)
	GetKubeConfig(ctx context.Context, clusterID string) (map[string]any, *sdkgo.APIResponse, error)
	CreateDataplatformCluster(ctx context.Context, cluster sdkgo.CreateClusterRequest) (sdkgo.ClusterResponseData, *sdkgo.APIResponse, error)
	PatchDataPlatformCluster(ctx context.Context, clusterID string, cluster sdkgo.PatchClusterRequest) (sdkgo.ClusterResponseData, *sdkgo.APIResponse, error)
	DeleteDataPlatformCluster(ctx context.Context, clusterID string) (*sdkgo.APIResponse, error)
	IsDataplatformDeleted(ctx context.Context, id ...string) (bool, error)
	GetAPIClient() *sdkgo.APIClient
}

Client is a wrapper around IONOS Service K8s Cluster methods