redshift

Documentation

Index

• func CreatePatch(target *v1alpha1.ClusterParameters, in *redshifttypes.Cluster) (*v1alpha1.ClusterParameters, error)
• func GenerateCreateClusterInput(p *v1alpha1.ClusterParameters, cid, pw *string) *redshift.CreateClusterInput
• func GenerateDeleteClusterInput(p *v1alpha1.ClusterParameters, cid *string) *redshift.DeleteClusterInput
• func GenerateModifyClusterInput(p *v1alpha1.ClusterParameters, cl redshifttypes.Cluster) *redshift.ModifyClusterInput
• func GenerateObservation(in redshifttypes.Cluster) v1alpha1.ClusterObservation
• func GetConnectionDetails(in v1alpha1.Cluster) managed.ConnectionDetails
• func IsNotFound(err error) bool
• func IsUpToDate(p v1alpha1.ClusterParameters, cl redshifttypes.Cluster) (bool, error)
• func LateInitialize(in *v1alpha1.ClusterParameters, cl *redshifttypes.Cluster)
• type Client
  • func NewClient(cfg aws.Config) Client

Functions

func CreatePatch

func CreatePatch(target *v1alpha1.ClusterParameters, in *redshifttypes.Cluster) (*v1alpha1.ClusterParameters, error)

CreatePatch creates a *v1alpha1.ClusterParameters that has only the changed values between the target *v1alpha1.ClusterParameters and the current *redshift.Cluster

func GenerateCreateClusterInput

func GenerateCreateClusterInput(p *v1alpha1.ClusterParameters, cid, pw *string) *redshift.CreateClusterInput

GenerateCreateClusterInput from RedshiftSpec

func GenerateDeleteClusterInput

func GenerateDeleteClusterInput(p *v1alpha1.ClusterParameters, cid *string) *redshift.DeleteClusterInput

GenerateDeleteClusterInput from RedshiftSpec

func GenerateModifyClusterInput

func GenerateModifyClusterInput(p *v1alpha1.ClusterParameters, cl redshifttypes.Cluster) *redshift.ModifyClusterInput

GenerateModifyClusterInput from RedshiftSpec

func GenerateObservation

func GenerateObservation(in redshifttypes.Cluster) v1alpha1.ClusterObservation

GenerateObservation is used to produce v1alpha1.ClusterObservation from redshift.Cluster.

func GetConnectionDetails

func GetConnectionDetails(in v1alpha1.Cluster) managed.ConnectionDetails

GetConnectionDetails extracts managed.ConnectionDetails out of v1alpha1.Cluster.

func IsNotFound

func IsNotFound(err error) bool

IsNotFound helper function to test for ErrCodeClusterNotFoundFault error

func IsUpToDate

func IsUpToDate(p v1alpha1.ClusterParameters, cl redshifttypes.Cluster) (bool, error)

IsUpToDate checks whether there is a change in any of the modifiable fields.

func LateInitialize

func LateInitialize(in *v1alpha1.ClusterParameters, cl *redshifttypes.Cluster)

LateInitialize fills the empty fields in *v1alpha1.ClusterParameters with the values seen in redshift.Cluster.

Types

type Client

type Client interface {
	DescribeClusters(ctx context.Context, input *redshift.DescribeClustersInput, opts ...func(*redshift.Options)) (*redshift.DescribeClustersOutput, error)
	CreateCluster(ctx context.Context, input *redshift.CreateClusterInput, opts ...func(*redshift.Options)) (*redshift.CreateClusterOutput, error)
	ModifyCluster(ctx context.Context, input *redshift.ModifyClusterInput, opts ...func(*redshift.Options)) (*redshift.ModifyClusterOutput, error)
	DeleteCluster(ctx context.Context, input *redshift.DeleteClusterInput, opts ...func(*redshift.Options)) (*redshift.DeleteClusterOutput, error)
}

Client defines Redshift client operations

func NewClient

func NewClient(cfg aws.Config) Client

NewClient creates new Redshift Client with provided AWS Configurations/Credentials