diff options
Diffstat (limited to 'plugin/trace/setup.go')
| -rw-r--r-- | plugin/trace/setup.go | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/plugin/trace/setup.go b/plugin/trace/setup.go index abe5db0f7..8672dcc53 100644 --- a/plugin/trace/setup.go +++ b/plugin/trace/setup.go @@ -4,6 +4,7 @@ import ( "fmt" "strconv" "strings" + "time" "github.com/coredns/caddy" "github.com/coredns/coredns/core/dnsserver" @@ -100,6 +101,33 @@ func traceParse(c *caddy.Controller) (*trace, error) { if tr.datadogAnalyticsRate > 1 || tr.datadogAnalyticsRate < 0 { return nil, fmt.Errorf("datadog analytics rate must be between 0 and 1, '%f' is not supported", tr.datadogAnalyticsRate) } + case "zipkin_max_backlog_size": + args := c.RemainingArgs() + if len(args) != 1 { + return nil, c.ArgErr() + } + tr.zipkinMaxBacklogSize, err = strconv.Atoi(args[0]) + if err != nil { + return nil, err + } + case "zipkin_max_batch_size": + args := c.RemainingArgs() + if len(args) != 1 { + return nil, c.ArgErr() + } + tr.zipkinMaxBatchSize, err = strconv.Atoi(args[0]) + if err != nil { + return nil, err + } + case "zipkin_max_batch_interval": + args := c.RemainingArgs() + if len(args) != 1 { + return nil, c.ArgErr() + } + tr.zipkinMaxBatchInterval, err = time.ParseDuration(args[0]) + if err != nil { + return nil, err + } } } } |