BLOB - Code Search

internal/event/target/mqtt.go

func NewMQTTTarget(id string, args MQTTArgs, loggerOnce logger.LogOnce) (*MQTTTarget, error) {
	if args.MaxReconnectInterval == 0 {
		// Default interval
		// https://github.com/eclipse/paho.mqtt.golang/blob/master/options.go#L115
		args.MaxReconnectInterval = 10 * time.Minute
	}

	if args.KeepAlive == 0 {
		args.KeepAlive = 10 * time.Second
	}

	var queueStore store.Store[event.Event]

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Fri Sep 06 23:06:30 UTC 2024

- 8.2K bytes

- Viewed (0)

github.com/square/okhttp

gradlew

#
#       There are tweaks for specific operating systems such as AIX, CygWin,
#       Darwin, MinGW, and NonStop.
#
#   (3) This script is generated from the Groovy template
#       https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
#       within the Gradle project.
#
#       You can find Gradle at https://github.com/gradle/gradle/.
#

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Thu Sep 18 20:55:41 UTC 2025

- 8.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/api-headers.go

			// report encoding bugs to AWS, and use ASCII-only metadata to ensure reliable S3 API
			// compatibility.
			if needsMimeEncoding(v) {
				// see https://github.com/golang/go/blob/release-branch.go1.24/src/net/mail/message.go#L325
				if strings.ContainsAny(v, "\"#$%&'(),.:;<>@[]^`{|}~") {
					v = mime.BEncoding.Encode("UTF-8", v)
				} else {
					v = mime.QEncoding.Encode("UTF-8", v)
				}

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 8.6K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/dcerpc/msrpc/netdfs.java

    }

    /**
     * DFS volume flavor indicating standalone DFS
     */
    public static final int DFS_VOLUME_FLAVOR_STANDALONE = 0x100;
    /**
     * DFS volume flavor indicating Active Directory blob storage
     */
    public static final int DFS_VOLUME_FLAVOR_AD_BLOB = 0x200;
    /**
     * DFS storage state indicating offline status
     */
    public static final int DFS_STORAGE_STATE_OFFLINE = 0x0001;
    /**

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 21.8K bytes

- Viewed (0)

github.com/minio/minio

docs/sts/wso2.md

These credentials can now be used to perform MinIO API operations, these credentials automatically expire in 1hr. To understand more about credential expiry duration and client grants STS API read further [here](https://github.com/minio/minio/blob/master/docs/sts/client-grants.md).

## Explore Further

- [MinIO STS Quickstart Guide](https://docs.min.io/community/minio-object-store/developers/security-token-service.html)

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 8.7K bytes

- Viewed (0)

github.com/tiangolo/fastapi

fastapi/openapi/docs.py

    """
    Generate the HTML response with the OAuth2 redirection for Swagger UI.

    You normally don't need to use or change this.
    """
    # copied from https://github.com/swagger-api/swagger-ui/blob/v4.14.0/dist/oauth2-redirect.html
    html = """
    <!doctype html>
    <html lang="en-US">
    <head>
        <title>Swagger UI: OAuth2 Redirect</title>
    </head>
    <body>
    <script>

Registered: Sun Dec 28 07:19:09 UTC 2025

- Last Modified: Wed Dec 17 21:25:59 UTC 2025

- 10.1K bytes

- Viewed (0)

github.com/minio/minio

docs/multi-user/README.md

- Install MinIO - [MinIO Quickstart Guide](https://docs.min.io/community/minio-object-store/operations/deployments/baremetal-deploy-minio-on-redhat-linux.html)
- Configure etcd - [Etcd V3 Quickstart Guide](https://github.com/minio/minio/blob/master/docs/sts/etcd.md)

### 2. Create a new user with canned policy

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 8.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/js/admin/bootstrap.min.js.map

subset of URLs that are safe.\n *\n * Shoutout to Angular https://github.com/angular/angular/blob/12.2.x/packages/core/src/sanitization/url_sanitizer.ts\n */\nconst SAFE_URL_PATTERN = /^(?:(?:https?|mailto|ftp|tel|file|sms):|[^#&/:?]*(?:[#/?]|$))/i\n\n/**\n * A pattern that matches safe data URLs. Only matches image, video and audio types.\n *\n * Shoutout to Angular https://github.com/angular/angular/blob/12.2.x/packages/core/src/sanitization/url_sanitizer.ts\n */\nconst DATA_URL_PATTERN = /^dat...

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Sat Oct 26 01:49:09 UTC 2024

- 180.9K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.2.md

to userspace mode. Kube-proxy is much more performant and less
resource-intensive in ‘iptables’ mode.
  * Node stability can be improved by reserving [resources](https://github.com/kubernetes/kubernetes/blob/release-1.2/docs/proposals/node-allocatable.md) for the base operating system using --system-reserved and --kube-reserved Kubelet flags
  * Liveness and readiness probes now support more configuration parameters:

Registered: Fri Dec 26 09:05:12 UTC 2025

- Last Modified: Fri Dec 04 06:36:19 UTC 2020

- 41.4K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-repository-metadata/src/test/java/org/apache/maven/artifact/repository/metadata/MetadataTest.java

        int buildNumber = 1;
        // this generates timestamped versions like maven-resolver-provider:
        // https://github.com/apache/maven/blob/03df5f7c639db744a3597c7175c92c8e2a27767b/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/RemoteSnapshotMetadata.java#L79
        String version = artifact.getVersion();

Registered: Sun Dec 28 03:35:09 UTC 2025

- Last Modified: Fri Oct 25 12:31:46 UTC 2024

- 13.7K bytes

- Viewed (0)

Search Options