upstream

type Backend ¶

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

func NewBackend(ctx context.Context, cfg *config.Backend, traceCfg *config.Observability) *Backend

func (b *Backend) IsHealthy() error

func (b *Backend) ProxyRequest(ctx *fasthttp.RequestCtx, traceCtx context.Context) (*fasthttp.Response, Releaser, error)

func (b *Backend) Refresh(entry *model.Entry) error

func (b *Backend) Request(nilableCtx *fasthttp.RequestCtx, rule *config.Rule, queries, headers [][2][]byte, traceCtx context.Context,
) (*fasthttp.Response, Releaser, error)

func (b *Backend) SetHealth(up bool)

type Policy ¶ added in v1.6.0

type Policy string

const (
	Deny  Policy = "deny"
	Await Policy = "await"
)

func ActualPolicy() Policy

func (p Policy) Uint64() uint64

type Releaser ¶ added in v1.6.0

type Releaser func(*fasthttp.Response)

type RequestReleaser ¶ added in v1.6.0

type RequestReleaser func(request *fasthttp.Request)

type Upstream ¶

type Upstream interface {
	Request(nilableCtx *fasthttp.RequestCtx, rule *config.Rule, queries, headers [][2][]byte, traceCtx context.Context) (*fasthttp.Response, Releaser, error)
	ProxyRequest(ctx *fasthttp.RequestCtx, traceCtx context.Context) (*fasthttp.Response, Releaser, error)
	Refresh(entry *model.Entry) error
	IsHealthy() error
}

Upstream defines the interface for external backends. Note: you need provide just one argument of inCtx or inReq.