client

Documentation

Index

• func NewDiscoverer(config DiscovererConfig) (client.Discoverer, error)
• func NewDiscoveryCacher(discoverer client.Discoverer, config client.DiscoveryCacherConfig) client.Discoverer
• func NewDistributedDiscoveryCacher(innerDiscoverer client.MultiDiscoverer, config client.DiscoveryCacherConfig) client.MultiDiscoverer
• func NewDistributedPodLabelDiscoverer(config DistributedPodLabelDiscovererConfig) (client.MultiDiscoverer, error)
• func NewPodLabelDiscoverer(config PodLabelDiscovererConfig) (client.Discoverer, error)
• type DiscovererConfig
• type DistributedPodLabelDiscovererConfig
• type LookupSRVFunc
• type PodLabelDiscovererConfig

Functions

func NewDiscoverer

func NewDiscoverer(config DiscovererConfig) (client.Discoverer, error)

func NewDiscoveryCacher

func NewDiscoveryCacher(discoverer client.Discoverer, config client.DiscoveryCacherConfig) client.Discoverer

NewDiscoveryCacher creates a new DiscoveryCacher that wraps a discoverer and caches the data into the specified storage

func NewDistributedDiscoveryCacher

func NewDistributedDiscoveryCacher(innerDiscoverer client.MultiDiscoverer, config client.DiscoveryCacherConfig) client.MultiDiscoverer

NewDistributedDiscoveryCacher initializes a client.MultiDiscoveryCacher with the given parameters. This should be the only way to create instances of client.MultiDiscoveryCacher, as it guarantees the cached data pointer is initialized.

func NewDistributedPodLabelDiscoverer

func NewDistributedPodLabelDiscoverer(config DistributedPodLabelDiscovererConfig) (client.MultiDiscoverer, error)

NewDistributedPodLabelDiscoverer creates a new KSM discoverer that will find KSM pods using k8s labels.

func NewPodLabelDiscoverer

func NewPodLabelDiscoverer(config PodLabelDiscovererConfig) (client.Discoverer, error)

NewPodLabelDiscoverer creates a new KSM discoverer that will find KSM pods using k8s labels.

Types

type DiscovererConfig

type DiscovererConfig struct {
	LookupSRV         LookupSRVFunc
	K8sClient         client.Kubernetes
	Logger            *logrus.Logger
	OverridenEndpoint string
	Namespace         string
}

DiscovererConfig holds parameters for creating discoverer.

type DistributedPodLabelDiscovererConfig

type DistributedPodLabelDiscovererConfig struct {
	KSMPodLabel  string
	NodeIP       string
	KSMNamespace string
	K8sClient    client.Kubernetes
	Logger       *logrus.Logger
}

DistributedPodLabelDiscovererConfig stores configuration for DistributedPodLabelDiscoverer.

type LookupSRVFunc

type LookupSRVFunc func(service, proto, name string) (cname string, addrs []*net.SRV, err error)

type PodLabelDiscovererConfig

type PodLabelDiscovererConfig struct {
	KSMPodLabel  string
	KSMPodPort   int
	KSMScheme    string
	KSMNamespace string
	Logger       *logrus.Logger
	K8sClient    client.Kubernetes
}

PodLabelDiscovererConfig holds KSM PodLabelDiscoverer configuration.