in server/internal/async/entityController.go [28:53]
func NewEntityController(ctx context.Context, options Options, matcher *opbus.Matcher, dbClient *sql.DB) (*EntityController, error) {
logger := ctxlogger.GetLogger(ctx)
if options.EntityTableName == "" {
logger.Error("No EntityTableName provided.")
return nil, errors.New("No EntityTableName provided.")
}
if matcher == nil {
logger.Error("No matcher provided.")
return nil, errors.New("No matcher provided.")
}
if dbClient == nil {
logger.Error("No dbClient provided.")
return nil, errors.New("No dbClient provided.")
}
newEntityController := &EntityController{
dbClient: dbClient,
entityTableName: options.EntityTableName,
matcher: matcher,
}
return newEntityController, nil
}