source

Documentation

Index

• func Register(name string, source Source)
• type Source
  • func Lookup(name string) Source
  • func LookupMultiple(names []string) ([]Source, error)
  • func NewDedupSource(source Source) Source
  • func NewFakeSource(dnsName string) (Source, error)
  • func NewIngressSource(client kubernetes.Interface, namespace string, fqdntemplate string) (Source, error)
  • 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 NewDedupSource

func NewDedupSource(source Source) Source

NewDedupSource creates a new dedupSource wrapping the provided Source.

func NewFakeSource

func NewFakeSource(dnsName string) (Source, error)

NewFakeSource creates a new fakeSource with the given client and namespace scope.

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 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.