class GrpcPruningService extends PruningService with HasPruningScheduler with GrpcPruningScheduler with NamedLogging
- Alphabetic
- By Inheritance
- GrpcPruningService
- NamedLogging
- GrpcPruningScheduler
- HasPruningScheduler
- PruningService
- AbstractService
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new GrpcPruningService(sync: CantonSyncService, scheduleAccessorBuilder: () => Option[ParticipantPruningScheduler], loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clearSchedule(request: Request): Future[Response]
- Definition Classes
- GrpcPruningScheduler
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- def convertF[T](f: => ParsingResult[T])(implicit traceContext: TraceContext): Future[T]
- Attributes
- protected
- Definition Classes
- GrpcPruningScheduler
- def convertRequiredF[P, T](field: String, value: Option[P], f: (P) => ParsingResult[T])(implicit traceContext: TraceContext): Future[T]
- Attributes
- protected
- Definition Classes
- GrpcPruningScheduler
- implicit val ec: ExecutionContext
- Definition Classes
- GrpcPruningService → HasPruningScheduler
- def ensureScheduler(implicit traceContext: TraceContext): Future[ParticipantPruningScheduler]
- Attributes
- protected
- Definition Classes
- GrpcPruningService → HasPruningScheduler
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def getParticipantSchedule(request: Request): Future[Response]
Retrieve the automatic, participant-specific pruning configuration.
Retrieve the automatic, participant-specific pruning configuration.
- Definition Classes
- GrpcPruningService → PruningService
- def getSafePruningOffset(request: GetSafePruningOffsetRequest): Future[GetSafePruningOffsetResponse]
Retrieve the safe pruning offset
Retrieve the safe pruning offset
- Definition Classes
- GrpcPruningService → PruningService
- def getSchedule(request: Request): Future[Response]
- Definition Classes
- GrpcPruningScheduler
- def handlePassiveHAStorageError(update: Future[Unit], commandName: String): Future[Unit]
- Attributes
- protected
- Definition Classes
- GrpcPruningScheduler
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- GrpcPruningService → NamedLogging
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def prune(request: PruneRequest): Future[PruneResponse]
Prune the participant specifying the offset before and at which ledger transactions should be removed.
Prune the participant specifying the offset before and at which ledger transactions should be removed. Only returns when the potentially long-running prune request ends successfully or with one of the following errors: -
: if the payload, particularly the offset is malformed or missing -INVALID_ARGUMENT
: if the participant has encountered a failure and has potentially applied pruning partially. Such cases warrant verifying the participant health before retrying the prune with the same (or a larger, valid) offset. Successful retries after such errors ensure that different components reach a consistent pruning state. -INTERNAL
: if the participant is not yet able to prune at the specified offset or if pruning is invoked on a participant running the Community Edition.FAILED_PRECONDITION
- Definition Classes
- GrpcPruningService → PruningService
- def serviceCompanion: ServiceCompanion[PruningService]
- Definition Classes
- PruningService → AbstractService
- def setCron(request: Request): Future[Response]
- Definition Classes
- GrpcPruningScheduler
- def setMaxDuration(request: Request): Future[Response]
- Definition Classes
- GrpcPruningScheduler
- def setParticipantSchedule(request: Request): Future[Response]
Enable automatic pruning with participant-specific schedule parameters.
Enable automatic pruning with participant-specific schedule parameters.
- Definition Classes
- GrpcPruningService → PruningService
- def setRetention(request: Request): Future[Response]
- Definition Classes
- GrpcPruningScheduler
- def setSchedule(request: Request): Future[Response]
- Definition Classes
- GrpcPruningScheduler
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])