baker

package module

v0.0.1-b1 Latest Latest Go to latest Published: May 15, 2024 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

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

func WithBufferSize(size int) serverOptFunc

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

func WithPingDuration(d time.Duration) serverOptFunc

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

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

func WithUpdateCallback(callback func(*Container, string, string)) func(*ActionRunner)

type ActionCallback func(*ActionRunner)

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

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

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

func (ar *ActionRunner) Close()

func (ar *ActionRunner) Get(ctx context.Context, domain, path string) *Container

func (ar *ActionRunner) Pinger()

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

func (ar *ActionRunner) Update(container *Container, domain string, path string)

type Config struct {
	Endpoints []Endpoint `json:"endpoints"`
}

type Container struct {
	Id         string
	ConfigPath string
	Addr       netip.AddrPort
}

type Driver interface {
	Add(*Container)
	Remove(*Container)
}

type Endpoint struct {
	Domain string `json:"domain"`
	Path   string `json:"path"`
}

type Event struct {
	Type      EventType
	Container *Container
	Domain    string
	Path      string
	Result    chan *Container
}

type EventType int

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

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)