Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 1,339 for contextos (0.06 sec)

  1. internal/bucket/bandwidth/monitor.go

    	bucketMovingAvgTicker *time.Ticker    // Ticker for calculating moving averages
    	ctx                   context.Context // Context for generate
    	NodeCount             uint64
    }
    
    // NewMonitor returns a monitor with defaults.
    func NewMonitor(ctx context.Context, numNodes uint64) *Monitor {
    	m := &Monitor{
    		bucketsMeasurement:    make(map[BucketOptions]*bucketMeasurement),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. doc/next/6-stdlib/99-minor/testing/36532.md

    The new [T.Context] and [B.Context] methods return a context that's canceled
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 20 17:36:54 UTC 2024
    - 141 bytes
    - Viewed (0)
  3. cmd/site-replication.go

    func (c *SiteReplicationSys) Init(ctx context.Context, objAPI ObjectLayer) error {
    	go c.startHealRoutine(ctx, objAPI)
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	for {
    		err := c.loadFromDisk(ctx, objAPI)
    		if err == errConfigNotFound {
    			return nil
    		}
    		if err == nil {
    			break
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  4. .github/workflows/update-jdks.yml

      workflow_dispatch: # Allows manual triggering of the action
      schedule: # Runs the action on the first day of every month at 3:42 UTC
        - cron: '42 3 1 * *'
    
    permissions:
      contents: write
      pull-requests: write
    
    jobs:
      update-jdks:
        permissions:
          contents: write
          pull-requests: write
        runs-on: ubuntu-latest
        steps:
          - name: Checkout repository
            uses: actions/checkout@v3
            with:
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Oct 29 03:45:07 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  5. cmd/erasure-encode_test.go

    	return nil, errFaultyDisk
    }
    
    func (a badDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error {
    	return errFaultyDisk
    }
    
    func (badDisk) Hostname() string {
    	return ""
    }
    
    const oneMiByte = 1 * humanize.MiByte
    
    var erasureEncodeTests = []struct {
    	dataBlocks                   int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. cmd/warm-backend-minio.go

    	// Part size.
    	partSize = int64(partSizeFlt)
    	if partSize == 0 {
    		return minPartSize, nil
    	}
    	return partSize, nil
    }
    
    func (m *warmBackendMinIO) PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error) {
    	partSize, err := optimalPartSize(length)
    	if err != nil {
    		return remoteVersionID(""), err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 4K bytes
    - Viewed (0)
  7. .github/workflows/osv-scanner-scheduled.yml

    name: OSV-Scanner Scheduled Scan
    
    on:
      schedule:
        - cron: 0 4 * * 1
    
    permissions:
      # Require writing security events to upload SARIF file to security tab
      security-events: write
      # Only need to read contents
      contents: read
    
    jobs:
      scan-scheduled:
        if: github.repository == 'tensorflow/tensorflow'
        uses: "google/osv-scanner-action/.github/workflows/osv-scanner-reusable.yml@v1.9.0"
        with:
          scan-args: |-
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Nov 01 08:40:10 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  8. schema/utils.go

    	if strings.Contains(t, value) {
    		return tag
    	}
    	return reflect.StructTag(fmt.Sprintf(`gorm:"%s;%s"`, value, t))
    }
    
    // GetRelationsValues get relations's values from a reflect value
    func GetRelationsValues(ctx context.Context, reflectValue reflect.Value, rels []*Relationship) (reflectResults reflect.Value) {
    	for _, rel := range rels {
    		reflectResults = reflect.MakeSlice(reflect.SliceOf(reflect.PtrTo(rel.FieldSchema.ModelType)), 0, 1)
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Aug 19 13:35:14 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/collect/IterablesFilterArrayListTest.java

    public final class IterablesFilterArrayListTest
        extends AbstractFilteredIterableTest<Iterable<Integer>> {
      @Override
      Iterable<Integer> createUnfiltered(Iterable<Integer> contents) {
        return Lists.newArrayList(contents);
      }
    
      @Override
      Iterable<Integer> filter(Iterable<Integer> elements, Predicate<? super Integer> predicate) {
        return Iterables.filter(elements, predicate);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Mar 16 21:55:55 UTC 2022
    - 1.1K bytes
    - Viewed (0)
  10. internal/grid/muxclient.go

    type muxClient struct {
    	MuxID              uint64
    	SendSeq, RecvSeq   uint32
    	LastPong           int64
    	BaseFlags          Flags
    	ctx                context.Context
    	cancelFn           context.CancelCauseFunc
    	parent             *Connection
    	respWait           chan<- Response
    	respMu             sync.Mutex
    	singleResp         bool
    	closed             bool
    	stateless          bool
    	acked              bool
    	init               bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
Back to top