- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 485 for Worker (0.04 sec)
-
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) -
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) -
.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) -
.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) -
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) -
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) -
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) -
docs/config/README.md
# MinIO Server Config Guide [](https://slack.min.io) [](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) -
docs/distributed/README.md
# Distributed MinIO Quickstart Guide [](https://slack.min.io) [](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) -
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)