user

Documentation

Index

• type Controller
  • func NewUserController(k8sClient kubernetes.Interface, ksClient kubesphere.Interface, ...) *Controller
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error
  • func (c *Controller) Start(stopCh <-chan struct{}) error
• type EmailValidator
  • func (a *EmailValidator) Handle(ctx context.Context, req admission.Request) admission.Response
  • func (a *EmailValidator) InjectDecoder(d *admission.Decoder) error
• type LoginRecordController
  • func NewLoginRecordController(k8sClient kubernetes.Interface, ksClient kubesphere.Interface, ...) *LoginRecordController
  • func (c *LoginRecordController) Run(threadiness int, stopCh <-chan struct{}) error
  • func (c *LoginRecordController) Start(stopCh <-chan struct{}) error

Types

type Controller

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

func NewUserController

func NewUserController(k8sClient kubernetes.Interface, ksClient kubesphere.Interface,
	config *rest.Config, userInformer iamv1alpha2informers.UserInformer,
	fedUserCache cache.Store, fedUserController cache.Controller,
	loginRecordInformer iamv1alpha2informers.LoginRecordInformer,
	configMapInformer corev1informers.ConfigMapInformer,
	ldapClient ldapclient.Interface,
	devopsClient devops.Interface,
	authenticationOptions *authoptions.AuthenticationOptions,
	multiClusterEnabled bool) *Controller

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error

func (*Controller) Start

func (c *Controller) Start(stopCh <-chan struct{}) error

type EmailValidator

type EmailValidator struct {
	Client client.Client
	// contains filtered or unexported fields
}

func (*EmailValidator) Handle

func (a *EmailValidator) Handle(ctx context.Context, req admission.Request) admission.Response

func (*EmailValidator) InjectDecoder

func (a *EmailValidator) InjectDecoder(d *admission.Decoder) error

InjectDecoder injects the decoder.

type LoginRecordController

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

func NewLoginRecordController

func NewLoginRecordController(k8sClient kubernetes.Interface, ksClient kubesphere.Interface,
	loginRecordInformer iamv1alpha2informers.LoginRecordInformer,
	loginHistoryRetentionPeriod time.Duration) *LoginRecordController

func (*LoginRecordController) Run

func (c *LoginRecordController) Run(threadiness int, stopCh <-chan struct{}) error

func (*LoginRecordController) Start

func (c *LoginRecordController) Start(stopCh <-chan struct{}) error