diff options
author | Aliaksandr Valialkin <valyala@gmail.com> | 2015-12-21 11:32:27 +0200 |
---|---|---|
committer | Aliaksandr Valialkin <valyala@gmail.com> | 2015-12-21 11:32:27 +0200 |
commit | 6a8707cd8d9b2fe3f0544fad69e1ac4428398874 (patch) | |
tree | 1a9f2955b4a1012819aa2427892eb68e96e2bdf2 /server_example_test.go | |
parent | Added an example for HostClient (diff) | |
download | fasthttp-6a8707cd8d9b2fe3f0544fad69e1ac4428398874.tar.gz fasthttp-6a8707cd8d9b2fe3f0544fad69e1ac4428398874.tar.bz2 fasthttp-6a8707cd8d9b2fe3f0544fad69e1ac4428398874.zip |
Import fasthttp in server examples
Diffstat (limited to 'server_example_test.go')
-rw-r--r-- | server_example_test.go | 30 |
1 files changed, 16 insertions, 14 deletions
diff --git a/server_example_test.go b/server_example_test.go index bd51e9e..68321fb 100644 --- a/server_example_test.go +++ b/server_example_test.go @@ -1,4 +1,4 @@ -package fasthttp +package fasthttp_test import ( "fmt" @@ -6,6 +6,8 @@ import ( "math/rand" "net" "time" + + "github.com/valyala/fasthttp" ) func ExampleListenAndServe() { @@ -16,7 +18,7 @@ func ExampleListenAndServe() { // // RequestCtx provides a lot of functionality related to http request // processing. See RequestCtx docs for details. - requestHandler := func(ctx *RequestCtx) { + requestHandler := func(ctx *fasthttp.RequestCtx) { fmt.Fprintf(ctx, "Hello, world! Requested path is %q", ctx.Path()) } @@ -24,7 +26,7 @@ func ExampleListenAndServe() { // Create Server instance for adjusting server settings. // // ListenAndServe returns only on error, so usually it blocks forever. - if err := ListenAndServe(listenAddr, requestHandler); err != nil { + if err := fasthttp.ListenAndServe(listenAddr, requestHandler); err != nil { log.Fatalf("error in ListenAndServe: %s", err) } } @@ -44,7 +46,7 @@ func ExampleServe() { // // RequestCtx provides a lot of functionality related to http request // processing. See RequestCtx docs for details. - requestHandler := func(ctx *RequestCtx) { + requestHandler := func(ctx *fasthttp.RequestCtx) { fmt.Fprintf(ctx, "Hello, world! Requested path is %q", ctx.Path()) } @@ -52,7 +54,7 @@ func ExampleServe() { // Create Server instance for adjusting server settings. // // Serve returns on ln.Close() or error, so usually it blocks forever. - if err := Serve(ln, requestHandler); err != nil { + if err := fasthttp.Serve(ln, requestHandler); err != nil { log.Fatalf("error in Serve: %s", err) } } @@ -62,12 +64,12 @@ func ExampleServer() { // // RequestCtx provides a lot of functionality related to http request // processing. See RequestCtx docs for details. - requestHandler := func(ctx *RequestCtx) { + requestHandler := func(ctx *fasthttp.RequestCtx) { fmt.Fprintf(ctx, "Hello, world! Requested path is %q", ctx.Path()) } // Create custom server. - s := &Server{ + s := &fasthttp.Server{ Handler: requestHandler, // Every response will contain 'Server: My super server' header. @@ -100,7 +102,7 @@ func ExampleRequestCtx_Hijack() { } // requestHandler is called for each incoming request. - requestHandler := func(ctx *RequestCtx) { + requestHandler := func(ctx *fasthttp.RequestCtx) { path := ctx.Path() switch { case string(path) == "/hijack": @@ -117,13 +119,13 @@ func ExampleRequestCtx_Hijack() { } } - if err := ListenAndServe(":80", requestHandler); err != nil { + if err := fasthttp.ListenAndServe(":80", requestHandler); err != nil { log.Fatalf("error in ListenAndServe: %s", err) } } func ExampleRequestCtx_TimeoutError() { - requestHandler := func(ctx *RequestCtx) { + requestHandler := func(ctx *fasthttp.RequestCtx) { // Emulate long-running task, which touches ctx. doneCh := make(chan struct{}) go func() { @@ -148,16 +150,16 @@ func ExampleRequestCtx_TimeoutError() { } } - if err := ListenAndServe(":80", requestHandler); err != nil { + if err := fasthttp.ListenAndServe(":80", requestHandler); err != nil { log.Fatalf("error in ListenAndServe: %s", err) } } func ExampleRequestCtx_Logger() { - requestHandler := func(ctx *RequestCtx) { + requestHandler := func(ctx *fasthttp.RequestCtx) { if string(ctx.Path()) == "/top-secret" { ctx.Logger().Printf("Alarm! Alien intrusion detected!") - ctx.Error("Access denied!", StatusForbidden) + ctx.Error("Access denied!", fasthttp.StatusForbidden) return } @@ -169,7 +171,7 @@ func ExampleRequestCtx_Logger() { logger.Printf("Multiple log messages may be written during a single request") } - if err := ListenAndServe(":80", requestHandler); err != nil { + if err := fasthttp.ListenAndServe(":80", requestHandler); err != nil { log.Fatalf("error in ListenAndServe: %s", err) } } |