baker

Aug 26, 2024

Changes in this version

type Container

+ Meta Meta

+ type Meta struct

+ Static struct{ ... }

Aug 22, 2024

Changes in this version

type Event

+ Meta *MetaData

+ type MetaData struct

+ StaticDomain string

+ StaticPath string

Jul 14, 2024

Changes in this version

+ func NewEntryList() *entryList

Jul 13, 2024

Changes in this version

+ func WithAddCallback(callback func(*Container)) func(*ActionRunner)

+ func WithBufferSize(size int) serverOptFunc

+ func WithGetCallback(callback func(string, string) (*Container, *Endpoint)) func(*ActionRunner)

+ func WithPingDuration(d time.Duration) serverOptFunc

+ func WithPingerCallback(callback func()) func(*ActionRunner)

+ func WithRemoveCallback(callback func(*Container)) func(*ActionRunner)

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

+ func WithUpdateCallback(callback func(*Container, *Endpoint)) func(*ActionRunner)

+ type ActionCallback func(*ActionRunner)

+ type ActionRunner struct

+ func NewActionRunner(bufferSize int, cbs ...ActionCallback) *ActionRunner

+ func (ar *ActionRunner) Add(container *Container)

+ func (ar *ActionRunner) Close()

+ func (ar *ActionRunner) Get(ctx context.Context, endpoint *Endpoint) (*Container, *Endpoint)

+ func (ar *ActionRunner) Pinger()

+ func (ar *ActionRunner) Remove(container *Container)

+ func (ar *ActionRunner) Update(container *Container, endpoint *Endpoint)

+ type Config struct

+ Endpoints []Endpoint

+ type Container struct

+ Addr netip.AddrPort

+ ConfigPath string

+ Id string

+ type Driver interface

+ Add func(*Container)

+ Remove func(*Container)

+ type Endpoint struct

+ Domain string

+ Path string

+ Rules []Rule

+ type Event struct

+ Container *Container

+ Endpoint *Endpoint

+ Result ...

+ Type EventType

+ type EventType int

+ type Rule struct

+ Args json.RawMessage

+ Type string

+ type Server struct

+ func NewServer(opts ...serverOpt) *Server

+ func (s *Server) Close()

+ func (s *Server) RegisterDriver(fn func(Driver))

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

+ type Service struct

+ Containers []*Container

+ Endpoint *Endpoint