client

package

Go to main page

Versions in this module

v1

v1.2.1

Jul 29, 2023

v1.2.0

Apr 21, 2023

Changes in this version

type SyncConfig

+ DefaultIngressHostname string

v1.1.2

Oct 22, 2022

v1.1.1

Oct 15, 2022

v1.1.0

Oct 15, 2022

Changes in this version

+ type Controller struct

+ ClientConfig *rest.Config

+ Context context.Context

+ DefaultClient kubernetes.Interface

+ IngressReplicator common.Replicator

+ ServiceReplicator common.Replicator

+ SyncConfig *SyncConfig

+ TraefikClient *versioned.Clientset

+ TraefikIngressRouteReplicator common.Replicator

+ func NewController() *Controller

+ func (c *Controller) Initialize(config *SyncConfig) (*Controller, error)

+ func (c *Controller) InitializeClients() (err error)

+ func (c *Controller) InitializeClusterConfig() (err error)

+ func (c *Controller) InitializeDefaultClient() (err error)

+ func (c *Controller) InitializeReplicators()

+ func (c *Controller) InitializeTraefikClient() (err error)

type SyncConfig

+ EnableTraefik bool

v1.0.0

Sep 20, 2022

Changes in this version

+ func InitializeClient(config *SyncConfig) (*kubernetes.Clientset, error)

+ func InitializeClusterConfig(config *SyncConfig) (*rest.Config, error)

type SyncConfig

+ LivenessPort int

+ ResyncPeriod time.Duration

v0

v0.3.0

Sep 17, 2022

Changes in this version

+ func IngressRuleValuesAreEqual(a, b []networkingv1.IngressRule) bool

+ func IngressesAreEqual(a, b *networkingv1.Ingress) bool

+ func IsIngressManagedBy(ingress *networkingv1.Ingress) bool

+ func Manage(m map[string]string) map[string]string

+ func OwnerReference(rule *typesv1.ExternalSyncRule) metav1.OwnerReference

+ func PrepareIngress(rule *typesv1.ExternalSyncRule, namespace *v1.Namespace, ...) *networkingv1.Ingress

type Client

+ IngressWatcher watch.Interface

+ func (client *Client) AddedIngressHandler(ingress *networkingv1.Ingress) error

+ func (client *Client) CreateIngress(rule *typesv1.ExternalSyncRule, namespace *v1.Namespace, ...) error

+ func (client *Client) CreateUpdateIngress(rule *typesv1.ExternalSyncRule, namespace *v1.Namespace, ...) error

+ func (client *Client) DeleteIngress(namespace *v1.Namespace, ingress *networkingv1.Ingress) (err error)

+ func (client *Client) DeletedIngressHandler(ingress *networkingv1.Ingress) error

+ func (client *Client) GetIngress(namespace, name string) (ingress *networkingv1.Ingress, err error)

+ func (client *Client) IngressEventHandler(event watch.Event) error

+ func (client *Client) ListIngresses(namespace string) (list *networkingv1.IngressList, err error)

+ func (client *Client) ModifiedIngressHandler(ingress *networkingv1.Ingress) error

+ func (client *Client) StartIngressWatcher() (err error)

+ func (client *Client) SyncAddedModifiedIngress(ingress *networkingv1.Ingress) error

+ func (client *Client) SyncDeletedIngress(namespace *v1.Namespace, ingress *networkingv1.Ingress) error

+ func (client *Client) UpdateIngress(rule *typesv1.ExternalSyncRule, namespace *v1.Namespace, ...) error

v0.2.0

Sep 15, 2022

Changes in this version

+ func AnnotationsAreEqual(a, b map[string]string) bool

+ func CopyAnnotations(m map[string]string) map[string]string

+ func ExternalNameServicesAreEqual(a, b *v1.Service) bool

+ func IsServiceManagedBy(service *v1.Service) bool

+ func PrepareExternalNameService(rule *typesv1.ExternalSyncRule, namespace *v1.Namespace, service *v1.Service) *v1.Service

+ type Client struct

+ ClusterConfig *rest.Config

+ Context context.Context

+ DefaultClientset kubernetes.Interface

+ ExternalSyncRuleWatcher watch.Interface

+ KubeExternalSyncClientset *kesclientset.KubeExternalSyncClientset

+ NamespaceWatcher watch.Interface

+ ServiceWatcher watch.Interface

+ SignalChannel chan os.Signal

+ StartTime time.Time

+ SyncConfig *SyncConfig

+ func (client *Client) AddedExternalSyncRuleHandler(rule *typesv1.ExternalSyncRule) (err error)

+ func (client *Client) AddedNamespaceHandler(namespace *v1.Namespace) error

+ func (client *Client) AddedServiceHandler(service *v1.Service) error

+ func (client *Client) CreateExternalNameService(rule *typesv1.ExternalSyncRule, namespace *v1.Namespace, service *v1.Service) error

+ func (client *Client) CreateUpdateExternalNameService(rule *typesv1.ExternalSyncRule, namespace *v1.Namespace, service *v1.Service) error

+ func (client *Client) DeleteService(namespace *v1.Namespace, service *v1.Service) (err error)

+ func (client *Client) DeletedExternalSyncRuleHandler(rule *typesv1.ExternalSyncRule) error

+ func (client *Client) DeletedServiceHandler(service *v1.Service) error

+ func (client *Client) ExternalSyncRuleEventHandler(event watch.Event) error

+ func (client *Client) GetService(namespace, name string) (service *v1.Service, err error)

+ func (client *Client) Initialize(config *SyncConfig) error

+ func (client *Client) InitializeClientsets() error

+ func (client *Client) InitializeClusterConfig() (err error)

+ func (client *Client) InitializeDefault() (err error)

+ func (client *Client) InitializeKubeExternalSync() (err error)

+ func (client *Client) InitializeSignalChannel()

+ func (client *Client) InitializeWatchers() (err error)

+ func (client *Client) ListExternalSyncRules() (rules *typesv1.ExternalSyncRuleList, err error)

+ func (client *Client) ListNamespaces() (namespaces *v1.NamespaceList, err error)

+ func (client *Client) ListServices(namespace string) (list *v1.ServiceList, err error)

+ func (client *Client) ModifiedExternalSyncRuleHandler(rule *typesv1.ExternalSyncRule) error

+ func (client *Client) ModifiedServiceHandler(service *v1.Service) error

+ func (client *Client) NamespaceEventHandler(event watch.Event) error

+ func (client *Client) ServiceEventHandler(event watch.Event) error

+ func (client *Client) StartExternalSyncRuleWatcher() (err error)

+ func (client *Client) StartNamespaceWatcher() (err error)

+ func (client *Client) StartServiceWatcher() (err error)

+ func (client *Client) SyncAddedModifiedService(service *v1.Service) error

+ func (client *Client) SyncDeletedService(namespace *v1.Namespace, service *v1.Service) error

+ func (client *Client) SyncNamespace(namespace *v1.Namespace) error

+ func (client *Client) SyncResourcesToNamespace(namespace *v1.Namespace, rule *typesv1.ExternalSyncRule) error

+ func (client *Client) UpdateExternalNameService(rule *typesv1.ExternalSyncRule, namespace *v1.Namespace, service *v1.Service) error

v0.1.0

Sep 11, 2022

Changes in this version

+ func SyncExternals(config *SyncConfig) (err error)

+ type SyncConfig struct

+ KubeConfig string

+ OutOfCluster bool

+ PodNamespace string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL