- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 569 for ARGS (0.11 sec)
-
internal/s3select/csv/reader.go
func NewReader(readCloser io.ReadCloser, args *ReaderArgs) (*Reader, error) { if args == nil || args.IsEmpty() { panic(fmt.Errorf("empty args passed %v", args)) } csvIn := io.Reader(readCloser) if args.RecordDelimiter != "\n" { csvIn = &recordTransform{ reader: readCloser, recordDelimiter: []byte(args.RecordDelimiter), oneByte: make([]byte, len(args.RecordDelimiter)-1), } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
prepare_stmt.go
} return nil, ErrInvalidTransaction } func (db *PreparedStmtDB) ExecContext(ctx context.Context, query string, args ...interface{}) (result sql.Result, err error) { stmt, err := db.prepare(ctx, db.ConnPool, false, query) if err == nil { result, err = stmt.ExecContext(ctx, args...) if errors.Is(err, driver.ErrBadConn) { db.Mux.Lock() defer db.Mux.Unlock() go stmt.Close()
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 28 08:47:39 GMT 2024 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/reflect/AbstractInvocationHandler.java
throws Throwable { if (args == null) { args = NO_ARGS; } if (args.length == 0 && method.getName().equals("hashCode")) { return hashCode(); } if (args.length == 1 && method.getName().equals("equals") && method.getParameterTypes()[0] == Object.class) { Object arg = args[0]; if (arg == null) { return false;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jan 05 17:43:40 GMT 2022 - 5.2K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate.go
} func addManifestGenerateFlags(cmd *cobra.Command, args *ManifestGenerateArgs) { cmd.PersistentFlags().StringSliceVarP(&args.InFilenames, "filename", "f", nil, filenameFlagHelpStr) cmd.PersistentFlags().StringVarP(&args.OutFilename, "output", "o", "", "Manifest output directory path.") cmd.PersistentFlags().StringArrayVarP(&args.Set, "set", "s", nil, setFlagHelpStr) cmd.PersistentFlags().BoolVar(&args.Force, "force", false, ForceFlagHelpStr)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
} func newClientV7(args ElasticsearchArgs) (*esClientV7, error) { // Client options elasticConfig := elasticsearch7.Config{ Addresses: []string{args.URL.String()}, Transport: args.Transport, MaxRetries: 10, } // Set basic auth if args.Username != "" && args.Password != "" { elasticConfig.Username = args.Username elasticConfig.Password = args.Password } // Create a client
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
internal/logger/legacy.go
func SetLoggerHTTPAudit(scfg config.Config, k string, args http.Config) { if !args.Enabled { // Do not enable audit targets, if not enabled return } scfg[config.AuditWebhookSubSys][k] = config.KVS{ config.KV{ Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: Endpoint, Value: args.Endpoint.String(), }, config.KV{ Key: AuthToken,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 03 09:47:07 GMT 2023 - 2K bytes - Viewed (1) -
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) -
operator/cmd/mesh/profile-dump.go
Args: func(cmd *cobra.Command, args []string) error { if len(args) > 1 { return fmt.Errorf("too many positional arguments") } return nil }, RunE: func(cmd *cobra.Command, args []string) error { l := clog.NewConsoleLogger(cmd.OutOrStdout(), cmd.ErrOrStderr(), installerScope) return profileDump(args, pdArgs, l) }, } } func prependHeader(yml string) (string, error) { out, err := tpath.AddSpecRoot(yml)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K bytes - Viewed (0) -
istioctl/pkg/admin/admin.go
istioctl admin log`, Aliases: []string{"istiod"}, Args: func(cmd *cobra.Command, args []string) error { if len(args) != 0 { return fmt.Errorf("unknown subcommand %q", args[0]) } return nil }, RunE: func(cmd *cobra.Command, args []string) error { cmd.HelpFunc()(cmd, args) return nil }, } istiodLog := istiodLogCmd(ctx) adminCmd.AddCommand(istiodLog)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/exception/EmptyArgumentException.java
* * @param argName * 引数の名前 * @param messageCode * メッセージコード * @param args * 引数の配列 */ public EmptyArgumentException(final String argName, final String messageCode, final Object[] args) { this(argName, messageCode, args, null); } /** * {@link EmptyArgumentException}を作成します。 * * @param argName * 引数の名前
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 1.8K bytes - Viewed (0)