 935645b03a
			
		
	
	935645b03a
	
	
	
		
			
			Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: update events package to include emitter and use envelope proto Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: add events service Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: enable events service and update ctr events to use events service Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> event listeners Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: helper func for emitting in services Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: improved cli for containers and tasks Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> create event envelope with poster Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: introspect event data to use for type url Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: use pb encoding; add event types Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: instrument content and snapshot services with events Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: instrument image service with events Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: instrument namespace service with events Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: add namespace support Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: only send events from namespace requested from client Signed-off-by: Evan Hazlett <ejhazlett@gmail.com> events: switch to go-events for broadcasting Signed-off-by: Evan Hazlett <ejhazlett@gmail.com>
		
			
				
	
	
		
			16 lines
		
	
	
		
			457 B
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			16 lines
		
	
	
		
			457 B
		
	
	
	
		
			Go
		
	
	
	
	
	
| package events
 | |
| 
 | |
| // Event marks items that can be sent as events.
 | |
| type Event interface{}
 | |
| 
 | |
| // Sink accepts and sends events.
 | |
| type Sink interface {
 | |
| 	// Write an event to the Sink. If no error is returned, the caller will
 | |
| 	// assume that all events have been committed to the sink. If an error is
 | |
| 	// received, the caller may retry sending the event.
 | |
| 	Write(event Event) error
 | |
| 
 | |
| 	// Close the sink, possibly waiting for pending events to flush.
 | |
| 	Close() error
 | |
| }
 |