clusterops

Documentation

Index

• Variables
• func CreateHTTPSCAFilesFromSecret(secret *corev1.Secret) error
• func CreateHTTPSCASecretWithLock(ctx context.Context, client kubernetes.Interface) error
• func EnsureCASecretExist(client kubernetes.Interface, ...) error
• func PrepareWebHookHTTPSServer(KubeanClusterOpsSet clusterOperationClientSet.Interface) *http.Server
• func StartWebHookHTTPSServer(server *http.Server) error
• func UpdateClusterOperationWebhook(clientSet kubernetes.Interface) error
• func WaitForCASecretExist(client kubernetes.Interface) *corev1.Secret
• type AdmissionReviewHandler
  • func (handler AdmissionReviewHandler) ServeHTTP(writer http.ResponseWriter, request *http.Request)
• type PingHandler
  • func (p PingHandler) ServeHTTP(writer http.ResponseWriter, request *http.Request)

Variables

var (
	Organization      = "kubean.io"
	DefaultEffectTime = 10 * 365 * 24 * time.Hour
	// #nosec
	CAStoreSecret = "webhook-http-ca-secret"

	WebHookPath             = "/webhook"
	WebhookSVCNamespace, _  = os.LookupEnv("WEBHOOK_SERVICE_NAMESPACE")
	WebhookSVCName, _       = os.LookupEnv("WEBHOOK_SERVICE_NAME")
	ClusterOperationWebhook = "kubean-admission-webhook"
	FailurePolicy, _        = os.LookupEnv("WEBHOOK_FAILURE_POLICY")
)

Functions

func CreateHTTPSCAFilesFromSecret

func CreateHTTPSCAFilesFromSecret(secret *corev1.Secret) error

func CreateHTTPSCASecretWithLock

func CreateHTTPSCASecretWithLock(ctx context.Context, client kubernetes.Interface) error

func EnsureCASecretExist

func EnsureCASecretExist(client kubernetes.Interface, createHTTPSCAInSecret func() (*corev1.Secret, error)) error

func PrepareWebHookHTTPSServer

func PrepareWebHookHTTPSServer(KubeanClusterOpsSet clusterOperationClientSet.Interface) *http.Server

func StartWebHookHTTPSServer

func StartWebHookHTTPSServer(server *http.Server) error

func UpdateClusterOperationWebhook

func UpdateClusterOperationWebhook(clientSet kubernetes.Interface) error

func WaitForCASecretExist

func WaitForCASecretExist(client kubernetes.Interface) *corev1.Secret

Types

type AdmissionReviewHandler

type AdmissionReviewHandler struct {
	KubeanClusterOpsSet clusterOperationClientSet.Interface
}

func (AdmissionReviewHandler) ServeHTTP

func (handler AdmissionReviewHandler) ServeHTTP(writer http.ResponseWriter, request *http.Request)

type PingHandler

type PingHandler struct{}

func (PingHandler) ServeHTTP

func (p PingHandler) ServeHTTP(writer http.ResponseWriter, request *http.Request)