Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for clients (0.16 sec)

  1. internal/config/etcd/etcd.go

    	Enabled     bool   `json:"enabled"`
    	PathPrefix  string `json:"pathPrefix"`
    	CoreDNSPath string `json:"coreDNSPath"`
    	clientv3.Config
    }
    
    // New - initialize new etcd client.
    func New(cfg Config) (*clientv3.Client, error) {
    	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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  2. cmd/etcd.go

    }
    
    func saveKeyEtcd(ctx context.Context, client *etcd.Client, key string, data []byte, opts ...options) error {
    	timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    	if len(opts) > 0 {
    		return saveKeyEtcdWithTTL(ctx, client, key, data, opts[0].ttl)
    	}
    	_, err := client.Put(timeoutCtx, key, string(data))
    	etcdLogIf(ctx, err)
    	return etcdErrToErr(err, client.Endpoints())
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 2.9K bytes
    - Viewed (0)
Back to top