Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 485 for Worker (0.18 sec)

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

    	sconfig.Metadata.Retry.Backoff = (10 * time.Second)
    	sconfig.Metadata.RefreshFrequency = (15 * time.Minute)
    
    	h.config = sconfig
    
    	var brokers []string
    	for _, broker := range h.kconfig.Brokers {
    		brokers = append(brokers, broker.String())
    	}
    
    	client, err := sarama.NewClient(brokers, sconfig)
    	if err != nil {
    		return err
    	}
    
    	producer, err := sarama.NewSyncProducerFromClient(client)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  2. internal/lsync/lrwmutex.go

    	lm.mu.Lock()
    	defer lm.mu.Unlock()
    
    	lm.ref = 0
    	lm.isWriteLock = false
    }
    
    // DRLocker returns a sync.Locker interface that implements
    // the Lock and Unlock methods by calling drw.RLock and drw.RUnlock.
    func (lm *LRWMutex) DRLocker() sync.Locker {
    	return (*drlocker)(lm)
    }
    
    type drlocker LRWMutex
    
    func (dr *drlocker) Lock()   { (*LRWMutex)(dr).RLock() }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  3. .github/workflows/mint/minio-compress-encrypt.yaml

        MINIO_KMS_SECRET_KEY: "my-minio-key:OSMM+vkKUTCvQs9YL/CVMIMt43HFhkUpqJxTmGl6rYw="
      healthcheck:
        test: ["CMD", "mc", "ready", "local"]
        interval: 5s
        timeout: 5s
        retries: 5
    
    # starts 4 docker containers running minio server instances.
    # using nginx reverse proxy, load balancing, you can access
    # it through port 9000.
    services:
      minio1:
        <<: *minio-common
        hostname: minio1
        volumes:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Nov 03 21:18:18 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  4. .github/workflows/mint/minio-resiliency.yaml

        MINIO_DRIVE_MAX_TIMEOUT: "5s"
      healthcheck:
        test: ["CMD", "mc", "ready", "local"]
        interval: 5s
        timeout: 5s
        retries: 5
    
    # starts 4 docker containers running minio server instances.
    # using nginx reverse proxy, load balancing, you can access
    # it through port 9000.
    services:
      minio1:
        <<: *minio-common
        hostname: minio1
        volumes:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  5. docs/ja/llm-prompt.md

    ### Headings
    
    1) Follow the existing Japanese style: short, descriptive headings (often noun phrases), e.g. 「チェック」.
    2) Do not add a trailing period at the end of headings.
    
    ### Quotes
    
    1) Prefer Japanese corner brackets 「」 in normal prose when quoting a term.
    2) Do not change quotes inside inline code, code blocks, URLs, or file paths.
    
    ### Ellipsis
    
    1) Keep ellipsis style consistent with existing Japanese docs (commonly `...`).
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 20 17:30:52 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  6. docs/en/docs/fastapi-people.md

    {% endfor %}
    {% endif %}
    
    {% if sponsors.silver %}
    
    ### Silver Sponsors
    
    {% for sponsor in sponsors.silver -%}
    <a href="{{ sponsor.url }}" target="_blank" title="{{ sponsor.title }}"><img src="{{ sponsor.img }}" style="border-radius:15px"></a>
    {% endfor %}
    {% endif %}
    
    {% if sponsors.bronze %}
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Jan 28 20:34:56 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  7. internal/dsync/drwmutex.go

    	locks := make([]string, len(restClnts))
    
    	// Add total timeout
    	ctx, cancel := context.WithTimeout(ctx, opts.Timeout)
    	defer cancel()
    
    	// Tolerance is not set, defaults to half of the locker clients.
    	tolerance := len(restClnts) / 2
    
    	// Quorum is effectively = total clients subtracted with tolerance limit
    	quorum := len(restClnts) - tolerance
    	if !isReadLock {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  8. docs/config/README.md

    # MinIO Server Config Guide [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![Docker Pulls](https://img.shields.io/docker/pulls/minio/minio.svg?maxAge=604800)](https://hub.docker.com/r/minio/minio/)
    
    ## Configuration Directory
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.1K bytes
    - Viewed (1)
  9. docs/distributed/README.md

    # Distributed MinIO Quickstart Guide [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![Docker Pulls](https://img.shields.io/docker/pulls/minio/minio.svg?maxAge=604800)](https://hub.docker.com/r/minio/minio/)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  10. docs/fr/docs/advanced/index.md

    un cours pour débutants avancés pour compléter cette section de la documentation, vous pouvez consulter : <a href="https://testdrive.io/courses/tdd-fastapi/" class="external- link" target="_blank">Développement piloté par les tests avec FastAPI et Docker</a> par **TestDriven.io**.
    
    10 % de tous les bénéfices de ce cours sont reversés au développement de **FastAPI**. 🎉 😄...
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 1.3K bytes
    - Viewed (0)
Back to top