- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 465 for Done (0.26 sec)
-
internal/ioutil/wait_pipe.go
// PipeWriter is similar to io.PipeWriter with wait group type PipeWriter struct { *io.PipeWriter once sync.Once done func() } // CloseWithError close with supplied error the writer end. func (w *PipeWriter) CloseWithError(err error) error { err = w.PipeWriter.CloseWithError(err) w.once.Do(func() { w.done() }) return err } // PipeReader is similar to io.PipeReader with wait group type PipeReader struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Viewed (0) -
cmd/batch-expire.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
internal/grid/muxclient.go
}() return } select { case <-m.ctx.Done(): if debugPrint { fmt.Println("Client sending disconnect to mux", m.MuxID) } m.addErrorNonBlockingClose(internalResp, context.Cause(m.ctx)) errState = true continue case req, ok := <-requests: if !ok { // Done send EOF if debugPrint { fmt.Println("Client done, sending EOF to mux", m.MuxID) } msg := message{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
helm-releases/minio-5.0.5.tgz
buckets: # # Name of the bucket # - name: bucket1 # # Policy to be set on the # # bucket [none|download|upload|public] # policy: none # # Purge if bucket exists already # purge: false # # set versioning for # # bucket [true|false] # versioning: false # # set objectlocking for # # bucket [true|false] NOTE: versioning is enabled by default if you use locking # objectlocking: false # - name: bucket2 # policy: none # purge: false # versioning: true # # set objectlocking for # # bucket [true|false] NOTE:...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 03 20:54:02 GMT 2023 - 20.3K bytes - Viewed (0) -
helm-releases/minio-5.0.7.tgz
buckets: # # Name of the bucket # - name: bucket1 # # Policy to be set on the # # bucket [none|download|upload|public] # policy: none # # Purge if bucket exists already # purge: false # # set versioning for # # bucket [true|false] # versioning: false # # set objectlocking for # # bucket [true|false] NOTE: versioning is enabled by default if you use locking # objectlocking: false # - name: bucket2 # policy: none # purge: false # versioning: true # # set objectlocking for # # bucket [true|false] NOTE:...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 13 10:37:23 GMT 2023 - 20.3K bytes - Viewed (0) -
helm-releases/minio-3.6.6.tgz
affinity: {} ## List of buckets to be created after minio install ## buckets: # # Name of the bucket # - name: bucket1 # # Policy to be set on the # # bucket [none|download|upload|public] # policy: none # # Purge if bucket exists already # purge: false # # set versioning for # # bucket [true|false] # versioning: false # - name: bucket2 # policy: none # purge: false # versioning: true ## Additional Annotations for the Kubernetes Job makeBucketJob makeBucketJob: podAnnotations: annotations: securityContext:...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 17 21:46:44 GMT 2022 - 18.2K bytes - Viewed (0) -
helm-releases/minio-4.0.0.tgz
affinity: {} ## List of buckets to be created after minio install ## buckets: # # Name of the bucket # - name: bucket1 # # Policy to be set on the # # bucket [none|download|upload|public] # policy: none # # Purge if bucket exists already # purge: false # # set versioning for # # bucket [true|false] # versioning: false # - name: bucket2 # policy: none # purge: false # versioning: true ## Additional Annotations for the Kubernetes Job makeBucketJob makeBucketJob: podAnnotations: annotations: securityContext:...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 26 02:41:39 GMT 2022 - 18K bytes - Viewed (0) -
helm-releases/minio-3.6.1.tgz
affinity: {} ## List of buckets to be created after minio install ## buckets: # # Name of the bucket # - name: bucket1 # # Policy to be set on the # # bucket [none|download|upload|public] # policy: none # # Purge if bucket exists already # purge: false # # set versioning for # # bucket [true|false] # versioning: false # - name: bucket2 # policy: none # purge: false # versioning: true ## Additional Annotations for the Kubernetes Job makeBucketJob makeBucketJob: podAnnotations: annotations: securityContext:...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 15 00:13:17 GMT 2022 - 17.9K bytes - Viewed (0) -
internal/http/listener.go
send := func(result acceptResult) bool { select { case listener.acceptCh <- result: // Successfully written to acceptCh return true case <-listener.ctx.Done(): return false } } // Closure to handle TCPListener until done channel is closed. handleListener := func(idx int, listener net.Listener) { for { conn, err := listener.Accept() send(acceptResult{conn, err, idx}) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
docs/bucket/replication/sio-error.sh
args1+=("http://localhost:$((9000 + i))/tmp/xl/1/$i ") args2+=("http://localhost:$((9100 + i))/tmp/xl/2/$i ") done for i in $(seq 1 $NODES); do ./minio server --address "127.0.0.1:$((9000 + i))" ${args1[@]} & # | tee /tmp/minio/node.$i & ./minio server --address "127.0.0.1:$((9100 + i))" ${args2[@]} & # | tee /tmp/minio/node.$i & done sleep 10 ./mc alias set myminio1 http://localhost:9001 minioadmin minioadmin
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 1.6K bytes - Viewed (0)