Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for Bainter (0.17 sec)

  1. internal/grid/muxserver.go

    	// The client will refill the tokens as they confirm delivery of the messages.
    	for i := 0; i < outboundCap; i++ {
    		m.outBlock <- struct{}{}
    	}
    
    	// Handler goroutine.
    	var handlerErr atomic.Pointer[RemoteErr]
    	go func() {
    		wg.Wait()
    		defer xioutil.SafeClose(send)
    		err := m.handleRequests(ctx, msg, send, handler, handlerIn)
    		if err != nil {
    			handlerErr.Store(err)
    		}
    	}()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  2. cmd/jwt.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v2/policy"
    )
    
    const (
    	jwtAlgorithm = "Bearer"
    
    	// Default JWT token for web handlers is one day.
    	defaultJWTExpiry = 24 * time.Hour
    
    	// Inter-node JWT token expiry is 15 minutes.
    	defaultInterNodeJWTExpiry = 15 * time.Minute
    )
    
    var (
    	errInvalidAccessKeyID = errors.New("The access key ID you provided does not exist in our records")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:14 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  3. internal/logger/target/http/http.go

    	defer atomic.AddInt64(&h.workers, -1)
    
    	h.wg.Add(1)
    	defer h.wg.Done()
    
    	entries := make([]interface{}, 0)
    	name := h.Name()
    
    	defer func() {
    		// re-load the global buffer pointer
    		// in case it was modified by a new target.
    		logChLock.Lock()
    		currentGlobalBuffer, ok := logChBuffers[name]
    		logChLock.Unlock()
    		if !ok {
    			return
    		}
    
    		for _, v := range entries {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  4. cmd/utils.go

    )
    
    // dump the request into a string in JSON format.
    func dumpRequest(r *http.Request) string {
    	header := r.Header.Clone()
    	header.Set("Host", r.Host)
    	// Replace all '%' to '%%' so that printer format parser
    	// to ignore URL encoded values.
    	rawURI := strings.ReplaceAll(r.RequestURI, "%", "%%")
    	req := struct {
    		Method     string      `json:"method"`
    		RequestURI string      `json:"reqURI"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  5. cmd/storage-rest_test.go

    	"reflect"
    	"runtime"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/grid"
    	xnet "github.com/minio/pkg/v2/net"
    )
    
    // Storage REST server, storageRESTReceiver and StorageRESTClient are
    // inter-dependent, below test functions are sufficient to test all of them.
    func testStorageAPIDiskInfo(t *testing.T, storage StorageAPI) {
    	testCases := []struct {
    		expectErr bool
    	}{
    		{true},
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 11.4K bytes
    - Viewed (0)
  6. CREDITS

    to attach them to the start of each source file to most effectively
    state the exclusion of warranty; and each file should have at least
    the "copyright" line and a pointer to where the full notice is found.
    
        <one line to give the program's name and a brief idea of what it does.>
        Copyright (C) <year>  <name of author>
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:31:35 GMT 2024
    - 1.6M bytes
    - Viewed (0)
Back to top