autoops

func CurrentNamespace() (string, error)

func EnsureSecretAsKeyPair(
	ctx context.Context,
	client *kubernetes.Clientset,
	namespace string,
	name string,
	opts KeyPairOptions,
) (
	certPEM []byte,
	keyPEM []byte,
	err error,
)

func GenerateCert(template, parent *x509.Certificate, publicKey *rsa.PublicKey, privateKey *rsa.PrivateKey) (certOut *x509.Certificate, certPEM []byte, err error)

func GenerateKeyPair(opts KeyPairOptions) (certPEM, keyPEM []byte, err error)

func GenerateRootCA() (certOut *x509.Certificate, certPEM []byte, keyOut *rsa.PrivateKey, keyPEM []byte, err error)

func GenerateServerCert(names []string, caCertPEM, caKeyPEM []byte) (certOut *x509.Certificate, certPEM []byte, keyOut *rsa.PrivateKey, keyPEM []byte, err error)

func InClusterClient() (client *kubernetes.Clientset, err error)

func ListenAndServeAdmission(s *http.Server) (err error)

func NewMutatingAdmissionHTTPHandler(
	fn func(ctx context.Context, request *admissionv1.AdmissionRequest, patches *[]map[string]interface{}) (deny string, err error),
) http.HandlerFunc

func RunAdmissionServer(s *http.Server) (err error)

func ServiceGetOrCreate(ctx context.Context, client *kubernetes.Clientset, service *corev1.Service) (serviceOut *corev1.Service, err error)

func StatefulSetGetOrCreate(ctx context.Context, client *kubernetes.Clientset, sts *appsv1.StatefulSet) (stsOut *appsv1.StatefulSet, err error)