controller

Oct 4, 2023

Changes in this version

type KeyOp

+ Operation operation

type NodeConfiguration

+ MaxRequeueCount int

+ UnreadyGracePeriod time.Duration

Sep 21, 2023

Changes in this version

+ const AddOp

+ const DeleteOp

+ const UpdateOp

+ type KeyOp struct

+ Attempts int

+ Key string

+ Obj interface{}

+ func NewKeyOp(key string, obj interface{}, op operation) KeyOp

+ type NodeConfiguration struct

+ MinCount int

+ Selectors []string

May 25, 2023

Changes in this version

type ExportedService

+ IngressSNI string

May 4, 2023

Changes in this version

+ const ServiceAnnotationIngressServiceName

+ const ServiceAnnotationIngressServiceNamespace

+ const ServiceAnnotationIngressServicePortName

type ExportedService

+ IngressServiceName string

+ IngressServiceNamespace string

+ IngressServicePortName string

+ func (es *ExportedService) MergeIngressService(svc *v1.Service) bool

Oct 8, 2021

Changes in this version

+ const ServiceAnnotationIdPrefix

type ExportedService

+ IdPrefix string

+ Version int

Dec 6, 2019

Changes in this version

+ const ServiceAnnotationCustomAttrs

+ const ServiceAnnotationExported

+ const ServiceAnnotationLoadBalancerBEProtocol

+ const ServiceAnnotationLoadBalancerClass

+ const ServiceAnnotationLoadBalancerDNSName

+ const ServiceAnnotationLoadBalancerHealthCheckPath

+ const ServiceAnnotationLoadBalancerHealthCheckPort

+ const ServiceAnnotationLoadBalancerListenPort

+ const ServiceAnnotationLoadBalancerServicePerCluster

+ const ServiceAnnotationProxyProtocol

+ func IsExportableService(service *v1.Service) bool

+ func NewClientSet() (kubernetes.Interface, error)

+ type ConsulTarget struct

+ func NewConsulTarget(cfg ConsulTargetConfig) (*ConsulTarget, error)

+ func (t *ConsulTarget) Create(es *ExportedService) (bool, error)

+ func (t *ConsulTarget) Delete(es *ExportedService) (bool, error)

+ func (t *ConsulTarget) Update(es *ExportedService) (bool, error)

+ func (t *ConsulTarget) WriteNodes(nodes []*v1.Node) error

+ type ConsulTargetConfig struct

+ ClusterId string

+ ConsulConfig *capi.Config

+ Elector leader.LeaderElector

+ KvPrefix string

+ ServicesEnabled bool

+ ServicesKeyTmpl string

+ type ExportTarget interface

+ Create func(*ExportedService) (bool, error)

+ Delete func(*ExportedService) (bool, error)

+ Update func(*ExportedService) (bool, error)

+ WriteNodes func([]*v1.Node) error

+ type ExportedNode struct

+ Address string

+ Name string

+ type ExportedService struct

+ BackendProtocol string

+ ClusterId string

+ CustomAttrs map[string]interface{}

+ DNSName string

+ HealthCheckPath string

+ HealthCheckPort int32

+ LoadBalancerClass string

+ LoadBalancerListenPort int32

+ Name string

+ Namespace string

+ Port int32

+ PortName string

+ ProxyProtocol bool

+ ServicePerCluster bool

+ func NewExportedService(service *v1.Service, clusterId string, portIdx int) (*ExportedService, error)

+ func NewExportedServicesFromKubeService(service *v1.Service, clusterId string) ([]*ExportedService, error)

+ func (es *ExportedService) Hash() (string, error)

+ func (es *ExportedService) Id() string

+ func (es *ExportedService) MarshalJSON() ([]byte, error)

+ type InformerConfig struct

+ ClientSet kubernetes.Interface

+ ListerWatcher cache.ListerWatcher

+ ResyncPeriod time.Duration

+ func NewInformerConfig() (*InformerConfig, error)

+ type NodeInformerConfig struct

+ ClientSet kubernetes.Interface

+ ResyncPeriod time.Duration

+ func NewNodeInformerConfig() (*NodeInformerConfig, error)

+ type NodeWatcher struct

+ func NewNodeWatcher(config *NodeInformerConfig, target ExportTarget, nodeSelector string) *NodeWatcher

+ func (nw *NodeWatcher) Run() error

+ func (nw *NodeWatcher) Stop()

+ func (sw *NodeWatcher) String() string

+ type ServiceWatcher struct

+ func NewServiceWatcher(config *InformerConfig, namespaces []string, clusterId string, ...) *ServiceWatcher

+ func (sw *ServiceWatcher) Run() error

+ func (sw *ServiceWatcher) Stop()

+ func (sw *ServiceWatcher) String() string