- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 60 for conj (0.18 sec)
-
cmd/common-main.go
ctxt.Interface = ctx.String("interface") ctxt.UserTimeout = ctx.Duration("conn-user-timeout") ctxt.ConnReadDeadline = ctx.Duration("conn-read-deadline") ctxt.ConnWriteDeadline = ctx.Duration("conn-write-deadline") ctxt.ConnClientReadDeadline = ctx.Duration("conn-client-read-deadline") ctxt.ConnClientWriteDeadline = ctx.Duration("conn-client-write-deadline") ctxt.SendBufSize = ctx.Int("send-buf-size")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
.github/workflows/replication.yaml
sudo sysctl net.ipv6.conf.default.disable_ipv6=0 make test-configfile - name: Test Replication run: | sudo sysctl net.ipv6.conf.all.disable_ipv6=0 sudo sysctl net.ipv6.conf.default.disable_ipv6=0 make test-replication - name: Test MinIO IDP for automatic site replication run: |
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:48:19 GMT 2024 - 1.8K bytes - Viewed (0) -
cmd/warm-backend-minio.go
} func newWarmBackendMinIO(conf madmin.TierMinIO, tier string) (*warmBackendMinIO, error) { // Validation of credentials if conf.AccessKey == "" || conf.SecretKey == "" { return nil, errors.New("both access and secret keys are required") } if conf.Bucket == "" { return nil, errors.New("no bucket name was provided") } u, err := url.Parse(conf.Endpoint) if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
defer conn.Close() context.AfterFunc(ctx, func() { log.Debug("context cancelled - closing conn") conn.Close() }) // before doing anything, add the connection to the list of active connections z.conns.addConn(conn) defer z.conns.deleteConn(conn) // get hello message from ztunnel m, _, err := readProto[zdsapi.ZdsHello](conn.u, readWriteDeadline, nil) if err != nil { return err }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/http/listener.go
} // Accept - reads from httpListener.acceptCh for one of previously accepted TCP connection and returns the same. func (listener *httpListener) Accept() (conn net.Conn, err error) { select { case result, ok := <-listener.acceptCh: if ok { return deadlineconn.New(result.conn). WithReadDeadline(listener.opts.ClientReadTimeout). WithWriteDeadline(listener.opts.ClientWriteTimeout), result.err } case <-listener.ctx.Done(): }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/warm-backend-s3.go
case conf.AccessKey == "" && conf.SecretKey != "" || conf.AccessKey != "" && conf.SecretKey == "": return nil, errors.New("both the access and secret keys are required") case conf.AWSRole && (conf.AWSRoleWebIdentityTokenFile != "" || conf.AWSRoleARN != "" || conf.AccessKey != "" || conf.SecretKey != ""): return nil, errors.New("AWS Role cannot be activated with static credentials or the web identity token file") case conf.Bucket == "":
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/config/identity/ldap/ldap.go
return l.GetValidatedDNUnderBaseDN(conn, userDN, l.LDAP.UserDNSearchBaseDistNames) } // GetValidatedGroupDN validates the given group DN. If conn is nil, creates a // connection. The returned boolean is true iff the group DN is found under one // of the configured LDAP base DNs. func (l *Config) GetValidatedGroupDN(conn *ldap.Conn, groupDN string) (string, bool, error) { if conn == nil { var err error conn, err = l.LDAP.Connect()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 9.9K bytes - Viewed (0) -
.github/workflows/iam-integrations.yaml
_MINIO_ETCD_TEST_SERVER: ${{ matrix.etcd }} _MINIO_OPENID_TEST_SERVER: ${{ matrix.openid }} run: | sudo sysctl net.ipv6.conf.all.disable_ipv6=0 sudo sysctl net.ipv6.conf.default.disable_ipv6=0 make test-iam - name: Test with multiple OpenID providers if: matrix.openid == 'http://127.0.0.1:5556/dex' env:
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:49:53 GMT 2024 - 4.2K bytes - Viewed (0) -
docs/es/docs/async.md
Pero al mismo tiempo, las funciones definidas con `async def` deben ser "esperadas". Por lo tanto, las funciones con `async def` solo se pueden invocar dentro de las funciones definidas con `async def` también. Entonces, relacionado con la paradoja del huevo y la gallina, ¿cómo se llama a la primera función `async`?
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 24.9K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
} return false, nil } func newWarmBackendGCS(conf madmin.TierGCS, tier string) (*warmBackendGCS, error) { // Validation code if conf.Creds == "" { return nil, errors.New("empty credentials unsupported") } if conf.Bucket == "" { return nil, errors.New("no bucket name was provided") } credsJSON, err := conf.GetCredentialJSON() if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.9K bytes - Viewed (0)