- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 890 for sync (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
schema/schema.go
} // Parse get data type from dialector func Parse(dest interface{}, cacheStore *sync.Map, namer Namer) (*Schema, error) { return ParseWithSpecialTableName(dest, cacheStore, namer, "") } // ParseWithSpecialTableName get data type from dialector with extra schema table func ParseWithSpecialTableName(dest interface{}, cacheStore *sync.Map, namer Namer, specialTableName string) (*Schema, error) { if dest == nil {
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 13.3K bytes - Click Count (0) -
cmd/site-replication-utils.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 ( "context" "maps" "math/rand" "sync" "time" "github.com/minio/madmin-go/v3" ) //go:generate msgp -file=$GOFILE // SiteResyncStatus captures current replication resync status for a target site type SiteResyncStatus struct {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.8K bytes - Click Count (0) -
internal/s3select/json/preader.go
kvDstPool bpool.Pool[[]jstream.KVS] // pool of []jstream.KVS used for output close chan struct{} // used for shutting down the splitter before end of stream readerWg sync.WaitGroup // used to keep track of async reader. } // queueItem is an item in the queue. type queueItem struct { input []byte // raw input sent to the worker dst chan []jstream.KVS // result of block decode
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 6.5K bytes - Click Count (0) -
api/go1.15.txt
pkg os, var ErrDeadlineExceeded error pkg regexp, method (*Regexp) SubexpIndex(string) int pkg strconv, func FormatComplex(complex128, uint8, int, int) string pkg strconv, func ParseComplex(string, int) (complex128, error) pkg sync, method (*Map) LoadAndDelete(interface{}) (interface{}, bool) pkg testing, method (*B) TempDir() string pkg testing, method (*T) Deadline() (time.Time, bool) pkg testing, method (*T) TempDir() string
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Jul 17 02:15:01 GMT 2020 - 7.6K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/AbstractMapBasedMultimap.java
return (list instanceof RandomAccess) ? new RandomAccessWrappedList(key, list, ancestor) : new WrappedList(key, list, ancestor); } /** * Collection decorator that stays in sync with the multimap values for a key. There are two kinds * of wrapped collections: full and subcollections. Both have a delegate pointing to the * underlying collection class. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Aug 12 15:51:57 GMT 2025 - 46.9K bytes - Click Count (0) -
api/go1.17.txt
pkg runtime/cgo (openbsd-amd64-cgo), method (Handle) Value() interface{} pkg runtime/cgo (openbsd-amd64-cgo), type Handle uintptr pkg strconv, func QuotedPrefix(string) (string, error) pkg sync/atomic, method (*Value) CompareAndSwap(interface{}, interface{}) bool pkg sync/atomic, method (*Value) Swap(interface{}) interface{} pkg syscall (netbsd-386), const SYS_WAIT6 = 481 pkg syscall (netbsd-386), const SYS_WAIT6 ideal-int
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Feb 17 20:31:46 GMT 2023 - 18K bytes - Click Count (0) -
cmd/format-erasure.go
"encoding/json" "errors" "fmt" "io/fs" "os" "sync" "github.com/dustin/go-humanize" "github.com/minio/minio/internal/color" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/config/storageclass" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/sync/errgroup" ) const ( // Represents Erasure backend.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 23.1K bytes - Click Count (0) -
cmd/metrics-v3-handler.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "encoding/json" "fmt" "net/http" "slices" "strings" "sync" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/mcontext" "github.com/minio/mux" "github.com/minio/pkg/v3/env" "github.com/prometheus/client_golang/prometheus"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 7.7K bytes - Click Count (0) -
tests/table_test.go
package tests_test import ( "regexp" "sync" "testing" "gorm.io/driver/gaussdb" "gorm.io/driver/postgres" "gorm.io/gorm" "gorm.io/gorm/schema" "gorm.io/gorm/utils/tests" . "gorm.io/gorm/utils/tests" ) type UserWithTable struct { gorm.Model Name string } func (UserWithTable) TableName() string { return "gorm.user" } func TestTable(t *testing.T) {
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Mon Jul 21 02:46:58 GMT 2025 - 12.7K bytes - Click Count (0) -
misc/go_android_exec/main.go
package main import ( "bytes" "errors" "fmt" "io" "log" "os" "os/exec" "os/signal" "path" "path/filepath" "regexp" "runtime" "strconv" "strings" "sync" "syscall" ) func adbRun(args string) (int, error) { // The exit code of adb is often wrong. In theory it was fixed in 2016 // (https://code.google.com/p/android/issues/detail?id=3254), but it's
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Click Count (0)