aws

Documentation

Index

• Constants
• type AWSCluster
  • func (c AWSCluster) GetBaseDomain() string
  • func (c AWSCluster) GetCredentials() cluster.Credentials
  • func (c AWSCluster) GetName() string
  • func (c AWSCluster) GetNamespace() string
  • func (c AWSCluster) GetRegion() string
  • func (c AWSCluster) GetTags() map[string]string
• type AWSClusterGetter
  • func (c AWSClusterGetter) GetCluster(ctx context.Context) (cluster.Cluster, error)
• type AWSCredentials
• type AWSObjectStorageService
  • func (s AWSObjectStorageService) NewAccessRoleService(ctx context.Context, logger logr.Logger, cluster cluster.Cluster) (objectstorage.AccessRoleService, error)
  • func (s AWSObjectStorageService) NewObjectStorageService(ctx context.Context, logger logr.Logger, cluster cluster.Cluster, ...) (objectstorage.ObjectStorageService, error)
• type BucketPolicyData
• type IAMAccessRoleServiceAdapter
  • func NewIamService(iamClient *iam.Client, logger logr.Logger, accountId string, ...) IAMAccessRoleServiceAdapter
  • func (s IAMAccessRoleServiceAdapter) ConfigureRole(ctx context.Context, bucket *v1alpha1.Bucket) error
  • func (s IAMAccessRoleServiceAdapter) DeleteRole(ctx context.Context, bucket *v1alpha1.Bucket) error
• type RolePolicyData
• type S3ObjectStorageAdapter
  • func NewS3Service(s3Client *s3.Client, logger logr.Logger, cluster AWSCluster) S3ObjectStorageAdapter
  • func (s S3ObjectStorageAdapter) ConfigureBucket(ctx context.Context, bucket *v1alpha1.Bucket) error
  • func (s S3ObjectStorageAdapter) CreateBucket(ctx context.Context, bucket *v1alpha1.Bucket) error
  • func (s S3ObjectStorageAdapter) DeleteBucket(ctx context.Context, bucket *v1alpha1.Bucket) error
  • func (s S3ObjectStorageAdapter) ExistsBucket(ctx context.Context, bucket *v1alpha1.Bucket) (bool, error)
  • func (s S3ObjectStorageAdapter) UpdateBucket(ctx context.Context, bucket *v1alpha1.Bucket) error
• type TrustIdentityPolicyData

Constants

const (
	Group                  = "infrastructure.cluster.x-k8s.io"
	KindCluster            = "AWSCluster"
	VersionCluster         = "v1beta2"
	KindClusterIdentity    = "AWSClusterRoleIdentity"
	VersionClusterIdentity = "v1beta2"
)

Types

type AWSCluster

type AWSCluster struct {
	Client      client.Client
	Name        string
	Namespace   string
	BaseDomain  string
	Region      string
	Tags        map[string]string
	Credentials AWSCredentials
}

AWSCluster implements Cluster Interface with AWS data

func (AWSCluster) GetBaseDomain

func (c AWSCluster) GetBaseDomain() string

func (AWSCluster) GetCredentials

func (c AWSCluster) GetCredentials() cluster.Credentials

func (AWSCluster) GetName

func (c AWSCluster) GetName() string

func (AWSCluster) GetNamespace

func (c AWSCluster) GetNamespace() string

func (AWSCluster) GetRegion

func (c AWSCluster) GetRegion() string

func (AWSCluster) GetTags

func (c AWSCluster) GetTags() map[string]string

type AWSClusterGetter

type AWSClusterGetter struct {
	Client            client.Client
	ManagementCluster flags.ManagementCluster
}

AWSClusterGetter implements ClusterGetter Interface It creates an AWSCluster object

func (AWSClusterGetter) GetCluster

func (c AWSClusterGetter) GetCluster(ctx context.Context) (cluster.Cluster, error)

type AWSCredentials

type AWSCredentials struct {
	Role string
}

type AWSObjectStorageService

type AWSObjectStorageService struct {
}

func (AWSObjectStorageService) NewAccessRoleService

func (s AWSObjectStorageService) NewAccessRoleService(ctx context.Context, logger logr.Logger, cluster cluster.Cluster) (objectstorage.AccessRoleService, error)

func (AWSObjectStorageService) NewObjectStorageService

func (s AWSObjectStorageService) NewObjectStorageService(ctx context.Context, logger logr.Logger, cluster cluster.Cluster, client client.Client) (objectstorage.ObjectStorageService, error)

type BucketPolicyData

type BucketPolicyData struct {
	AWSDomain  string
	BucketName string
}

type IAMAccessRoleServiceAdapter

type IAMAccessRoleServiceAdapter struct {
	// contains filtered or unexported fields
}

func NewIamService

func NewIamService(iamClient *iam.Client, logger logr.Logger, accountId string, cluster AWSCluster) IAMAccessRoleServiceAdapter

func (IAMAccessRoleServiceAdapter) ConfigureRole

func (s IAMAccessRoleServiceAdapter) ConfigureRole(ctx context.Context, bucket *v1alpha1.Bucket) error

func (IAMAccessRoleServiceAdapter) DeleteRole

func (s IAMAccessRoleServiceAdapter) DeleteRole(ctx context.Context, bucket *v1alpha1.Bucket) error

type RolePolicyData

type RolePolicyData struct {
	AWSDomain        string
	BucketName       string
	ExtraBucketNames []string
}

type S3ObjectStorageAdapter

type S3ObjectStorageAdapter struct {
	// contains filtered or unexported fields
}

func NewS3Service

func NewS3Service(s3Client *s3.Client, logger logr.Logger, cluster AWSCluster) S3ObjectStorageAdapter

func (S3ObjectStorageAdapter) ConfigureBucket

func (s S3ObjectStorageAdapter) ConfigureBucket(ctx context.Context, bucket *v1alpha1.Bucket) error

func (S3ObjectStorageAdapter) CreateBucket

func (s S3ObjectStorageAdapter) CreateBucket(ctx context.Context, bucket *v1alpha1.Bucket) error

func (S3ObjectStorageAdapter) DeleteBucket

func (s S3ObjectStorageAdapter) DeleteBucket(ctx context.Context, bucket *v1alpha1.Bucket) error

func (S3ObjectStorageAdapter) ExistsBucket

func (s S3ObjectStorageAdapter) ExistsBucket(ctx context.Context, bucket *v1alpha1.Bucket) (bool, error)

func (S3ObjectStorageAdapter) UpdateBucket

func (s S3ObjectStorageAdapter) UpdateBucket(ctx context.Context, bucket *v1alpha1.Bucket) error

UpdateBucket does nothing as we cannot update an s3 bucket

type TrustIdentityPolicyData

type TrustIdentityPolicyData struct {
	AccountId               string
	AWSDomain               string
	CloudFrontDomain        string
	ServiceAccountName      string
	ServiceAccountNamespace string
}