Packages

class ParticipantRepairAdministration extends FeatureFlagFilter with NoTracing with Helpful

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ParticipantRepairAdministration
  2. Helpful
  3. NoTracing
  4. FeatureFlagFilter
  5. NamedLogging
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ParticipantRepairAdministration(consoleEnvironment: ConsoleEnvironment, runner: AdminCommandRunner, loggerFactory: NamedLoggerFactory)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def cantonConfig: CantonConfig
    Attributes
    protected
    Definition Classes
    FeatureFlagFilter
  6. def check[T](flag: FeatureFlag)(command: => T): T
    Attributes
    protected
    Definition Classes
    FeatureFlagFilter
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  8. val consoleEnvironment: ConsoleEnvironment
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  12. def export_acs(parties: Set[PartyId], partiesOffboarding: Boolean, outputFile: String = ParticipantRepairAdministration.ExportAcsDefaultFile, filterDomainId: Option[DomainId] = None, timestamp: Option[Instant] = None, contractDomainRenames: Map[DomainId, (DomainId, ProtocolVersion)] = Map.empty): Unit
    Annotations
    @Summary(s = "Export active contracts for the given set of parties to a file.", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """This command exports the current Active Contract Set (ACS) of a given set of parties to ACS snapshot file.
    |Afterwards, the 'import_acs' command allows importing it into a participant's ACS again.
    |Such ACS export (and import) is interesting for recovery and operational purposes only.
    |Note that the 'export_acs' command execution may take a long time to complete and may require significant
    |resources.
    |
    |The arguments are:
    |- parties: identifying contracts having at least one stakeholder from the given set
    |- partiesOffboarding: true if the parties will be offboarded (party migration)
    |- outputFile: the output file name where to store the data. Use .gz as a suffix to get a compressed file (recommended)
    |- filterDomainId: restrict the export to a given domain
    |- timestamp: optionally a timestamp for which we should take the state (useful to reconcile states of a domain)
    |- contractDomainRenames: As part of the export, allow to rename the associated domain id of contracts from one domain to another based on the mapping.
    """
    )
  13. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. def help(methodName: String)(implicit consoleEnvironment: ConsoleEnvironment): Unit
    Definition Classes
    Helpful
    Annotations
    @Summary(s = "Help for specific commands (use help() or help(\"method\") for more information)", flag = console.this.Help.Summary.<init>$default$2) @Topic(t = Seq("Top-level Commands"))
  16. def help()(implicit consoleEnvironment: ConsoleEnvironment): Unit
    Definition Classes
    Helpful
  17. def import_acs(inputFile: String = ParticipantRepairAdministration.ExportAcsDefaultFile, onboardedParties: Set[PartyId], workflowIdPrefix: String = ""): Unit
    Annotations
    @Summary(s = "Import active contracts from an Active Contract Set (ACS) snapshot file.", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """This command imports contracts from an ACS snapshot file into the participant's ACS.
    |The given ACS snapshot file needs to be the resulting file from a previous 'export_acs' command invocation.
    |
    |Arguments are:
    | - inputFile: the path to the file containing the ACS export
    | - onboardedParties: the list of new parties whose contracts are imported
    """
    )
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  20. val loggerFactory: NamedLoggerFactory
  21. def migrate_domain(source: DomainAlias, target: DomainConnectionConfig): Unit
    Annotations
    @Summary(s = "Migrate contracts from one domain to another one.", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """This method can be used to migrate all the contracts associated with a domain to a new domain connection.
    This method will register the new domain, connect to it and then re-associate all contracts on the source
    domain to the target domain. Please note that this migration needs to be done by all participants
    at the same time. The domain should only be used once all participants have finished their migration.

    The arguments are:
    source: the domain alias of the source domain
    target: the configuration for the target domain
    """
    )
  22. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  23. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  25. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  26. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  27. def purge(domain: DomainAlias, contractIds: Seq[LfContractId], offboardedParties: Set[PartyId], ignoreAlreadyPurged: Boolean = true): Unit
    Annotations
    @Summary(s = "Purge contracts with specified Contract IDs from local participant.", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """This is a last resort command to recover from data corruption, e.g. in scenarios in which participant
    |contracts have somehow gotten out of sync and need to be manually purged, or in situations in which
    |stakeholders are no longer available to agree to their archival. The participant needs to be disconnected from
    |the domain on which the contracts with "contractIds" reside at the time of the call, and as of now the domain
    |cannot have had any inflight requests.
    |The "ignoreAlreadyPurged" flag makes it possible to invoke the command multiple times with the same
    |parameters in case an earlier command invocation has failed.
    |As repair commands are powerful tools to recover from unforeseen data corruption, but dangerous under normal
    |operation, use of this command requires (temporarily) enabling the "features.enable-repair-commands"
    |configuration. In addition repair commands can run for an unbounded time depending on the number of
    |contract ids passed in. Be sure to not connect the participant to the domain until the call returns.
    |
    |Arguments are:
    | - inputFile: the path to the file containing the ACS export
    | - offboardedParties: the list of parties that will be offboarded after the purge."""
    )
  28. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  29. def toString(): String
    Definition Classes
    AnyRef → Any
  30. implicit def traceContext: TraceContext
    Attributes
    protected
    Definition Classes
    NoTracing
  31. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  32. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  33. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def download(parties: Set[PartyId], partiesOffboarding: Boolean, outputFile: String = ParticipantRepairAdministration.DefaultFile, filterDomainId: String = "", timestamp: Option[Instant] = None, protocolVersion: Option[ProtocolVersion] = None, chunkSize: Option[PositiveInt] = None, contractDomainRenames: Map[DomainId, DomainId] = Map.empty): Unit
    Annotations
    @Summary(s = "Download all contracts for the given set of parties to a file.", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """This command can be used to download the current active contract set of a given set of parties to a text file.
    |This is mainly interesting for recovery and operational purposes.
    |
    |The file will contain base64 encoded strings, one line per contract. The lines are written
    |sorted according to their domain and contract id. This allows to compare the contracts stored
    |by two participants using standard file comparison tools.
    |The domain-id is printed with the prefix domain-id before the block of contracts starts.
    |
    |This command may take a long time to complete and may require significant resources.
    |It will first load the contract ids of the active contract set into memory and then subsequently
    |load the contracts in batches and inspect their stakeholders. As this operation needs to traverse
    |the entire datastore, it might take a long time to complete.
    |
    |The command will return a map of domainId -> number of active contracts stored
    |
    The arguments are:
    - parties: identifying contracts having at least one stakeholder from the given set
    - partiesOffboarding: true if the parties will be offboarded (party migration)
    - outputFile: the output file name where to store the data. Use .gz as a suffix to get a compressed file (recommended)
    - filterDomainId: restrict the export to a given domain
    - timestamp: optionally a timestamp for which we should take the state (useful to reconcile states of a domain)
    - protocolVersion: optional the protocol version to use for the serialization. Defaults to the one of the domains.
    - chunkSize: size of the byte chunks to stream back: default 1024 * 1024 * 2 = (2MB)
    - contractDomainRenames: As part of the export, allow to rename the associated domain id of contracts from one domain to another based on the mapping.
    """
    )
    @deprecated
    Deprecated

    (Since version 2.8.0) Use export_acs

  2. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated
  3. def upload(inputFile: String = ParticipantRepairAdministration.DefaultFile): Unit
    Annotations
    @Summary(s = "Import ACS snapshot", flag = console.this.Help.Summary.<init>$default$2) @Description(s = """Uploads a binary into the participant's ACS""") @deprecated
    Deprecated

    (Since version 2.8.0) Use import_acs

Inherited from Helpful

Inherited from NoTracing

Inherited from FeatureFlagFilter

Inherited from NamedLogging

Inherited from AnyRef

Inherited from Any

Ungrouped