httpsrv

README

HTTP Server

The package core/workers/httpsrv provides a default set of configuration for hosting a http server in a service.

Configuration

The HTTP server can be configured through these environment variables:

• HTTP_ADDR the HTTP server listener's network address (default: 0.0.0.0:80)

Examples

Starting default server and expose the service

srv := httpsrv.NewDefault(handler)
srv.Run(ctx, os.Stdout)

Starting server with a custom http server

srv := httpsrv.New(&http.Server{
    Handler: Handler,
    ReadTimeout: 1 * time.Second,
})
srv.Run(ctx)

Documentation

Overview

Package httpsrv provides a default set of configuration for hosting a http server in a service.

Example

package main

import (
	"context"
	"net/http"
	"time"

	"github.com/LUSHDigital/core/workers/httpsrv"
)

var (
	handler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		w.WriteHeader(200)
		return
	})
	ctx context.Context
)

func main() {
	go httpsrv.New(&http.Server{
		Handler:     handler,
		ReadTimeout: 1 * time.Second,
	}).Run(ctx)
}

Index

• Constants
• Variables
• func HealthHandler(now func() time.Time) http.HandlerFunc
• func WrapperHandler(now func() time.Time, next http.Handler) http.HandlerFunc
• type HealthResponse
• type Server
  • func New(server *http.Server) *Server
  • func NewDefault(handler http.Handler) *Server
  • func (gs *Server) Addr() *net.TCPAddr
  • func (gs *Server) Halt(ctx context.Context) error
  • func (gs *Server) Run(ctx context.Context) error

Examples

• Package

Constants

const (
	// Port is the default HTTP port.
	Port = 80
)

Variables

var (
	// NotFoundHandler responds with the default a 404 response.
	NotFoundHandler = http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) {
		res := &rest.Response{
			Code:    http.StatusNotFound,
			Message: http.StatusText(http.StatusNotFound),
		}
		res.WriteTo(w)
	})

	// DefaultHTTPServer represents the default configuration for the http server
	DefaultHTTPServer = http.Server{
		WriteTimeout:      5 * time.Second,
		ReadTimeout:       5 * time.Second,
		IdleTimeout:       5 * time.Second,
		ReadHeaderTimeout: 1 * time.Second,
	}
)

Functions

func HealthHandler

func HealthHandler(now func() time.Time) http.HandlerFunc

HealthHandler responds with service health.

func WrapperHandler

func WrapperHandler(now func() time.Time, next http.Handler) http.HandlerFunc

WrapperHandler returns the wrapper handler for the http server.

Types

type HealthResponse

type HealthResponse struct {
	Latency       string `json:"latency"`
	StackInUse    string `json:"stack_in_use"`
	HeapInUse     string `json:"heap_in_use"`
	HeapAlloc     string `json:"heap_alloc"`
	NumGoRoutines int    `json:"num_go_routines"`
}

HealthResponse contains information about the service health.

type Server

type Server struct {
	Server *http.Server
	Now    func() time.Time
	// contains filtered or unexported fields
}

Server represents a collection of functions for starting and running an RPC server.

func New

func New(server *http.Server) *Server

New sets up a new HTTP server.

func NewDefault

func NewDefault(handler http.Handler) *Server

NewDefault returns a http server

func (*Server) Addr

func (gs *Server) Addr() *net.TCPAddr

Addr will block until you have received an address for your server.

func (*Server) Halt

func (gs *Server) Halt(ctx context.Context) error

Halt will attempt to gracefully shut down the server.

func (*Server) Run

func (gs *Server) Run(ctx context.Context) error

Run will start the gRPC server and listen for requests.