Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 313 for Join (0.07 sec)

  1. internal/logger/target/kafka/kafka.go

    	}
    	if err := h.init(); err != nil {
    		return err
    	}
    	go h.startKafkaLogger()
    	return nil
    }
    
    func (h *Target) initQueueStore(ctx context.Context) (err error) {
    	queueDir := filepath.Join(h.kconfig.QueueDir, h.Name())
    	queueStore := store.NewQueueStore[interface{}](queueDir, uint64(h.kconfig.QueueSize), kafkaLoggerExtension)
    	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
    - 10.2K bytes
    - Viewed (0)
  2. src/bytes/bytes_test.go

    			continue
    		}
    
    		if want := tt.a[len(tt.a)-1] + "z"; string(x) != want {
    			t.Errorf("last appended result was %s; want %s", x, want)
    		}
    
    		s := Join(a, []byte(tt.sep))
    		if string(s) != tt.s {
    			t.Errorf(`Join(Split(%q, %q, %d), %q) = %q`, tt.s, tt.sep, tt.n, tt.sep, s)
    		}
    		if tt.n < 0 {
    			b := sliceOfString(Split([]byte(tt.s), []byte(tt.sep)))
    			if !slices.Equal(result, b) {
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Aug 19 19:09:04 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  3. cmd/admin-handlers-site-replication.go

    }
    
    func getSRAddOptions(r *http.Request) (opts madmin.SRAddOptions) {
    	opts.ReplicateILMExpiry = r.Form.Get("replicateILMExpiry") == "true"
    	return
    }
    
    // SRPeerJoin - PUT /minio/admin/v3/site-replication/join
    //
    // used internally to tell current cluster to enable SR with
    // the provided peer clusters and service account.
    func (a adminAPIHandlers) SRPeerJoin(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  4. internal/logger/target/http/http.go

    	ctx, cancel := context.WithCancel(ctx)
    	h.storeCtxCancel = cancel
    	h.lastStarted = time.Now()
    	go h.startQueueProcessor(ctx, true)
    
    	queueStore := store.NewQueueStore[interface{}](
    		filepath.Join(h.config.QueueDir, h.Name()),
    		uint64(h.config.QueueSize),
    		httpLoggerExtension,
    	)
    
    	if err := queueStore.Open(); err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. internal/config/notify/legacy.go

    		},
    		config.KV{
    			Key: target.KafkaBrokers,
    			Value: func() string {
    				var brokers []string
    				for _, broker := range cfg.Brokers {
    					brokers = append(brokers, broker.String())
    				}
    				return strings.Join(brokers, config.ValueSeparator)
    			}(),
    		},
    		config.KV{
    			Key:   target.KafkaTopic,
    			Value: cfg.Topic,
    		},
    		config.KV{
    			Key:   target.KafkaQueueDir,
    			Value: cfg.QueueDir,
    		},
    		config.KV{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  6. internal/event/target/nats.go

    // NewNATSTarget - creates new NATS target.
    func NewNATSTarget(id string, args NATSArgs, loggerOnce logger.LogOnce) (*NATSTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-nats-"+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
    - 12.9K bytes
    - Viewed (0)
  7. src/archive/tar/format.go

    		if f.has(f2) {
    			ss = append(ss, formatNames[f2])
    		}
    	}
    	switch len(ss) {
    	case 0:
    		return "<unknown>"
    	case 1:
    		return ss[0]
    	default:
    		return "(" + strings.Join(ss, " | ") + ")"
    	}
    }
    
    // Magics used to identify various formats.
    const (
    	magicGNU, versionGNU     = "ustar ", " \x00"
    	magicUSTAR, versionUSTAR = "ustar\x00", "00"
    	trailerSTAR              = "tar\x00"
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  8. src/bytes/example_test.go

    	fmt.Println(bytes.IndexRune([]byte("chicken"), 'd'))
    	// Output:
    	// 4
    	// -1
    }
    
    func ExampleJoin() {
    	s := [][]byte{[]byte("foo"), []byte("bar"), []byte("baz")}
    	fmt.Printf("%s", bytes.Join(s, []byte(", ")))
    	// Output: foo, bar, baz
    }
    
    func ExampleLastIndex() {
    	fmt.Println(bytes.Index([]byte("go gopher"), []byte("go")))
    	fmt.Println(bytes.LastIndex([]byte("go gopher"), []byte("go")))
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Aug 07 17:22:36 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  9. helm-releases/minio-4.0.11.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: Sun Aug 07 05:41:47 UTC 2022
    - 19.2K bytes
    - Viewed (0)
  10. helm-releases/minio-4.0.2.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: Mon May 09 04:25:47 UTC 2022
    - 18K bytes
    - Viewed (0)
Back to top