- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 578 for Chan (0.21 sec)
-
internal/s3select/message.go
getProgressFunc func() (int64, int64) bytesReturned int64 payloadBuffer []byte payloadBufferIndex int payloadCh chan *bytes.Buffer finBytesScanned, finBytesProcessed int64 errCh chan []byte doneCh chan struct{} } func (writer *messageWriter) write(data []byte) bool { if _, err := writer.writer.Write(data); err != nil { return false }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
cmd/metacache-stream.go
func (w *metacacheWriter) stream() (chan<- metaCacheEntry, error) { if w.creator != nil { err := w.creator() w.creator = nil if err != nil { return nil, fmt.Errorf("metacacheWriter: unable to create writer: %w", err) } if w.mw == nil { return nil, errors.New("metacacheWriter: writer not initialized") } } objs := make(chan metaCacheEntry, 100) w.streamErr = nil
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
cni/pkg/install/install_test.go
t.Fatal(err) } // Listen for isReady to be set to true ticker := time.NewTicker(500 * time.Millisecond) defer ticker.Stop() readyChan := make(chan bool) go func(ctx context.Context, tick <-chan time.Time) { for { select { case <-ctx.Done(): return case <-tick: if isReady.Load().(bool) { readyChan <- true } }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
cni/pkg/install/cniconfig_test.go
// Call with goroutine to test fsnotify watcher parent, cancel := context.WithCancel(context.Background()) defer cancel() resultChan, errChan := make(chan string, 1), make(chan error, 1) go func(resultChan chan string, errChan chan error, ctx context.Context, cfg pluginConfig) { result, err := getCNIConfigFilepath(ctx, cfg) if err != nil { errChan <- err return }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed May 17 02:22:22 GMT 2023 - 15.4K bytes - Viewed (0) -
internal/ioutil/ioutil.go
func WithDeadline[V any](ctx context.Context, timeout time.Duration, work func(ctx context.Context) (result V, err error)) (result V, err error) { ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel() c := make(chan ioret[V], 1) go func() { v, err := work(ctx) c <- ioret[V]{val: v, err: err} }() select { case v := <-c: return v.val, v.err case <-ctx.Done(): var zero V
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
cmd/metrics-resource.go
func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) { var wg sync.WaitGroup publish := func(in <-chan MetricV2) { defer wg.Done() for metric := range in {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Apr 17 05:10:25 GMT 2024 - 17.3K bytes - Viewed (0) -
cmd/metacache-walk.go
return err })) } // WalkDirHandler - remote caller to list files and folders in a requested directory path. func (s *storageRESTServer) WalkDirHandler(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) (gerr *grid.RemoteErr) { var opts WalkDirOptions _, err := opts.UnmarshalMsg(payload) if err != nil { return grid.NewRemoteErr(err) } if !s.checkID(opts.DiskID) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/metacache-set.go
// The returned function will return the results once there is enough or input is closed, // or the context is canceled. func (o *listPathOptions) gatherResults(ctx context.Context, in <-chan metaCacheEntry) func() (metaCacheEntriesSorted, error) { resultsDone := make(chan metaCacheEntriesSorted) // Copy so we can mutate resCh := resultsDone var done bool var mu sync.Mutex resErr := io.EOF go func() {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 18 04:42:11 GMT 2024 - 30.4K bytes - Viewed (0) -
schema/schema.go
BeforeCreate, AfterCreate bool BeforeUpdate, AfterUpdate bool BeforeDelete, AfterDelete bool BeforeSave, AfterSave bool AfterFind bool err error initialized chan struct{} namer Namer cacheStore *sync.Map } func (schema Schema) String() string { if schema.ModelType.Name() == "" { return fmt.Sprintf("%s(%s)", schema.Name, schema.Table)
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Tue Oct 10 06:50:29 GMT 2023 - 13.7K bytes - Viewed (0) -
src/cmd/api/main_test.go
buf.WriteString("map[") w.writeType(buf, typ.Key()) buf.WriteByte(']') w.writeType(buf, typ.Elem()) case *types.Chan: var s string switch typ.Dir() { case types.SendOnly: s = "chan<- " case types.RecvOnly: s = "<-chan " case types.SendRecv: s = "chan " default: panic("unreachable") } buf.WriteString(s) w.writeType(buf, typ.Elem()) case *types.Alias:
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0)