Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for connection (0.41 sec)

  1. cmd/grid.go

    	"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()
    	g, err := grid.NewManager(ctx, grid.ManagerOptions{
    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

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    // Package grid provides single-connection two-way grid communication.
    package grid
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"io"
    	"sync"
    	"time"
    
    	"github.com/gobwas/ws/wsutil"
    )
    
    // ErrDisconnected is returned when the connection to the remote has been lost during the call.
    var ErrDisconnected = RemoteErr("remote disconnected")
    
    const (
    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