client

type BuildClientFunc func(api.ClusterCfgInfo, *Options) (api.MingleClient, error)

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

type FakeClient struct {
	rtclient.WithWatch

	StopCh chan struct{}

	*Options
	ClusterCfg api.ClusterCfgInfo

	AddResourceEventHandlerFunc func(obj rtclient.Object, handler cache.ResourceEventHandler) error
	CreateFunc                  func(obj rtclient.Object, opts ...rtclient.CreateOption) error
	DeleteFunc                  func(obj rtclient.Object, opts ...rtclient.DeleteOption) error
	DeleteAllOfFunc             func(obj rtclient.Object, opts ...rtclient.DeleteAllOfOption) error
	GetFunc                     func(key ktypes.NamespacedName, obj rtclient.Object) error
	GetInformerFunc             func(obj rtclient.Object) (rtcache.Informer, error)
	HasSyncedFunc               func() bool
	ListFunc                    func(obj rtclient.ObjectList, opts ...rtclient.ListOption) error
	PatchFunc                   func(obj rtclient.Object, patch rtclient.Patch, opts ...rtclient.PatchOption) error
	SetIndexFieldFunc           func(obj rtclient.Object, field string, extractValue rtclient.IndexerFunc) error
	StatusUpdateFunc            func(obj rtclient.Object, opts ...rtclient.SubResourceUpdateOption) error
	UpdateFunc                  func(obj rtclient.Object, opts ...rtclient.UpdateOption) error
	AnnotatedEventfFunc         func(object runtime.Object, annotations map[string]string, eventtype string, reason string, messageFmt string, args ...interface{})
	EventFunc                   func(object runtime.Object, eventtype string, reason string, message string)
	EventfFunc                  func(object runtime.Object, eventtype string, reason string, messageFmt string, args ...interface{})
	GetDynamicInterfaceFunc     func() dynamic.Interface
	GetKubeInterfaceFunc        func() kubernetes.Interface
	GetKubeRestConfigFunc       func() *rest.Config
	GetCtrlRtCacheFunc          func() rtcache.Cache
	GetCtrlRtClientFunc         func() rtclient.Client
	GetCtrlRtManagerFunc        func() rtmanager.Manager
	WatchFunc                   func(src rtclient.Object, queue api.WorkQueue, handler api.EventHandler, predicates ...api.Predicate) error
	GetClusterCfgInfoFunc       func() api.ClusterCfgInfo
	IsConnectedFunc             func() bool
}

type MultiClientConfig struct {
	*Options
	FetchInterval     time.Duration
	ClusterCfgManager api.ClusterConfigurationManager
	BuildClientFunc   BuildClientFunc
}

type Options struct {
	WebhookOptions

	Scheme                  *runtime.Scheme
	Logger                  logr.Logger
	LoggerDevMode           bool
	LeaderElection          bool
	LeaderElectionNamespace string
	LeaderElectionID        string
	SyncPeriod              time.Duration
	HealthCheckInterval     time.Duration
	ExecTimeout             time.Duration
	UserAgent               string
	QPS                     int
	Burst                   int
	SetKubeRestConfigFnList []api.SetKubeRestConfig
}

type WebhookOptions struct {
	// Port is the port that the webhook server serves at.
	// It is used to set webhook.Server.Port if WebhookServer is not set.
	Port int
	// Host is the hostname that the webhook server binds to.
	// It is used to set webhook.Server.Host if WebhookServer is not set.
	Host string

	// CertDir is the directory that contains the server key and certificate.
	// If not set, webhook server would look up the server key and certificate in
	// {TempDir}/k8s-webhook-server/serving-certs. The server key and certificate
	// must be named tls.key and tls.crt, respectively.
	// It is used to set webhook.Server.CertDir if WebhookServer is not set.
	CertDir string

	// TLSOpts is used to allow configuring the TLS config used for the webhook server.
	TLSOpts []func(*tls.Config)
}