13 lines
332 B
Go
13 lines
332 B
Go
package messaging
|
|
|
|
import (
|
|
me "github.com/tech/sendico/pkg/messaging/envelope"
|
|
"github.com/tech/sendico/pkg/model"
|
|
)
|
|
|
|
type Broker interface {
|
|
Publish(envelope me.Envelope) error
|
|
Subscribe(event model.NotificationEvent) (<-chan me.Envelope, error)
|
|
Unsubscribe(event model.NotificationEvent, subChan <-chan me.Envelope) error
|
|
}
|