- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for typeurl (0.28 sec)
-
pilot/pkg/xds/delta.go
return conn.deltaStream.Send(res) } err := sendResonse() if err == nil { if !strings.HasPrefix(res.TypeUrl, v3.DebugType) { conn.proxy.UpdateWatchedResource(res.TypeUrl, func(wr *model.WatchedResource) *model.WatchedResource { if wr == nil { wr = &model.WatchedResource{TypeUrl: res.TypeUrl} } // some resources dynamically update ResourceNames. Most don't though if newResourceNames != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
deleted model.DeletedResources, usedDelta bool, delta model.ResourceDelta, incremental bool, ) { current := con.proxy.GetWatchedResource(w.TypeUrl).LastResources if current == nil { log.Debugf("ADS:%s: resources initialized", v3.GetShortType(w.TypeUrl)) return } if deltaRes == nil && deleted == nil && len(sotwRes) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
// Another removal should behave the same s.MemRegistry.RemoveService("eds.test.svc.cluster.local") resp = ads.ExpectResponse() // ACK ads.Request(&discovery.DeltaDiscoveryRequest{ TypeUrl: resp.TypeUrl, ResponseNonce: resp.Nonce, }) assertResources(resp) assert.Equal(t, resp.RemovedResources, []string{"outbound|8080||eds.test.svc.cluster.local"}) // Another removal should behave the same
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
hack/unwanted-dependencies.json
], "github.com/gogo/protobuf": [ "github.com/Microsoft/hcsshim", "github.com/containerd/cgroups", "github.com/containerd/ttrpc", "github.com/containerd/typeurl", "github.com/google/cadvisor", "github.com/grpc-ecosystem/go-grpc-middleware", "go.etcd.io/etcd/api/v3", "go.etcd.io/etcd/client/v3", "go.etcd.io/etcd/raft/v3",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 13 12:31:38 UTC 2024 - 9.8K bytes - Viewed (0) -
pilot/test/xds/fake.go
f.t.Helper() p = f.SetupProxy(p) initialWatch := []*discovery.DiscoveryRequest{} for _, typeURL := range watch { initialWatch = append(initialWatch, &discovery.DiscoveryRequest{TypeUrl: typeURL}) } opts := []grpc.DialOption{grpc.WithTransportCredentials(insecure.NewCredentials())} if f.BufListener != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
go.mod
github.com/census-instrumentation/opencensus-proto v0.4.1 // indirect github.com/chai2010/gettext-go v1.0.2 // indirect github.com/containerd/stargz-snapshotter/estargz v0.15.1 // indirect github.com/containerd/typeurl/v2 v2.1.1 // indirect github.com/cpuguy83/go-md2man/v2 v2.0.3 // indirect github.com/cyphar/filepath-securejoin v0.2.4 // indirect github.com/decred/dcrd/dcrec/secp256k1/v4 v4.2.0 // indirect
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 15:32:28 UTC 2024 - 10.6K bytes - Viewed (0) -
go.sum
github.com/containerd/ttrpc v1.2.2 h1:9vqZr0pxwOF5koz6N0N3kJ0zDHokrcPxIR/ZR2YFtOs= github.com/containerd/ttrpc v1.2.2/go.mod h1:sIT6l32Ph/H9cvnJsfXM5drIVzTr5A2flTf1G5tYZak= github.com/containerd/typeurl v1.0.2 h1:Chlt8zIieDbzQFzXzAeBEF92KhExuE4p9p92/QmY7aY= github.com/containerd/typeurl v1.0.2/go.mod h1:9trJWW2sRlGub4wZJRTW83VtbOLS6hwcDZXTn6oPz9s= github.com/coredns/caddy v1.1.0/go.mod h1:A6ntJQlAWuQfFlsd9hvigKbo2WS0VUs2l1e2F+BawD4=
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:11 UTC 2024 - 93.1K bytes - Viewed (0) -
go.sum
github.com/containerd/stargz-snapshotter/estargz v0.15.1/go.mod h1:gr2RNwukQ/S9Nv33Lt6UC7xEx58C+LHRdoqbEKjz1Kk= github.com/containerd/typeurl/v2 v2.1.1 h1:3Q4Pt7i8nYwy2KmQWIw2+1hTvwTE/6w9FqcttATPO/4= github.com/containerd/typeurl/v2 v2.1.1/go.mod h1:IDp2JFvbwZ31H8dQbEIY7sDl2L3o3HZj1hsSQlywkQ0= github.com/containernetworking/cni v1.2.0 h1:fEjhlfWwWAXEvlcMQu/i6z8DA0Kbu7EcmR5+zb6cm5I=
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 15:32:28 UTC 2024 - 101.6K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10TypeProvider.kt
import org.jetbrains.kotlin.types.error.ErrorType import org.jetbrains.kotlin.types.error.ErrorTypeKind import org.jetbrains.kotlin.types.error.ErrorUtils import org.jetbrains.kotlin.types.typeUtil.builtIns import org.jetbrains.kotlin.types.typeUtil.isNothing import org.jetbrains.kotlin.util.containingNonLocalDeclaration internal class KaFe10TypeProvider( override val analysisSession: KaFe10Session
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 23.3K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10ExpressionTypeProvider.kt
import org.jetbrains.kotlin.types.checker.intersectWrappedTypes import org.jetbrains.kotlin.types.error.ErrorTypeKind import org.jetbrains.kotlin.types.error.ErrorUtils import org.jetbrains.kotlin.types.typeUtil.makeNullable class KaFe10ExpressionTypeProvider( override val analysisSession: KaFe10Session ) : KaExpressionTypeProvider(), KaFe10SessionComponent { private companion object {
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 15.4K bytes - Viewed (0)