- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 173 for clientV3 (0.12 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/storage/objectreader.go
return fmt.Errorf("error setting storage object %s, %s from etcd at key %s: %v", ns, name, key, err) } return nil } // GetEtcdClients returns an initialized clientv3.Client and clientv3.KV. func GetEtcdClients(config storagebackend.TransportConfig) (*clientv3.Client, clientv3.KV, error) { tlsInfo := transport.TLSInfo{ CertFile: config.CertFile, KeyFile: config.KeyFile, TrustedCAFile: config.TrustedCAFile, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 4.7K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate_client.go
if len(kvs) != 1 { return "", fmt.Errorf("expected exactly one value for key %s but got %d", key, len(kvs)) } return string(kvs[0].Value), nil } func (e *CombinedEtcdClient) clientV3() (*clientv3.Client, error) { return clientv3.New(clientv3.Config{ Endpoints: []string{e.endpoint()}, DialTimeout: 20 * time.Second, DialOptions: []grpc.DialOption{ grpc.WithBlock(), // block until the underlying connection is up },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 6.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/latency_tracker.go
package etcd3 import ( "context" "time" clientv3 "go.etcd.io/etcd/client/v3" endpointsrequest "k8s.io/apiserver/pkg/endpoints/request" ) // NewETCDLatencyTracker returns an implementation of // clientv3.KV that times the calls from the specified // 'delegate' KV instance in order to track latency incurred. func NewETCDLatencyTracker(delegate clientv3.KV) clientv3.KV { return &clientV3KVLatencyTracker{KV: delegate} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/event_test.go
"go.etcd.io/etcd/api/v3/mvccpb" clientv3 "go.etcd.io/etcd/client/v3" "testing" ) func TestParseEvent(t *testing.T) { for _, tc := range []struct { name string etcdEvent *clientv3.Event expectedEvent *event expectedErr string }{ { name: "successful create", etcdEvent: &clientv3.Event{ Type: clientv3.EventTypePut, PrevKv: nil, Kv: &mvccpb.KeyValue{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/lease_manager.go
// are expensive. In the implementation, we only store one previous lease, // since all the events have the same ttl. type leaseManager struct { client *clientv3.Client // etcd client used to grant leases leaseMu sync.Mutex prevLeaseID clientv3.LeaseID prevLeaseExpirationTime time.Time // The period of time in seconds and percent of TTL that each lease is
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/compact.go
// Note that CAS fail will not incur any error. func compact(ctx context.Context, client *clientv3.Client, t, rev int64) (int64, int64, error) { resp, err := client.KV.Txn(ctx).If( clientv3.Compare(clientv3.Version(compactRevKey), "=", t), ).Then( clientv3.OpPut(compactRevKey, strconv.FormatInt(rev, 10)), // Expect side effect: increment Version ).Else( clientv3.OpGet(compactRevKey), ).Commit() if err != nil { return t, rev, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 17 02:54:36 UTC 2022 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/testserver/test_server.go
t.Fatal(err) } client, err := clientv3.New(clientv3.Config{ TLS: tlsConfig, Endpoints: e.Server.Cluster().ClientURLs(), DialTimeout: 10 * time.Second, DialOptions: []grpc.DialOption{grpc.WithBlock()}, Logger: zaptest.NewLogger(t, zaptest.Level(zapcore.ErrorLevel)).Named("etcd-client"), }) if err != nil { t.Fatal(err) } return client
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 06 11:40:40 UTC 2023 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/etcd.go
*/ package fixtures import ( "context" "encoding/json" "path" clientv3 "go.etcd.io/etcd/client/v3" apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1" apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1" "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 3K bytes - Viewed (0) -
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)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/event.go
See the License for the specific language governing permissions and limitations under the License. */ package etcd3 import ( "fmt" "go.etcd.io/etcd/api/v3/mvccpb" clientv3 "go.etcd.io/etcd/client/v3" ) type event struct { key string value []byte prevValue []byte rev int64 isDeleted bool isCreated bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 2.3K bytes - Viewed (0)