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 BucketObjectState
• type CloudConfigMock
  • func (c *CloudConfigMock) NewMasterTemplate(ctx context.Context, customObject v1alpha1.AWSConfig, ...) (string, error)
  • func (c *CloudConfigMock) NewWorkerTemplate(ctx context.Context, customObject v1alpha1.AWSConfig, ...) (string, error)
• type Config
• type KMSClientMock
  • func (k *KMSClientMock) Encrypt(input *kms.EncryptInput) (*kms.EncryptOutput, error)
• 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 (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{}) (*controller.Patch, error)
  • func (r *Resource) NewUpdatePatch(ctx context.Context, obj, currentState, desiredState interface{}) (*controller.Patch, error)
• 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)

Constants

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

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 BucketObjectState

type BucketObjectState struct {
	Bucket string
	Body   string
	Key    string
}

type CloudConfigMock

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

func (*CloudConfigMock) NewMasterTemplate

func (c *CloudConfigMock) NewMasterTemplate(ctx context.Context, customObject v1alpha1.AWSConfig, clusterCerts certs.Cluster, randomKeys randomkeys.Cluster) (string, error)

func (*CloudConfigMock) NewWorkerTemplate

func (c *CloudConfigMock) NewWorkerTemplate(ctx context.Context, customObject v1alpha1.AWSConfig, clusterCerts certs.Cluster) (string, error)

type Config

type Config struct {
	CertsSearcher      certs.Interface
	CloudConfig        cloudconfig.Interface
	Logger             micrologger.Logger
	RandomKeysSearcher randomkeys.Interface
}

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

type KMSClientMock

type KMSClientMock struct {
	kmsiface.KMSAPI
}

func (*KMSClientMock) Encrypt

func (k *KMSClientMock) Encrypt(input *kms.EncryptInput) (*kms.EncryptOutput, 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) 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{}) (*controller.Patch, error)

func (*Resource) NewUpdatePatch

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

type S3ClientMock

type S3ClientMock struct {
	s3iface.S3API
	// 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)