events

type Event struct {
	ID         int
	Payload    any
	Headers    map[string]any
	Status     int
	ModelID    int
	RoutingKey string
	Exchange   string
	CreatedAt  time.Time
	UpdatedAt  time.Time
}

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

type EventData interface {
	GetModelID() int
	GetID() string
}

type Repository interface {
	Create(ctx context.Context, entity *Event) error
	Update(ctx context.Context, entity *Event) error
}