penalize directive

lib/gat/gatcaddyfile/critic.go

+package gatcaddyfile
+
+import (
+	"github.com/caddyserver/caddy/v2"
+	"github.com/caddyserver/caddy/v2/caddyconfig"
+	"github.com/caddyserver/caddy/v2/caddyconfig/caddyfile"
+
+	"gfx.cafe/gfx/pggat/lib/gat/handlers/pool/critics/latency"
+)
+
+func init() {
+	RegisterDirective(Critic, "latency", func(d *caddyfile.Dispenser, warnings *[]caddyconfig.Warning) (caddy.Module, error) {
+		if !d.NextArg() {
+			return nil, d.ArgErr()
+		}
+		threshold, err := caddy.ParseDuration(d.Val())
+		if err != nil {
+			return nil, d.WrapErr(err)
+		}
+
+		return &latency.Critic{
+			Threshold: caddy.Duration(threshold),
+		}, nil
+	})
+}

lib/gat/gatcaddyfile/pool.go

@@ -146,6 +146,22 @@ func init() {
 					}
 
 					module.TrackedParameters = append(module.TrackedParameters, strutil.MakeCIString(d.Val()))
+				case "penalize":
+					if !d.NextArg() {
+						return nil, d.ArgErr()
+					}
+
+					critic, err := UnmarshalDirectiveJSONModuleObject(
+						d,
+						Critic,
+						"critic",
+						warnings,
+					)
+					if err != nil {
+						return nil, err
+					}
+
+					module.RawCritics = append(module.RawCritics, critic)
 				default:
 					return nil, d.ArgErr()
 				}
@@ -221,6 +237,22 @@ func init() {
 					}
 
 					module.TrackedParameters = append(module.TrackedParameters, strutil.MakeCIString(d.Val()))
+				case "penalize":
+					if !d.NextArg() {
+						return nil, d.ArgErr()
+					}
+
+					critic, err := UnmarshalDirectiveJSONModuleObject(
+						d,
+						Critic,
+						"critic",
+						warnings,
+					)
+					if err != nil {
+						return nil, err
+					}
+
+					module.RawCritics = append(module.RawCritics, critic)
 				default:
 					return nil, d.ArgErr()
 				}

lib/gat/gatcaddyfile/unmarshallers.go

@@ -17,6 +17,7 @@ const (
 	Matcher            = "pggat.matchers"
 	Pool               = "pggat.handlers.pool.pools"
 	Pooler             = "pggat.handlers.pool.poolers"
+	Critic             = "pggat.handlers.pool.critics"
 	SSLServer          = "pggat.ssl.servers"
 	SSLClient          = "pggat.ssl.clients"
 )