transport

type ClockStatus struct {
	// Mode is "manual" when the clock is client-controlled, else "real".
	Mode string `json:"mode"`
	Now  string `json:"now"`
	// Pending is the number of timers still scheduled — scheduled tasks, ack
	// deadlines, TTLs — waiting for the clock to reach them. Virtual mode only.
	Pending int `json:"pending"`
}

type Config struct {
	Clock clock.Clock

	// Version is reported by /_emu/health. Empty means "dev".
	Version string

	// Runner describes the function runner.
	Runner RunnerInfo

	// Functions hosts deployed functions. Nil means none are served.
	Functions FunctionHost

	// Mounts are service handlers keyed by path prefix, tried before the
	// built-in mux. Services own their own routing, so the front door needs no
	// knowledge of their URL grammar.
	Mounts map[string]http.Handler

	// Fallback handles paths no route claimed. Cloud Storage needs it: the Go
	// client downloads from /{bucket}/{object}, which has no prefix to mount
	// on and is only distinguishable from anything else by asking.
	Fallback http.Handler

	// Reset clears emulator state. An empty project clears everything.
	Reset func(ctx context.Context, project string) error

	// GRPC handles requests on the gRPC branch. Nil answers them with 501.
	GRPC http.Handler

	// Faults fails requests on purpose. Nil fails nothing.
	Faults *faults.Set

	// Services hosts deployed Cloud Run services. Nil means none are served.
	Services ServiceHost

	// Drain waits for the asynchronous work a clock jump sets off (task and
	// scheduler deliveries, triggered function invocations). Called after a
	// virtual-clock advance/goto so the response follows the side effects. Nil
	// waits for nothing.
	Drain func()
}

type FaultRule struct {
	Method  string  `json:"method,omitempty"`
	Path    string  `json:"path"`
	Status  int     `json:"status,omitempty"`
	Message string  `json:"message,omitempty"`
	Latency string  `json:"latency,omitempty"`
	Count   int     `json:"count,omitempty"`
	Rate    float64 `json:"rate,omitempty"`
}

type FunctionHost interface {
	// Route resolves a request path to a function and the path it should see.
	Route(escapedPath string) (h http.Handler, rest string, ok bool)

	// Admin serves the deploy, list, describe and delete API.
	Admin() http.Handler
}

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

type HandlerFunc func(w http.ResponseWriter, r *http.Request, p Params) error

type Health struct {
	Status  string     `json:"status"`
	Version string     `json:"version"`
	Uptime  string     `json:"uptime"`
	Runner  RunnerInfo `json:"runner"`
}

type Params map[string]string

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

type RunnerInfo struct {
	Configured string `json:"configured"`
	Mode       string `json:"mode"`
}

type ServiceHost interface {
	Route(escapedPath string) (h http.Handler, rest string, ok bool)
}