bucket

Documentation

Index

• func GenerateBucket(name string, params v1alpha1.BucketParameters) *domain.Bucket
• func GenerateBucketObservation(b *domain.Bucket) v1alpha1.BucketObservation
• func IsNotFoundFn(name string) resource.ErrorIs
• func IsUpToDate(params v1alpha1.BucketParameters, obs *domain.Bucket) bool
• func LateInitialize(params *v1alpha1.BucketParameters, obs *domain.Bucket) bool
• func Setup(mgr ctrl.Manager, l logging.Logger, rl workqueue.RateLimiter) error

Functions

func GenerateBucket

func GenerateBucket(name string, params v1alpha1.BucketParameters) *domain.Bucket

GenerateBucket returns a Bucket model that the InfluxDB API accepts for creation and update.

func GenerateBucketObservation

func GenerateBucketObservation(b *domain.Bucket) v1alpha1.BucketObservation

GenerateBucketObservation converts an Bucket response to an observation.

func IsNotFoundFn

func IsNotFoundFn(name string) resource.ErrorIs

IsNotFoundFn returns an ErrorIs function that can tell whether the error is of kind NotFound.

func IsUpToDate

func IsUpToDate(params v1alpha1.BucketParameters, obs *domain.Bucket) bool

IsUpToDate returns whether an update call is necessary.

func LateInitialize

func LateInitialize(params *v1alpha1.BucketParameters, obs *domain.Bucket) bool

LateInitialize sets the defaults from the API if user didn't set a value for such fields.

func Setup

func Setup(mgr ctrl.Manager, l logging.Logger, rl workqueue.RateLimiter) error

Setup adds a controller that reconciles Bucket managed resources.