Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewLineBuffer (0.2 sec)

  1. pkg/proxy/util/linebuffer_test.go

    		},
    		{
    			name:     "mixed",
    			input:    []interface{}{"s1", "s2", []string{"s3", "s4"}, "", "s5", []string{}, []string{"s6"}, "s7"},
    			expected: "s1 s2 s3 s4  s5  s6 s7\n",
    		},
    	}
    	testBuffer := NewLineBuffer()
    	for _, testCase := range testCases {
    		t.Run(testCase.name, func(t *testing.T) {
    			testBuffer.Reset()
    			testBuffer.Write(testCase.input...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 12:38:25 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  2. pkg/proxy/util/linebuffer.go

    	Lines() int
    }
    
    var _ logr.Marshaler = &realLineBuffer{}
    
    type realLineBuffer struct {
    	b     bytes.Buffer
    	lines int
    }
    
    // NewLineBuffer returns a new "real" LineBuffer
    func NewLineBuffer() LineBuffer {
    	return &realLineBuffer{}
    }
    
    // Write is part of LineBuffer
    func (buf *realLineBuffer) Write(args ...interface{}) {
    	for i, arg := range args {
    		if i > 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. pkg/proxy/iptables/proxier.go

    		iptablesData:             bytes.NewBuffer(nil),
    		existingFilterChainsData: bytes.NewBuffer(nil),
    		filterChains:             proxyutil.NewLineBuffer(),
    		filterRules:              proxyutil.NewLineBuffer(),
    		natChains:                proxyutil.NewLineBuffer(),
    		natRules:                 proxyutil.NewLineBuffer(),
    		localhostNodePorts:       localhostNodePorts,
    		nodePortAddresses:        nodePortAddresses,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/proxier.go

    		iptablesData:          bytes.NewBuffer(nil),
    		filterChainsData:      bytes.NewBuffer(nil),
    		natChains:             proxyutil.NewLineBuffer(),
    		natRules:              proxyutil.NewLineBuffer(),
    		filterChains:          proxyutil.NewLineBuffer(),
    		filterRules:           proxyutil.NewLineBuffer(),
    		netlinkHandle:         NewNetLinkHandle(ipFamily == v1.IPv6Protocol),
    		ipset:                 ipset,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  5. pkg/proxy/ipvs/proxier_test.go

    		iptablesData:          bytes.NewBuffer(nil),
    		filterChainsData:      bytes.NewBuffer(nil),
    		natChains:             proxyutil.NewLineBuffer(),
    		natRules:              proxyutil.NewLineBuffer(),
    		filterChains:          proxyutil.NewLineBuffer(),
    		filterRules:           proxyutil.NewLineBuffer(),
    		netlinkHandle:         netlinkHandle,
    		ipsetList:             ipsetList,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  6. pkg/proxy/iptables/proxier_test.go

    		iptablesData:             bytes.NewBuffer(nil),
    		existingFilterChainsData: bytes.NewBuffer(nil),
    		filterChains:             proxyutil.NewLineBuffer(),
    		filterRules:              proxyutil.NewLineBuffer(),
    		natChains:                proxyutil.NewLineBuffer(),
    		natRules:                 proxyutil.NewLineBuffer(),
    		nodeIP:                   netutils.ParseIPSloppy(testNodeIP),
    		localhostNodePorts:       true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 249.9K bytes
    - Viewed (0)
Back to top