tape - Code Search

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)

github.com/golang/go

src/archive/zip/fuzz_test.go

			f.Fatalf("failed to read testdata: %s", err)
		}
		f.Add(b)
	}

	f.Fuzz(func(t *testing.T, b []byte) {
		r, err := NewReader(bytes.NewReader(b), int64(len(b)))
		if err != nil {
			return
		}

		type file struct {
			header  *FileHeader
			content []byte
		}
		files := []file{}

		for _, f := range r.File {
			fr, err := f.Open()
			if err != nil {
				continue
			}
			content, err := io.ReadAll(fr)

Registered: Tue Nov 05 11:13:11 UTC 2024

- Last Modified: Thu Jan 13 18:06:33 UTC 2022

- 1.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/es/log/allcommon/EsPagingResultBean.java

import org.dbflute.cbean.result.PagingResultBean;
import org.opensearch.action.search.SearchRequestBuilder;
import org.opensearch.search.aggregations.Aggregations;

/**
 * @param <ENTITY> The type of entity.
 * @author ESFlute (using FreeGen)
 */
public class EsPagingResultBean<ENTITY> extends PagingResultBean<ENTITY> {

    private static final long serialVersionUID = 1L;

    protected long took;

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 2.5K bytes

- Viewed (0)

github.com/minio/minio

docs/bucket/replication/README.md

# Bucket Replication Guide [![slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![Docker Pulls](https://img.shields.io/docker/pulls/minio/minio.svg?maxAge=604800)](https://hub.docker.com/r/minio/minio/)

Bucket replication is designed to replicate selected objects in a bucket to a destination bucket.

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

- Last Modified: Tue Jan 24 23:46:33 UTC 2023

- 18.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/bootstrap-messages.go

package cmd

import (
	"context"
	"sync"

	"github.com/minio/madmin-go/v3"
	"github.com/minio/minio/internal/pubsub"
)

const bootstrapTraceLimit = 4 << 10

type bootstrapTracer struct {
	mu   sync.RWMutex
	info []madmin.TraceInfo
}

var globalBootstrapTracer = &bootstrapTracer{}

func (bs *bootstrapTracer) Record(info madmin.TraceInfo) {
	bs.mu.Lock()

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

- Last Modified: Wed Aug 23 10:07:06 UTC 2023

- 1.7K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/netbios/SessionRequestPacket.java

    SessionRequestPacket() {
        calledName = new Name();
        callingName = new Name();
    }
    public SessionRequestPacket( Name calledName, Name callingName ) {
        type = SESSION_REQUEST;
        this.calledName = calledName;
        this.callingName = callingName;
    }
    int writeTrailerWireFormat( byte[] dst, int dstIndex ) {
        int start = dstIndex;

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

- Last Modified: Fri Mar 22 20:39:42 UTC 2019

- 2.1K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial003_py39.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: Sat Mar 18 12:29:59 UTC 2023

- 2.5K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/util/ambient/util.go

	}
	return isZtunnel
}

// InAmbient returns true if a resource is in ambient data plane mode.
func InAmbient(obj metav1.Object) bool {
	if obj == nil {
		return false
	}
	switch t := obj.(type) {
	case *corev1.Pod:
		return t.GetAnnotations()[annotation.AmbientRedirection.Name] == constants.AmbientRedirectionEnabled
	case *corev1.Namespace:
		if t.GetLabels()["istio-injection"] == "enabled" {
			return false
		}

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

- Last Modified: Wed Oct 09 16:05:45 UTC 2024

- 1.8K bytes

- Viewed (0)

github.com/minio/minio

docs/throttle/README.md

# MinIO Server Throttling Guide [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![Docker Pulls](https://img.shields.io/docker/pulls/minio/minio.svg?maxAge=604800)](https://hub.docker.com/r/minio/minio/)

MinIO server allows to throttle incoming requests:

- limit the number of active requests allowed across the cluster
- limit the wait duration for each request in the queue

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

- Last Modified: Fri Aug 16 08:43:49 UTC 2024

- 1.5K bytes

- Viewed (1)

Search Options