- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 36 for krt (0.01 sec)
-
pkg/kube/krt/join_test.go
"istio.io/istio/pkg/kube/kclient/clienttest" "istio.io/istio/pkg/kube/krt" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/assert" ) func TestJoinCollection(t *testing.T) { c1 := krt.NewStatic[Named](nil) c2 := krt.NewStatic[Named](nil) c3 := krt.NewStatic[Named](nil) j := krt.JoinCollection([]krt.Collection[Named]{c1.AsCollection(), c2.AsCollection(), c3.AsCollection()})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/meshconfig.go
cmName = cmName + "-" + options.Revision } return krt.NewSingleton[MeshConfig]( func(ctx krt.HandlerContext) *MeshConfig { meshCfg := mesh.DefaultMeshConfig() cms := []*v1.ConfigMap{} if features.SharedMeshConfig != "" { cms = AppendNonNil(cms, krt.FetchOne(ctx, ConfigMaps, krt.FilterObjectName(types.NamespacedName{Name: features.SharedMeshConfig, Namespace: options.SystemNamespace})))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 2.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services.go
"istio.io/istio/pkg/kube/krt" "istio.io/istio/pkg/log" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/workloadapi" ) func (a *index) ServicesCollection( Services krt.Collection[*v1.Service], ServiceEntries krt.Collection[*networkingclient.ServiceEntry], Waypoints krt.Collection[Waypoint], Namespaces krt.Collection[*v1.Namespace], ) krt.Collection[model.ServiceInfo] {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/kube/krt/recomputetrigger_test.go
package krt_test import ( "testing" "istio.io/istio/pkg/kube/krt" "istio.io/istio/pkg/ptr" "istio.io/istio/pkg/test/util/assert" ) func TestRecomputeTrigger(t *testing.T) { rt := krt.NewRecomputeTrigger() col1 := krt.NewStatic(ptr.Of("foo")).AsCollection() response := "foo" col2 := krt.NewCollection(col1, func(ctx krt.HandlerContext, i string) *string { rt.MarkDependant(ctx) return ptr.Of(response)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:51:56 UTC 2024 - 1.3K bytes - Viewed (0) -
pkg/kube/krt/recomputetrigger.go
// limitations under the License. package krt import ( "go.uber.org/atomic" "istio.io/istio/pkg/ptr" ) // RecomputeTrigger trigger provides an escape hatch to allow krt transformations to depend on external state and recompute // correctly when those change. // Typically, all state is registered and fetched through krt.Fetch. Through this mechanism, any changes are automatically
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:51:56 UTC 2024 - 2K bytes - Viewed (0) -
pkg/kube/krt/krttest/helpers.go
}) return mc } func GetMockCollection[T any](mc *MockCollection) krt.Collection[T] { return krt.NewStaticCollection(extractType[T](&mc.inputs)) } func GetMockSingleton[T any](mc *MockCollection) krt.StaticSingleton[T] { t := extractType[T](&mc.inputs) if len(t) > 1 { mc.t.Helper() mc.t.Fatalf("multiple types returned") } return krt.NewStatic(slices.First(t)) } func extractType[T any](items *[]any) []T {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 19:33:01 UTC 2024 - 2.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services_test.go
networking "istio.io/api/networking/v1alpha3" networkingclient "istio.io/client-go/pkg/apis/networking/v1alpha3" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pkg/kube/krt" "istio.io/istio/pkg/kube/krt/krttest" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/workloadapi" ) func TestServiceEntryServices(t *testing.T) { cases := []struct { name string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 2.9K bytes - Viewed (0) -
architecture/networking/controllers.md
*All Istio informer usage should use this library and not operate on Kubernetes informers directly.* **`krt`** is a very high level wrapper around Kubernetes informers, building on top of `kclient`. See the [krt README](../../pkg/kube/krt/README.md) for more information. *krt is currently experimental; please ask maintainers before utilizing it in new areas.* ## Writing Controllers
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go
"istio.io/istio/pilot/pkg/model" "istio.io/istio/pkg/config/labels" "istio.io/istio/pkg/config/mesh" "istio.io/istio/pkg/config/schema/kind" "istio.io/istio/pkg/kube/krt" "istio.io/istio/pkg/kube/krt/krttest" "istio.io/istio/pkg/network" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/workloadapi" "istio.io/istio/pkg/workloadapi/security" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.3K bytes - Viewed (0) -
pkg/kube/krt/core.go
// See the License for the specific language governing permissions and // limitations under the License. package krt import ( "istio.io/istio/pkg/kube/controllers" istiolog "istio.io/istio/pkg/log" ) var log = istiolog.RegisterScope("krt", "") // Collection is the core resource type for krt, representing a collection of objects. Items can be listed, or fetched
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 6.9K bytes - Viewed (0)