Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 1,425 for Func (0.03 sec)

  1. internal/event/target/postgresql.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *PostgreSQLTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *PostgreSQLTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *PostgreSQLTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    	jt, _ := workers.New(int(numHealers))
    
    	healEntryDone := func(name string) healEntryResult {
    		return healEntryResult{
    			entryDone: true,
    			name:      name,
    		}
    	}
    
    	healEntrySuccess := func(sz uint64) healEntryResult {
    		return healEntryResult{
    			bytes:   sz,
    			success: true,
    		}
    	}
    
    	healEntryFailure := func(sz uint64) healEntryResult {
    		return healEntryResult{
    			bytes: sz,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  3. src/archive/zip/writer_test.go

    	b.ResetTimer()
    
    	b.RunParallel(func(pb *testing.PB) {
    		var buf bytes.Buffer
    		for pb.Next() {
    			runOnce(&buf)
    		}
    	})
    }
    
    func writeTestsToFS(tests []WriteTest) fs.FS {
    	fsys := fstest.MapFS{}
    	for _, wt := range tests {
    		fsys[wt.Name] = &fstest.MapFile{
    			Data: wt.Data,
    			Mode: wt.Mode,
    		}
    	}
    	return fsys
    }
    
    func TestWriterAddFS(t *testing.T) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  4. internal/s3select/sql/value.go

    	v.value = f
    }
    
    func (v *Value) setString(s string) {
    	v.value = s
    }
    
    func (v *Value) setBool(b bool) {
    	v.value = b
    }
    
    func (v *Value) setTimestamp(t time.Time) {
    	v.value = t
    }
    
    func (v Value) String() string {
    	return fmt.Sprintf("%#v", v.value)
    }
    
    // CSVString - convert to string for CSV serialization
    func (v Value) CSVString() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Feb 25 20:31:19 UTC 2022
    - 20.2K bytes
    - Viewed (0)
  5. cmd/metacache_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgmetacache(b *testing.B) {
    	v := metacache{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgmetacache(b *testing.B) {
    	v := metacache{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  6. cmd/storage-rest-server.go

    // waitForHTTPResponse should be used to the receiving side.
    func keepHTTPReqResponseAlive(w http.ResponseWriter, r *http.Request) (resp func(error), body io.ReadCloser) {
    	bodyDoneCh := make(chan struct{})
    	doneCh := make(chan error)
    	ctx := r.Context()
    	go func() {
    		canWrite := true
    		write := func(b []byte) {
    			if canWrite {
    				n, err := w.Write(b)
    				if err != nil || n != len(b) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/table/writer.go

    		output = append(output, row.Cells)
    	}
    	return output
    }
    
    func (c *ColoredTableWriter) SetAddRowFunc(f func(obj interface{}) Row) {
    	c.addRowFunc = f
    }
    
    func (c *ColoredTableWriter) AddHeader(names ...string) {
    	cells := make([]Cell, 0)
    	for _, name := range names {
    		cells = append(cells, NewCell(name))
    	}
    	c.header = Row{Cells: cells}
    }
    
    func (c *ColoredTableWriter) AddRow(obj interface{}) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 09:43:25 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/netns_linux.go

    )
    
    type NetnsWrapper struct {
    	innerNetns netns.NetNS
    	inode      uint64
    }
    
    func (n *NetnsWrapper) Inode() uint64 {
    	return n.inode
    }
    
    func (n *NetnsWrapper) Close() error {
    	return n.innerNetns.Close()
    }
    
    func (n *NetnsWrapper) Fd() uintptr {
    	return n.innerNetns.Fd()
    }
    
    func inodeForFd(n NetnsFd) (uint64, error) {
    	stats := &unix.Stat_t{}
    	err := unix.Fstat(int(n.Fd()), stats)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 31 10:05:36 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/compare/sds/util.go

    }
    
    // Name sets the name field on a secretItemBuilder
    func (s *secretItemBuilder) Name(name string) SecretItemBuilder {
    	s.name = name
    	return s
    }
    
    // Data sets the data field on a secretItemBuilder
    func (s *secretItemBuilder) Data(data string) SecretItemBuilder {
    	s.data = data
    	return s
    }
    
    // Source sets the source field on a secretItemBuilder
    func (s *secretItemBuilder) Source(source string) SecretItemBuilder {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  10. src/bytes/buffer_test.go

    type negativeReader struct{}
    
    func (r *negativeReader) Read([]byte) (int, error) { return -1, nil }
    
    func init() {
    	testBytes = make([]byte, N)
    	for i := 0; i < N; i++ {
    		testBytes[i] = 'a' + byte(i%26)
    	}
    	testString = string(testBytes)
    }
    
    // Verify that contents of buf match the string s.
    func check(t *testing.T, testname string, buf *Buffer, s string) {
    	bytes := buf.Bytes()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 18.6K bytes
    - Viewed (0)
Back to top