feat(infra): allow creation of resources and projects without MQ depe… (#2389)
This commit is contained in:
@ -38,13 +38,14 @@ type projectHandlerImpl struct {
|
||||
|
||||
type ConsumerHandler = eventbus.ConsumerHandler
|
||||
|
||||
var defaultProjectHandle *projectHandlerImpl // deprecate
|
||||
var defaultProjectHandle *projectHandlerImpl
|
||||
|
||||
func NewProjectHandler(ctx context.Context, e es.Client) ConsumerHandler {
|
||||
handler := &projectHandlerImpl{
|
||||
esClient: e,
|
||||
}
|
||||
|
||||
defaultProjectHandle = handler
|
||||
return handler
|
||||
}
|
||||
|
||||
|
||||
@ -36,13 +36,14 @@ type resourceHandlerImpl struct {
|
||||
esClient es.Client
|
||||
}
|
||||
|
||||
var defaultResourceHandler *resourceHandlerImpl // deprecate
|
||||
var defaultResourceHandler *resourceHandlerImpl
|
||||
|
||||
func NewResourceHandler(ctx context.Context, e es.Client) ConsumerHandler {
|
||||
handler := &resourceHandlerImpl{
|
||||
esClient: e,
|
||||
}
|
||||
|
||||
defaultResourceHandler = handler
|
||||
return handler
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user