- Sort Score
- Result 10 results
- Languages All
Results 801 - 810 of 1,341 for varr (0.02 sec)
-
internal/event/target/amqp.go
return false, err } defer func() { ch.Close() }() return true, nil } func (target *AMQPTarget) channel() (*amqp091.Channel, chan amqp091.Confirmation, error) { var err error var conn *amqp091.Connection var ch *amqp091.Channel isAMQPClosedErr := func(err error) bool { if err == amqp091.ErrClosed { return true } if nerr, ok := err.(*net.OpError); ok {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10K bytes - Viewed (0) -
internal/store/queuestore_test.go
package store import ( "fmt" "os" "path/filepath" "reflect" "testing" ) type TestItem struct { Name string `json:"Name"` Property string `json:"property"` } var ( // TestDir queueDir = filepath.Join(os.TempDir(), "minio_test") // Sample test item. testItem = TestItem{Name: "test-item", Property: "property"} // Ext for test item testItemExt = ".test" )
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.7K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
"strings" "syscall" ) const debug = false var tmpdir string var ( devID string appID string teamID string bundleID string deviceID string ) // lock is a file lock to serialize iOS runs. It is global to avoid the // garbage collector finalizing it, closing the file and releasing the // lock prematurely. var lock *os.File func main() { log.SetFlags(0)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Jun 18 16:32:49 UTC 2024 - 8.7K bytes - Viewed (0) -
callbacks/preload.go
var ( reflectValue = tx.Statement.ReflectValue relForeignKeys []string relForeignFields []*schema.Field foreignFields []*schema.Field foreignValues [][]interface{} identityMap = map[string][]reflect.Value{} inlineConds []interface{} ) if rel.JoinTable != nil { var (
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jun 12 10:52:33 UTC 2024 - 11.6K bytes - Viewed (0) -
internal/s3select/sql/analysis.go
// function combined with a row function is meaningless ("AVG(s.Age) + // s.Salary"). Analysis determines if such a scenario exists so an // error can be returned. var ( // Fatal error for query processing. errNestedAggregation = errors.New("Cannot nest aggregations") errFunctionNotImplemented = errors.New("Function is not yet implemented")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 8.5K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
resource := "test" runtime.GOMAXPROCS(gomaxprocs) // Number of active readers + 10000 * number of active writers. var activity int32 cdone := make(chan bool) go writer(resource, numIterations, &activity, cdone) var i int for i = 0; i < numReaders/2; i++ { go reader(resource, numIterations, &activity, cdone) } go writer(resource, numIterations, &activity, cdone)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
// Flaky https://github.com/square/okhttp/issues/4953 @RegisterExtension var clientTestRule = configureClientTestRule() @RegisterExtension var platform = PlatformRule() @RegisterExtension var testLogHandler = TestLogHandler(OkHttpClient::class.java) private lateinit var webServer: MockWebServer private val handshakeCertificates = platform.localhostHandshakeCertificates()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0) -
src/archive/zip/zip_test.go
} for i := 0; i < nFiles; i++ { want := fmt.Sprintf("%d.dat", i) if zr.File[i].Name != want { t.Fatalf("File(%d) = %q, want %q", i, zr.File[i].Name, want) } } } func TestModTime(t *testing.T) { var testTime = time.Date(2009, time.November, 10, 23, 45, 58, 0, time.UTC) fh := new(FileHeader) fh.SetModTime(testTime) outTime := fh.ModTime() if !outTime.Equal(testTime) {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.6K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/admin/failureurl/admin_failureurl.jsp
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 13 07:47:04 UTC 2020 - 13.3K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/admin/scheduler/admin_scheduler.jsp
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Wed Feb 12 20:25:27 UTC 2020 - 6.4K bytes - Viewed (0)