Skip to content

Instantly share code, notes, and snippets.

@by-sabbir

by-sabbir/main.go

Created October 8, 2022 20:35
Show Gist options
  • Save by-sabbir/03be20d1e2cf4e2d3562b1eb43e5be2c to your computer and use it in GitHub Desktop.
Save by-sabbir/03be20d1e2cf4e2d3562b1eb43e5be2c to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. by-sabbir created this gist Oct 8, 2022.
    49 changes: 49 additions & 0 deletions main.go
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,49 @@
    package main

    import (
    "encoding/json"
    "fmt"
    "log"
    "net/http"

    consulApi "github.com/by-sabbir/consul-kv-discovery/pkg/consul"
    )

    var (
    CONSUL_ADDR = "consul:8500"
    SERVICE_ID = "go-service"
    SERVICE_NAME = "go-service-test"
    SERVICE_PORT = 8000
    SERVICE_HOST = "0.0.0.0"
    )

    func init() {
    cli, err := consulApi.NewClient(CONSUL_ADDR)
    if err != nil {
    log.Fatalf("can't initiate consul client: %+v\n", err)
    }
    if err := cli.Register(SERVICE_ID); err != nil {
    log.Println("error registering... ", err)
    }
    }

    func main() {
    if err := Run(); err != nil {
    log.Fatalf("error starting service: %+v\n", err)
    }
    }

    func Run() error {
    http.HandleFunc("/health", healthcheck)
    srvString := fmt.Sprintf("%s:%d", SERVICE_HOST, SERVICE_PORT)
    if err := http.ListenAndServe(srvString, nil); err != nil {
    return err
    }
    return nil
    }

    func healthcheck(w http.ResponseWriter, r *http.Request) {
    json.NewEncoder(w).Encode(map[string]string{
    "status": "ok!",
    })
    }