char - Code Search

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 {

Created: Sun Dec 28 19:28:13 GMT 2025

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

- 10K bytes

- Click Count (0)

github.com/minio/minio

cmd/data-scanner_test.go

			wantExpired: nil,
		},
	}
	for i, test := range tests {
		t.Run(fmt.Sprintf("TestApplyNewerNoncurrentVersionsLimit-%d", i), func(t *testing.T) {
			workers := []chan expiryOp{make(chan expiryOp)}
			es.workers.Store(&workers)
			workerReady := make(chan struct{})
			var wg sync.WaitGroup
			wg.Add(1)
			var gotExpired []ObjectToDelete
			go expiryWorker(&wg, workerReady, workers[0], &gotExpired)
			<-workerReady

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 12K bytes

- Click Count (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 }}

Created: Sun Dec 28 19:28:13 GMT 2025

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

- 936 bytes

- Click Count (0)

github.com/golang/go

.github/ISSUE_TEMPLATE/12-telemetry.yml

      A CL containing proposed changes to the
      [config.txt](https://go.googlesource.com/telemetry/+/master/internal/chartconfig/config.txt)
      chart configuration.
      See the [chartconfig](https://pkg.go.dev/golang.org/x/telemetry/internal/chartconfig)
      package for an explanation of the chart config format.
      For an example change, see [CL 564619](https://go.dev/cl/564619).
  validations:

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Tue May 07 19:58:26 GMT 2024

- 1.2K bytes

- Click Count (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 }}

Created: Sun Dec 28 19:28:13 GMT 2025

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

- 1.8K bytes

- Click Count (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)

Created: Sun Dec 28 19:28:13 GMT 2025

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

- 16.7K bytes

- Click Count (0)

github.com/minio/minio

internal/s3select/message.go

	getProgressFunc func() (int64, int64)
	bytesReturned   int64

	payloadBuffer      []byte
	payloadBufferIndex int
	payloadCh          chan *bytes.Buffer

	finBytesScanned, finBytesProcessed int64

	errCh  chan []byte
	doneCh chan struct{}
}

func (writer *messageWriter) write(data []byte) bool {
	if _, err := writer.writer.Write(data); err != nil {
		return false
	}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Feb 18 16:25:55 GMT 2025

- 15.3K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/de/docs/help-fastapi.md

Nutzen Sie den Chat nur für andere allgemeine Gespräche.

///

### Den Chat nicht für Fragen verwenden { #dont-use-the-chat-for-questions }

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sat Sep 20 15:10:09 GMT 2025

- 16.2K bytes

- Click Count (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'>

Created: Sun Dec 28 07:19:09 GMT 2025

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

- 1.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/namespace-lock_test.go

		// not be required but makes reproduction much easier.
		nsLk.lockMapMutex.Lock()

		// lk3 blocks.
		lk3ch := make(chan bool)
		go func() {
			lk3ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0)
		}()

		// lk4, blocks.
		lk4ch := make(chan bool)
		go func() {
			lk4ch <- nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 0)
		}()
		runtime.Gosched()

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 3K bytes

- Click Count (0)

Search Options