Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 484 for listFn (0.14 sec)

  1. .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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. .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)
  8. 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)
  9. 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)
  10. 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)
Back to top