util

Documentation

Index

• func ApplyManifests(ctx context.Context, kubeClient *RetryableClient, manifestYamlsCombined string) (d diag.Diagnostics)
• func DescribeKubeCluster(ctx context.Context, dp awsconfig.AWSDataplane, cfg aws.Config) (cluster *types.Cluster, err error)
• func GetARNForCPService(ctx context.Context, cfg aws.Config, cc awsconfig.ClusterConfiguration, ...) string
• func GetARNForService(ctx context.Context, cfg aws.Config, cc awsconfig.ClusterConfiguration, ...) string
• func GetAwsConfig(ctx context.Context, dp awsconfig.AWSDataplane) (cfg aws.Config, d diag.Diagnostics)
• func GetKubeClusterName(ctx context.Context, dp awsconfig.AWSDataplane) (name string, err error)
• func GetKubeConfig(ctx context.Context, dp awsconfig.AWSDataplane, cfg aws.Config) (kubeConfig []byte, err error)
• func LogError(ctx context.Context, d diag.Diagnostics, summary string, err error) diag.Diagnostics
• func RenderAndApplyTemplate(ctx context.Context, kubeClient *RetryableClient, name string, ...) (d diag.Diagnostics)
• type RetryableClient
  • func GetKubeClient(ctx context.Context, cfg aws.Config, dp awsconfig.AWSDataplane) (rClient *RetryableClient, err error)
  • func (r *RetryableClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (r *RetryableClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (r *RetryableClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
  • func (r *RetryableClient) Get(ctx context.Context, key k8stypes.NamespacedName, obj client.Object, ...) error
  • func (r *RetryableClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (r *RetryableClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (r *RetryableClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

Functions

func ApplyManifests

func ApplyManifests(ctx context.Context, kubeClient *RetryableClient, manifestYamlsCombined string) (d diag.Diagnostics)

func DescribeKubeCluster

func DescribeKubeCluster(ctx context.Context, dp awsconfig.AWSDataplane, cfg aws.Config) (cluster *types.Cluster, err error)

func GetARNForCPService

func GetARNForCPService(ctx context.Context, cfg aws.Config, cc awsconfig.ClusterConfiguration, service string) string

func GetARNForService

func GetARNForService(ctx context.Context, cfg aws.Config, cc awsconfig.ClusterConfiguration, service string) string

func GetAwsConfig

func GetAwsConfig(ctx context.Context, dp awsconfig.AWSDataplane) (cfg aws.Config, d diag.Diagnostics)

func GetKubeClusterName

func GetKubeClusterName(ctx context.Context, dp awsconfig.AWSDataplane) (name string, err error)

func GetKubeConfig

func GetKubeConfig(ctx context.Context, dp awsconfig.AWSDataplane, cfg aws.Config) (kubeConfig []byte, err error)

func LogError

func LogError(ctx context.Context, d diag.Diagnostics, summary string, err error) diag.Diagnostics

func RenderAndApplyTemplate

func RenderAndApplyTemplate(ctx context.Context, kubeClient *RetryableClient, name string, templateData []byte, data map[string]string) (d diag.Diagnostics)

Types

type RetryableClient

type RetryableClient struct {
	Client client.Client
}

func GetKubeClient

func GetKubeClient(ctx context.Context, cfg aws.Config, dp awsconfig.AWSDataplane) (rClient *RetryableClient, err error)

func (*RetryableClient) Create

func (r *RetryableClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*RetryableClient) Delete

func (r *RetryableClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*RetryableClient) DeleteAllOf

func (r *RetryableClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (*RetryableClient) Get

func (r *RetryableClient) Get(ctx context.Context, key k8stypes.NamespacedName, obj client.Object, opts ...client.GetOption) error

func (*RetryableClient) List

func (r *RetryableClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*RetryableClient) Patch

func (r *RetryableClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*RetryableClient) Update

func (r *RetryableClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error