Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 547 for joins (0.04 sec)

  1. src/bytes/bytes.go

    	a := make([][]byte, len(spans))
    	for i, span := range spans {
    		a[i] = s[span.start:span.end:span.end]
    	}
    
    	return a
    }
    
    // Join concatenates the elements of s to create a new byte slice. The separator
    // sep is placed between elements in the resulting slice.
    func Join(s [][]byte, sep []byte) []byte {
    	if len(s) == 0 {
    		return []byte{}
    	}
    	if len(s) == 1 {
    		// Just return a copy.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 35.6K bytes
    - Viewed (0)
  2. cmd/data-scanner-metric.go

    			p.latency[s].add(duration)
    		}
    
    		if s > scannerMetricStartTrace && globalTrace.NumSubscribers(madmin.TraceScanner) > 0 {
    			globalTrace.Publish(scannerTrace(s, startTime, duration, strings.Join(paths, " "), custom))
    		}
    	}
    }
    
    // time a scanner action.
    // Use for s < scannerMetricLastRealtime
    func (p *scannerMetrics) time(s scannerMetric) func() {
    	startTime := time.Now()
    	return func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 25 05:15:31 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  3. cni/pkg/plugin/sidecar_redirect.go

    		redir.excludeInboundPorts += ","
    	}
    	redir.excludeInboundPorts += "15020,15021,15090"
    	redir.excludeInboundPorts = strings.Join(dedupPorts(splitPorts(redir.excludeInboundPorts)), ",")
    	isFound, redir.excludeInterfaces, valErr = getAnnotationOrDefault("excludeInterfaces", pi.Annotations)
    	if valErr != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. helm-releases/minio-3.6.4.tgz

    -}} {{- $statements_length := sub $statements_length 1 -}} { "Version": "2012-10-17", "Statement": [ {{- range $i, $statement := .statements }} { "Effect": "Allow", "Action": [ "{{ $statement.actions | join "\",\n\"" }}" ]{{ if $statement.resources }}, "Resource": [ "{{ $statement.resources | join "\",\n\"" }}" ]{{ end }} }{{ if lt $i $statements_length }},{{end }} {{- end }} ] } minio/templates/_helpers.tpl {{/* vim: set filetype=mustache: */}} {{/* Expand the name of the chart. */}} {{- define...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Apr 12 01:30:28 UTC 2022
    - 17.9K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

                final InputStreamThread it = new InputStreamThread(currentProcess.getInputStream(), commandOutputEncoding, maxOutputLine);
                it.start();
    
                currentProcess.waitFor();
                it.join(5000);
    
                if (mt.isTeminated()) {
                    throw new ExecutionTimeoutException("The command execution is timeout: " + cmdList);
                }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. internal/event/target/amqp.go

    // NewAMQPTarget - creates new AMQP target.
    func NewAMQPTarget(id string, args AMQPArgs, loggerOnce logger.LogOnce) (*AMQPTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-amqp-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); 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)
  7. internal/store/queuestore_test.go

    	"fmt"
    	"os"
    	"path/filepath"
    	"reflect"
    	"testing"
    )
    
    type TestItem struct {
    	Name     string `json:"Name"`
    	Property string `json:"property"`
    }
    
    var (
    	// TestDir
    	queueDir = filepath.Join(os.TempDir(), "minio_test")
    	// Sample test item.
    	testItem = TestItem{Name: "test-item", Property: "property"}
    	// Ext for test item
    	testItemExt = ".test"
    )
    
    // Initialize the queue store.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. cmd/signature-v4-utils.go

    func signV4TrimAll(input string) string {
    	// Compress adjacent spaces (a space is determined by
    	// unicode.IsSpace() internally here) to one space and return
    	return strings.Join(strings.Fields(input), " ")
    }
    
    // checkMetaHeaders will check if the metadata from header/url is the same with the one from signed headers
    func checkMetaHeaders(signedHeadersMap http.Header, r *http.Request) APIErrorCode {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

      // clean up these threads.
      @SuppressWarnings("deprecation")
      @Override
      public void tearDown() throws Exception {
        stop();
        join();
    
        if (uncaughtThrowable != null) {
          throw new AssertionError("Uncaught throwable in " + getName(), uncaughtThrowable);
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  10. cmd/ftp-server-driver.go

    func (m *ftpMetrics) log(s *ftp.Context, paths ...string) func(sz int64, err error) {
    	startTime := time.Now()
    	source := getSource(2)
    	return func(sz int64, err error) {
    		globalTrace.Publish(ftpTrace(s, startTime, source, strings.Join(paths, " "), err, sz))
    	}
    }
    
    // Stat implements ftpDriver
    func (driver *ftpDriver) Stat(ctx *ftp.Context, objPath string) (fi os.FileInfo, err error) {
    	stopFn := globalFtpMetrics.log(ctx, objPath)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
Back to top