ctype - Code Search

docs_src/websockets/tutorial003.py

    <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"/>
            <button>Send</button>
        </form>
        <ul id='messages'>
        </ul>
        <script>
            var client_id = Date.now()

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Sun Aug 09 13:52:19 UTC 2020

- 2.5K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/PublicApi.kt

package gradlebuild.basics

import java.util.regex.Pattern


/**
 * This is the definition of what constitutes the Gradle public API.
 *
 * A type is part of the Gradle public API if and only if its FQCN matches {@link #includes} and does not match {@link #excludes}.
 */
// NOTE: If you update this, please also change .idea/scopes/Gradle_public_API.xml
object PublicApi {
    val includes = listOf(
        "org/gradle/*",

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Wed Jun 12 23:20:08 UTC 2024

- 2.4K bytes

- Viewed (0)

github.com/istio/istio

common/scripts/check_clean_repo.sh

    [ -n "${JOB_NAME}" ] && [ -n "${BUILD_ID}" ]
    # shellcheck disable=SC2319
    IN_PROW="$?"

    # Don't persist large diffs (30M+) on CI
    LARGE_FILE="$(find "${ARTIFACTS}" -name "${PATCH_NAME}" -type 'f' -size +30M)"
    if [ "${IN_PROW}" -eq 0 ] && [ -n "${LARGE_FILE}" ]; then
      rm "${PATCH_OUT}"
      echo "WARNING: patch file was too large to persist ($(du -h "${PATCH_OUT}"))"
      return 0
    fi

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Thu Jun 27 16:44:16 UTC 2024

- 1.7K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/dsync-server_test.go

)

func getLockArgs(r *http.Request) (args LockArgs, err error) {
	buf, err := io.ReadAll(r.Body)
	if err != nil {
		return args, err
	}
	_, err = args.UnmarshalMsg(buf)
	return args, err
}

type lockServerHandler struct {
	lsrv *lockServer
}

func (lh *lockServerHandler) writeErrorResponse(w http.ResponseWriter, err error) {
	w.WriteHeader(http.StatusForbidden)
	w.Write([]byte(err.Error()))
}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Jan 23 16:46:37 UTC 2023

- 8.3K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/dcerpc/DcerpcBind.java


    DcerpcBind ( DcerpcBinding binding, DcerpcHandle handle ) {
        this.binding = binding;
        this.max_xmit = handle.getMaxXmit();
        this.max_recv = handle.getMaxRecv();
        this.ptype = 11;
        this.flags = DCERPC_FIRST_FRAG | DCERPC_LAST_FRAG;
    }


    @Override
    public int getOpnum () {
        return 0;
    }


    @Override

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Sun Jul 01 13:12:10 UTC 2018

- 3.4K bytes

- Viewed (0)

github.com/minio/minio

docs/metrics/prometheus/grafana/README.md

# How to monitor MinIO server with Grafana [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io)

[Grafana](https://grafana.com/) allows you to query, visualize, alert on and understand your metrics no matter where they are stored. Create, explore, and share dashboards with your team and foster a data driven culture.

## Prerequisites

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Thu Oct 31 17:38:53 UTC 2024

- 2.4K bytes

- Viewed (0)

github.com/minio/minio

internal/bucket/bandwidth/measurement.go

const (
	// betaBucket is the weight used to calculate exponential moving average
	betaBucket = 0.1 // Number of averages considered = 1/(1-betaObject)
)

// bucketMeasurement captures the bandwidth details for one bucket
type bucketMeasurement struct {
	lock                 sync.Mutex
	bytesSinceLastWindow uint64    // Total bytes since last window was processed
	startTime            time.Time // Start time for window

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Sat Jun 03 20:41:51 UTC 2023

- 2.9K bytes

- Viewed (0)

github.com/apache/maven

api/maven-api-core/src/main/java/org/apache/maven/api/JavaToolchain.java

 */
package org.apache.maven.api;

import org.apache.maven.api.annotations.Experimental;

/**
 * Represents a Java toolchain in the Maven build system.
 *
 * <p>A Java toolchain is a specific type of toolchain that provides access
 * to Java development tools, such as the Java compiler and Java runtime
 * environment. This interface allows users to define and configure

Registered: Sun Nov 03 03:35:11 UTC 2024

- Last Modified: Tue Aug 27 21:13:34 UTC 2024

- 1.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/peer-rest-common.go

	peerRESTUser            = "user"
	peerRESTGroup           = "group"
	peerRESTUserTemp        = "user-temp"
	peerRESTPolicy          = "policy"
	peerRESTUserOrGroup     = "user-or-group"
	peerRESTUserType        = "user-type"
	peerRESTIsGroup         = "is-group"
	peerRESTSignal          = "signal"
	peerRESTSubSys          = "sub-sys"
	peerRESTProfiler        = "profiler"
	peerRESTSize            = "size"

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Sep 09 16:58:30 UTC 2024

- 3K bytes

- Viewed (0)

github.com/minio/minio

internal/config/ilm/ilm.go

	config.KV{
		Key:   transitionWorkers,
		Value: "100",
	},
	config.KV{
		Key:   expirationWorkers,
		Value: "100",
	},
}

// Config represents the different configuration values for ILM subsystem
type Config struct {
	TransitionWorkers int
	ExpirationWorkers int
}

// LookupConfig - lookup ilm config and override with valid environment settings if any.
func LookupConfig(kvs config.KVS) (cfg Config, err error) {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri May 24 23:05:23 UTC 2024

- 1.9K bytes

- Viewed (0)

Search Options