- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for kindOf (0.13 sec)
-
pilot/pkg/config/kube/crdclient/client.go
} // List implements store interface func (cl *Client) List(kind config.GroupVersionKind, namespace string) []config.Config { h, f := cl.kind(kind) if !f { return nil } list := h.List(namespace, klabels.Everything()) out := make([]config.Config, 0, len(list)) for _, item := range list { cfg := TranslateObject(item, kind, cl.domainSuffix) out = append(out, cfg) } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging.go
"bytes_received": {Kind: &structpb.Value_StringValue{StringValue: "%BYTES_RECEIVED%"}}, "bytes_sent": {Kind: &structpb.Value_StringValue{StringValue: "%BYTES_SENT%"}}, "duration": {Kind: &structpb.Value_StringValue{StringValue: "%DURATION%"}},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 23K bytes - Viewed (0) -
pilot/pkg/networking/core/peer_authentication_simulation_test.go
func TestPeerAuthenticationPassthrough(t *testing.T) { paStrict := ` apiVersion: security.istio.io/v1beta1 kind: PeerAuthentication metadata: name: default spec: selector: matchLabels: app: foo mtls: mode: STRICT ---` paDisable := ` apiVersion: security.istio.io/v1beta1 kind: PeerAuthentication metadata: name: default spec: selector: matchLabels: app: foo mtls:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 16.2K bytes - Viewed (0) -
cmd/encryption-v1.go
default: return crypto.ObjectKey{}, fmt.Errorf("encryption type '%v' not supported", kind) } } func newEncryptReader(ctx context.Context, content io.Reader, kind crypto.Type, keyID string, key []byte, bucket, object string, metadata map[string]string, cryptoCtx kms.Context) (io.Reader, crypto.ObjectKey, error) { objectEncryptionKey, err := newEncryptMetadata(ctx, kind, keyID, key, bucket, object, metadata, cryptoCtx) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 37.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
// http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // nolint: gocritic package ambient import ( "net/netip"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
// Service is removed while connection is closed s.MemRegistry.RemoveService("adsupdate.example.com") s.Discovery.ConfigUpdate(&model.PushRequest{ Full: true, ConfigsUpdated: sets.New(model.ConfigKey{Kind: kind.ServiceEntry, Name: "adsupdate.example.com", Namespace: "default"}), }) s.EnsureSynced(t) ads = s.ConnectDeltaADS() // Sometimes we get an EDS request first before CDS
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
Fields: map[string]*structpb.Value{ "req1": {Kind: &structpb.Value_StringValue{StringValue: "%REQ_WITHOUT_QUERY(key1:val1)%"}}, "req2": {Kind: &structpb.Value_StringValue{StringValue: "%REQ_WITHOUT_QUERY(key2:val1)%"}}, "key1": {Kind: &structpb.Value_StringValue{StringValue: "%METADATA(CLUSTER:istio)%"}}, "key2": {Kind: &structpb.Value_StringValue{StringValue: "%METADATA(UPSTREAM_HOST:istio)%"}}, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
// deleted clusters for this config. var deleted []string var svcs []*model.Service switch key.Kind { case kind.ServiceEntry: svcs, deleted = configgen.deltaFromServices(key, proxy, updates.Push, serviceClusters, servicePortClusters, subsetClusters) case kind.DestinationRule: svcs, deleted = configgen.deltaFromDestinationRules(key, proxy, subsetClusters) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package model import ( "sort" "sync" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/serviceregistry/provider" "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/config/schema/kind" "istio.io/istio/pkg/util/sets" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/networking/util/util.go
strcase.CamelCaseToKebabCase(config.GroupVersionKind.Kind) + "/" + config.Name if _, ok := metadata.FilterMetadata[IstioMetadataKey]; !ok { metadata.FilterMetadata[IstioMetadataKey] = &structpb.Struct{ Fields: map[string]*structpb.Value{}, } } metadata.FilterMetadata[IstioMetadataKey].Fields["config"] = &structpb.Value{ Kind: &structpb.Value_StringValue{ StringValue: s, }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 28.5K bytes - Viewed (0)