Function ExampleWatcher_watchWithProgressNotify

client/v3/example_watch_test.go:128–159

()

}

func ExampleWatcher_watchWithProgressNotify() {
	forUnitTestsRunInMockedContext(mockWatcher_watchWithProgressNotify, func() {
		cli, err := clientv3.New(clientv3.Config{
			Endpoints:   exampleEndpoints(),
			DialTimeout: dialTimeout,
		})
		if err != nil {
			log.Fatal(err)
		}

		rch := cli.Watch(context.Background(), "foo", clientv3.WithProgressNotify())
		closedch := make(chan bool)
		go func() {
			// This assumes that cluster is configured with frequent WatchProgressNotifyInterval
			// e.g. WatchProgressNotifyInterval: 200 * time.Millisecond.
			time.Sleep(time.Second)
			err := cli.Close()
			if err != nil {
				log.Fatal(err)
			}
			close(closedch)
		}()
		wresp := <-rch
		fmt.Println("wresp.IsProgressNotify:", wresp.IsProgressNotify())
		<-closedch
	})

	// TODO: Rather wresp.IsProgressNotify: true should be expected

	// Output:
	// wresp.IsProgressNotify: true
}