- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 375 for Sync (0.15 sec)
-
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 {
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Tue Oct 10 06:50:29 GMT 2023 - 13.7K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleBuildDocumentationPlugin.java
} private void applyConventions(Project project, TaskContainer tasks, ObjectFactory objects, ProjectLayout layout, GradleDocumentationExtension extension) { TaskProvider<Sync> stageDocs = tasks.register("stageDocs", Sync.class, task -> { // release notes goes in the root of the docs task.from(extension.getReleaseNotes().getRenderedDocumentation()); // DSL reference goes into dsl/
Java - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 17 20:04:00 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/bootstrap-messages.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "sync" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/pubsub" ) const bootstrapTraceLimit = 4 << 10 type bootstrapTracer struct { mu sync.RWMutex info []madmin.TraceInfo } var globalBootstrapTracer = &bootstrapTracer{}
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 1.7K bytes - Viewed (0) -
docs/bucket/replication/README.md
### Sync/Async Replication By default, replication is completed asynchronously. If synchronous replication is desired, set the --sync flag while adding a remote replication target using the `mc admin bucket remote add` command. For mc releases on or after `RELEASE.2022-12-24T15-21-38Z`, the
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 24 23:46:33 GMT 2023 - 18.2K bytes - Viewed (0) -
internal/s3select/json/preader.go
err error // global error state, only touched by Reader.Read bufferPool sync.Pool // pool of []byte objects for input kvDstPool sync.Pool // pool of []jstream.KV 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.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
internal/s3select/simdj/reader.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 simdj import ( "fmt" "io" "sync" "sync/atomic" "github.com/minio/minio/internal/s3select/json" "github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) // Reader - JSON record reader for S3Select. type Reader struct {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
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(),
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Sat Feb 19 09:02:53 GMT 2022 - 12.7K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import ( "fmt" "io" "net/http" "net/http/httptest" "sync" "sync/atomic" "time" "github.com/minio/mux" ) const numberOfNodes = 5 var ( ds *Dsync nodes = make([]*httptest.Server, numberOfNodes) // list of node IP addrs or hostname with ports.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
Cache map[string]*BucketReplicationStats mostRecentStats BucketStatsMap registry metrics.Registry sync.RWMutex // mutex for Cache mostRecentStatsMu sync.Mutex // mutex for mostRecentStats wlock sync.RWMutex // mutex for active workers movingAvgTicker *time.Ticker // Ticker for calculating moving averages
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/erasure-sets.go
for _, endpoint := range endpoints.Endpoints { if _, ok := erasureLockers[endpoint.Host]; !ok { erasureLockers[endpoint.Host] = newLockAPI(endpoint) } } var wg sync.WaitGroup var lk sync.Mutex for i := 0; i < setCount; i++ { lockerEpSet := set.NewStringSet() for j := 0; j < setDriveCount; j++ { wg.Add(1) go func(i int, endpoint Endpoint) { defer wg.Done()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 37.5K bytes - Viewed (5)