- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 452 for Nevett (0.2 sec)
-
cmd/object-lambda-handlers.go
if err != nil { return levent.Event{}, err } token, err := authenticateNode(cred.AccessKey, cred.SecretKey, u.RawQuery) if err != nil { return levent.Event{}, err } eventData := levent.Event{ GetObjectContext: &levent.GetObjectContext{ InputS3URL: u.String(), OutputRoute: shortuuid.New(), OutputToken: token, }, UserRequest: levent.UserRequest{ URL: r.URL.String(),
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Sep 15 04:58:17 GMT 2023 - 10.2K bytes - Viewed (1) -
cmd/globals.go
"github.com/minio/minio/internal/config/subnet" xhttp "github.com/minio/minio/internal/http" etcd "go.etcd.io/etcd/client/v3" levent "github.com/minio/minio/internal/config/lambda/event" "github.com/minio/minio/internal/event" "github.com/minio/minio/internal/pubsub" "github.com/minio/pkg/v2/certs" "github.com/minio/pkg/v2/env" xnet "github.com/minio/pkg/v2/net" )
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/event/target/postgresql.go
} else { var data []byte if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil { return err } _, err = target.updateStmt.Exec(key, data) } return err } if target.args.Format == event.AccessFormat { eventTime, err := time.Parse(event.AMZTimeFormat, eventData.EventTime) if err != nil { return err }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
terminatedEvent(NEW); private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_STARTING_EVENT = terminatedEvent(STARTING); private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_RUNNING_EVENT = terminatedEvent(RUNNING); private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_STOPPING_EVENT =
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 20.4K bytes - Viewed (0) -
internal/event/target/amqp.go
func NewAMQPTarget(id string, args AMQPArgs, loggerOnce logger.LogOnce) (*AMQPTarget, error) { var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-amqp-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/LifecycleExecutorTest.java
assertNotNull(event.getSession()); assertNotNull(event.getProject()); assertNotNull(event.getExecution()); assertNotNull(event.getMojo()); assertNull(event.getCause()); log.add("beforeMojoExecution " + event.getProject().getArtifactId() + ":"
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Jan 09 20:57:17 GMT 2024 - 24.7K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-elasticsearch-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
internal/event/config_test.go
dataCase1 := []byte(` <QueueConfiguration> <Id>1</Id> <Filter></Filter> <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue> <Event>s3:ObjectAccessed:*</Event> <Event>s3:ObjectCreated:*</Event> <Event>s3:ObjectRemoved:*</Event> </QueueConfiguration>`) dataCase2 := []byte(` <QueueConfiguration> <Id>1</Id> <Filter> <S3Key> <FilterRule>
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 29K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
return fmt.Errorf("unexpected event type: %+v", input) } } func (s *InformerHandlers) reconcileNamespace(input any) error { event := input.(controllers.Event) ns := event.Latest().(*corev1.Namespace) switch event.Event { case controllers.EventAdd: log.Debugf("Namespace %s added", ns.Name) s.enqueueNamespace(ns) case controllers.EventUpdate: newNs := event.New.(*corev1.Namespace)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 9.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/EventBusTest.java
bus.post(EVENT); bus.register(catcher2); bus.post(EVENT); List<String> expectedEvents = Lists.newArrayList(); expectedEvents.add(EVENT); expectedEvents.add(EVENT); assertEquals("Two correct events should be delivered.", expectedEvents, catcher1.getEvents()); assertEquals( "One correct event should be delivered.", Lists.newArrayList(EVENT), catcher2.getEvents());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0)