source

Documentation

Index

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

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) ([]Source, error)

LookupMultiple returns multiple Sources given multiple names.

func NewIngressSource

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

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, fqdntemplate string, compatibility string) (Source, error)

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