NewWatcher - Code Search

Sort Score
Num 10 results
Language All

Results 1 - 1 of 1 for NewWatcher (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

internal/config/etcd/etcd.go

	if !cfg.Enabled {
		return nil, nil
	}
	cli, err := clientv3.New(cfg.Config)
	if err != nil {
		return nil, err
	}
	cli.KV = namespace.NewKV(cli.KV, cfg.PathPrefix)
	cli.Watcher = namespace.NewWatcher(cli.Watcher, cfg.PathPrefix)
	cli.Lease = namespace.NewLease(cli.Lease, cfg.PathPrefix)
	return cli, nil
}

func parseEndpoints(endpoints string) ([]string, bool, error) {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri May 16 14:27:42 GMT 2025

- 5.2K bytes

- Click Count (0)

Search Options

internal/config/etcd/etcd.go