- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 155 for arg2 (0.13 sec)
-
internal/s3select/sql/funceval.go
return nil, errIncorrectSQLFunctionArgumentType(err) } // Assemble other arguments arg2, arg3 := e.From, e.For // Check if the second form of substring is being used if e.From == nil { arg2, arg3 = e.Arg2, e.Arg3 } // Evaluate the FROM argument v2, err := arg2.evalNode(r, tableAlias) if err != nil { return nil, err } inferTypeForArithOp(v2)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 13.2K bytes - Viewed (0) -
internal/s3select/sql/analysis.go
result.combine(e.Substring.From.analyze(s)) if e.Substring.For != nil { result.combine(e.Substring.Expr.analyze(s)) } case e.Substring.Arg2 != nil: result.combine(e.Substring.Arg2.analyze(s)) if e.Substring.Arg3 != nil { result.combine(e.Substring.Arg3.analyze(s)) } default: result.err = errVal } return result case sqlFnUTCNow: if len(e.SFunc.ArgsList) != 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 8.5K bytes - Viewed (0) -
docs/debugging/reorder-disks/main.go
minor |= (devID & 0x00000ffffff00000) >> 12 return fmt.Sprintf("%d:%d", major, minor), nil } func filterLocalDisks(node, args string) ([]localDisk, error) { var result []localDisk argP, err := ellipses.FindEllipsesPatterns(args) if err != nil { return nil, err } exp := argP.Expand() if node == "" { for index, e := range exp {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
internal/logger/console.go
args = append(args, msg) msg = "%s" } console.quiet(msg+"\n", args...) default: if len(msg) != 0 && len(args) == 0 { args = append(args, msg) msg = "%s" } console.pretty(msg+"\n", args...) } } // Fatal prints only fatal error message with no stack trace // it will be called for input validation failures func Fatal(err error, msg string, data ...interface{}) { fatal(err, msg, data...) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/event/target/kafka.go
} config.Net.KeepAlive = 60 * time.Second config.Net.SASL.User = args.SASL.User config.Net.SASL.Password = args.SASL.Password initScramClient(args, config) // initializes configured scram client. config.Net.SASL.Enable = args.SASL.Enable tlsConfig, err := saramatls.NewConfig(args.TLS.ClientTLSCert, args.TLS.ClientTLSKey) if err != nil { target.loggerOnce(context.Background(), err, target.ID().String()) return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/event/target/webhook.go
} // Only called from init() func (target *WebhookTarget) initWebhook() error { args := target.args transport := target.transport if args.ClientCert != "" && args.ClientKey != "" { manager, err := certs.NewManager(context.Background(), args.ClientCert, args.ClientKey, tls.LoadX509KeyPair) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 20 22:40:07 GMT 2023 - 8.5K bytes - Viewed (0) -
internal/event/target/nats.go
} if target.stanConn != nil { if target.args.Streaming.Async { _, err = target.stanConn.PublishAsync(target.args.Subject, data, nil) } else { err = target.stanConn.Publish(target.args.Subject, data) } } else { if target.jstream != nil { _, err = target.jstream.Publish(target.args.Subject, data) } else { err = target.natsConn.Publish(target.args.Subject, data) } } return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/config/dns/operator_dns.go
func Authentication(username, password string) OperatorOption { return func(args *OperatorDNS) { args.username = username args.password = password } } // RootCAs - add custom trust certs pool func RootCAs(certPool *x509.CertPool) OperatorOption { return func(args *OperatorDNS) { args.rootCAs = certPool } } // NewOperatorDNS - initialize a new K8S Operator DNS set/unset values.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 6.6K bytes - Viewed (0) -
buildscripts/verify-healing.sh
first_time=$(find ${WORK_DIR}/ | grep format.json | wc -l) start_port=$2 args="" for d in $(seq 1 3 5); do args="$args http://127.0.0.1:$((start_port + 1))${WORK_DIR}/1/${d}/ http://127.0.0.1:$((start_port + 2))${WORK_DIR}/2/${d}/ http://127.0.0.1:$((start_port + 3))${WORK_DIR}/3/${d}/ " d=$((d + 1))
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 4.2K bytes - Viewed (1) -
cmd/iam.go
if hasSessionPolicy { return isAllowedSP && (isOwnerDerived || combinedPolicy.IsAllowed(args)) } // Sub policy not set, this is most common since subPolicy // is optional, use the inherited policies. return isOwnerDerived || combinedPolicy.IsAllowed(args) } func isAllowedBySessionPolicyForServiceAccount(args policy.Args) (hasSessionPolicy bool, isAllowed bool) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1)