- Sort Score
- Num 10 results
- Language All
Results 801 - 810 of 1,104 for Async (0.02 seconds)
-
schema/field_test.go
package schema_test import ( "context" "database/sql" "reflect" "sync" "testing" "time" "gorm.io/gorm" "gorm.io/gorm/schema" "gorm.io/gorm/utils/tests" ) func TestFieldValuerAndSetter(t *testing.T) { var ( userSchema, _ = schema.Parse(&tests.User{}, &sync.Map{}, schema.NamingStrategy{}) user = tests.User{ Model: gorm.Model{ ID: 10, CreatedAt: time.Now(),
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Feb 19 09:02:53 GMT 2022 - 12.7K bytes - Click Count (0) -
internal/pubsub/pubsub.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package pubsub import ( "bytes" "encoding/json" "fmt" "sync" "sync/atomic" ) // GetByteBuffer returns a byte buffer from the pool. var GetByteBuffer = func() []byte { return make([]byte, 0, 4096) } // Sub - subscriber entity. type Sub[T Maskable] struct {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Click Count (0) -
internal/bucket/replication/rule_test.go
opts: ObjectOpts{Name: "c1test", DeleteMarker: false, OpType: ObjectReplicationType, Replica: false}, // 1. Replica mod sync enabled; not a replica expectedResult: true, }, // case 2 - rule with replica modification disabled; a replica {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.6K bytes - Click Count (0) -
go.sum
golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20201207232520-09787c993a3a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 79.8K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/auth/chain/LdapChainTest.java
// Test successful password change when LDAP admin sync is enabled testLdapManager.changePasswordResult = true; testFessConfig.ldapAdminSyncPassword = true; boolean result = ldapChain.changePassword("testuser", "newpassword"); assertTrue(result); // !changed || sync = !true || true = true assertEquals("testuser", testLdapManager.changePasswordUsername);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 9.5K bytes - Click Count (0) -
cmd/dynamic-timeouts.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "math" "sync" "sync/atomic" "time" ) const ( dynamicTimeoutIncreaseThresholdPct = 0.33 // Upper threshold for failures in order to increase timeout
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.5K bytes - Click Count (0) -
internal/s3select/progress.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package s3select import ( "context" "errors" "fmt" "io" "runtime" "sync" "sync/atomic" "github.com/cosnicolaou/pbzip2" "github.com/klauspost/compress/s2" "github.com/klauspost/compress/zstd" gzip "github.com/klauspost/pgzip" "github.com/pierrec/lz4/v4" )
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 22 00:33:43 GMT 2024 - 4.3K bytes - Click Count (0) -
api/go1.9.txt
pkg runtime/pprof, type LabelSet struct pkg sync, method (*Map) Delete(interface{}) pkg sync, method (*Map) Load(interface{}) (interface{}, bool) pkg sync, method (*Map) LoadOrStore(interface{}, interface{}) (interface{}, bool) pkg sync, method (*Map) Range(func(interface{}, interface{}) bool) pkg sync, method (*Map) Store(interface{}, interface{}) pkg sync, type Map struct
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Oct 04 20:20:20 GMT 2021 - 10.7K bytes - Click Count (0) -
cmd/notification.go
"context" "errors" "fmt" "io" "math/rand" "net/http" "net/url" "runtime" "sync" "time" "github.com/cespare/xxhash/v2" "github.com/klauspost/compress/zip" "github.com/minio/madmin-go/v3" xioutil "github.com/minio/minio/internal/ioutil" xnet "github.com/minio/pkg/v3/net" "github.com/minio/pkg/v3/sync/errgroup" "github.com/minio/pkg/v3/workers" "github.com/minio/minio/internal/bucket/bandwidth"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 46K bytes - Click Count (0) -
.github/workflows/test.yml
pyproject.toml uv.lock - name: Install Dependencies run: uv sync --no-dev --group tests --extra all - name: CodSpeed benchmarks uses: CodSpeedHQ/action@v4 with: mode: simulation run: uv run --no-sync pytest tests/benchmarks --codspeed coverage-combine: needs: - test runs-on: ubuntu-latestCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Mon Mar 23 12:36:49 GMT 2026 - 6.4K bytes - Click Count (0)