(h httpcaddyfile.Helper)
| 36 | } |
| 37 | |
| 38 | func parseRequestHandler(h httpcaddyfile.Helper) (caddyhttp.MiddlewareHandler, error) { |
| 39 | var p = Publish{ |
| 40 | WithReply: true, |
| 41 | Timeout: publishDefaultTimeout, |
| 42 | } |
| 43 | err := p.UnmarshalCaddyfile(h.Dispenser) |
| 44 | return p, err |
| 45 | } |
| 46 | |
| 47 | func parseSubscribeHandler(d *caddyfile.Dispenser) (Subscribe, error) { |
| 48 | s := Subscribe{} |
nothing calls this directly
no test coverage detected