You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
35 lines
916 B
35 lines
916 B
package event
|
|
|
|
import (
|
|
"context"
|
|
)
|
|
|
|
// Event is an absctraction for all messages that
|
|
// are sent to quque or received from queue.
|
|
type Event struct {
|
|
// Key sets the key of the message for routing policy
|
|
Key string
|
|
// Payload for the message
|
|
Payload []byte
|
|
// Properties attach application defined properties on the message
|
|
Properties map[string]string
|
|
}
|
|
|
|
// Handler is a callback function that processes messages delivered
|
|
// to asynchronous subscribers.
|
|
type Handler func(context.Context, Event) error
|
|
|
|
// Publisher is absctraction for sending messages
|
|
// to queue.
|
|
type Publisher interface {
|
|
Publish(ctx context.Context, event Event) error
|
|
PublishAsync(ctx context.Context, event Event, callback func(err error)) error
|
|
Close() error
|
|
}
|
|
|
|
// Subscriber is an absctraction for receiving messages
|
|
// from queue.
|
|
type Subscriber interface {
|
|
Subscribe(ctx context.Context, h Handler) error
|
|
Close() error
|
|
}
|
|
|