typs - Code Search

internal/config/identity/ldap/config.go

const (
	defaultLDAPExpiry = time.Hour * 1

	minLDAPExpiry time.Duration = 15 * time.Minute
	maxLDAPExpiry time.Duration = 365 * 24 * time.Hour
)

// Config contains AD/LDAP server connectivity information.
type Config struct {
	LDAP ldap.Config

	stsExpiryDuration time.Duration // contains converted value
}

// Enabled returns if LDAP is enabled.
func (l *Config) Enabled() bool {
	return l.LDAP.Enabled
}

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

- Last Modified: Wed Aug 07 12:59:47 UTC 2024

- 8.4K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/collect/AbstractSortedKeySortedSetMultimap.java

/**
 * Basic implementation of a {@link SortedSetMultimap} with a sorted key set.
 *
 * <p>This superclass allows {@code TreeMultimap} to override methods to return navigable set and
 * map types in non-GWT only, while GWT code will inherit the SortedMap/SortedSet overrides.
 *
 * @author Louis Wasserman
 */
@GwtCompatible
@ElementTypesAreNonnullByDefault
abstract class AbstractSortedKeySortedSetMultimap<

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Tue Jun 15 21:08:00 UTC 2021

- 1.8K 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)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.9.md

    * master subnet.  It is ignored if the service is not on Azure, if the type is not
    * LoadBalancer, or if the load balancer is not internal.
* Adds a command-line argument to kube-apiserver called ([#51698](https://github.com/kubernetes/kubernetes/pull/51698), [@rphillips](https://github.com/rphillips))
    * --alpha-endpoint-reconciler-type=(master-count, lease, none) (default

Registered: Fri Nov 01 09:05:11 UTC 2024

- Last Modified: Tue Nov 16 10:46:27 UTC 2021

- 313.7K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

  /** Does all the work necessary to build a full HTTP or HTTPS connection on a raw socket. */
  @Throws(IOException::class)
  private fun connectSocket() {
    val rawSocket =
      when (route.proxy.type()) {
        Proxy.Type.DIRECT, Proxy.Type.HTTP -> route.address.socketFactory.createSocket()!!
        else -> Socket(route.proxy)
      }
    this.rawSocket = rawSocket

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sat Apr 20 17:03:43 UTC 2024

- 18.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/admin-handlers-config-kv.go

	w.Header().Set(madmin.ConfigAppliedHeader, madmin.ConfigAppliedTrue)
}

type badConfigErr struct {
	Err error
}

// Error - return the error message
func (bce badConfigErr) Error() string {
	return bce.Err.Error()
}

// Unwrap the error to its underlying error.
func (bce badConfigErr) Unwrap() error {
	return bce.Err
}

type setConfigResult struct {
	Cfg                     config.Config

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

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

- 15.7K bytes

- Viewed (0)

Search Options