eventbus

type DefaultEvent struct {
	Topic string `json:"topic"`

	Producer string `json:"producer"`
}

type Event interface {
	GetTopic() string

	GetProducer() string

	GetData() interface{}
}

type Eventbus interface {
	// Register registers the event to the topic
	Register(topic string, subscribers ...*Subscriber) error
	// Post posts the event to the topic
	Post(ctx context.Context, event Event) error
	// Serve starts the event bus async
	Serve(ctx context.Context)
}

type Subscriber struct {
	// UID
	UID func() string

	// NewEvent is a function that creates a new event from a message.
	NewEvent func() Event

	// HandleEvent handles the event
	HandleEvent func(ctx context.Context, event Event) error
}

type Subscribers struct {
	sync.RWMutex
	// contains filtered or unexported fields
}