- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 484 for listFn (0.2 sec)
-
.github/workflows/codeql.yml
build-mode: ${{ matrix.build-mode }} # If you wish to specify custom queries, you can do so here or in a config file. # By default, queries listed here will override any specified in a config file. # Prefix the list here with "+" to use these queries and those in the config file.
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Wed Aug 14 23:51:19 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/global-heal.go
retErr = fmt.Errorf("one or more errors reported during listing: %v", errors.Join(errs...)) } }, }) jt.Wait() // synchronize all the concurrent heal jobs if err != nil { // Set this such that when we return this function // we let the caller retry this disk again for the // buckets it failed to list. retErr = err } if retErr != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
docs/sts/assume-role.go
if bucketToList == "" { bucketToList = minioUsername } fmt.Printf("Calling list objects on bucket named `%s` with temp creds:\n===\n", bucketToList) objCh := minioClient.ListObjects(context.Background(), bucketToList, minio.ListObjectsOptions{}) for obj := range objCh { if obj.Err != nil { log.Fatalf("Listing error: %v", obj.Err) }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Aug 17 01:24:54 UTC 2024 - 4.4K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/sources/SourcesRepository.kt
data class JavaSourceQuery<T : Any?>( val defaultValue: T, val visitor: GenericVisitor<T, Unit?> ) internal class SourcesRepository( private val sourceRoots: List<File>, private val compilationClasspath: List<File> ) : AutoCloseable { private val openJavaCompilationUnitsByFile = mutableMapOf<File, CompilationUnit>() private
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Fri Jun 28 08:29:24 UTC 2024 - 4K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
zipPath, _, err := splitZipExtensionPath(prefix) if err != nil { // Return empty listing return ListObjectsV2Info{}, nil } zipObjInfo, err := objectAPI.GetObjectInfo(ctx, bucket, zipPath, ObjectOptions{}) if err != nil { // Return empty listing return ListObjectsV2Info{}, nil } zipInfo := zipObjInfo.ArchiveInfo(h) if len(zipInfo) == 0 {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
internal/http/server.go
) // Server - extended http.Server supports multiple addresses to serve and enhanced connection handling. type Server struct { http.Server Addrs []string // addresses on which the server listens for new connection. TCPOptions TCPOptions // all the configurable TCP conn specific configurable options. listenerMutex sync.Mutex // to guard 'listener' field.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jun 19 18:42:47 UTC 2024 - 6.1K bytes - Viewed (0) -
.teamcity/src/test/kotlin/PromotionProjectTests.kt
val model = setupModelFor("master") assertEquals("Promotion", model.name) assertEquals(10, model.buildTypes.size) assertEquals(
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Tue Feb 13 14:18:23 UTC 2024 - 13.4K bytes - Viewed (0) -
cmd/globals.go
// global Trace system to send HTTP request/response // and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8) // global Listen system to send S3 API events to registered listeners globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0) // global console system to send console logs to // registered listeners
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (0) -
cmd/event-notification.go
return arns } region := globalSite.Region() for targetID := range evnot.targetList.TargetMap() { // httpclient target is part of ListenNotification // which doesn't need to be listed as part of the ARN list // This list is only meant for external targets, filter // this out pro-actively. if !strings.HasPrefix(targetID.ID, "httpclient+") { arns = append(arns, targetID.ToARN(region).String()) } }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 7.7K bytes - Viewed (0) -
cmd/mrf.go
rc, err := localDrive.ReadFileStream(context.Background(), minioMetaBucket, pathJoin(healMRFDir, "list.bin"), 0, -1) if err != nil { continue } err = loadMRF(rc, m.opCh) if err != nil { continue } // finally delete the file after processing mrf entries localDrive.Delete(GlobalContext, minioMetaBucket, pathJoin(healMRFDir, "list.bin"), DeleteOptions{}) break } return }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0)