Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for BuildTCP (0.1 sec)

  1. pilot/pkg/networking/plugin/authz/authorization.go

    	b := builder.New(tdBundle, push, policies, option)
    	return &Builder{builder: b}
    }
    
    func (b *Builder) BuildTCP() []*listener.Filter {
    	if b == nil || b.builder == nil {
    		return nil
    	}
    	if b.tcpBuilt {
    		return b.tcpFilters
    	}
    	b.tcpBuilt = true
    	b.tcpFilters = b.builder.BuildTCP()
    
    	return b.tcpFilters
    }
    
    func (b *Builder) BuildHTTP(class networking.ListenerClass) []*hcm.HttpFilter {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. pilot/pkg/security/authz/builder/fuzz_test.go

    		option := fuzz.Struct[Option](fg)
    		b := New(bundle, push, policies, option)
    		if b == nil {
    			fg.T().Skip()
    			return // To help linter
    		}
    		b.BuildTCP()
    	})
    }
    
    func validatePush(in *model.PushContext) bool {
    	if in == nil {
    		return false
    	}
    	if in.AuthzPolicies == nil {
    		return false
    	}
    	return true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  3. pilot/pkg/security/authz/builder/builder.go

    		b.logger.AppendDebugf("built %d HTTP filters for ALLOW action", len(configs.http))
    		filters = append(filters, configs.http...)
    	}
    	return filters
    }
    
    // BuildTCP returns the TCP filters built from the authorization policy.
    func (b Builder) BuildTCP() []*listener.Filter {
    	b.logger = &AuthzLogger{}
    	defer b.logger.Report()
    	if b.option.IsCustomBuilder {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Nov 20 22:15:12 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/networkfilter.go

    	}
    	// TODO: not sure why it goes here
    	filters = append(filters, authzCustomBuilder.BuildTCP()...)
    
    	// Authn
    	filters = extension.PopAppendNetwork(filters, wasm, extensions.PluginPhase_AUTHN)
    
    	// Authz
    	filters = extension.PopAppendNetwork(filters, wasm, extensions.PluginPhase_AUTHZ)
    	filters = append(filters, authzBuilder.BuildTCP()...)
    
    	// Stats
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  5. pilot/pkg/security/authz/builder/builder_test.go

    			policies := push.AuthzPolicies.ListAuthorizationPolicies(selectionOpts)
    			g := New(tc.tdBundle, push, policies, option)
    			if g == nil {
    				t.Fatalf("failed to create generator")
    			}
    			got := g.BuildTCP()
    			verify(t, convertTCP(got), baseDir, tc.want, true /* forTCP */)
    		})
    	}
    }
    
    func verify(t *testing.T, gots []proto.Message, baseDir string, wants []string, forTCP bool) {
    	t.Helper()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.8K bytes
    - Viewed (0)
Back to top