char - Code Search

docs_src/websockets_/tutorial003_py310.py

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

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <h2>Your ID: <span id="ws-id"></span></h2>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Feb 27 12:34:37 GMT 2026

- 2.5K bytes

- Click Count (0)

github.com/minio/minio

docs/orchestration/kubernetes/README.md

- Helm Chart: MinIO Helm Chart offers customizable and easy MinIO deployment with a single command. Refer [MinIO Helm Chart documentation](https://github.com/minio/minio/tree/master/helm/minio) for more details.

## Monitoring MinIO in Kubernetes

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue Aug 12 18:20:36 GMT 2025

- 1.6K bytes

- Click Count (0)

github.com/minio/minio

cmd/background-heal-ops.go

	opts      madmin.HealOpts
	// Healing response will be sent here
	respCh chan healResult
}

// healResult represents a healing result with a possible error
type healResult struct {
	result madmin.HealResultItem
	err    error
}

// healRoutine receives heal tasks, to heal buckets, objects and format.json
type healRoutine struct {
	tasks   chan healTask
	workers int
}

func activeListeners() int {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue May 27 15:19:03 GMT 2025

- 4.6K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/entity/ChatMessage.java

 */
package org.codelibs.fess.entity;

import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * Represents a message in a chat conversation.
 *
 * @author FessProject
 */
public class ChatMessage implements Serializable {

    private static final long serialVersionUID = 1L;

    /** The role identifier for user messages. */

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Mar 12 04:52:31 GMT 2026

- 10.1K bytes

- Click Count (0)

github.com/minio/minio

cmd/shared-lock.go

)

var sharedLockTimeout = newDynamicTimeoutWithOpts(dynamicTimeoutOpts{
	timeout:       30 * time.Second,
	minimum:       10 * time.Second,
	retryInterval: time.Minute,
})

type sharedLock struct {
	lockContext chan LockContext
}

func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) {
	for {
		locker := objAPI.NewNSLock(minioMetaBucket, lockName)

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Mon Feb 13 09:26:38 GMT 2023

- 2.3K bytes

- Click Count (0)

github.com/minio/minio

helm/minio/values.yaml

    # nginx.ingress.kubernetes.io/whitelist-source-range: 0.0.0.0/0
  path: /
  hosts:
    - minio-example.local
  tls: []
  #  - secretName: chart-example-tls
  #    hosts:
  #      - chart-example.local

consoleService:
  type: ClusterIP
  clusterIP: ~
  port: "9001"
  nodePort: 32001
  loadBalancerIP: ~
  externalIPs: []
  annotations: {}

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue Aug 12 18:20:36 GMT 2025

- 19.7K bytes

- Click Count (1)

github.com/minio/minio

internal/dsync/dsync_test.go

}

// Borrowed from mutex_test.go
func HammerMutex(m *DRWMutex, loops int, cdone chan bool) {
	for range loops {
		m.Lock(id, source)
		m.Unlock(context.Background())
	}
	cdone <- true
}

// Borrowed from mutex_test.go
func TestMutex(t *testing.T) {
	loops := 200
	if testing.Short() {
		loops = 5
	}
	c := make(chan bool)
	m := NewDRWMutex(ds, "test")
	for range 10 {
		go HammerMutex(m, loops, c)

Created: Sun Apr 05 19:28:12 GMT 2026

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

- 10.8K bytes

- Click Count (0)

github.com/minio/minio

helm/minio/templates/secrets.yaml

{{- if not .Values.existingSecret }}
apiVersion: v1
kind: Secret
metadata:
  name: {{ template "minio.secretName" . }}
  labels:
    app: {{ template "minio.name" . }}
    chart: {{ template "minio.chart" . }}
    release: {{ .Release.Name }}
    heritage: {{ .Release.Service }}
type: Opaque
data:
  rootUser: {{ include "minio.root.username" . | b64enc | quote }}
  rootPassword: {{ include "minio.root.password" . | b64enc | quote }}

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Wed Apr 12 04:09:29 GMT 2023

- 706 bytes

- Click Count (0)

github.com/minio/minio

internal/grid/stream.go

	// All responses *must* be read by the caller until either an error is returned or the channel is closed.
	// Canceling the context will cause the context cancellation error to be returned.
	responses <-chan Response
	cancel    context.CancelCauseFunc

	// Requests sent to the server.
	// If the handler is defined with 0 incoming capacity this will be nil.
	// Channel *must* be closed to signal the end of the stream.

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Jun 07 15:51:52 GMT 2024

- 3.1K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets_/tutorial002_an_py310.py

    WebSocketException,
    status,
)
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)">
            <label>Item ID: <input type="text" id="itemId" autocomplete="off" value="foo"/></label>

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Feb 27 12:34:37 GMT 2026

- 2.8K bytes

- Click Count (0)

Search Options