Package app.ductape.sdk

Class Ductape

java.lang.Object
app.ductape.sdk.Ductape
@Stable(since="0.1.0") public class Ductape extends Object
Java SDK entrypoint; mirrors the service surface of sdk/ts/src/index.ts (see PARITY_MAP.md Ductape row for gaps). Constructors wire API clients, product services, jobs/graph/database/vector/brokers/resilience/feature/warehouse/agents/models/secrets, optional Redis/Redisson for cache + monitor worker queues.

  • Constructor Details

  • Method Details

    • monitor

      public void monitor()
      Boot the SDK's runtime worker loops on top of the RedissonClient wired into the constructor.

      TS uses BullMQ for jobs/healthcheck workers; Java is Redisson-native by design and does not speak the BullMQ wire protocol. We provide the same functional surface using RedissonJobQueueAdapter:

      • Jobs loop — claims due jobs from ductape_jobs with worker-token locks and dispatches to app.ductape.sdk.processor.ProcessorService#runJobs; emits jobs.active / jobs.completed / jobs.failed events.
      • Healthcheck loop — same pattern over ductape_healthchecks, persisting per-env results under healthcheck:{product}:{tag}:{env} Redis keys; emits healthchecks.active / healthchecks.completed / healthchecks.failed.
      • Healthcheck updater — repeatable healthchecks-updater job that aggregates per-env results and forwards via app.ductape.sdk.processor.ProcessorService#updateHealthcheckOnProcessor; emits healthchecks-updater.completed / healthchecks-updater.failed.
      Subscribe to events with onMonitorEvent(String, BiConsumer); payloads are normalized Map<String, Object> (id, name, data, …), not raw BullMQ Job objects.

    • stopMonitor

      public void stopMonitor()
      Stops all SDK-owned monitor worker loops started by monitor().

    • onMonitorEvent

      public void onMonitorEvent(String event, BiConsumer<Map<String,Object>,Throwable> listener)
      Registers a listener for monitor worker lifecycle events such as jobs.completed.

    • env

      public EnvType env()
      Returns the SDK environment used to resolve API service base URLs.

    • auth

      public RequestContext auth()
      Returns the request context used for authenticated API calls.

    • products

      public ProductsApiService products()
      Returns the low-level products API service.

    • product

      public ProductOperations product()
      TS ductape.product.

    • fetchWorkspaceApps

      public List<Map<String,Object>> fetchWorkspaceApps(String status)
      TS fetchWorkspaceApps.

    • fetchWorkspaceProjects

      public List<Map<String,Object>> fetchWorkspaceProjects(String status)
      TS fetchWorkspaceProjects.

    • app

      public AppCatalogOperations app()
      TS Ductape.app.

    • auths

      public AppAuthOperations auths()
      TS Ductape.auths: app auth/credential CRUD.

    • productsService

      public ProductsService productsService()
      Returns the high-level products service.

    • users

      public UserApiService users()
      Returns the user API service.

    • workspaces

      public WorkspaceApiService workspaces()
      Returns the workspace API service.

    • apps

      public AppApiService apps()
      Returns the app API service.

    • features

      public FeatureApiService features()
      Returns the feature API service.

    • webhooks

      public WebhooksApiService webhooks()
      Returns the webhooks API service.

    • logs

      public LogApiService logs()
      Returns the logs API service.

    • pricing

      public PricingApiService pricing()
      Returns the pricing API service.

    • processor

      public ProcessorApiService processor()
      Returns the processor API service.

    • secrets

      public SecretsApiService secrets()
      Returns the secrets API service.

    • resilience

      public ResilienceApiService resilience()
      Returns the resilience API service.

    • storage

      public StorageService storage()
      Returns the storage service.

    • sessions

      public SessionsService sessions()
      Returns the sessions service.

    • cache

      public CacheService cache()
      Returns the cache service.

    • notifications

      public NotificationsService notifications()
      Returns the notifications service.

    • jobs

      public JobsService jobs()
      Returns the jobs service.

    • databases

      public DatabaseService databases()
      Returns the database service.

    • graphs

      public GraphService graphs()
      Returns the graph service.

    • vectors

      public VectorDatabaseService vectors()
      Returns the vector database service.

    • events

      public BrokersService events()
      Returns the events service (message brokers: produce, subscribe, topics).

    • brokers

      @Deprecated public BrokersService brokers()
      Deprecated.
      Use events() instead.

    • resiliences

      public ResilienceService resiliences()
      Returns the high-level resilience service.

    • featureService

      public FeatureService featureService()
      Returns the high-level feature service.

    • warehouse

      public WarehouseService warehouse()
      Returns the warehouse orchestration service.

    • agents

      public AgentsService agents()
      Returns the agents service.

    • api

      public ApiService api()
      App-action runtime: run, dispatch, config, OAuth (TS ductape.api).

    • actions

      @Deprecated public ApiService actions()
      Deprecated.
      Use api().

    • imports

      public ImportService imports()
      Returns the import service.

    • models

      public ModelService models()
      Returns the model service.

    • secretService

      public SecretsService secretService()
      Returns the high-level secrets service.

    • cloudApiService

      public CloudApiService cloudApiService()

    • cloudService

      public CloudService cloudService()