Documentation
¶
Index ¶
- func Compose(funcs ...func(p *KubeServiceProvider) *KubeServiceProvider) func(p *KubeServiceProvider) *KubeServiceProvider
- func SubscribeOnAddService(f servicediscovery.ServiceFunc) func(provider *KubeServiceProvider) *KubeServiceProvider
- func SubscribeOnRemoveService(f servicediscovery.ServiceFunc) func(provider *KubeServiceProvider) *KubeServiceProvider
- func SubscribeOnUpdateService(f func(old servicediscovery.Service, new servicediscovery.Service)) func(provider *KubeServiceProvider) *KubeServiceProvider
- type KubeServiceProvider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Compose ¶
func Compose(funcs ...func(p *KubeServiceProvider) *KubeServiceProvider) func(p *KubeServiceProvider) *KubeServiceProvider
Compose composes provider functions
func SubscribeOnAddService ¶
func SubscribeOnAddService(f servicediscovery.ServiceFunc) func(provider *KubeServiceProvider) *KubeServiceProvider
SubscribeOnAddService registers some handlers to be called when a new service is found
func SubscribeOnRemoveService ¶
func SubscribeOnRemoveService(f servicediscovery.ServiceFunc) func(provider *KubeServiceProvider) *KubeServiceProvider
SubscribeOnRemoveService registers some handlers to be called when a service is removed
func SubscribeOnUpdateService ¶
func SubscribeOnUpdateService(f func(old servicediscovery.Service, new servicediscovery.Service)) func(provider *KubeServiceProvider) *KubeServiceProvider
SubscribeOnUpdateService registers some handlers to be called when a service gets updated
Types ¶
type KubeServiceProvider ¶ added in v1.1.15
type KubeServiceProvider struct {
// contains filtered or unexported fields
}
KubeServiceProvider is a service discovery provider implementation, using Kubernetes
func NewKubernetesServiceDiscoveryProvider ¶
func NewKubernetesServiceDiscoveryProvider(inCluster bool, overrideServiceAddress string, filterServiceNamespaceByPrefix string, loggerFactory log.Factory) *KubeServiceProvider
NewKubernetesServiceDiscoveryProvider creates a new kube provider
func Start ¶
func Start(provider *KubeServiceProvider) *KubeServiceProvider
Start starts the discovery process
func Stop ¶
func Stop(provider *KubeServiceProvider) *KubeServiceProvider
Stop stops the discovery process
Source Files
Click to show internal directories.
Click to hide internal directories.