s3object

package
v0.0.0-...-17b5b8b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 21, 2018 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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 (*S3ClientMock) GetObject

func (*S3ClientMock) ListObjectsV2

func (*S3ClientMock) PutObject

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL