api

package
v1.8.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 2, 2025 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source 
const CacheGetPath = "/{any:*}"

CacheGetPath for getting pagedata from cache via HTTP.

View Source 
const PrometheusMetricsPath = "/metrics"

Variables

This section is empty.

Functions

This section is empty.

Types

type AdmissionController added in v1.8.1 

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

func NewAdmissionController added in v1.8.1 

func NewAdmissionController(cfg config.Config) *AdmissionController

func (*AdmissionController) AddRoute added in v1.8.1 

func (c *AdmissionController) AddRoute(r *router.Router)

func (*AdmissionController) Get added in v1.8.1 

func (c *AdmissionController) Get(ctx *fasthttp.RequestCtx)

func (*AdmissionController) Off added in v1.8.1 

func (c *AdmissionController) Off(ctx *fasthttp.RequestCtx)

func (*AdmissionController) On added in v1.8.1 

func (c *AdmissionController) On(ctx *fasthttp.RequestCtx)

type CacheProxyController 

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

CacheProxyController handles cache API requests (read/write-through, error reporting, metrics).

func NewCacheProxyController 

func NewCacheProxyController(
	ctx context.Context,
	cfg config.Config,
	cache storage.Storage,
	backend upstream.Upstream,
) *CacheProxyController

NewCacheProxyController builds a cache API controller with all dependencies. If debug is enabled, launches internal stats logger goroutine.

func (*CacheProxyController) AddRoute 

func (c *CacheProxyController) AddRoute(router *router.Router)

AddRoute attaches controller's route(s) to the provided router.

func (*CacheProxyController) Index 

func (c *CacheProxyController) Index(rCtx *fasthttp.RequestCtx)

Index is the main HTTP handler.

type ChangeBackendPolicyController 

type ChangeBackendPolicyController struct {
}

func NewChangeBackendPolicyController 

func NewChangeBackendPolicyController() *ChangeBackendPolicyController

func (*ChangeBackendPolicyController) AddRoute 

func (c *ChangeBackendPolicyController) AddRoute(r *router.Router)

func (*ChangeBackendPolicyController) ShowPolicy added in v1.7.0 

func (c *ChangeBackendPolicyController) ShowPolicy(ctx *fasthttp.RequestCtx)

func (*ChangeBackendPolicyController) TurnOnAwaitPolicy 

func (c *ChangeBackendPolicyController) TurnOnAwaitPolicy(ctx *fasthttp.RequestCtx)

func (*ChangeBackendPolicyController) TurnOnDenyPolicy 

func (c *ChangeBackendPolicyController) TurnOnDenyPolicy(ctx *fasthttp.RequestCtx)

type ClearController 

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

func NewClearController 

func NewClearController(cfg config.Config, db storage.Storage) *ClearController

func (*ClearController) AddRoute 

func (c *ClearController) AddRoute(r *router.Router)

func (*ClearController) HandleClear 

func (c *ClearController) HandleClear(ctx *fasthttp.RequestCtx)

HandleClear is mounted at GET /cache/clear. Without ?token, returns a valid token (5min TTL). With ?token, validates, clears storage, logs, and returns status.

type ClearOneController 

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

func NewMarkOutdatedController 

func NewMarkOutdatedController(cfg config.Config, db storage.Storage) *ClearOneController

func (*ClearOneController) AddRoute 

func (c *ClearOneController) AddRoute(r *router.Router)

func (*ClearOneController) Invalidate added in v1.7.0 

func (c *ClearOneController) Invalidate(ctx *fasthttp.RequestCtx)

type EvictionController added in v1.8.1 

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

func NewEvictionController added in v1.8.1 

func NewEvictionController(orchestrator orchestrator.Governor) *EvictionController

func (*EvictionController) AddRoute added in v1.8.1 

func (c *EvictionController) AddRoute(r *router.Router)

func (*EvictionController) Get added in v1.8.1 

func (c *EvictionController) Get(ctx *fasthttp.RequestCtx)

func (*EvictionController) Off added in v1.8.1 

func (c *EvictionController) Off(ctx *fasthttp.RequestCtx)

func (*EvictionController) On added in v1.8.1 

func (c *EvictionController) On(ctx *fasthttp.RequestCtx)

func (*EvictionController) Scale added in v1.8.1 

func (c *EvictionController) Scale(ctx *fasthttp.RequestCtx)

type GcController added in v1.8.1 

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

func NewGcController added in v1.8.1 

func NewGcController(orchestrator orchestrator.Governor) *GcController

func (*GcController) AddRoute added in v1.8.1 

func (c *GcController) AddRoute(r *router.Router)

func (*GcController) Call added in v1.8.1 

func (c *GcController) Call(ctx *fasthttp.RequestCtx)

func (*GcController) Get added in v1.8.1 

func (c *GcController) Get(ctx *fasthttp.RequestCtx)

func (*GcController) Off added in v1.8.1 

func (c *GcController) Off(ctx *fasthttp.RequestCtx)

func (*GcController) On added in v1.8.1 

func (c *GcController) On(ctx *fasthttp.RequestCtx)

type GetController added in v1.8.0 

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

func NewGetController added in v1.8.0 

func NewGetController(db storage.Storage) *GetController

func (*GetController) AddRoute added in v1.8.0 

func (c *GetController) AddRoute(r *router.Router)

func (*GetController) Get added in v1.8.0 

func (c *GetController) Get(ctx *fasthttp.RequestCtx)

type HttpCompressionController 

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

func NewHttpCompressionController 

func NewHttpCompressionController() *HttpCompressionController

func (*HttpCompressionController) AddRoute 

func (c *HttpCompressionController) AddRoute(r *router.Router)

func (*HttpCompressionController) Get 

func (c *HttpCompressionController) Get(ctx *fasthttp.RequestCtx)

func (*HttpCompressionController) Off 

func (c *HttpCompressionController) Off(ctx *fasthttp.RequestCtx)

func (*HttpCompressionController) On 

func (c *HttpCompressionController) On(ctx *fasthttp.RequestCtx)

type LifetimeManagerController added in v1.8.1 

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

func NewLifetimeManagerController added in v1.8.1 

func NewLifetimeManagerController(cfg config.Config, orchestrator orchestrator.Governor) *LifetimeManagerController

func (*LifetimeManagerController) AddRoute added in v1.8.1 

func (c *LifetimeManagerController) AddRoute(r *router.Router)

func (*LifetimeManagerController) Get added in v1.8.1 

func (c *LifetimeManagerController) Get(ctx *fasthttp.RequestCtx)

func (*LifetimeManagerController) Off added in v1.8.1 

func (c *LifetimeManagerController) Off(ctx *fasthttp.RequestCtx)

func (*LifetimeManagerController) On added in v1.8.1 

func (c *LifetimeManagerController) On(ctx *fasthttp.RequestCtx)

func (*LifetimeManagerController) Policy added in v1.8.1 

func (c *LifetimeManagerController) Policy(ctx *fasthttp.RequestCtx)

func (*LifetimeManagerController) Rate added in v1.8.2 

func (c *LifetimeManagerController) Rate(ctx *fasthttp.RequestCtx)

func (*LifetimeManagerController) Scale added in v1.8.1 

func (c *LifetimeManagerController) Scale(ctx *fasthttp.RequestCtx)

func (*LifetimeManagerController) ToRefreshPolicy added in v1.8.1 

func (c *LifetimeManagerController) ToRefreshPolicy(ctx *fasthttp.RequestCtx)

func (*LifetimeManagerController) ToRemovePolicy added in v1.8.1 

func (c *LifetimeManagerController) ToRemovePolicy(ctx *fasthttp.RequestCtx)

type LivenessProbeController added in v1.8.1 

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

func NewLivenessProbeController added in v1.8.1 

func NewLivenessProbeController(probe liveness.Prober) *LivenessProbeController

func (*LivenessProbeController) AddRoute added in v1.8.1 

func (c *LivenessProbeController) AddRoute(router *router.Router)

func (*LivenessProbeController) Probe added in v1.8.1 

func (c *LivenessProbeController) Probe(ctx *fasthttp.RequestCtx)

type ObservabilityController added in v1.8.1 

type ObservabilityController struct {
}

func NewObservabilityController added in v1.8.1 

func NewObservabilityController() *ObservabilityController

func (*ObservabilityController) AddRoute added in v1.8.1 

func (c *ObservabilityController) AddRoute(r *router.Router)

func (*ObservabilityController) Get added in v1.8.1 

func (c *ObservabilityController) Get(ctx *fasthttp.RequestCtx)

func (*ObservabilityController) Off added in v1.8.1 

func (c *ObservabilityController) Off(ctx *fasthttp.RequestCtx)

func (*ObservabilityController) On added in v1.8.1 

func (c *ObservabilityController) On(ctx *fasthttp.RequestCtx)

type OnOffController 

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

OnOffController provides endpoints to switch the advanced cache on and off.

func NewOnOffController 

func NewOnOffController(cfg config.Config) *OnOffController

NewOnOffController creates a new OnOffController instance.

func (*OnOffController) AddRoute 

func (c *OnOffController) AddRoute(r *router.Router)

AddRoute attaches the on/off routes to the given router.

func (*OnOffController) BypassIs added in v1.7.0 

func (c *OnOffController) BypassIs(ctx *fasthttp.RequestCtx)

func (*OnOffController) Off 

func (c *OnOffController) Off(ctx *fasthttp.RequestCtx)

Off handles POST /adv-cache/off and disables the advanced cache, returning JSON.

func (*OnOffController) On 

func (c *OnOffController) On(ctx *fasthttp.RequestCtx)

On handles POST /adv-cache/on and enables the advanced cache, returning JSON.

type PrometheusMetricsController added in v1.8.1 

type PrometheusMetricsController struct{}

func NewPrometheusMetricsController added in v1.8.1 

func NewPrometheusMetricsController() *PrometheusMetricsController

func (*PrometheusMetricsController) AddRoute added in v1.8.1 

func (m *PrometheusMetricsController) AddRoute(router *router.Router)

func (*PrometheusMetricsController) Get added in v1.8.1 

func (m *PrometheusMetricsController) Get(ctx *fasthttp.RequestCtx)

type ShowConfigController added in v1.7.0 

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

func NewShowConfigController added in v1.7.0 

func NewShowConfigController(cfg config.Config) *ShowConfigController

func (*ShowConfigController) AddRoute added in v1.7.0 

func (c *ShowConfigController) AddRoute(r *router.Router)

func (*ShowConfigController) ShowConfig added in v1.7.0 

func (c *ShowConfigController) ShowConfig(ctx *fasthttp.RequestCtx)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.