Packages

package admin

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package grpc
  2. package v0
  3. package workflows

Type Members

  1. sealed trait AcceptRejectError extends AnyRef
  2. class AcceptRejectException extends RuntimeException

    Exception to carry the accept reject error where a Future[Unit] return is expected (transaction processing)

  3. case class AdminWorkflowConfig(bongTestMaxLevel: Long = 0, retries: Int = 10, submissionTimeout: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofHours(1), autoloadDar: Boolean = true) extends Product with Serializable

    Configuration options for Canton admin workflows like participant.health.ping

    Configuration options for Canton admin workflows like participant.health.ping

    bongTestMaxLevel

    Upper bound on the level of a bong that the participant can initiate. The participant can still participate in bongs at higher levels. Use this to limit the load the participants can cause by initiating bongs.

    retries

    The maximum number of times the com.digitalasset.canton.participant.ledger.api.client.CommandSubmitterWithRetry will retry an admin command submitted to the com.digitalasset.canton.participant.admin.AdminWorkflowServices.

    submissionTimeout

    Defines how long an admin workflow waits until it observes a completion for its command submissions before it assumes that the submission is lost and retries. If a lower timeout value is specified for an admin workflow, they take precedence.

  4. trait AdminWorkflowService extends AutoCloseable

    Admin service that connects to the ledger and process events

  5. class AdminWorkflowServices extends FlagCloseableAsync with NamedLogging with Spanning with NoTracing

    Manages our admin workflow applications (ping, dar distribution).

    Manages our admin workflow applications (ping, dar distribution). Currently each is individual application with their own ledger connection and acting independently.

  6. trait DarDistribution extends AnyRef

    Dar distribution operations

  7. class DarDistributionService extends AdminWorkflowService with DarDistribution with NamedLogging
  8. trait DarService extends AnyRef
  9. class DomainConnectivityService extends NamedLogging
  10. class EnterpriseResourceManagementService extends ResourceManagementService
  11. class InMemoryShareOfferStore extends InMemorySimpleTrackerStore[ShareDar] with ShareOfferStore
  12. class InMemoryShareRequestStore extends InMemorySimpleTrackerStore[ShareDar] with ShareRequestStore
  13. class InMemorySimpleTrackerStore[A] extends SimpleContractTrackerStore[A]
  14. class InMemoryWhitelistStore extends WhitelistStore
  15. trait PackageInspectionOps extends NamedLogging
  16. class PackageInspectionOpsImpl extends PackageInspectionOps
  17. class PackageService extends DarService with PackageInfoService with NamedLogging with FlagCloseable
  18. class PingService extends AdminWorkflowService with FlagCloseableAsync with NamedLogging

    Implements the core of the ledger ping service for a participant.

    Implements the core of the ledger ping service for a participant. The service measures the time needed for a nanobot on the responder to act on a contract created by the initiator.

    The main functionality: 1. once instantiated, it automatically starts a Scala Nanobot that responds to pings for this participant 2. it provides a ping method that sends a ping to the given (target) party

    Parameters:

    Annotations
    @SuppressWarnings()
  19. class RepairService extends NamedLogging with FlagCloseableAsync with HasCloseContext

    Implements the repair commands.

    Implements the repair commands. Repair commands work only if the participant has disconnected from the affected domains. Every individual repair commands is executed transactionally, i.e., either all its effects are applied or none. This is achieved in the same way as for request processing:

    If anything goes wrong before advancing the clean request prehead, the already persisted data will be cleaned up upon the next repair request or reconnection to the domain.

  20. case class ResourceLimits(maxDirtyRequests: Option[NonNegativeInt], maxRate: Option[NonNegativeInt]) extends Product with Serializable

    Encapsulated resource limits for a participant.

    Encapsulated resource limits for a participant.

    maxDirtyRequests

    the maximum number of requests that are currently being validated. This also covers requests submitted by other participants.

    maxRate

    the maximum rate at which commands may be submitted through the ledger api.

  21. trait ResourceManagementService extends AnyRef
  22. sealed trait ShareError extends AnyRef
  23. trait ShareOfferStore extends SimpleContractTrackerStore[ShareDar]

    Store for received DAR sharing offers I've not yet responded to

  24. trait ShareRequestStore extends SimpleContractTrackerStore[ShareDar]

    Store for DAR sharing requests I've sent that haven't yet been accepted or rejected

  25. trait SimpleContractTrackerStore[A] extends AnyRef

    Simple store for tracking ledger contracts of a given type

  26. class SyncStateInspection extends NamedLogging

    Implements inspection functions for the sync state of a participant node

  27. class TransferService extends AnyRef
  28. trait WhitelistStore extends AnyRef

    Store for parties I have whitelisted DARs from (permitting them to be automatically installed)

Value Members

  1. object AcceptRejectError
  2. object AdminWorkflowServices extends AdminWorkflowServicesErrorGroup
  3. object CantonPackageServiceError extends PackageServiceErrorGroup
  4. object Converters

    Conversions between types used by the admin-api

  5. object PackageService
  6. object PingService
  7. object RepairService
  8. object ResourceLimits extends Serializable
  9. object ResourceManagementService
  10. object ShareError
  11. object SyncStateInspection

Ungrouped