package eventing

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. class AsyncEventingFunctionManager extends AnyRef
    Annotations
    @Uncommitted()
  2. case class EventingFunction(name: String, code: String, sourceKeyspace: EventingFunctionKeyspace, metadataKeyspace: EventingFunctionKeyspace, settings: Option[EventingFunctionSettings] = None, version: Option[String] = None, enforceSchema: Option[Boolean] = None, handlerUuid: Option[Long] = None, functionInstanceId: Option[String] = None, bucketBindings: Option[Seq[EventingFunctionBucketBinding]] = None, urlBindings: Option[Seq[EventingFunctionUrlBinding]] = None, constantBindings: Option[Seq[EventingFunctionConstantBinding]] = None) extends Product with Serializable
  3. sealed trait EventingFunctionBucketAccess extends AnyRef
  4. case class EventingFunctionBucketBinding(alias: String, name: EventingFunctionKeyspace, access: EventingFunctionBucketAccess) extends Product with Serializable
  5. case class EventingFunctionConstantBinding(alias: String, literal: String) extends Product with Serializable
  6. sealed trait EventingFunctionDcpBoundary extends AnyRef
  7. sealed trait EventingFunctionDeploymentStatus extends AnyRef
  8. case class EventingFunctionKeyspace(bucket: String, scope: Option[String] = None, collection: Option[String] = None) extends Product with Serializable
  9. sealed trait EventingFunctionLanguageCompatibility extends AnyRef
  10. sealed trait EventingFunctionLogLevel extends AnyRef
  11. class EventingFunctionManager extends AnyRef
    Annotations
    @Uncommitted()
  12. sealed trait EventingFunctionProcessingStatus extends AnyRef
  13. case class EventingFunctionSettings(cppWorkerThreadCount: Option[Long] = None, dcpStreamBoundary: Option[EventingFunctionDcpBoundary] = None, description: Option[String] = None, logLevel: Option[EventingFunctionLogLevel] = None, languageCompatibility: Option[EventingFunctionLanguageCompatibility] = None, executionTimeout: Option[Duration] = None, lcbInstCapacity: Option[Long] = None, lcbRetryCount: Option[Long] = None, lcbTimeout: Option[Duration] = None, queryConsistency: Option[QueryScanConsistency] = None, numTimerPartitions: Option[Long] = None, sockBatchSize: Option[Long] = None, tickDuration: Option[Duration] = None, timerContextSize: Option[Long] = None, userPrefix: Option[String] = None, bucketCacheSize: Option[Long] = None, bucketCacheAge: Option[Long] = None, curlMaxAllowedRespSize: Option[Long] = None, workerCount: Option[Long] = None, queryPrepareAll: Option[Boolean] = None, handlerHeaders: Option[Seq[String]] = None, handlerFooters: Option[Seq[String]] = None, enableAppLogRotation: Option[Boolean] = None, appLogDir: Option[String] = None, appLogMaxSize: Option[Long] = None, appLogMaxFiles: Option[Long] = None, checkpointInterval: Option[Duration] = None, processingStatus: Option[EventingFunctionProcessingStatus] = None, deploymentStatus: Option[EventingFunctionDeploymentStatus] = None) extends Product with Serializable
  14. case class EventingFunctionState(name: String, status: EventingFunctionStatus, numBootstrappingNodes: Int, numDeployedNodes: Int, deploymentStatus: EventingFunctionDeploymentStatus, processingStatus: EventingFunctionProcessingStatus) extends Product with Serializable
  15. sealed trait EventingFunctionStatus extends AnyRef
  16. sealed trait EventingFunctionUrlAuth extends AnyRef
  17. case class EventingFunctionUrlBinding(hostname: String, alias: String, auth: EventingFunctionUrlAuth, allowCookies: Boolean, validateSslCertificate: Boolean) extends Product with Serializable
  18. case class EventingStatus(numEventingNodes: Int, functions: Seq[EventingFunctionState]) extends Product with Serializable
  19. class ReactiveEventingFunctionManager extends AnyRef
    Annotations
    @Uncommitted()

Ungrouped