oss

Documentation

Index

• func GetConnectionDetails(cr *v1alpha1.Bucket) managed.ConnectionDetails
• func SetupBucket(mgr ctrl.Manager, l logging.Logger) error
• type Connector
  • func (c *Connector) Connect(ctx context.Context, mg resource.Managed) (managed.ExternalClient, error)
• type External
  • func (e *External) Create(ctx context.Context, mg resource.Managed) (managed.ExternalCreation, error)
  • func (e *External) Delete(ctx context.Context, mg resource.Managed) error
  • func (e *External) Observe(ctx context.Context, mg resource.Managed) (managed.ExternalObservation, error)
  • func (e *External) Update(ctx context.Context, mg resource.Managed) (managed.ExternalUpdate, error)

Functions

func GetConnectionDetails

func GetConnectionDetails(cr *v1alpha1.Bucket) managed.ConnectionDetails

GetConnectionDetails generates connection details

func SetupBucket

func SetupBucket(mgr ctrl.Manager, l logging.Logger) error

SetupBucket adds a controller that reconciles Bucket.

Types

type Connector

type Connector struct {
	Client      client.Client
	Usage       resource.Tracker
	NewClientFn func(ctx context.Context, endpoint, accessKeyID, accessKeySecret, stsToken string) (*ossclient.SDKClient, error)
}

Connector stores Kubernetes client and oss client

func (*Connector) Connect

func (c *Connector) Connect(ctx context.Context, mg resource.Managed) (managed.ExternalClient, error)

Connect initials cloud resource client

type External

type External struct {
	ExternalClient ossclient.ClientInterface
}

External includes external OSS client

func (*External) Create

func (e *External) Create(ctx context.Context, mg resource.Managed) (managed.ExternalCreation, error)

Create managed resource OSS bucket

func (*External) Delete

func (e *External) Delete(ctx context.Context, mg resource.Managed) error

Delete managed resource OSS bucket

func (*External) Observe

func (e *External) Observe(ctx context.Context, mg resource.Managed) (managed.ExternalObservation, error)

Observe managed resource OSS bucket

func (*External) Update

func (e *External) Update(ctx context.Context, mg resource.Managed) (managed.ExternalUpdate, error)

Update managed resource OSS bucket