resolvers

type CacheSyncError ¶

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

func (c *CacheSyncError) Error() string

type KubernetesConfig ¶

type KubernetesConfig struct {
	InformerResyncPeriodSeconds int    `mapstructure:"informer_resync_period_seconds"`
	TailscaleOperatorNamespace  string `mapstructure:"tailscale_operator_namespace"`
}

type KubernetesResolver ¶

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

KubernetesResolver is a Resolver that resolves Tailscale IPs from external IPs by peeking at internal state of the tailscale-operator. This resolver is able to map Services with an External (ingress) IP to the corresponding Tailscale IP, provided the Service is exposed by the tailscale-operator.

Note that this resolver must first be started before use with [KubernetesResolver.StartAndWaitForCacheSync]. TODO implement self resolver func

func NewKubernetesResolver(client kubernetes.Interface, resync time.Duration, tailscaleOperatorNamespace string) (*KubernetesResolver, error)

func NewKubernetesResolverFromConfig(client kubernetes.Interface, config *KubernetesConfig) (*KubernetesResolver, error)

func NewKubernetesResolverWithDefaultClient(config *KubernetesConfig) (*KubernetesResolver, error)

func (r *KubernetesResolver) GetTailscaleIPsByExternalIP(externalIP net.IP) ([]net.IP, error)

func (r *KubernetesResolver) GetTailscaleIPsByService(serviceNamespace string, serviceName string) ([]string, error)

func (r *KubernetesResolver) Start(cancel <-chan struct{}) error

type Resolver ¶

type Resolver interface {
	GetTailscaleIPsByExternalIP(ip net.IP) ([]net.IP, error)
}

type SelfResolver ¶

type SelfResolver interface {
	GetProcessTailscaleIPs() ([]net.IP, error)
}

type Startable ¶

type Startable interface {
	Start(cancel <-chan struct{}) error
}