Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 313 for Join (0.21 sec)

  1. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/taglib/FessFunctions.java

            if (StringUtil.isBlank(input)) {
                return input;
            }
            return ComponentUtil.getDocumentHelper().encodeSimilarDocHash(input);
        }
    
        public static String join(final Object input) {
            String[] values = null;
            if (input instanceof String[]) {
                values = (String[]) input;
            } else if (input instanceof List) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  4. docs/debugging/xl-meta/main.go

    							}
    
    							var buf bytes.Buffer
    							if err := rs.Join(&buf, splitFilled, m.size); err == nil {
    								m.filled = buf.Bytes()
    							}
    							buf = bytes.Buffer{}
    							if err := rs.Join(&buf, splitData, m.size); err == nil {
    								m.mapped = buf.Bytes()
    							}
    							for i, v := range m.filled {
    								if v == 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  5. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Apr 12 01:30:28 UTC 2022
    - 17.9K bytes
    - Viewed (0)
  6. internal/config/config.go

    	}
    
    	kvs := KVS{}
    	var prevK string
    	for _, v := range fields {
    		kv := strings.SplitN(v, KvSeparator, 2)
    		if len(kv) == 0 {
    			continue
    		}
    		if len(kv) == 1 && prevK != "" {
    			value := strings.Join([]string{
    				kvs.Get(prevK),
    				madmin.SanitizeValue(kv[0]),
    			}, KvSpaceSeparator)
    			kvs.Set(prevK, value)
    			continue
    		}
    		if len(kv) == 2 {
    			prevK = kv[0]
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/helper/SearchHelper.java

                builder.setSize(fessConfig.getPagingSearchPageMaxSizeAsInteger());
                builder.setFetchSource(fields, null);
                queryHelper.processSearchPreference(builder, userBean, String.join(StringUtil.EMPTY, docIds));
                return true;
            });
        }
    
        public boolean update(final String id, final String field, final Object value) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  8. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  9. fastapi/openapi/docs.py

                }
    
                arr = qp.split("&");
                arr.forEach(function (v,i,_arr) { _arr[i] = '"' + v.replace('=', '":"') + '"';});
                qp = qp ? JSON.parse('{' + arr.join() + '}',
                        function (key, value) {
                            return key === "" ? value : decodeURIComponent(value);
                        }
                ) : {};
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Thu May 23 22:59:02 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. internal/event/target/mqtt.go

    	}
    
    	if args.KeepAlive == 0 {
    		args.KeepAlive = 10 * time.Second
    	}
    
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-mqtt-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
Back to top