Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,179 for funcs (0.07 sec)

  1. cmd/peer-rest-client.go

    	if err != nil {
    		return
    	}
    	st.Results(func(b *grid.Bytes) error {
    		select {
    		case listenCh <- *b:
    		default:
    			// Do not block on slow receivers.
    			b.Recycle()
    		}
    		return nil
    	})
    }
    
    // Listen - listen on peers.
    func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    	go func() {
    		for {
    			client.doListen(ctx, listenCh, v)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. cmd/batch-job-common-types_gen.go

    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z BatchJobKV) Msgsize() (s int) {
    	s = 1 + 4 + msgp.StringPrefixSize + len(z.Key) + 6 + msgp.StringPrefixSize + len(z.Value)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobNotification) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 21.9K bytes
    - Viewed (0)
  5. tests/preload_test.go

    	sort.Slice(users2, func(i, j int) bool {
    		return users2[i].ID < users2[j].ID
    	})
    
    	for idx, user := range users2[1:2] {
    		if user.Account.Number != "" {
    			t.Errorf("No account should found for user %v but got %v", idx+2, user.Account.Number)
    		}
    	}
    
    	CheckUser(t, users2[0], users[0])
    
    	var users3 []User
    	if err := DB.Preload("Account", func(tx *gorm.DB) *gorm.DB {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:00:47 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  6. cmd/storage-datatypes_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBaseOptions(b *testing.B) {
    	v := BaseOptions{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBaseOptions(b *testing.B) {
    	v := BaseOptions{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 73.9K bytes
    - Viewed (0)
  7. internal/config/lambda/event/targetlist.go

    }
    
    // Remove - closes and removes targets by given target IDs.
    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    	defer list.Unlock()
    
    	for id := range targetIDSet {
    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    func (list *TargetList) Targets() []Target {
    	if list == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  8. cmd/data-scanner-metric.go

    func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) {
    	initialPtr := unsafe.Pointer(&initial)
    	tracker := &currentPathTracker{
    		name: &initialPtr,
    	}
    
    	p.currentPaths.Store(disk, tracker)
    	return func(path string) {
    			atomic.StorePointer(tracker.name, unsafe.Pointer(&path))
    		}, func() {
    			p.currentPaths.Delete(disk)
    		}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 25 05:15:31 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  9. internal/s3select/sql/analysis.go

    	for _, ex := range e.Expressions {
    		result.combine(ex.analyze(s))
    	}
    	return
    }
    
    func (e *AliasedExpression) analyze(s *Select) qProp {
    	return e.Expression.analyze(s)
    }
    
    func (e *Expression) analyze(s *Select) (result qProp) {
    	for _, ac := range e.And {
    		result.combine(ac.analyze(s))
    	}
    	return
    }
    
    func (e *AndCondition) analyze(s *Select) (result qProp) {
    	for _, ac := range e.Condition {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  10. src/bytes/bytes_test.go

    }
    
    func bmIndexByte(index func([]byte, byte) int) func(b *testing.B, n int) {
    	return func(b *testing.B, n int) {
    		buf := bmbuf[0:n]
    		buf[n-1] = 'x'
    		for i := 0; i < b.N; i++ {
    			j := index(buf, 'x')
    			if j != n-1 {
    				b.Fatal("bad index", j)
    			}
    		}
    		buf[n-1] = '\x00'
    	}
    }
    
    func BenchmarkIndexRune(b *testing.B) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Aug 19 19:09:04 UTC 2024
    - 61.2K bytes
    - Viewed (0)
Back to top