Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for New (0.11 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

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    
    	etcd "go.etcd.io/etcd/client/v3"
    )
    
    var errEtcdUnreachable = errors.New("etcd is unreachable, please check your endpoints")
    
    func etcdErrToErr(err error, etcdEndpoints []string) error {
    	if err == nil {
    		return nil
    	}
    	switch err {
    	case context.DeadlineExceeded:
    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