provider

Documentation

Index

• Variables
• func Validate(data []byte) (err E.Error)
• type DockerProvider
  • func (p *DockerProvider) IsExplicitOnly() bool
  • func (p *DockerProvider) Logger() *zerolog.Logger
  • func (p *DockerProvider) NewWatcher() watcher.Watcher
  • func (p *DockerProvider) ShortName() string
  • func (p *DockerProvider) String() string
• type EventHandler
  • func (handler *EventHandler) Add(parent task.Parent, route *route.Route)
  • func (handler *EventHandler) Handle(parent task.Parent, events []watcher.Event)
  • func (handler *EventHandler) Log()
  • func (handler *EventHandler) Remove(route *route.Route)
  • func (handler *EventHandler) Update(parent task.Parent, oldRoute *route.Route, newRoute *route.Route)
• type FileProvider
  • func (p *FileProvider) IsExplicitOnly() bool
  • func (p *FileProvider) Logger() *zerolog.Logger
  • func (p *FileProvider) NewWatcher() W.Watcher
  • func (p *FileProvider) ShortName() string
  • func (p *FileProvider) String() string
• type Provider
  • func NewDockerProvider(name string, dockerHost string) (p *Provider, err error)
  • func NewFileProvider(filename string) (p *Provider, err error)
  • func (p *Provider) GetRoute(alias string) (r *route.Route, ok bool)
  • func (p *Provider) GetType() types.ProviderType
  • func (p *Provider) LoadRoutes() (err E.Error)
  • func (p *Provider) MarshalText() ([]byte, error)
  • func (p *Provider) NumRoutes() int
  • func (p *Provider) RangeRoutes(do func(string, *route.Route))
  • func (p *Provider) Start(parent task.Parent) E.Error
  • func (p *Provider) Statistics() ProviderStats
• type ProviderImpl
  • func DockerProviderImpl(name, dockerHost string) (ProviderImpl, error)
  • func FileProviderImpl(filename string) (ProviderImpl, error)
• type ProviderStats
• type RouteStats
  • func (stats *RouteStats) Add(r *R.Route)
  • func (stats *RouteStats) AddOther(other RouteStats)

Variables

var ErrAliasRefIndexOutOfRange = E.New("index out of range")

var ErrEmptyProviderName = errors.New("empty provider name")

Functions

func Validate

func Validate(data []byte) (err E.Error)

Types

type DockerProvider

type DockerProvider struct {
	// contains filtered or unexported fields
}

func (*DockerProvider) IsExplicitOnly

func (p *DockerProvider) IsExplicitOnly() bool

func (*DockerProvider) Logger

func (p *DockerProvider) Logger() *zerolog.Logger

func (*DockerProvider) NewWatcher

func (p *DockerProvider) NewWatcher() watcher.Watcher

func (*DockerProvider) ShortName

func (p *DockerProvider) ShortName() string

func (*DockerProvider) String

func (p *DockerProvider) String() string

type EventHandler

type EventHandler struct {
	// contains filtered or unexported fields
}

func (*EventHandler) Add

func (handler *EventHandler) Add(parent task.Parent, route *route.Route)

func (*EventHandler) Handle

func (handler *EventHandler) Handle(parent task.Parent, events []watcher.Event)

func (*EventHandler) Log

func (handler *EventHandler) Log()

func (*EventHandler) Remove

func (handler *EventHandler) Remove(route *route.Route)

func (*EventHandler) Update

func (handler *EventHandler) Update(parent task.Parent, oldRoute *route.Route, newRoute *route.Route)

type FileProvider

type FileProvider struct {
	// contains filtered or unexported fields
}

func (*FileProvider) IsExplicitOnly

func (p *FileProvider) IsExplicitOnly() bool

func (*FileProvider) Logger

func (p *FileProvider) Logger() *zerolog.Logger

func (*FileProvider) NewWatcher

func (p *FileProvider) NewWatcher() W.Watcher

func (*FileProvider) ShortName

func (p *FileProvider) ShortName() string

func (*FileProvider) String

func (p *FileProvider) String() string

type Provider

type Provider struct {
	ProviderImpl
	// contains filtered or unexported fields
}

func NewDockerProvider

func NewDockerProvider(name string, dockerHost string) (p *Provider, err error)

func NewFileProvider

func NewFileProvider(filename string) (p *Provider, err error)

func (*Provider) GetRoute

func (p *Provider) GetRoute(alias string) (r *route.Route, ok bool)

func (*Provider) GetType

func (p *Provider) GetType() types.ProviderType

func (*Provider) LoadRoutes

func (p *Provider) LoadRoutes() (err E.Error)

func (*Provider) MarshalText

func (p *Provider) MarshalText() ([]byte, error)

to work with json marshaller.

func (*Provider) NumRoutes

func (p *Provider) NumRoutes() int

func (*Provider) RangeRoutes

func (p *Provider) RangeRoutes(do func(string, *route.Route))

func (*Provider) Start

func (p *Provider) Start(parent task.Parent) E.Error

Start implements task.TaskStarter.

func (*Provider) Statistics

func (p *Provider) Statistics() ProviderStats

type ProviderImpl

type ProviderImpl interface {
	fmt.Stringer
	ShortName() string
	IsExplicitOnly() bool

	NewWatcher() W.Watcher
	Logger() *zerolog.Logger
	// contains filtered or unexported methods
}

func DockerProviderImpl

func DockerProviderImpl(name, dockerHost string) (ProviderImpl, error)

func FileProviderImpl

func FileProviderImpl(filename string) (ProviderImpl, error)

type ProviderStats

type ProviderStats struct {
	Total   uint16             `json:"total"`
	RPs     RouteStats         `json:"reverse_proxies"`
	Streams RouteStats         `json:"streams"`
	Type    types.ProviderType `json:"type"`
}

type RouteStats

type RouteStats struct {
	Total        uint16 `json:"total"`
	NumHealthy   uint16 `json:"healthy"`
	NumUnhealthy uint16 `json:"unhealthy"`
	NumNapping   uint16 `json:"napping"`
	NumError     uint16 `json:"error"`
	NumUnknown   uint16 `json:"unknown"`
}

func (*RouteStats) Add

func (stats *RouteStats) Add(r *R.Route)

func (*RouteStats) AddOther

func (stats *RouteStats) AddOther(other RouteStats)