Documentation ¶
Index ¶
- type CFConfigIngress
- type CFConfigOriginRequest
- type CFConfigYaml
- type CFController
- type CFControllerCloudflareConfig
- type CFControllerConfig
- type CFEndpointMapping
- type CFTunnelParameter
- type CFTunnelParameterWithID
- type CFTunnelSecret
- type ClassIngressAnnotationMapping
- type K8SClient
- type K8SItem
- type K8SList
- type K8SResourceName
- type K8sData
- type RestClients
- type StackIngressAnnotationMapping
- type SvcAnnotationMapping
- type TunnelConfigMaps
- type WatchFunc
- type Watcher
- type WatcherBindingConfigMap
- type WatcherBindingConfigMapClient
- type WatcherBindingConfigMapList
- type WatcherBindingIngress
- type WatcherBindingIngressClient
- type WatcherBindingIngressList
- type WatcherBindingNamespace
- type WatcherBindingNamespaceClient
- type WatcherBindingNamespaceList
- type WatcherBindingService
- type WatcherBindingServiceClient
- type WatcherBindingServiceList
- type WatcherConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CFConfigIngress ¶ added in v0.0.11
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 ¶ added in v0.0.11
type CFConfigYaml ¶ added in v0.0.11
type CFConfigYaml struct { Tunnel string `yaml:"tunnel"` CredentialsFile string `yaml:"credentials-file"` Ingress []CFConfigIngress `yaml:"ingress"` }
type CFController ¶
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 ¶ added in v0.1.0
type CFControllerConfig ¶ added in v0.0.11
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 Leader struct { Name string Namespace string LeaseDuration time.Duration RenewDeadline time.Duration RetryPeriod time.Duration } }
type CFEndpointMapping ¶ added in v0.0.11
type CFTunnelParameter ¶ added in v0.0.11
func (*CFTunnelParameter) K8SConfigMapName ¶ added in v0.0.11
func (cft *CFTunnelParameter) K8SConfigMapName() K8SResourceName
func (*CFTunnelParameter) K8SSecretName ¶ added in v0.0.11
func (cft *CFTunnelParameter) K8SSecretName() K8SResourceName
func (*CFTunnelParameter) ObjectMeta ¶ added in v0.0.11
func (cft *CFTunnelParameter) ObjectMeta(ometa *metav1.ObjectMeta) metav1.ObjectMeta
type CFTunnelParameterWithID ¶ added in v0.0.11
type CFTunnelParameterWithID struct { CFTunnelParameter ID uuid.UUID }
type CFTunnelSecret ¶ added in v0.0.11
type ClassIngressAnnotationMapping ¶ added in v0.1.0
type ClassIngressAnnotationMapping struct { Hostname string Schema string HostHeader *string Path string }
hostname/schema[/hostheader]|path,
type K8SResourceName ¶ added in v0.0.11
func FromFQDN ¶ added in v0.0.11
func FromFQDN(fqdn string, ns string) K8SResourceName
type K8sData ¶
type K8sData struct { // Get func() []TunnelConfigMap TunnelConfigMaps TunnelConfigMaps Namespaces Watcher[*corev1.Namespace] // [corev1.Namespace, *corev1.Namespace, WatcherBindingNamespace, WatcherBindingNamespaceClient] }
type RestClients ¶
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 StackIngressAnnotationMapping ¶ added in v0.1.0
type StackIngressAnnotationMapping struct { Schema string Hostname string InternPort int HostHeader *string ExtHostName string Path string }
schema/hostname/int-port/hostheader/ext-host|path,
type SvcAnnotationMapping ¶ added in v0.1.0
type TunnelConfigMaps ¶
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 WatcherBindingConfigMap ¶
type WatcherBindingConfigMap struct {
// contains filtered or unexported fields
}
func (WatcherBindingConfigMap) GetItem ¶
func (nl WatcherBindingConfigMap) GetItem() *corev1.ConfigMap
func (WatcherBindingConfigMap) GetUID ¶
func (nl WatcherBindingConfigMap) GetUID() types.UID
type WatcherBindingConfigMapClient ¶
type WatcherBindingConfigMapClient struct {
Cif v1.ConfigMapInterface
}
func (WatcherBindingConfigMapClient) List ¶
func (nl WatcherBindingConfigMapClient) List(ctx context.Context, options metav1.ListOptions) (K8SList[*corev1.ConfigMap, WatcherBindingConfigMap], error)
func (WatcherBindingConfigMapClient) Watch ¶
func (nl WatcherBindingConfigMapClient) Watch(ctx context.Context, options metav1.ListOptions) (watch.Interface, error)
type WatcherBindingConfigMapList ¶
type WatcherBindingConfigMapList struct {
// contains filtered or unexported fields
}
func (*WatcherBindingConfigMapList) GetItems ¶
func (nl *WatcherBindingConfigMapList) GetItems() []WatcherBindingConfigMap
type WatcherBindingIngress ¶
type WatcherBindingIngress struct {
// contains filtered or unexported fields
}
func (WatcherBindingIngress) GetItem ¶
func (nl WatcherBindingIngress) GetItem() *netv1.Ingress
func (WatcherBindingIngress) GetUID ¶
func (nl WatcherBindingIngress) GetUID() types.UID
type WatcherBindingIngressClient ¶
type WatcherBindingIngressClient struct {
Cif v1.IngressInterface
}
func (WatcherBindingIngressClient) List ¶
func (nl WatcherBindingIngressClient) List(ctx context.Context, options metav1.ListOptions) (K8SList[*netv1.Ingress, WatcherBindingIngress], error)
func (WatcherBindingIngressClient) Watch ¶
func (nl WatcherBindingIngressClient) Watch(ctx context.Context, options metav1.ListOptions) (watch.Interface, error)
type WatcherBindingIngressList ¶
type WatcherBindingIngressList struct {
// contains filtered or unexported fields
}
func (*WatcherBindingIngressList) GetItems ¶
func (nl *WatcherBindingIngressList) GetItems() []WatcherBindingIngress
type WatcherBindingNamespace ¶
type WatcherBindingNamespace struct {
// contains filtered or unexported fields
}
func (WatcherBindingNamespace) GetItem ¶
func (nl WatcherBindingNamespace) GetItem() *corev1.Namespace
func (WatcherBindingNamespace) GetUID ¶
func (nl WatcherBindingNamespace) GetUID() types.UID
type WatcherBindingNamespaceClient ¶
type WatcherBindingNamespaceClient struct {
Nif v1.NamespaceInterface
}
func (WatcherBindingNamespaceClient) List ¶
func (nl WatcherBindingNamespaceClient) List(ctx context.Context, options metav1.ListOptions) (K8SList[*corev1.Namespace, WatcherBindingNamespace], error)
func (WatcherBindingNamespaceClient) Watch ¶
func (nl WatcherBindingNamespaceClient) Watch(ctx context.Context, options metav1.ListOptions) (watch.Interface, error)
type WatcherBindingNamespaceList ¶
type WatcherBindingNamespaceList struct {
// contains filtered or unexported fields
}
func (*WatcherBindingNamespaceList) GetItems ¶
func (nl *WatcherBindingNamespaceList) GetItems() []WatcherBindingNamespace
type WatcherBindingService ¶
type WatcherBindingService struct {
// contains filtered or unexported fields
}
func (WatcherBindingService) GetItem ¶
func (nl WatcherBindingService) GetItem() *corev1.Service
func (WatcherBindingService) GetUID ¶
func (nl WatcherBindingService) GetUID() types.UID
type WatcherBindingServiceClient ¶
type WatcherBindingServiceClient struct {
Sif v1.ServiceInterface
}
func (WatcherBindingServiceClient) List ¶
func (nl WatcherBindingServiceClient) List(ctx context.Context, options metav1.ListOptions) (K8SList[*corev1.Service, WatcherBindingService], error)
func (WatcherBindingServiceClient) Watch ¶
func (nl WatcherBindingServiceClient) Watch(ctx context.Context, options metav1.ListOptions) (watch.Interface, error)
type WatcherBindingServiceList ¶
type WatcherBindingServiceList struct {
// contains filtered or unexported fields
}
func (*WatcherBindingServiceList) GetItems ¶
func (nl *WatcherBindingServiceList) GetItems() []WatcherBindingService
Click to show internal directories.
Click to hide internal directories.