producers

Documentation

Index

• func NewFakeProducer(cfg *FakeProducerOptions) (*fakeProducer, error)
• func NewKubernetesIngress(cfg *KubernetesOptions) (*kubernetesIngressProducer, error)
• func NewKubernetesNodePorts(cfg *KubernetesOptions) (*kubernetesNodePortsProducer, error)
• func NewKubernetesProducer(cfg *KubernetesOptions) (*kubernetesProducer, error)
• func NewKubernetesService(cfg *KubernetesOptions) (*kubernetesServiceProducer, error)
• func NewNullProducer() (*nullProducer, error)
• type FakeProducerOptions
• type KubernetesOptions
• type Producer

Functions

func NewFakeProducer

func NewFakeProducer(cfg *FakeProducerOptions) (*fakeProducer, error)

func NewKubernetesIngress

func NewKubernetesIngress(cfg *KubernetesOptions) (*kubernetesIngressProducer, error)

func NewKubernetesNodePorts

func NewKubernetesNodePorts(cfg *KubernetesOptions) (*kubernetesNodePortsProducer, error)

func NewKubernetesProducer

func NewKubernetesProducer(cfg *KubernetesOptions) (*kubernetesProducer, error)

func NewKubernetesService

func NewKubernetesService(cfg *KubernetesOptions) (*kubernetesServiceProducer, error)

func NewNullProducer

func NewNullProducer() (*nullProducer, error)

Types

type FakeProducerOptions

type FakeProducerOptions struct {
	DNSName       string
	Mode          string
	TargetDomain  string
	FixedDNSName  string
	FixedIP       string
	FixedHostname string
}

type KubernetesOptions

type KubernetesOptions struct {
	APIServer      *url.URL
	Format         string
	TrackNodePorts bool
	Filter         map[string]string
}

type Producer

type Producer interface {
	Endpoints() ([]*pkg.Endpoint, error)
	Monitor(chan *pkg.Endpoint, chan error, chan struct{}, *sync.WaitGroup)
}