- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 125 for clientV3 (0.12 sec)
-
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/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) -
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) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/testing/test_server.go
*/ package testing import ( "testing" clientv3 "go.etcd.io/etcd/client/v3" "k8s.io/apiserver/pkg/storage/etcd3/testserver" "k8s.io/apiserver/pkg/storage/storagebackend" ) // EtcdTestServer encapsulates the datastructures needed to start local instance for testing type EtcdTestServer struct { V3Client *clientv3.Client } func (e *EtcdTestServer) Terminate(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 13:35:58 UTC 2023 - 1.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/server.go
*/ package fixtures import ( "os" "strings" "time" "github.com/google/uuid" "go.etcd.io/etcd/client/pkg/v3/transport" clientv3 "go.etcd.io/etcd/client/v3" "google.golang.org/grpc" "k8s.io/apiextensions-apiserver/pkg/apiserver" "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset" serveroptions "k8s.io/apiextensions-apiserver/pkg/cmd/server/options"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/feature/feature_support_checker_test.go
{endpointsVersion: []mockEndpointVersion{ {Version: "3.5.14", Endpoint: "localhost:2391"}}, expectedResult: true}}, }, { testName: "Disabled - enabled success on first client, error on second client, disabled success on third client", rounds: []testCase{ {endpointsVersion: []mockEndpointVersion{ {Version: "3.6.0", Endpoint: "localhost:2390"}}, expectedResult: true, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/feature/feature_support_checker.go
// Returns true if all endpoints in etcd clients are supporting the feature. // If client A supports and client B doesn't support the feature, the `Supports` will // first return true at client A initializtion and then return false on client B // initialzation, it can flip the support at runtime. Supports(feature storage.Feature) bool // CheckClient works with etcd client to recalcualte feature support and cache it internally.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 6.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_testing_utils_test.go
return server, storage } func computePodKey(obj *example.Pod) string { return fmt.Sprintf("/pods/%s/%s", obj.Namespace, obj.Name) } func compactStorage(c *Cacher, client *clientv3.Client) storagetesting.Compaction { return func(ctx context.Context, t *testing.T, resourceVersion string) { versioner := storage.APIObjectVersioner{} rv, err := versioner.ParseResourceVersion(resourceVersion)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 20:43:52 UTC 2023 - 3.8K bytes - Viewed (0)