Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/codegangsta/caddy-nats
/ functions
Functions
38 in github.com/codegangsta/caddy-nats
⨍
Functions
38
◇
Types & classes
6
↓ 15 callers
Function
reqPath
Returns a basic request for testing
replacer_test.go:14
↓ 4 callers
Method
CaddyModule
CaddyModule returns the Caddy module information.
app.go:35
↓ 3 callers
Method
UnmarshalCaddyfile
(d *caddyfile.Dispenser)
caddyfile.go:67
↓ 2 callers
Method
ServeHTTP
(w http.ResponseWriter, r *http.Request, next caddyhttp.Handler)
publish.go:51
↓ 2 callers
Method
WriteHeader
(statusCode int)
noop_response_writer.go:13
↓ 2 callers
Function
addNATSPublishVarsToReplacer
(repl *caddy.Replacer, req *http.Request)
replacer.go:13
↓ 2 callers
Function
addNatsSubscribeVarsToReplacer
(repl *caddy.Replacer, msg *nats.Msg)
replacer.go:41
↓ 2 callers
Function
minMax
(i int, min int, max int)
replacer.go:112
↓ 2 callers
Function
parseQueueSubscribeHandler
(d *caddyfile.Dispenser)
caddyfile.go:57
↓ 2 callers
Function
parseSubscribeHandler
(d *caddyfile.Dispenser)
caddyfile.go:47
↓ 2 callers
Function
subSlice
subSlice returns a subslice of the given slice based off the string exp. expressions can be in the format of ":" "n", "n:", ":n", or "n:n", with n bei
replacer.go:70
↓ 1 callers
Method
Subscribe
(conn *nats.Conn)
handler.go:6
↓ 1 callers
Method
Unsubscribe
(conn *nats.Conn)
handler.go:7
↓ 1 callers
Method
Write
(p []byte)
noop_response_writer.go:9
↓ 1 callers
Method
matchServer
(servers map[string]*caddyhttp.Server, req *http.Request)
subscribe.go:124
↓ 1 callers
Method
natsRequestReply
(subject string, reqBody []byte, w http.ResponseWriter)
publish.go:79
↓ 1 callers
Method
prepareRequest
(method string, rawURL string, body io.Reader)
subscribe.go:138
Method
CaddyModule
()
publish.go:31
Method
CaddyModule
()
subscribe.go:35
Method
Header
()
noop_response_writer.go:17
Method
Provision
Provision sets up the app
app.go:43
Method
Provision
(ctx caddy.Context)
publish.go:38
Method
Provision
(ctx caddy.Context)
subscribe.go:42
Method
Start
()
app.go:63
Method
Stop
()
app.go:84
Method
Subscribe
(conn *nats.Conn)
subscribe.go:49
Function
TestAddNatsPublishVarsToReplacer
(t *testing.T)
replacer_test.go:19
Function
TestAddNatsSubscribeVarsToReplacer
(t *testing.T)
replacer_test.go:63
Method
UnmarshalCaddyfile
(d *caddyfile.Dispenser)
caddyfile.go:122
Method
Unsubscribe
(conn *nats.Conn)
subscribe.go:72
Method
handler
(msg *nats.Msg)
subscribe.go:85
Function
init
()
caddyfile.go:12
Function
init
()
app.go:14
Function
init
()
publish.go:18
Function
init
()
subscribe.go:31
Function
parseApp
(d *caddyfile.Dispenser, _ interface{})
caddyfile.go:18
Function
parsePublishHandler
(h httpcaddyfile.Helper)
caddyfile.go:29
Function
parseRequestHandler
(h httpcaddyfile.Helper)
caddyfile.go:38