- Sort Score
- Num 10 results
- Language All
Results 851 - 860 of 942 for create (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)