types

type CFController interface {
	WithComponent(component string, fns ...func(CFController)) CFController
	RegisterShutdown(sfn func()) func()
	Shutdown() error
	Log() *zerolog.Logger
	SetLog(*zerolog.Logger)
	Cfg() *config.CFControllerConfig
	SetCfg(*config.CFControllerConfig)
	Rest() RestClients
	K8sData() *K8sData
	Context() context.Context
	CancelFunc() context.CancelFunc
}

type K8SClient[R runtime.Object, L K8SItem[R]] interface {
	Watch(ctx context.Context, options metav1.ListOptions) (watch.Interface, error)
	List(ctx context.Context, options metav1.ListOptions) (K8SList[R, L], error)
}

type K8SItem[R runtime.Object] interface {
	GetUID() types.UID
	GetItem() R
}

type K8SList[R runtime.Object, T K8SItem[R]] interface {
	GetItems() []T
}

type K8sData struct {
	// Get              func() []TunnelConfigMap
	TunnelConfigMaps TunnelConfigMaps
	Namespaces       Watcher[*corev1.Namespace] // [corev1.Namespace, *corev1.Namespace, WatcherBindingNamespace, WatcherBindingNamespaceClient]
}

type RestClients interface {
	// cfc *CFController
	// // Cf  *cfapi.RESTClient
	// cfsLock sync.Mutex
	// cfs     map[string]*cfapi.RESTClient
	CFClientWithoutZoneID() (*cfapi.RESTClient, error)
	GetCFClientForDomain(string) (*cfapi.RESTClient, error)
	K8s() *kubernetes.Clientset
	SetK8s(*kubernetes.Clientset)
}

type TunnelConfigMaps interface {
	Register(func([]*corev1.ConfigMap, watch.Event)) func()
	Get() []*corev1.ConfigMap
}

type WatchFunc[RO runtime.Object] func(state []RO, ev watch.Event)

type Watcher[RO runtime.Object] interface {
	Start() error
	Stop()
	GetState() []RO
	GetContext() context.Context
	RegisterEvent(WatchFunc[RO]) func()
}

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

type WatcherBindingConfigMapClient struct {
	Cif v1.ConfigMapInterface
}

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

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

type WatcherBindingIngressClient struct {
	Cif v1.IngressInterface
}

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

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

type WatcherBindingNamespaceClient struct {
	Nif v1.NamespaceInterface
}

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

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

type WatcherBindingServiceClient struct {
	Sif v1.ServiceInterface
}

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

type WatcherConfig[R any, RO runtime.Object, I K8SItem[RO], C K8SClient[RO, I]] struct {
	ListOptions metav1.ListOptions
	Log         *zerolog.Logger
	Context     context.Context
	K8sClient   C
}