types

type CFConfigIngress struct {
	Hostname      string                 `yaml:"hostname,omitempty"`
	Path          string                 `yaml:"path,omitempty"`
	Service       string                 `yaml:"service,omitempty"`
	OriginRequest *CFConfigOriginRequest `yaml:"originRequest,omitempty"`
}

type CFConfigOriginRequest struct {
	NoTLSVerify    bool   `yaml:"noTLSVerify" json:"noTLSVerify"`
	HttpHostHeader string `yaml:"httpHostHeader,omitempty"`
}

type CFConfigYaml struct {
	Tunnel          string            `yaml:"tunnel"`
	CredentialsFile string            `yaml:"credentials-file"`
	Ingress         []CFConfigIngress `yaml:"ingress"`
}

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

type CFControllerCloudflareConfig struct {
	ApiUrl                   string
	ApiToken                 string
	AccountId                string
	TunnelConfigMapNamespace string
}

type CFControllerConfig struct {
	KubeConfigFile         string
	PresetNamespaces       []string
	Identity               string
	NoCloudFlared          bool
	Version                string
	Debug                  bool
	ShowVersion            bool
	RunningInstanceDir     string
	CloudFlaredFname       string
	ChannelSize            int
	ClusterName            string
	RestartDelay           time.Duration
	ConfigMapLabelSelector string
	CloudFlare             CFControllerCloudflareConfig
	TestCreateAccess       bool
	AccessGroup            struct {
		ConfigMapsNames []string
	}
	Leader struct {
		Name          string
		Namespace     string
		LeaseDuration time.Duration
		RenewDeadline time.Duration
		RetryPeriod   time.Duration
	}
}

type CFEndpointMapping struct {
	Path     string
	External string
	Internal string
}

type CFTunnelParameter struct {
	Name      string
	Namespace string
}

type CFTunnelParameterWithID struct {
	CFTunnelParameter
	ID uuid.UUID
}

type CFTunnelSecret struct {
	AccountTag   string    `json:"AccountTag"`
	TunnelSecret string    `json:"TunnelSecret"`
	TunnelID     uuid.UUID `json:"TunnelID"`
}

type ClassIngressAnnotationMapping struct {
	Hostname   string
	Schema     string
	HostHeader *string
	Path       string
}

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 K8SResourceName struct {
	Namespace string
	Name      string
	FQDN      string
}

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
	Cfgo() (*cfgo.API, error)
	CFClientWithoutZoneID() (*cfapi.RESTClient, error)
	GetCFClientForDomain(string) (*cfapi.RESTClient, error)
	K8s() *kubernetes.Clientset
	SetK8s(*kubernetes.Clientset)
}

type StackIngressAnnotationMapping struct {
	Schema      string
	Hostname    string
	InternPort  int
	HostHeader  *string
	ExtHostName string
	Path        string
}

type SvcAnnotationMapping struct {
	PortName string
	Schema   string
	Path     string
	Order    int
}

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

	UpsertConfigMap(cfc CFController, tparam *CFTunnelParameter, kind string, meta *metav1.ObjectMeta, cfcis []CFConfigIngress) error
	RemoveConfigMap(cfc CFController, kind string, meta *metav1.ObjectMeta)
}

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
}