aboutsummaryrefslogtreecommitdiff
path: root/middleware/erratic/setup.go
diff options
context:
space:
mode:
Diffstat (limited to 'middleware/erratic/setup.go')
-rw-r--r--middleware/erratic/setup.go59
1 files changed, 59 insertions, 0 deletions
diff --git a/middleware/erratic/setup.go b/middleware/erratic/setup.go
new file mode 100644
index 000000000..207db317b
--- /dev/null
+++ b/middleware/erratic/setup.go
@@ -0,0 +1,59 @@
+package erratic
+
+import (
+ "fmt"
+ "strconv"
+
+ "github.com/miekg/coredns/core/dnsserver"
+ "github.com/miekg/coredns/middleware"
+
+ "github.com/mholt/caddy"
+)
+
+func init() {
+ caddy.RegisterPlugin("erratic", caddy.Plugin{
+ ServerType: "dns",
+ Action: setupErratic,
+ })
+}
+
+func setupErratic(c *caddy.Controller) error {
+ e, err := parseErratic(c)
+ if err != nil {
+ return middleware.Error("erratic", err)
+ }
+
+ dnsserver.GetConfig(c).AddMiddleware(func(next middleware.Handler) middleware.Handler {
+ return e
+ })
+
+ return nil
+}
+
+func parseErratic(c *caddy.Controller) (*Erratic, error) {
+ e := &Erratic{amount: 2}
+ for c.Next() { // 'erratic'
+ for c.NextBlock() {
+ switch c.Val() {
+ case "drop":
+ args := c.RemainingArgs()
+ if len(args) > 1 {
+ return nil, c.ArgErr()
+ }
+
+ if len(args) == 0 {
+ return nil, nil
+ }
+ amount, err := strconv.ParseInt(args[0], 10, 32)
+ if err != nil {
+ return nil, err
+ }
+ if amount < 0 {
+ return nil, fmt.Errorf("illegal amount value given %q", args[0])
+ }
+ e.amount = uint64(amount)
+ }
+ }
+ }
+ return e, nil
+}