- Sort Score
- Num 10 results
- Language All
Results 581 - 590 of 1,617 for var0 (0.02 seconds)
-
internal/event/target/nats.go
func (target *NATSTarget) initNATS() error { args := target.args var err error if args.Streaming.Enable { target.loggerOnce(context.Background(), errors.New("NATS Streaming is deprecated please migrate to JetStream"), target.ID().String()) var stanConn stan.Conn stanConn, err = args.connectStan() target.stanConn = stanConn } else { var natsConn *nats.Conn natsConn, err = args.connectNats()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.5K bytes - Click Count (0) -
cmd/erasure-common.go
package cmd import ( "context" "math/rand" "sync" "time" ) func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) { disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { wg.Add(1) go func() { defer wg.Done() if disks[i] == nil { return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 2.3K bytes - Click Count (0) -
internal/rest/rpc-stats.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 13 18:21:34 GMT 2024 - 2.6K bytes - Click Count (0) -
src/main/webapp/js/purify.min.js
otype.replace),E=D(String.prototype.indexOf),A=D(String.prototype.trim),_=D(Object.prototype.hasOwnProperty),b=D(RegExp.prototype.test),S=(N=TypeError,function(){for(var e=arguments.length,t=new Array(e),n=0;n<e;n++)t[n]=arguments[n];return s(N,t)});var N;function D(e){return function(t){t instanceof RegExp&&(t.lastIndex=0);for(var n=arguments.length,o=new Array(n>1?n-1:0),r=1;r<n;r++)o[r-1]=arguments[r];return c(e,t,o)}}function R(e,o){let r=arguments.length>2&&void 0!==arguments[2]?arguments[2...Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Mar 15 06:21:57 GMT 2026 - 22.7K bytes - Click Count (0) -
docs/sts/custom-token-identity.go
package main import ( "context" "flag" "fmt" "log" "net/url" "time" "github.com/minio/minio-go/v7" cr "github.com/minio/minio-go/v7/pkg/credentials" ) var ( // LDAP integrated Minio endpoint stsEndpoint string // token to use with AssumeRoleWithCustomToken token string // Role ARN to use roleArn string // Display credentials flag
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri May 27 00:58:09 GMT 2022 - 3.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
* continuation frames as they are needed by [Hpack.Reader.readHeaders]. */ internal class ContinuationSource( private val source: BufferedSource, ) : Source { var flags: Int = 0 var streamId: Int = 0 var left: Int = 0 var padding: Int = 0 @Throws(IOException::class) override fun read( sink: Buffer, byteCount: Long, ): Long { while (left == 0) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 19.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt
@RegisterExtension @JvmField val platform = PlatformRule() @RegisterExtension @JvmField var clientTestRule = OkHttpClientTestRule() private val eventRecorder = EventRecorder() private val handshakeCertificates = platform.localhostHandshakeCertificates() private var client = clientTestRule .newClientBuilder() .eventListenerFactory(clientTestRule.wrap(eventRecorder))
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 11:54:15 GMT 2026 - 10.7K bytes - Click Count (0) -
internal/config/policy/plugin/config.go
type opaResult struct { Result bool `json:"result"` } respBody := bytes.NewReader(opaRespBytes) var result opaResult if err = json.NewDecoder(respBody).Decode(&result); err != nil { respBody.Seek(0, 0) var resultAllow opaResultAllow if err = json.NewDecoder(respBody).Decode(&resultAllow); err != nil { return false, err } return resultAllow.Result.Allow, nilCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.8K bytes - Click Count (0) -
src/main/webapp/WEB-INF/orig/view/profile/index.jsp
<div class="alert alert-info">${msg}</div> </la:info> <la:errors /> </div> <la:form styleId="updatePassword" method="post"> <div class="input-group mb-3"> <c:set var="ph_old_password"> <la:message key="labels.profile.placeholder_old_password" /> </c:set> <la:password property="oldPassword" class="form-control" placeholder="${ph_old_password}" />Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Feb 23 08:03:44 GMT 2026 - 3.6K bytes - Click Count (0) -
buildscripts/gen-ldflags.go
if relSuffix != "" { relTag += "." + relSuffix } return relTag, t } // commitID returns the abbreviated commit-id hash of the last commit. func commitID() string { // git log --format="%H" -n1 var ( commit []byte err error ) cmdName := "git" cmdArgs := []string{"log", "--format=%H", "-n1"} if commit, err = exec.Command(cmdName, cmdArgs...).Output(); err != nil {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Jun 16 23:10:48 GMT 2022 - 3.3K bytes - Click Count (0)