Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 250 for sekunt (0.11 sec)

  1. cmd/signature-v4-utils.go

    		}
    		if ok {
    			extractedSignedHeaders[http.CanonicalHeaderKey(header)] = val
    			continue
    		}
    		switch header {
    		case "expect":
    			// Golang http server strips off 'Expect' header, if the
    			// client sent this as part of signed headers we need to
    			// handle otherwise we would see a signature mismatch.
    			// `aws-cli` sets this as part of signed headers.
    			//
    			// According to
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  2. internal/s3select/csv/reader.go

    	readerWg     sync.WaitGroup   // used to keep track of async reader.
    }
    
    // queueItem is an item in the queue.
    type queueItem struct {
    	input []byte          // raw input sent to the worker
    	dst   chan [][]string // result of block decode
    	err   error           // any error encountered will be set here
    }
    
    // Read - reads single record.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. internal/event/target/amqp.go

    		return err
    	}
    	defer ch.Close()
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData, ch, confirms); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. internal/event/target/kafka_scram_client_contrib.go

    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 09 04:04:01 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  5. cmd/bucket-versioning-handler.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/policy"
    )
    
    const (
    	bucketVersioningConfig = "versioning.xml"
    
    	// Maximum size of bucket versioning configuration payload sent to the PutBucketVersioningHandler.
    	maxBucketVersioningConfigSize = 1 * humanize.MiByte
    )
    
    // PutBucketVersioningHandler - PUT Bucket Versioning.
    // ----------
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. internal/event/target/nats.go

    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

          assertThat(queueSize).isBetween(0L, messageCount * message.size)
          // Expect to fail before enqueueing 32 MiB.
          assertThat(messageCount).isLessThan(32L)
        }
    
        // Confirm all sent messages were received, followed by a client-initiated close.
        val server = serverListener.assertOpen()
        for (i in 0 until messageCount) {
          serverListener.assertBinaryMessage(message)
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

                        logger.info("Sent {} docs (Doc:{process {}ms, send {}ms, size {}}, {})", docList.size(), docList.getProcessingTime(),
                                systemHelper.getCurrentTimeAsLong() - execTime, MemoryUtil.byteCountToDisplaySize(docList.getContentSize()),
                                MemoryUtil.getMemoryUsageLog());
                    } else {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  9. cmd/signature-v2.go

    //
    // returns ErrNone if matches. S3 errors otherwise.
    func doesPresignV2SignatureMatch(r *http.Request) APIErrorCode {
    	// r.RequestURI will have raw encoded URI as sent by the client.
    	tokens := strings.SplitN(r.RequestURI, "?", 2)
    	encodedResource := tokens[0]
    	encodedQuery := ""
    	if len(tokens) == 2 {
    		encodedQuery = tokens[1]
    	}
    
    	var (
    		filteredQueries []string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  10. cmd/handler-utils.go

    	cred, _, _ = getReqAccessKeyV4(r, region, serviceS3)
    	if cred.AccessKey == "" {
    		cred, _, _ = getReqAccessKeyV2(r)
    	}
    	return cred
    }
    
    // Extract request params to be sent with event notification.
    func extractReqParams(r *http.Request) map[string]string {
    	if r == nil {
    		return nil
    	}
    
    	region := globalSite.Region()
    	cred := getReqAccessCred(r, region)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
Back to top