source

Documentation

Index

• func Register(name string, source Source)
• type Source
  • func Lookup(name string) Source
  • func LookupMultiple(names ...string) (sources []Source)
  • func NewIngressSource(client kubernetes.Interface, namespace string) Source
  • func NewMockSource(endpoints []*endpoint.Endpoint) Source
  • func NewMultiSource(children ...Source) Source
  • func NewServiceSource(client kubernetes.Interface, namespace string) Source

Functions

func Register

func Register(name string, source Source)

Register registers a Source under a given name.

Types

type Source

type Source interface {
	Endpoints() ([]*endpoint.Endpoint, error)
}

Source defines the interface Endpoint sources should implement.

func Lookup

func Lookup(name string) Source

Lookup returns a Source by the given name.

func LookupMultiple

func LookupMultiple(names ...string) (sources []Source)

LookupMultiple returns multiple Sources given multiple names.

func NewIngressSource

func NewIngressSource(client kubernetes.Interface, namespace string) Source

NewIngressSource creates a new ingressSource with the given client and namespace scope.

func NewMockSource

func NewMockSource(endpoints []*endpoint.Endpoint) Source

NewMockSource creates a new mockSource returning the given endpoints.

func NewMultiSource

func NewMultiSource(children ...Source) Source

NewMultiSource creates a new multiSource.

func NewServiceSource

func NewServiceSource(client kubernetes.Interface, namespace string) Source

NewServiceSource creates a new serviceSource with the given client and namespace scope.