kubernetes

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
  • func NewKubernetesServiceDiscoveryProvider(inCluster bool, overrideServiceAddress string, ...) *KubeServiceProvider
  • func Start(provider *KubeServiceProvider) *KubeServiceProvider
  • func Stop(provider *KubeServiceProvider) *KubeServiceProvider

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

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