baker

package module

Go to main page

Versions in this module

v1

v1.2.0

Jan 29, 2024

Changes in this version

+ func WithOnAfterPinger(onAfterPinger func(containerSet *collection.Set[string, *Container])) bakerOptionFunc

+ func WithPingDuration(d time.Duration) bakerOptionFunc

+ func WithRules(rules ...rule.RegisterFunc) bakerOptionFunc

v1.2.0-rc1

Jan 28, 2024

v1.1.4

May 1, 2023

v1.1.3

Dec 14, 2022

Changes in this version

type Domains

+ func (d *Domains) Paths(domain string, insert bool) *Paths

v1.1.2

Dec 14, 2022

v1.1.1

May 23, 2022

v1.1.0

May 23, 2022

v1.0.2

May 9, 2022

Changes in this version

type Container

+ Path string

type Paths

+ func (p *Paths) Service(path string, insert bool) *Service

+ type Server struct

+ func New(containers <-chan *Container, rules ...rule.RegisterFunc) *Server

+ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Service

+ func (s *Service) Select() (*Container, *Endpoint, bool)

v1.0.1

Apr 16, 2021

v1.0.0

Apr 14, 2021

Changes in this version

+ func StartAcme(handler http.Handler, cachePath string) error

type Container

+ Addr func() string

+ type ContainerRegistor interface

+ FindContainer func(domain, path string) (Container, *Endpoint)

+ UpdateContainer func(container Container, endpoint *Endpoint)

+ type Endpoint struct

+ Domain string

+ Path string

+ Ready bool

+ Rules []Rule

+ type EndpointsFetcher interface

+ FetchEndpoints func() ([]*Endpoint, error)

+ type Middleware interface

+ Process func(next http.Handler) http.Handler

type Paths

+ func (p *Paths) Del(key []rune)

+ func (p *Paths) Put(key []rune, val *Service)

+ func (p *Paths) Size() int

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) FindContainer(domain string, path string) (Container, *Endpoint)

+ func (r *Registry) UpdateContainer(container Container, endpoint *Endpoint)

type Rule

+ Args json.RawMessage

+ Type string

type Service

+ func NewService() *Service

+ func (s *Service) Random() (Container, *Endpoint)

+ func (s *Service) Size() int

type Services

+ func (s *Services) Get(path string) (Container, *Endpoint)

+ func (s *Services) Remove(endpoint *Endpoint, container Container)

type Watcher

+ Watch func(errs chan<- error) <-chan Container

v0

v0.5.0

Apr 11, 2021

v0.3.0

Dec 26, 2020

v0.2.0

Aug 19, 2020

v0.1.0

Mar 12, 2020

Changes in this version

+ const ErrDomainNotFound

+ const ErrPathNotFound

+ const ErrServiceNotInitialized

+ const ErrTargetNotFound

+ type Config struct

+ Domain string

+ Path string

+ Ready bool

+ Rules rule.Handlers

+ type Domain struct

+ func (d *Domain) Add(container *Container, config *Config) error

+ func (d *Domain) Get(path string) (*Service, error)

+ func (d *Domain) Remove(containerID string, path string) error

type Service

+ func (s *Service) Add(container *Container, config *Config) error

+ func (s *Service) Get() (*Target, error)

+ func (s *Service) Remove(containerID string) error

type Store

+ func NewStore() *Store

+ func (s *Store) Add(container *Container, config *Config) error

+ func (s *Store) Get(domain string) (*Domain, error)

+ func (s *Store) Remove(container *Container) error

+ type Target struct

+ Config *Config

+ Container *Container

v0.0.4

Apr 11, 2021

Changes in this version

+ var DefaultDockerWatcherConfig = DockerWatcherConfig

+ var ErrNotFound = errors.New("not found")

+ var ErrPingerClosed = errors.New("pinger closed")

+ var ErrWatcherClosed = errors.New("watcher closed")

+ type AcmeServer struct

