Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 683 for event (0.22 sec)

  1. cmd/event-notification.go

    	if escape {
    		keyName = url.QueryEscape(args.Object.Name)
    	}
    
    	newEvent := event.Event{
    		EventVersion:      "2.0",
    		EventSource:       "minio:s3",
    		AwsRegion:         args.ReqParams["region"],
    		EventTime:         eventTime.Format(event.AMZTimeFormat),
    		EventName:         args.EventName,
    		UserIdentity:      event.Identity{PrincipalID: args.ReqParams["principalId"]},
    		RequestParameters: args.ReqParams,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  2. docs/en/docs/advanced/events.md

    ```
    
    In this case, the `startup` event handler function will initialize the items "database" (just a `dict`) with some values.
    
    You can add more than one event handler function.
    
    And your application won't start receiving requests until all the `startup` event handlers have completed.
    
    ### `shutdown` event
    
    To add a function that should be run when the application is shutting down, declare it with the event `"shutdown"`:
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  3. 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)
  4. guava-tests/test/com/google/common/eventbus/EventBusTest.java

        assertEquals("The dead event should wrap the original event.", EVENT, events.get(0).getEvent());
      }
    
      public void testDeadEventPosting() {
        GhostCatcher catcher = new GhostCatcher();
        bus.register(catcher);
    
        bus.post(new DeadEvent(this, EVENT));
    
        List<DeadEvent> events = catcher.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)
  5. android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

        assertEquals("The dead event should wrap the original event.", EVENT, events.get(0).getEvent());
      }
    
      public void testDeadEventPosting() {
        GhostCatcher catcher = new GhostCatcher();
        bus.register(catcher);
    
        bus.post(new DeadEvent(this, EVENT));
    
        List<DeadEvent> events = catcher.getEvents();
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 21 18:32:41 GMT 2024
    - 11.3K bytes
    - Viewed (0)
  6. docs/de/docs/advanced/events.md

    Diese Funktionen können mit `async def` oder normalem `def` deklariert werden.
    
    ### `startup`-Event
    
    Um eine Funktion hinzuzufügen, die vor dem Start der Anwendung ausgeführt werden soll, deklarieren Sie diese mit dem Event `startup`:
    
    ```Python hl_lines="8"
    {!../../../docs_src/events/tutorial001.py!}
    ```
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sat Mar 30 20:30:59 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  7. common-protos/k8s.io/api/events/v1/generated.proto

      repeated Event items = 2;
    }
    
    // EventSeries contain information on series of events, i.e. thing that was/is happening
    // continuously for some time. How often to update the EventSeries is up to the event reporters.
    // The default event reporter in "k8s.io/client-go/tools/events/event_broadcaster.go" shows
    // how this struct is updated on heartbeats and can guide customized reporter implementations.
    message EventSeries {
    Plain Text
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/events/v1beta1/generated.proto

    // Events have a limited retention time and triggers and messages may evolve
    // with time.  Event consumers should not rely on the timing of an event
    // with a given Reason reflecting a consistent underlying trigger, or the
    // continued existence of events with that Reason.  Events should be
    // treated as informative, best-effort, supplemental data.
    message Event {
      // Standard object's metadata.
    Plain Text
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  9. internal/event/target/redis.go

    }
    
    // RedisAccessEvent holds event log data and timestamp
    type RedisAccessEvent struct {
    	Event     []event.Event
    	EventTime string
    }
    
    // Validate RedisArgs fields
    func (r RedisArgs) Validate() error {
    	if !r.Enable {
    		return nil
    	}
    
    	if r.Format != "" {
    		f := strings.ToLower(r.Format)
    		if f != event.NamespaceFormat && f != event.AccessFormat {
    			return fmt.Errorf("unrecognized format")
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  10. internal/event/targetlist.go

    		ntargets[k] = v
    	}
    	return ntargets
    }
    
    // Send - sends events to targets identified by target IDs.
    func (list *TargetList) Send(event Event, targetIDset TargetIDSet, sync bool) {
    	if sync {
    		list.sendSync(event, targetIDset)
    	} else {
    		list.sendAsync(event, targetIDset)
    	}
    }
    
    func (list *TargetList) sendSync(event Event, targetIDset TargetIDSet) {
    	var wg sync.WaitGroup
    	for id := range targetIDset {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
Back to top