publisher

package

v0.3.1 Latest Latest Go to latest Published: Mar 18, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type EventPublisher struct {
	// contains filtered or unexported fields
}

func NewPublisher(ctx context.Context, logger *zap.Logger, clientName string) (*EventPublisher, error)

func (p *EventPublisher) Close() error

func (p *EventPublisher) Publish(ctx context.Context, event eventing.MdaiEvent, subject eventing.MdaiEventSubject) error

type Publisher interface {
	Publish(ctx context.Context, event eventing.MdaiEvent, subject eventing.MdaiEventSubject) error
	Close() error
}