dsx-ai-factory/nvke

Largest clones in the code

• 12 lines in 12 placesgo69 tokens
  controller/internal/clients/controlplaneconfignodeprovider.go:32–43·controller/internal/clients/controlplaneconfigpayloadvalidator.go:30–41·controller/internal/clients/machine.go:50–61·controller/internal/clients/newnodeprovider.go:43–54·controller/internal/clients/nodeagentprofilevalidator.go:29–40and 7 more

  32func GetControlPlaneConfigNodeProvider(cluster db.Cluster) (ControlPlaneConfigNodeProvider, error) {
  33    switch cluster.ProviderType {
  34    case db.ProviderTypeCAPI:
  35        return capi.New(), nil
  36    case db.ProviderTypeNico:
  37        return nico.New(), nil
  38    case db.ProviderTypeLaunchLayer:
  39        return launchlayer.New(), nil
  40    default:
  41        return nil, fmt.Errorf("unsupported provider type %q for cluster %s", cluster.ProviderType, cluster.ID)
  

  First 10 of 12 lines.

• 8 lines in 6 placesgo75 tokens
  controller/nico-sim/internal/state/queries_static.go:126–133·controller/nico-sim/internal/state/queries_static.go:141–148·controller/nico-sim/internal/state/queries_static.go:156–163·controller/nico-sim/internal/state/queries_static.go:202–209·controller/nico-sim/internal/state/queries_static.go:217–224and 1 more

  126if err := s.db.NewSelect().
  127    Model(&rows).
  128    Where("site_id = ?", siteID).
  129    Order("id ASC").
  130    Limit(int64(page.Size)).
  131    Offset(int64((page.Number - 1) * page.Size)).
  132    Scan(ctx); err != nil {
  133    return nil, fmt.Errorf("failed to list vpcs: %w", err)
  

  141if err := s.db.NewSelect().
  142    Model(&rows).
  143    Where("site_id = ?", siteID).
  144    Order("id ASC").
  145    Limit(int64(page.Size)).
  146    Offset(int64((page.Number - 1) * page.Size)).
  147    Scan(ctx); err != nil {
  148    return nil, fmt.Errorf("failed to list subnets: %w", err)
  

• 6 lines in 6 placesgo63 tokens
  controller/internal/temporal/activities/certificate_renewal.go:469–474·controller/internal/temporal/activities/enable_etcd_encryption.go:346–351·controller/internal/temporal/activities/etcd_encryption_key_rotation.go:38–43·controller/internal/temporal/activities/mark_oidc_enabled.go:34–39·controller/internal/temporal/activities/mark_oidc_enabled.go:89–94and 1 more

  469) (FailCertificateRenewalResult, error) {
  470    err := a.db.RunInTx(ctx, func(ctx context.Context, tx db.Tx) error {
  471        cluster, err := tx.GetClusterForUpdate(ctx, input.ClusterID)
  472        if err != nil {
  473            if errors.Is(err, db.ErrNotFound) {
  474                return nil
  

  346) (ClearEtcdEncryptionUpdateInProgressResult, error) {
  347    err := a.db.RunInTx(ctx, func(ctx context.Context, tx db.Tx) error {
  348        cluster, err := tx.GetClusterForUpdate(ctx, input.ClusterID)
  349        if err != nil {
  350            if errors.Is(err, db.ErrNotFound) {
  351                return temporal.NewNonRetryableApplicationError("cluster not found in database", "db.ErrNotFound", err)