k8scrdclient

Documentation

Index

• func IsInvalidConfig(err error) bool
• func IsNameConflict(err error) bool
• func IsNotEstablished(err error) bool
• type CRDClient
  • func New(config Config) (*CRDClient, error)
  • func (c *CRDClient) EnsureCreated(ctx context.Context, crd *apiextensionsv1.CustomResourceDefinition, ...) error
  • func (c *CRDClient) EnsureDeleted(ctx context.Context, crd *apiextensionsv1.CustomResourceDefinition, ...) error
• type Config
• type Interface

Functions

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func IsNameConflict

func IsNameConflict(err error) bool

IsNameConflict asserts nameConflictError.

func IsNotEstablished

func IsNotEstablished(err error) bool

IsNotEstablished asserts notEstablishedError.

Types

type CRDClient

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

func New

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

func (*CRDClient) EnsureCreated

func (c *CRDClient) EnsureCreated(ctx context.Context, crd *apiextensionsv1.CustomResourceDefinition, b backoff.Interface) error

EnsureCreated ensures the given CRD exists, is active (aka. established) and does not have conflicting names.

func (*CRDClient) EnsureDeleted

func (c *CRDClient) EnsureDeleted(ctx context.Context, crd *apiextensionsv1.CustomResourceDefinition, b backoff.Interface) error

EnsureDeleted ensures the given CRD does not exist.

type Config

type Config struct {
	K8sExtClient apiextensionsclient.Interface
	Logger       micrologger.Logger
}

type Interface

type Interface interface {
	EnsureCreated(ctx context.Context, customResource *apiextensionsv1.CustomResourceDefinition, backOff backoff.Interface) error
	EnsureDeleted(ctx context.Context, customResource *apiextensionsv1.CustomResourceDefinition, backOff backoff.Interface) error
}