[v14] deprecate fanoutv1 (#38129)

* deprecate fanoutv1 (#37836) * fix bpf test
gravitational · Feb 23, 2024 · 3f70e74 · 3f70e74
1 parent 41cfaf0
commit 3f70e74
Show file tree

Hide file tree

Showing 5 changed files with 44 additions and 622 deletions.
diff --git a/lib/restrictedsession/restricted_test.go b/lib/restrictedsession/restricted_test.go
@@ -212,13 +212,15 @@ func setupBPFContext(t *testing.T) *bpfContext {
 
 	client := &mockClient{
 		restrictions: restrictions,
-		Fanout:       *services.NewFanout(),
+		FanoutV2: *services.NewFanoutV2(services.FanoutV2Config{
+			Capacity: 64,
+		}),
 	}
 
 	bpfCtx.restrictedMgr, err = New(config, client)
 	require.NoError(t, err)
 
-	client.Fanout.SetInit([]api.WatchKind{{Kind: api.KindNetworkRestrictions}})
+	client.FanoutV2.SetInit([]api.WatchKind{{Kind: api.KindNetworkRestrictions}})
 
 	time.Sleep(100 * time.Millisecond)
 
@@ -408,7 +410,7 @@ func TestRootNetwork(t *testing.T) {
 
 type mockClient struct {
 	restrictions api.NetworkRestrictions
-	services.Fanout
+	services.FanoutV2
 }
 
 func (mc *mockClient) GetNetworkRestrictions(context.Context) (api.NetworkRestrictions, error) {