Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 851 - 860 of 942 for create (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. compat/maven-compat/src/main/java/org/apache/maven/project/artifact/ActiveProjectArtifact.java

            artifact.setResolved(true);
        }
    
        /** {@inheritDoc} */
        @Override
        public File getFile() {
            // we need to get the latest file for the project, not the artifact that was created at one point in time
            return project.getArtifact().getFile();
        }
    
        /** {@inheritDoc} */
        @Override
        public String getGroupId() {
            return artifact.getGroupId();
        }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  2. internal/event/target/nsq.go

    	}
    
    	yes, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	if !yes {
    		return store.ErrNotConnected
    	}
    
    	return nil
    }
    
    // NewNSQTarget - creates new NSQ target.
    func NewNSQTarget(id string, args NSQArgs, loggerOnce logger.LogOnce) (*NSQTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-nsq-"+id)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  3. cmd/erasure-coding.go

    )
    
    // Erasure - erasure encoding details.
    type Erasure struct {
    	encoder                  func() reedsolomon.Encoder
    	dataBlocks, parityBlocks int
    	blockSize                int64
    }
    
    // NewErasure creates a new ErasureStorage.
    func NewErasure(ctx context.Context, dataBlocks, parityBlocks int, blockSize int64) (e Erasure, err error) {
    	// Check the parameters for sanity now.
    	if dataBlocks <= 0 || parityBlocks < 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  4. internal/event/target/redis.go

    	target.firstPing = true
    
    	yes, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	if !yes {
    		return store.ErrNotConnected
    	}
    
    	return nil
    }
    
    // NewRedisTarget - creates new Redis target.
    func NewRedisTarget(id string, args RedisArgs, loggerOnce logger.LogOnce) (*RedisTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  5. cmd/batch-expire.go

    //       name: NAME # match object names that satisfy the wildcard expression.
    //       olderThan: 70h # match objects older than this value
    //       createdBefore: "2006-01-02T15:04:05.00Z" # match objects created before "date"
    //       tags:
    //         - key: name
    //           value: pick* # match objects with tag 'name', all values starting with 'pick'
    //       metadata:
    //         - key: content-type
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 22 11:16:32 GMT 2025
    - 23K bytes
    - Click Count (0)
  6. src/bytes/buffer.go

    	// we allocate buffers rounded up to the closest size class.
    	c := len(b) + n // ensure enough space for n elements
    	if c < 2*cap(b) {
    		// The growth rate has historically always been 2x. In the future,
    		// we could rely purely on append to determine the growth rate.
    		c = 2 * cap(b)
    	}
    	b2 := append([]byte(nil), make([]byte, c)...)
    	i := copy(b2, b)
    	return b2[:i]
    }
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  7. cmd/event-notification.go

    // EventNotifier - notifies external systems about events in MinIO.
    type EventNotifier struct {
    	sync.RWMutex
    	targetList     *event.TargetList
    	bucketRulesMap map[string]event.RulesMap
    }
    
    // NewEventNotifier - creates new event notification object.
    func NewEventNotifier(ctx context.Context) *EventNotifier {
    	// targetList/bucketRulesMap/bucketRemoteTargetRulesMap are populated by NotificationSys.InitBucketTargets()
    	return &EventNotifier{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jun 21 22:22:24 GMT 2024
    - 7.7K bytes
    - Click Count (0)
  8. src/cmd/asm/internal/asm/testdata/mips.s

    // Copyright 2016 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // This input was created by taking the mips64 testcase and modified
    // by hand.
    
    #include "../../../../../runtime/textflag.h"
    
    TEXT foo(SB),DUPOK|NOSPLIT,$0
    
    	//inst:
    	//
    	// load ints and bytes
    	//
    	//	LMOVW rreg ',' rreg
    	//	{
    	//		outcode(int($1), &$2, 0, &$4);
    	//	}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 08 12:17:12 GMT 2023
    - 6.7K bytes
    - Click Count (0)
  9. internal/event/target/amqp.go

    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    	target.conn = conn
    
    	return nil
    }
    
    // NewAMQPTarget - creates new AMQP target.
    func NewAMQPTarget(id string, args AMQPArgs, loggerOnce logger.LogOnce) (*AMQPTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  10. internal/event/targetlist.go

    // Init initialize target send workers.
    func (list *TargetList) Init(workers int) *TargetList {
    	startOnce.Do(func() {
    		go list.startSendWorkers(workers)
    	})
    	return list
    }
    
    // NewTargetList - creates TargetList.
    func NewTargetList(ctx context.Context) *TargetList {
    	list := &TargetList{
    		targets:     make(map[TargetID]Target),
    		queue:       make(chan asyncEvent, maxConcurrentAsyncSend),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.2K bytes
    - Click Count (0)
Back to Top