Create a comment.
- Content-Type: "application/json"
- Accept: "application/json"
cfg := nsq.NewConfig() | |
producer, err := nsq.NewProducer("127.0.0.1:4161", cfg) | |
if err != nil { | |
fatal(err) | |
} | |
producer.Publish("topic", []byte("Test")) | |
producer.Stop() |
{ | |
"snippets": [ | |
{ | |
"match": {"global": true, "pkgname": ".", "fn": ".*_test.go"}, | |
"snippets": [ | |
{"text": "func Test", "title": "", "value": "func Test${1:ObjectName}${2:TestName}(t *testing.T) {\n\t$0\n}"}, | |
{"text": "func Benchmark", "title": "", "value": "func Benchmark${1:ObjectName}${2:BenchmarkName}(b *testing.B) {\n\n\tb.StopTimer()\n\n\t$0\n\n\tb.StartTimer()\n\n\tfor i := 0; i < b.N; i++ {\n\t\t\n\t}\n\n}"}, | |
{"text": "func Example", "title": "", "value": "func Example${1:ObjectName}${2:ExampleName}() {\n\n\t$0\n\n\t// Output:\n\t// \n\n}"} | |
] | |
}, |
package main | |
import ( | |
"fmt" | |
) | |
/* | |
Question: | |
What will be printed by this program? |
// pathParams parses the URL.Path of the Request with the given | |
// pattern, and extracts the value for each segment into a map. | |
func pathParams(r *http.Request, pattern string) map[string]string { | |
params := map[string]string{} | |
pathSegs := strings.Split(strings.Trim(r.URL.Path, "/"), "/") | |
for i, seg := range strings.Split(strings.Trim(pattern, "/"), "/") { | |
if i > len(pathSegs)-1 { | |
return params | |
} | |
params[seg] = pathSegs[i] |
func TestPathParams(t *testing.T) { | |
r, err := http.NewRequest("GET", "1/2/3/4/5", nil) | |
if err != nil { | |
t.Errorf("NewRequest: %s", err) | |
} | |
params := pathParams(r, "one/two/three/four") | |
if len(params) != 4 { | |
t.Errorf("expected 4 params but got %d: %v", len(params), params) | |
} | |
for k, v := range map[string]string{ |
### Keybase proof | |
I hereby claim: | |
* I am matryer on github. | |
* I am matryer (https://keybase.io/matryer) on keybase. | |
* I have a public key ASCC8YrsmU_t9rWCOgUqUGE0Zv9wb519A25FyiDH7xMXfAo | |
To claim this, I am signing this object: |
package main | |
import ( | |
"encoding/json" | |
"log" | |
"os" | |
"os/exec" | |
) | |
type result struct { |
func main() { | |
ctx := context.Background() | |
// trap Ctrl+C and call cancel on the context | |
ctx, cancel := context.WithCancel(ctx) | |
c := make(chan os.Signal, 1) | |
signal.Notify(c, os.Interrupt) | |
defer func() { | |
signal.Stop(c) |
package sending | |
// AUTOGENERATED BY MOQ - DO NOT EDIT | |
// github.com/matryer/moq | |
import ( | |
"sync" | |
) | |
var ( |