Gehen die Fehlerbehandlung auf einer REST-API

Ich bin ganz neu gehen und bereitgestellt haben, eine kleine service mit einer API-endpoint.

Ich habe gehört/gelesen, die gehen nicht try/catch so versuche ich herauszufinden, wie ich kann "catch" Probleme geschieht aus meiner service-Aufruf aus meiner API und stellen Sie sicher, dass die Ressource server nicht down gehen.

Mein code für mein API sieht wie folgt aus..

Ich habe eine routes.go - Datei mit dem folgenden

package main

import (
    "net/http"

    "github.com/gorilla/mux"
)

type Route struct {
    Name        string
    Method      string
    Pattern     string
    HandlerFunc http.HandlerFunc
}

type Routes []Route

func NewRouter() *mux.Router {
    router := mux.NewRouter().StrictSlash(true)
    for _, route := range routes {
        router.
            Methods(route.Method).
            Path(route.Pattern).
            Name(route.Name).
            Handler(route.HandlerFunc)
    }

    return router
}

var routes = Routes{
    Route{
        "CustomerLocationCreate",
        "POST",
        "/tracking/customer",
        CustomerLocationCreate,
    },
}

Ich habe eine handlers.go

package main

import (
    "encoding/json"
    "net/http"
    "io"
    "io/ioutil"
)

//curl -H "Content-Type: application/json" -d '{"userId":"1234"}' http://localhost:8181/tracking/customer
func CustomerLocationCreate(w http.ResponseWriter, r *http.Request) {
    var location CustomerLocation
    body, err := ioutil.ReadAll(io.LimitReader(r.Body, 1048576))
    if err != nil {
        panic(err)
    }
    if err := r.Body.Close(); err != nil {
        panic(err)
    }
    if err := json.Unmarshal(body, &location); err != nil {
        w.Header().Set("Content-Type", "application/json; charset=UTF-8")
        w.WriteHeader(422) //unprocessable entity
        if err := json.NewEncoder(w).Encode(err); err != nil {
            panic(err)
        }
    }

    c := RepoCreateCustomerLocation(location)
    w.Header().Set("Content-Type", "application/json; charset=UTF-8")
    w.WriteHeader(http.StatusCreated)
    if err := json.NewEncoder(w).Encode(c); err != nil {
        panic(err)
    }

    HandleCustomerLocationChange(c);
}

und ich habe eine bus.go hat die HandleCustomerLocationChange(...) Funktion.

func HandleCustomerLocationChange(custLoc CustomerLocation) {

    endpoint := og.Getenv("RABBIT_ENDPOINT")
    conn, err := amqp.Dial("amqp://guest:guest@" + endpoint)
    failOnError(err, "Failed to connect to RabbitMQ")
    defer conn.Close()

    ch, err := conn.Channel()
    failOnError(err, "Failed to open a channel")
    defer ch.Close()

    topic := "locationChange"
    err = ch.ExchangeDeclare(
        topic,   //name
        "topic", //type
        true,    //durable
        false,   //auto-deleted
        false,   //internal
        false,   //no-wait
        nil,     //arguments
    )
    failOnError(err, "Failed to declare an exchange")

    //Create JSON from the instance data.
    body, _ := json.Marshal(custLoc)
    //Convert bytes to string.

    err = ch.Publish(
        topic, //exchange
        "",    //routing key
        false, //mandatory
        false, //immediate
        amqp.Publishing{
            ContentType: "text/plain",
            Body:        body,
        })
    failOnError(err, "Failed to publish a message")

    log.Printf(" [x] Sent %s", body)

}

Meine Frage ist wie sollte ich ändern, sowohl die HandleCustomerLocationChange(...) function and if necessaryCustomerLocationChange(..)` handler behandeln Fehler richtig so, dass wenn ein Fehler Auftritt, meine gesamte API nicht nach unten gehen?