Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for changed (4.12 sec)

  1. cmd/grid.go

    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/rest"
    )
    
    // globalGrid is the global grid manager.
    var globalGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 2K bytes
    - Viewed (0)
  2. internal/grid/grid.go

    		return len(p), nil
    	case <-w.ctx.Done():
    		return 0, context.Cause(w.ctx)
    	}
    }
    
    // WriterToChannel will return an io.Writer that writes to the given channel.
    // The context both allows returning errors on writes and to ensure that
    // this isn't abandoned if the channel is no longer being read from.
    func WriterToChannel(ctx context.Context, ch chan<- []byte) io.Writer {
    	return &writerWrapper{ch: ch, ctx: ctx}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 15:56:18 GMT 2024
    - 4.8K bytes
    - Viewed (0)
Back to top