char - Code Search

helm/minio/templates/configmap.yaml

apiVersion: v1
kind: ConfigMap
metadata:
  name: {{ template "minio.fullname" . }}
  labels:
    app: {{ template "minio.name" . }}
    chart: {{ template "minio.chart" . }}
    release: {{ .Release.Name }}
    heritage: {{ .Release.Service }}
data:
  initialize: |-
    {{- include (print $.Template.BasePath "/_helper_create_bucket.txt") . | nindent 4 }}
  add-user: |-

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Mon Apr 17 06:04:15 UTC 2023

- 1.2K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/drwmutex_test.go

func doTestParallelReaders(numReaders, gomaxprocs int) {
	runtime.GOMAXPROCS(gomaxprocs)
	m := NewDRWMutex(ds, "test-parallel")

	clocked := make(chan bool)
	cunlock := make(chan bool)
	cdone := make(chan bool)
	for range numReaders {
		go parallelReader(context.Background(), m, clocked, cunlock, cdone)
	}
	// Wait for all parallel RLock()s to succeed.
	for range numReaders {
		<-clocked
	}
	for range numReaders {

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 9.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/metrics.go

	desc *prometheus.Desc
}

// Describe sends the super-set of all possible descriptors of metrics
func (c *minioCollector) Describe(ch chan<- *prometheus.Desc) {
	ch <- c.desc
}

// Collect is called by the Prometheus registry when collecting metrics.
func (c *minioCollector) Collect(ch chan<- prometheus.Metric) {
	// Expose MinIO's version information
	minioVersionInfo.WithLabelValues(Version, CommitID).Set(1.0)

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Fri Oct 24 04:06:31 UTC 2025

- 16.7K bytes

- Viewed (0)

github.com/minio/minio

helm/minio/templates/ciliumnetworkpolicy.yaml

kind: CiliumNetworkPolicy
apiVersion: cilium.io/v2
metadata:
  name: {{ template "minio.fullname" . }}
  labels:
    app: {{ template "minio.name" . }}
    chart: {{ template "minio.chart" . }}
    release: {{ .Release.Name }}
    heritage: {{ .Release.Service }}
spec:
  endpointSelector:
    matchLabels:
      app: {{ template "minio.name" . }}
      release: {{ .Release.Name }}

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Fri Apr 26 07:50:24 UTC 2024

- 936 bytes

- Viewed (0)

github.com/minio/minio

helm/minio/templates/console-service.yaml

{{ $scheme := .Values.tls.enabled | ternary "https" "http" }}
apiVersion: v1
kind: Service
metadata:
  name: {{ template "minio.fullname" . }}-console
  labels:
    app: {{ template "minio.name" . }}
    chart: {{ template "minio.chart" . }}
    release: {{ .Release.Name }}
    heritage: {{ .Release.Service }}
  {{- if .Values.consoleService.annotations }}
  annotations: {{- toYaml .Values.consoleService.annotations | nindent 4 }}
  {{- end }}

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Apr 28 10:05:53 UTC 2024

- 1.8K bytes

- Viewed (0)

github.com/minio/minio

internal/s3select/simdj/reader.go

)

// Reader - JSON record reader for S3Select.
type Reader struct {
	args    *json.ReaderArgs
	input   chan simdjson.Stream
	decoded chan simdjson.Object

	// err will only be returned after decoded has been closed.
	err          *error
	readCloser   io.ReadCloser
	onReaderExit func()

	exitReader chan struct{}
	readerWg   sync.WaitGroup
}

// Read - reads single record.

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Tue May 30 17:02:22 UTC 2023

- 4.9K bytes

- Viewed (0)

github.com/minio/minio

internal/event/target/amqp.go

		confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1))
		if err := ch.Confirm(false); err != nil {
			ch.Close()
			return nil, nil, err
		}
		return ch, confirms, nil
	}

	return ch, nil, nil
}

// send - sends an event to the AMQP091.
func (target *AMQPTarget) send(eventData event.Event, ch *amqp091.Channel, confirms chan amqp091.Confirmation) error {

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Thu Aug 21 04:25:07 UTC 2025

- 10K bytes

- Viewed (0)

github.com/minio/minio

internal/lsync/lrwmutex_test.go

	if m.GetRLock(ctx, "", "", time.Second) {
		clocked <- true
		<-cunlock
		m.RUnlock()
		cdone <- true
	}
}

// Borrowed from rwmutex_test.go
func doTestParallelReaders(numReaders, gomaxprocs int) {
	runtime.GOMAXPROCS(gomaxprocs)
	m := NewLRWMutex()

	clocked := make(chan bool)
	cunlock := make(chan bool)
	cdone := make(chan bool)

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 7.8K bytes

- Viewed (0)

github.com/minio/minio

helm/minio/templates/servicemonitor.yaml

  {{- if .Values.metrics.serviceMonitor.namespace }}
  namespace: {{ .Values.metrics.serviceMonitor.namespace }}
  {{- end }}
  labels:
    app: {{ template "minio.name" . }}
    chart: {{ template "minio.chart" . }}
    release: {{ .Release.Name }}
    heritage: {{ .Release.Service }}
    {{- if .Values.metrics.serviceMonitor.additionalLabels }}
      {{- toYaml .Values.metrics.serviceMonitor.additionalLabels | nindent 4 }}

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Mon Apr 17 06:04:15 UTC 2023

- 3.8K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial001_py39.py

from fastapi import FastAPI, WebSocket
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>
            <button>Send</button>
        </form>
        <ul id='messages'>

Registered: Sun Dec 28 07:19:09 UTC 2025

- Last Modified: Wed Dec 17 20:41:43 UTC 2025

- 1.4K bytes

- Viewed (0)

Search Options