- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for selector (0.17 sec)
-
helm/minio/templates/statefulset.yaml
spec: publishNotReadyAddresses: true clusterIP: None ports: - name: {{ $scheme }} port: {{ .Values.service.port }} protocol: TCP targetPort: {{ .Values.minioAPIPort }} selector: app: {{ template "minio.name" . }} release: {{ .Release.Name }} --- apiVersion: {{ template "minio.statefulset.apiVersion" . }} kind: StatefulSet metadata: name: {{ template "minio.fullname" . }}
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 07:50:24 GMT 2024 - 10.7K bytes - Viewed (0) -
helm/minio/values.yaml
tls: [] # - secretName: chart-example-tls # hosts: # - chart-example.local ## Node labels for pod assignment ## Ref: https://kubernetes.io/docs/user-guide/node-selection/ ## nodeSelector: {} tolerations: [] affinity: {} topologySpreadConstraints: [] ## Add stateful containers to have security context, if enabled MinIO will run as this
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 10:14:37 GMT 2024 - 18.4K bytes - Viewed (0) -
helm/minio/templates/console-service.yaml
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 10:05:53 GMT 2024 - 1.8K bytes - Viewed (0) -
helm/minio/templates/service.yaml
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 10:05:53 GMT 2024 - 1.7K bytes - Viewed (0) -
cmd/storage-rest-server.go
// Initiate ticker after body has been read. ticker := time.NewTicker(time.Second * 10) defer ticker.Stop() for { select { case <-ticker.C: // The done() might have been called // concurrently, check for it before we // write the filler byte. select { case err := <-doneCh: if err != nil { write([]byte{1}) write([]byte(err.Error())) } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
internal/grid/grid_test.go
Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr { // Send many responses. // Test that this doesn't block. for i := byte(0); i < 100; i++ { select { case resp <- []byte{i}: // ok case <-ctx.Done(): return NewRemoteErr(ctx.Err()) } if i == 0 { close(serverSent) } } return nil },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/metacache-entries.go
if selected != nil && selected.isDir() && dirExists >= r.dirQuorum { return selected, true } // If we would never be able to reach read quorum. if objsValid < r.objQuorum { return nil, false } // If all objects agree. if selected != nil && objsAgree == objsValid { return selected, true } // If cached is nil we shall skip the entry. if selected.cached == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/storage-rest-client.go
Cache: &cache, }) if err != nil { return cache, toStorageErr(err) } var final *dataUsageCache err = st.Results(func(resp *nsScannerResp) error { if resp.Update != nil { select { case <-ctx.Done(): case updates <- *resp.Update: } } if resp.Final != nil { final = resp.Final } // We can't reuse the response since it is sent upstream. return nil })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
diffCh, err := getReplicationDiff(ctx, objectAPI, bucket, opts) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } enc := json.NewEncoder(w) for { select { case entry, ok := <-diffCh: if !ok { return } if err := enc.Encode(entry); err != nil { return } if len(diffCh) == 0 { // Flush if nothing is queued
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
internal/event/target/postgresql.go
"github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v2/net" ) const ( psqlTableExists = `SELECT 1 FROM %s;` psqlCreateNamespaceTable = `CREATE TABLE %s (key VARCHAR PRIMARY KEY, value JSONB);` psqlCreateAccessTable = `CREATE TABLE %s (event_time TIMESTAMP WITH TIME ZONE NOT NULL, event_data JSONB);`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0)