func NewEntityController()

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
}