123456789101112131415 |
- 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
- }
|