Method List

internal/servers/schema_server.go:232–258

List retrieves all schema versions for a tenant with pagination

(ctx context.Context, request *v1.SchemaListRequest)

// List retrieves all schema versions for a tenant with pagination
func (r *SchemaServer) List(ctx context.Context, request *v1.SchemaListRequest) (*v1.SchemaListResponse, error) { // List schemas
	ctx, span := internal.Tracer.Start(ctx, "schemas.list")
	defer span.End()
	// Fetch schemas with pagination
	schemas, ct, err := r.sr.ListSchemas(ctx, request.GetTenantId(), database.NewPagination(database.Size(request.GetPageSize()), database.Token(request.GetContinuousToken()))) // List schemas
	if err != nil {                                                                                                                                                              // Check for errors
		span.RecordError(err)                        // Record error in span
		span.SetStatus(otelCodes.Error, err.Error()) // Set error status
		slog.ErrorContext(ctx, err.Error())
		return nil, status.Error(GetStatus(err), err.Error()) // Return list error
	}

	// Get the latest version
	head, err := r.sr.HeadVersion(ctx, request.GetTenantId()) // Get head version
	if err != nil {                                           // Check for errors
		return nil, status.Error(GetStatus(err), err.Error()) // Return version error
	}

	// Record metrics
	r.listSchemaHistogram.Record(ctx, 1)
	// Return schema list response
	return &v1.SchemaListResponse{ // Create response
		Head:            head,
		Schemas:         schemas,
		ContinuousToken: ct.String(),
	}, nil
}