Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPublisherForBus ¶
Types ¶
type PublishMode ¶
type PublishMode string
const ( PublishModeMQ PublishMode = "mq" PublishModeLogging PublishMode = "logging" PublishModeNop PublishMode = "nop" )
type RoutingPublisher ¶
type RoutingPublisher struct {
// contains filtered or unexported fields
}
func NewRoutingPublisher ¶
func NewRoutingPublisher(opts RoutingPublisherOptions) *RoutingPublisher
func (*RoutingPublisher) Publish ¶
func (p *RoutingPublisher) Publish(ctx context.Context, evt event.DomainEvent) error
func (*RoutingPublisher) PublishAll ¶
func (p *RoutingPublisher) PublishAll(ctx context.Context, events []event.DomainEvent) error
type RoutingPublisherOptions ¶
type RoutingPublisherOptions struct {
Catalog *eventcatalog.Catalog
TopicResolver eventcatalog.TopicResolver
Delivery eventcatalog.DeliveryClassResolver
MQPublisher messaging.Publisher
Source string
Mode PublishMode
}
Source Files
Click to show internal directories.
Click to hide internal directories.