vaultcrt

Documentation

Index

• Constants
• func IsInvalidConfig(err error) bool
• func IsMissingAnnotation(err error) bool
• func IsNotFound(err error) bool
• func IsWrongTypeError(err error) bool
• type Config
  • func DefaultConfig() Config
• 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{}) (*crud.Patch, error)
  • func (r *Resource) NewUpdatePatch(ctx context.Context, obj, currentState, desiredState interface{}) (*crud.Patch, error)

Constants

const (
	PrometheusNamespace = "cert_operator"
	PrometheusSubsystem = "vaultcrt_resource"
)

const (
	// AllowSubDomains defines whether to allow the generated root CA of the PKI
	// backend to allow sub domains as common names.
	AllowSubDomains = true
	Name            = "vaultcrt"
	// ConfigHashAnnotation is the annotation key used to track the hash
	// representation of the cert config. This is used to identify changes of the
	// config to trigger renewals.
	ConfigHashAnnotation = "cert.giantswarm.io/config-hash"
	// UpdateTimestampAnnotation is the annotation key used to track the last
	// update timestamp of certificates contained in the Kubernetes secrets.
	UpdateTimestampAnnotation = "giantswarm.io/update-timestamp"
	// UpdateTimestampLayout is the time layout used to format and parse the
	// update timestamps tracked in the annotations of the Kubernetes secrets.
	UpdateTimestampLayout = "2006-01-02T15:04:05.000000Z"
)

Functions

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func IsMissingAnnotation

func IsMissingAnnotation(err error) bool

IsMissingAnnotation asserts missingAnnotationError.

func IsNotFound

func IsNotFound(err error) bool

IsNotFound asserts notFoundError.

func IsWrongTypeError

func IsWrongTypeError(err error) bool

IsWrongTypeError asserts wrongTypeError.

Types

type Config

type Config struct {
	CurrentTimeFactory func() time.Time
	CtrlClient         client.Client
	K8sClient          kubernetes.Interface
	Logger             micrologger.Logger
	VaultCrt           vaultcrt.Interface

	ExpirationThreshold time.Duration
	Namespace           string
}

func DefaultConfig

func DefaultConfig() Config

type Resource

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

func New

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

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{}) (*crud.Patch, error)

func (*Resource) NewUpdatePatch

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