Function NewAutoSchemaManager

usecases/objects/auto_schema.go:51–80

(schemaManager schemaManager, vectorRepo VectorRepo,
	config *config.WeaviateConfig, logger logrus.FieldLogger,
	reg prometheus.Registerer,
)

}

func NewAutoSchemaManager(schemaManager schemaManager, vectorRepo VectorRepo,
	config *config.WeaviateConfig, logger logrus.FieldLogger,
	reg prometheus.Registerer,
) *AutoSchemaManager {
	r := promauto.With(reg)

	tenantsCount := r.NewCounter(
		prometheus.CounterOpts{
			Name: "weaviate_auto_tenant_total",
			Help: "Total number of tenants processed",
		},
	)

	opDuration := r.NewHistogramVec(
		prometheus.HistogramOpts{
			Name: "weaviate_auto_tenant_duration_seconds",
			Help: "Time spent in auto tenant operations",
		},
		[]string{"operation"},
	)

	return &AutoSchemaManager{
		schemaManager: schemaManager,
		vectorRepo:    vectorRepo,
		config:        config.Config.AutoSchema,
		logger:        logger,
		tenantsCount:  tenantsCount,
		opsDuration:   opDuration,
	}
}

func (m *AutoSchemaManager) autoSchema(ctx context.Context, principal *models.Principal,
	allowCreateClass bool, classes map[string]versioned.Class, objects ...*models.Object,