- Sort Score
- Num 10 results
- Language All
Results 591 - 600 of 1,064 for pool (0.01 seconds)
-
cmd/batch-handlers_test.go
yamlStr string } type PrefixTemp struct { Prefix BatchJobPrefix `yaml:"prefix"` } tests := []struct { name string b PrefixTemp args args want []string wantErr bool }{ { name: "test1", b: PrefixTemp{}, args: args{ yamlStr: ` prefix: "foo" `, }, want: []string{"foo"}, wantErr: false, }, { name: "test2",Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 01 12:53:30 GMT 2024 - 1.7K bytes - Click Count (0) -
internal/logger/utils.go
func ansiRestoreAttributes() { if runtime.GOOS == "windows" { return } if color.IsTerminal() { ansiEscape("8") } } // logIgnoreError if true,the error will ignore. func logIgnoreError(err error) bool { return err == nil || errors.Is(err, context.Canceled) || errors.Is(err, http.ErrServerClosed) || err.Error() == "drive not found"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 1.6K bytes - Click Count (0) -
tensorflow/c/c_api.cc
unsigned char value) { desc->node_builder.Attr(attr_name, static_cast<bool>(value)); } void TF_SetAttrBoolList(TF_OperationDescription* desc, const char* attr_name, const unsigned char* values, int num_values) { std::unique_ptr<bool[]> b(new bool[num_values]); for (int i = 0; i < num_values; ++i) { b[i] = values[i]; }Created: Tue Dec 30 12:39:10 GMT 2025 - Last Modified: Sat Oct 04 05:55:32 GMT 2025 - 102.4K bytes - Click Count (0) -
cmd/bucket-lifecycle.go
// IsEmpty returns true if output location not specified. func (o *OutputLocation) IsEmpty() bool { return o.S3.BucketName == "" } // SelectParameters specifies sql select parameters type SelectParameters struct { s3select.S3Select } // IsEmpty returns true if no select parameters set func (sp *SelectParameters) IsEmpty() bool { return sp == nil } var selectParamsXMLName = "SelectParameters"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 33.7K bytes - Click Count (0) -
guava/src/com/google/common/eventbus/Dispatcher.java
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 7.4K bytes - Click Count (0) -
src/archive/tar/common.go
// This does not contain "charset" or "comment", which are both PAX-specific, // so adding them as first-class features of Header is unlikely. // Users can use the PAXRecords field to set it themselves. var basicKeys = map[string]bool{ paxPath: true, paxLinkpath: true, paxSize: true, paxUid: true, paxGid: true, paxUname: true, paxGname: true, paxMtime: true, paxAtime: true, paxCtime: true, } // A Header represents a single header in a tar archive.
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Oct 07 19:46:36 GMT 2025 - 24.5K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt
override fun writeTo(sink: BufferedSink) { requestBodySinks.add(sink) } override fun isDuplex(): Boolean = true @Throws(InterruptedException::class) fun takeSink(): BufferedSink = requestBodySinks.poll(5, SECONDS) ?: throw AssertionError("no sink to take") fun assertNoMoreSinks() { assertTrue(requestBodySinks.isEmpty()) }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.5K bytes - Click Count (0) -
internal/ioutil/append-file_nix.go
package ioutil import ( "io" "os" ) // AppendFile - appends the file "src" to the file "dst" func AppendFile(dst string, src string, osync bool) error { flags := os.O_WRONLY | os.O_APPEND | os.O_CREATE if osync { flags |= os.O_SYNC } appendFile, err := os.OpenFile(dst, flags, 0o666) if err != nil { return err } defer appendFile.Close()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 1.3K bytes - Click Count (0) -
internal/config/identity/openid/provider/provider.go
} // User represents information about user. type User struct { Name string `json:"username"` ID string `json:"id"` Enabled bool `json:"enabled"` } // Standard errors. var ( ErrNotImplemented = errors.New("function not implemented") ErrAccessTokenExpired = errors.New("access_token expired or unauthorized") )Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.7K bytes - Click Count (0) -
internal/config/lambda/event/arn_test.go
} } } func TestParseARN(t *testing.T) { testCases := []struct { s string expectedARN *ARN expectErr bool }{ {"", nil, true}, {"arn:minio:s3-object-lambda:::", nil, true}, {"arn:minio:s3-object-lambda::1:webhook:remote", nil, true}, {"arn:aws:s3-object-lambda::1:webhook", nil, true},
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 2.2K bytes - Click Count (0)