kubeutils

Documentation

Index

• func AreSecretsEqual(secret corev1.Secret, other corev1.Secret) bool
• func NewSecret(name string, namespace string, data map[string][]byte) *corev1.Secret
• func ValidateCertificateExpiration(certData []byte, renewalThreshold time.Duration, now time.Time) (bool, error)
• type SecretQuery
  • func NewSecretQuery(kubeClient client.Client, kubeReader client.Reader, log logr.Logger) SecretQuery
  • func (query SecretQuery) Create(ctx context.Context, secret corev1.Secret) error
  • func (query SecretQuery) CreateOrUpdate(ctx context.Context, secret corev1.Secret) error
  • func (query SecretQuery) Get(ctx context.Context, objectKey client.ObjectKey) (corev1.Secret, error)
  • func (query SecretQuery) Update(ctx context.Context, secret corev1.Secret) error

Functions

func AreSecretsEqual

func AreSecretsEqual(secret corev1.Secret, other corev1.Secret) bool

func NewSecret

func NewSecret(name string, namespace string, data map[string][]byte) *corev1.Secret

func ValidateCertificateExpiration

func ValidateCertificateExpiration(certData []byte, renewalThreshold time.Duration, now time.Time) (bool, error)

Types

type SecretQuery

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

func NewSecretQuery

func NewSecretQuery(kubeClient client.Client, kubeReader client.Reader, log logr.Logger) SecretQuery

func (SecretQuery) Create

func (query SecretQuery) Create(ctx context.Context, secret corev1.Secret) error

func (SecretQuery) CreateOrUpdate

func (query SecretQuery) CreateOrUpdate(ctx context.Context, secret corev1.Secret) error

func (SecretQuery) Get

func (query SecretQuery) Get(ctx context.Context, objectKey client.ObjectKey) (corev1.Secret, error)

func (SecretQuery) Update

func (query SecretQuery) Update(ctx context.Context, secret corev1.Secret) error