s3object

Documentation

Index

• Constants
• func IsBucketNotFound(err error) bool
• func IsInvalidConfig(err error) bool
• func IsKeyNotFound(err error) bool
• func IsObjectNotFound(err error) bool
• func IsWrongType(err error) bool
• type AwsService
• type BucketObjectState
• type Clients
• type CloudConfigMock
  • func (c *CloudConfigMock) NewMasterTemplate(customObject v1alpha1.AWSConfig, certs legacy.CompactTLSAssets, ...) (string, error)
  • func (c *CloudConfigMock) NewWorkerTemplate(customObject v1alpha1.AWSConfig, certs legacy.CompactTLSAssets) (string, error)
• type CloudConfigService
• type Config
  • func DefaultConfig() Config
• type KMSClient
• type KMSClientMock
  • func (k *KMSClientMock) Encrypt(input *kms.EncryptInput) (*kms.EncryptOutput, error)
• type RandomKeyWatcher
• type Resource
  • func New(config Config) (*Resource, error)
  • func (r *Resource) ApplyCreateChange(ctx context.Context, obj, createChange interface{}) error
  • func (r *Resource) ApplyDeleteChange(ctx context.Context, obj, deleteChange interface{}) error
  • func (r *Resource) ApplyUpdateChange(ctx context.Context, obj, updateChange interface{}) error
  • func (s *Resource) EncryptionConfig(encryptionKey string) (string, error)
  • func (r *Resource) GetCurrentState(ctx context.Context, obj interface{}) (interface{}, error)
  • func (r *Resource) GetDesiredState(ctx context.Context, obj interface{}) (interface{}, error)
  • func (r *Resource) Name() string
  • func (r *Resource) NewDeletePatch(ctx context.Context, obj, currentState, desiredState interface{}) (*framework.Patch, error)
  • func (r *Resource) NewUpdatePatch(ctx context.Context, obj, currentState, desiredState interface{}) (*framework.Patch, error)
• type S3Client
• type S3ClientMock
  • func (s *S3ClientMock) DeleteObject(*s3.DeleteObjectInput) (*s3.DeleteObjectOutput, error)
  • func (s *S3ClientMock) GetObject(*s3.GetObjectInput) (*s3.GetObjectOutput, error)
  • func (s *S3ClientMock) ListObjectsV2(*s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, error)
  • func (s *S3ClientMock) PutObject(*s3.PutObjectInput) (*s3.PutObjectOutput, error)
• type TLSassets

Constants

const (
	// Name is the identifier of the resource.
	Name = "s3objectv8"
)

Functions

func IsBucketNotFound

func IsBucketNotFound(err error) bool

IsBucketNotFound asserts object not found error from upstream's API message.

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func IsKeyNotFound

func IsKeyNotFound(err error) bool

IsKeyNotFound asserts key not found error from upstream's API message.

func IsObjectNotFound

func IsObjectNotFound(err error) bool

IsObjectNotFound asserts object not found error from upstream's API message.

func IsWrongType

func IsWrongType(err error) bool

IsWrongType asserts wrongTypeError.

Types

type AwsService

type AwsService interface {
	GetAccountID() (string, error)
	GetKeyArn(string) (string, error)
}

type BucketObjectState

type BucketObjectState struct {
	Bucket string
	Body   string
	Key    string
}

type Clients

type Clients struct {
	S3  S3Client
	KMS KMSClient
}

type CloudConfigMock

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

func (*CloudConfigMock) NewMasterTemplate

func (c *CloudConfigMock) NewMasterTemplate(customObject v1alpha1.AWSConfig, certs legacy.CompactTLSAssets, randomKeys randomkeytpr.CompactRandomKeyAssets) (string, error)

func (*CloudConfigMock) NewWorkerTemplate

func (c *CloudConfigMock) NewWorkerTemplate(customObject v1alpha1.AWSConfig, certs legacy.CompactTLSAssets) (string, error)

type CloudConfigService

type CloudConfigService interface {
	NewMasterTemplate(v1alpha1.AWSConfig, legacy.CompactTLSAssets, randomkeytpr.CompactRandomKeyAssets) (string, error)
	NewWorkerTemplate(v1alpha1.AWSConfig, legacy.CompactTLSAssets) (string, error)
}

