- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 357 for clientV3 (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
startTime := time.Now() txnResp, err := s.client.KV.Txn(ctx).If( clientv3.Compare(clientv3.ModRevision(key), "=", origState.rev), ).Then( clientv3.OpDelete(key), ).Else( clientv3.OpGet(key), ).Commit() metrics.RecordEtcdRequest("delete", s.groupResourceString, err, startTime) if err != nil { return err } if !txnResp.Succeeded {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K 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/watcher.go
e.isInitialEventsEndBookmark = true return e }()) } opts := []clientv3.OpOption{clientv3.WithRev(wc.initialRev + 1), clientv3.WithPrevKV()} if wc.recursive { opts = append(opts, clientv3.WithPrefix()) } if wc.progressNotify { opts = append(opts, clientv3.WithProgressNotify()) } wch := wc.watcher.client.Watch(wc.ctx, wc.key, opts...) for wres := range wch { if wres.Err() != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K 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) -
internal/config/dns/etcd_dns.go
type CoreDNS struct { domainNames []string domainIPs set.StringSet domainPort string prefixPath string etcdClient *clientv3.Client } // EtcdOption - functional options pattern style type EtcdOption func(*CoreDNS) // DomainNames set a list of domain names used by this CoreDNS // client setting, note this will fail if set to empty when // constructor initializes. func DomainNames(domainNames []string) EtcdOption {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
getReactors []func() } func newEtcdClientKVWrapper(kv clientv3.KV) *etcdClientKVWrapper { return &etcdClientKVWrapper{ KV: kv, getCallCounter: 0, } } func (ecw *etcdClientKVWrapper) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { resp, err := ecw.KV.Get(ctx, key, opts...) ecw.getCallCounter++ if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.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)