- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 539 for Chan (0.2 sec)
-
istioctl/pkg/wait/wait.go
}) return g } type watcher struct { resultsChan chan string errorChan chan error ctx context.Context } func withContext(ctx context.Context) *watcher { return &watcher{ resultsChan: make(chan string, 1), errorChan: make(chan error, 1), ctx: ctx, } } func (w *watcher) Go(f func(chan string) error) { go func() { if err := f(w.resultsChan); err != nil {
Go - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
internal/grid/grid_test.go
remoteHost := remote.HostName() // 1: Echo serverSent := make(chan struct{}) serverCanceled := make(chan struct{}) register := func(manager *Manager) { errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{ Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, resp chan<- []byte) *RemoteErr { // Send many responses. // Test that this doesn't block.
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/grid/muxclient.go
func (m *muxClient) handleTwowayResponses(responseCh chan<- Response, internalResp <-chan Response) { defer m.parent.deleteMux(false, m.MuxID) defer xioutil.SafeClose(responseCh) for resp := range internalResp { responseCh <- resp m.send(message{Op: OpUnblockSrvMux, MuxID: m.MuxID}) } } func (m *muxClient) handleTwowayRequests(internalResp chan<- Response, requests <-chan []byte) { var errState bool if debugPrint {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/grid/handlers.go
func (h *StreamTypeHandler[Payload, Req, Resp]) RegisterNoPayload(m *Manager, handle func(ctx context.Context, in <-chan Req, out chan<- Resp) *RemoteErr, subroute ...string) error { h.WithPayload = false return h.register(m, func(ctx context.Context, p Payload, in <-chan Req, out chan<- Resp) *RemoteErr { return handle(ctx, in, out) }, subroute...) }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 26.9K bytes - Viewed (0) -
cmd/peer-rest-client.go
} func (client *peerRESTClient) GetResourceMetrics(ctx context.Context) (<-chan MetricV2, error) { resp, err := getResourceMetricsRPC.Call(ctx, client.gridConn(), grid.NewMSS()) if err != nil { return nil, err } ch := make(chan MetricV2) go func(ch chan<- MetricV2) { defer close(ch) for _, m := range resp.Value() { if m == nil { continue }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/metacache-server-pool.go
saver := z.serverPools[o.pool].sets[o.set] // Disconnect from call above, but cancel on exit. listCtx, cancel := context.WithCancel(GlobalContext) saveCh := make(chan metaCacheEntry, metacacheBlockSize) inCh := make(chan metaCacheEntry, metacacheBlockSize) outCh := make(chan metaCacheEntry, o.Limit) filteredResults := o.gatherResults(ctx, outCh) mc := o.newMetacache()
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 20:23:12 GMT 2024 - 12.9K bytes - Viewed (0) -
internal/event/target/amqp.go
confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1)) if err := ch.Confirm(false); err != nil { ch.Close() return nil, nil, err } return ch, confirms, nil } return ch, nil, nil } // send - sends an event to the AMQP091. func (target *AMQPTarget) send(eventData event.Event, ch *amqp091.Channel, confirms chan amqp091.Confirmation) error {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
cmd/handler-api.go
"github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/mcontext" ) type apiConfig struct { mu sync.RWMutex requestsDeadline time.Duration requestsPool chan struct{} clusterDeadline time.Duration listQuorum string corsAllowOrigins []string // total drives per erasure set across pools. totalDriveCount int replicationPriority string
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Mar 18 19:30:41 GMT 2024 - 10K bytes - Viewed (0) -
cmd/notification.go
} consolidatedReport.BucketStats[opts] = d } } return consolidatedReport } func (sys *NotificationSys) collectPeerMetrics(ctx context.Context, peerChannels []<-chan MetricV2, g *errgroup.Group) <-chan MetricV2 { ch := make(chan MetricV2) var wg sync.WaitGroup for index, err := range g.Wait() { if err != nil { if sys.peerClients[index] != nil {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 44.9K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
es := &expiryState{ ctx: ctx, objAPI: objAPI, } workers := make([]chan expiryOp, 0, n) es.workers.Store(&workers) es.ResizeWorkers(n) return es } func (es *expiryState) getWorkerCh(h uint64) chan<- expiryOp { w := es.workers.Load() if w == nil || len(*w) == 0 { return nil } workers := *w
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Mar 20 03:10:58 GMT 2024 - 33K bytes - Viewed (0)