type Config

type Config struct {
	// Dependencies.
	AwsService       AwsService
	CertWatcher      legacy.Searcher
	Clients          Clients
	CloudConfig      CloudConfigService
	Logger           micrologger.Logger
	RandomKeyWatcher RandomKeyWatcher
}

Config represents the configuration used to create a new cloudformation resource.

func DefaultConfig

func DefaultConfig() Config

DefaultConfig provides a default configuration to create a new cloudformation resource by best effort.

type KMSClient

type KMSClient interface {
	Encrypt(*kms.EncryptInput) (*kms.EncryptOutput, error)
}

type KMSClientMock

type KMSClientMock struct{}

func (*KMSClientMock) Encrypt

func (k *KMSClientMock) Encrypt(input *kms.EncryptInput) (*kms.EncryptOutput, error)

type RandomKeyWatcher

type RandomKeyWatcher interface {
	SearchKeys(clusterID string) (map[randomkeytpr.Key][]byte, error)
}

type Resource

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

Resource implements the cloudformation resource.

func New

func New(config Config) (*Resource, error)

New creates a new configured cloudformation resource.

func (*Resource) ApplyCreateChange

func (r *Resource) ApplyCreateChange(ctx context.Context, obj, createChange interface{}) error

func (*Resource) ApplyDeleteChange

func (r *Resource) ApplyDeleteChange(ctx context.Context, obj, deleteChange interface{}) error

func (*Resource) ApplyUpdateChange

func (r *Resource) ApplyUpdateChange(ctx context.Context, obj, updateChange interface{}) error

func (*Resource) EncryptionConfig

func (s *Resource) EncryptionConfig(encryptionKey string) (string, error)

func (*Resource) GetCurrentState

func (r *Resource) GetCurrentState(ctx context.Context, obj interface{}) (interface{}, error)

func (*Resource) GetDesiredState

func (r *Resource) GetDesiredState(ctx context.Context, obj interface{}) (interface{}, error)

func (*Resource) Name

func (r *Resource) Name() string

func (*Resource) NewDeletePatch

func (r *Resource) NewDeletePatch(ctx context.Context, obj, currentState, desiredState interface{}) (*framework.Patch, error)

func (*Resource) NewUpdatePatch

func (r *Resource) NewUpdatePatch(ctx context.Context, obj, currentState, desiredState interface{}) (*framework.Patch, error)

type S3Client

type S3Client interface {
	GetObject(*s3.GetObjectInput) (*s3.GetObjectOutput, error)
	PutObject(*s3.PutObjectInput) (*s3.PutObjectOutput, error)
	DeleteObject(*s3.DeleteObjectInput) (*s3.DeleteObjectOutput, error)
	ListObjectsV2(*s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, error)
}

type S3ClientMock

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

func (*S3ClientMock) DeleteObject

func (s *S3ClientMock) DeleteObject(*s3.DeleteObjectInput) (*s3.DeleteObjectOutput, error)

func (*S3ClientMock) GetObject

func (s *S3ClientMock) GetObject(*s3.GetObjectInput) (*s3.GetObjectOutput, error)

func (*S3ClientMock) ListObjectsV2

func (s *S3ClientMock) ListObjectsV2(*s3.ListObjectsV2Input) (*s3.ListObjectsV2Output, error)

func (*S3ClientMock) PutObject

func (s *S3ClientMock) PutObject(*s3.PutObjectInput) (*s3.PutObjectOutput, error)

type TLSassets

type TLSassets struct {
	APIServerCA       []byte
	APIServerKey      []byte
	APIServerCrt      []byte
	WorkerCA          []byte
	WorkerKey         []byte
	WorkerCrt         []byte
	ServiceAccountCA  []byte
	ServiceAccountKey []byte
	ServiceAccountCrt []byte
	CalicoClientCA    []byte
	CalicoClientKey   []byte
	CalicoClientCrt   []byte
	EtcdServerCA      []byte
	EtcdServerKey     []byte
	EtcdServerCrt     []byte
}