Consul ephemeral key example

main.go

package main

import (
        "log"

        "github.com/hashicorp/consul/api"
)

func main() {
        client, err := api.NewClient(api.DefaultConfig())
        if err != nil {
                log.Fatalf("Failed to create Consul client: %v", err)
        }

        sess := client.Session()
        id, _, err := sess.Create(&api.SessionEntry{
                Behavior: api.SessionBehaviorDelete,
                TTL:      "10s",
        }, nil)
        if err != nil {
                log.Fatalf("Failed to create session: %v", err)
        }

        kv := client.KV()
        ok, _, err := kv.Acquire(&api.KVPair{
                Key:     "ephemeral",
                Session: id,
        }, nil)
        if err != nil {
                log.Fatalf("Failed to create KV pair: %v", err)
        }
        if !ok {
                log.Fatalf("Failed to acquire lock")
        }
}