+ func NewAcmeServer(policyManager PolicyManager, certPath string) *AcmeServer

+ func (s *AcmeServer) Start(handler http.Handler) error

+ type BasePinger struct

+ func NewBasePinger(watcher Watcher) *BasePinger

+ func (p *BasePinger) Service() (*Service, error)

+ type BaseRouter struct

+ func NewBaseRouter(store Store) *BaseRouter

+ func (br *BaseRouter) HostPolicy(ctx context.Context, host string) error

+ func (br *BaseRouter) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (r *BaseRouter) AddProcessor(name string, builder func(config json.RawMessage) (Processor, error)) *BaseRouter

+ type BaseStore struct

+ func NewBaseStore(pinger Pinger) *BaseStore

+ func (br *BaseStore) Query(domain, path string) *Service

+ type Container struct

+ Active bool

+ ConfigPath string

+ Err error

+ ID string

+ RemoteAddr net.Addr

+ Type ContainerType

+ func (c Container) String() string

+ type ContainerType string

+ const DockerContainer

+ type DockerWatcher struct

+ func NewDockerWatcher(config DockerWatcherConfig) *DockerWatcher

+ func (d *DockerWatcher) Container() (*Container, error)

+ func (d *DockerWatcher) Start() error

+ type DockerWatcherConfig struct

+ Client *http.Client

+ Host string

+ Size int

+ type Domains struct

+ func NewDomains() *Domains

+ func (d *Domains) Add(service *Service)

+ func (d *Domains) Get(domain, path string) *Service

+ func (d *Domains) Remove(service *Service)

+ type Endpoints struct

+ func NewEndpoints() *Endpoints

+ func (e *Endpoints) Add(service *Service)

+ func (s *Endpoints) Get() *Service

+ func (s *Endpoints) Remove(service *Service)

+ type Paths struct

+ func NewPaths() *Paths

+ func (p *Paths) Add(service *Service)

+ func (p *Paths) Get(path string) *Endpoints

+ func (p *Paths) Remove(service *Service)

+ type Pinger interface

+ Service func() (*Service, error)

+ type PolicyManager interface

+ HostPolicy func(ctx context.Context, host string) error

+ type Processor interface

+ HandleError func(rw http.ResponseWriter, r *http.Request, err error)

+ Request func(r *http.Request)

+ Response func(r *http.Response) error

+ func CreateProcessorPathAppend(raw json.RawMessage) (Processor, error)

+ func CreateProcessorPathReplace(raw json.RawMessage) (Processor, error)

+ type ProcessorPathAppend struct

+ Begin string

+ End string

+ func (p *ProcessorPathAppend) HandleError(w http.ResponseWriter, r *http.Request, err error)

+ func (p *ProcessorPathAppend) Request(r *http.Request)

+ func (p *ProcessorPathAppend) Response(r *http.Response) error

+ type ProcessorPathReplace struct

+ Replace string

+ Search string

+ Times int

+ func (p *ProcessorPathReplace) HandleError(w http.ResponseWriter, r *http.Request, err error)

+ func (p *ProcessorPathReplace) Request(r *http.Request)

+ func (p *ProcessorPathReplace) Response(r *http.Response) error

+ type Recipe struct

+ Config json.RawMessage

+ Name string

+ type Rule struct

+ Domain string

+ Path string

+ Ready bool

+ Recipes []*Recipe

+ func (r Rule) String() string

+ type Rules []*Rule

+ func (r Rules) Each(fn func(r *Rule))

+ type Service struct

+ Container *Container

+ Rule *Rule

+ func (s Service) String() string

+ type Services struct

+ func NewServices() *Services

+ func (s *Services) Add(service *Service)

+ func (s *Services) Clean()

+ func (s *Services) Each(fn func(service *Service, i int))

+ type Store interface

+ Query func(domain, path string) *Service

+ type Watcher interface

+ Container func() (*Container, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL