repro-27133.go

package main

import (
	"context"
	"log"

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

func main() {
	config := api.DefaultConfig()
	//config.Address = url

	client, err := api.NewClient(config)
	if err != nil {
		return
	}

	defer client.Close()

	topics := map[api.Topic][]string{
		//api.TopicJob:        {"*"},
		api.TopicAllocation: {"*"},
	}

	ctx, _ := context.WithCancel(context.Background())

	stream, err := client.EventStream().Stream(ctx, topics, 0, &api.QueryOptions{})
	if err != nil {
		log.Fatalf("error streaming: %v", err)
	}

	for {
		select {
		case events, ok := <-stream:
			if !ok {
				log.Fatalf("stream close")
			}
			if events.Err != nil {
				log.Printf("error in stream: %v", events.Err)
			}
			log.Printf("event (%d) %v", len(events.Events), events.Events)
		case <-ctx.Done():
			log.Printf("Nomad Job stop")
		}
	}
}