c
pl.touk.nussknacker.ui.process.repository
DBFetchingProcessRepository
Companion object DBFetchingProcessRepository
abstract class DBFetchingProcessRepository[F[_]] extends FetchingProcessRepository[F] with LazyLogging
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DBFetchingProcessRepository
- LazyLogging
- FetchingProcessRepository
- ProcessDBQueryRepository
- EspTables
- AttachmentEntityFactory
- TagsEntityFactory
- ProcessActionEntityFactory
- EnvironmentsEntityFactory
- ProcessVersionEntityFactory
- CommentEntityFactory
- ProcessEntityFactory
- Repository
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
Type Members
-
class
AttachmentEntity extends slick.jdbc.JdbcProfile.API.Table[AttachmentEntityData]
- Definition Classes
- AttachmentEntityFactory
-
class
CommentEntity extends slick.jdbc.JdbcProfile.API.Table[CommentEntityData]
- Definition Classes
- CommentEntityFactory
-
class
EnvironmentsEntity extends slick.jdbc.JdbcProfile.API.Table[EnvironmentsEntityData]
- Definition Classes
- EnvironmentsEntityFactory
-
class
ProcessActionEntity extends slick.jdbc.JdbcProfile.API.Table[ProcessActionEntityData]
- Definition Classes
- ProcessActionEntityFactory
-
class
ProcessEntity extends slick.jdbc.JdbcProfile.API.Table[ProcessEntityData]
- Definition Classes
- ProcessEntityFactory
-
abstract
class
BaseProcessVersionEntity extends slick.jdbc.JdbcProfile.API.Table[ProcessVersionEntityData]
- Definition Classes
- ProcessVersionEntityFactory
-
class
ProcessVersionEntity extends BaseProcessVersionEntity
- Definition Classes
- ProcessVersionEntityFactory
-
class
ProcessVersionEntityNoJson extends BaseProcessVersionEntity
- Definition Classes
- ProcessVersionEntityFactory
-
class
TagsEntity extends slick.jdbc.JdbcProfile.API.Table[TagsEntityData]
- Definition Classes
- TagsEntityFactory
Abstract Value Members
-
abstract
def
run[R]: (DB[R]) ⇒ F[R]
- Definition Classes
- Repository
Concrete 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
-
lazy val
api: API
- Attributes
- protected
- Definition Classes
- Repository
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
val
attachmentsTable: TableQuery[AttachmentEntity]
- Definition Classes
- AttachmentEntityFactory
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
val
commentsTable: TableQuery[CommentEntity]
- Definition Classes
- CommentEntityFactory
-
val
dbConfig: DbConfig
- Definition Classes
- DBFetchingProcessRepository → Repository
-
implicit
def
deploymentMapper: JdbcType[ProcessActionType] with BaseTypedType[ProcessActionType]
- Definition Classes
- ProcessActionEntityFactory
-
val
environmentsTable: TableQuery[EnvironmentsEntity]
- Definition Classes
- EnvironmentsEntityFactory
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
fetchAllProcessesDetails[PS]()(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[List[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchArchivedProcesses[PS]()(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[List[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchCustomProcesses[PS]()(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[List[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchDeployedProcessesDetails[PS]()(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[List[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchLastActionPerProcessQuery: slick.jdbc.JdbcProfile.API.Query[(slick.jdbc.JdbcProfile.API.Rep[Long], (ProcessActionEntity, slick.jdbc.JdbcProfile.API.Rep[Option[CommentEntity]])), (Long, (ProcessActionEntityData, Option[CommentEntityData])), Seq]
- Attributes
- protected
- Definition Classes
- ProcessDBQueryRepository
-
def
fetchLastDeployedActionPerProcessQuery: slick.jdbc.JdbcProfile.API.Query[(slick.jdbc.JdbcProfile.API.Rep[Long], (ProcessActionEntity, slick.jdbc.JdbcProfile.API.Rep[Option[CommentEntity]])), (Long, (ProcessActionEntityData, Option[CommentEntityData])), Seq]
- Attributes
- protected
- Definition Classes
- ProcessDBQueryRepository
-
def
fetchLatestProcessDetailsForProcessId[PS](id: ProcessId)(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[Option[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchLatestProcessDetailsForProcessIdEither[PS](id: ProcessId)(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[XError[BaseProcessDetails[PS]]]
- Definition Classes
- FetchingProcessRepository
-
def
fetchLatestProcessVersion[PS](processId: ProcessId)(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser): F[Option[ProcessVersionEntityData]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchLatestProcessesQuery(query: (ProcessEntity) ⇒ slick.jdbc.JdbcProfile.API.Rep[Boolean], lastDeployedActionPerProcess: Seq[(Long, (ProcessActionEntityData, Option[CommentEntityData]))], isDeployed: Option[Boolean])(implicit fetchShape: ProcessShapeFetchStrategy[_], loggedUser: LoggedUser, ec: ExecutionContext): slick.jdbc.JdbcProfile.API.Query[(((slick.jdbc.JdbcProfile.API.Rep[Long], slick.jdbc.JdbcProfile.API.Rep[Option[Timestamp]]), BaseProcessVersionEntity), ProcessEntity), (((Long, Option[Timestamp]), ProcessVersionEntityData), ProcessEntityData), Seq]
- Attributes
- protected
- Definition Classes
- ProcessDBQueryRepository
-
def
fetchProcessActions(processId: ProcessId)(implicit ec: ExecutionContext): F[List[ProcessAction]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchProcessDetails(processName: ProcessName)(implicit ec: ExecutionContext): F[Option[ProcessEntityData]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchProcessDetailsForId[PS](processId: ProcessId, versionId: Long)(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[Option[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchProcessId(processName: ProcessName)(implicit ec: ExecutionContext): F[Option[ProcessId]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchProcessLatestActionsQuery(processId: ProcessId): slick.jdbc.JdbcProfile.API.Query[(ProcessActionEntity, slick.jdbc.JdbcProfile.API.Rep[Option[CommentEntity]]), (ProcessActionEntityData, Option[CommentEntityData]), Seq]
- Attributes
- protected
- Definition Classes
- ProcessDBQueryRepository
-
def
fetchProcessLatestVersionsQuery(processId: ProcessId)(implicit fetchShape: ProcessShapeFetchStrategy[_]): slick.jdbc.JdbcProfile.API.Query[BaseProcessVersionEntity, ProcessVersionEntityData, Seq]
- Attributes
- protected
- Definition Classes
- ProcessDBQueryRepository
-
def
fetchProcessName(processId: ProcessId)(implicit ec: ExecutionContext): F[Option[ProcessName]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchProcesses[PS](isSubprocess: Option[Boolean], isArchived: Option[Boolean], isDeployed: Option[Boolean], categories: Option[Seq[String]], processingTypes: Option[Seq[String]])(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[List[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchProcesses[PS]()(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[List[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchProcessesDetails[PS](processNames: List[ProcessName])(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[List[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchProcessesDetails[PS]()(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[List[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchProcessingType(processId: ProcessId)(implicit user: LoggedUser, ec: ExecutionContext): F[ProcessingType]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchSubProcessesDetails[PS]()(implicit arg0: ProcessShapeFetchStrategy[PS], loggedUser: LoggedUser, ec: ExecutionContext): F[List[BaseProcessDetails[PS]]]
- Definition Classes
- DBFetchingProcessRepository → FetchingProcessRepository
-
def
fetchTagsPerProcess(implicit fetchShape: ProcessShapeFetchStrategy[_], ec: ExecutionContext): slick.jdbc.JdbcProfile.API.DBIOAction[Map[Long, List[TagsEntityData]], slick.jdbc.JdbcProfile.API.NoStream, Read]
- Attributes
- protected
- Definition Classes
- ProcessDBQueryRepository
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
latestProcessVersionsNoJsonQuery(processName: ProcessName): slick.jdbc.JdbcProfile.API.Query[BaseProcessVersionEntity, ProcessVersionEntityData, Seq]
- Attributes
- protected
- Definition Classes
- ProcessDBQueryRepository
-
lazy val
logger: Logger
- Attributes
- protected
- Definition Classes
- LazyLogging
- Annotations
- @transient()
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
val
processActionsTable: TableQuery[ProcessActionEntity]
- Definition Classes
- ProcessActionEntityFactory
-
def
processTableFilteredByUser(implicit loggedUser: LoggedUser): slick.jdbc.JdbcProfile.API.Query[ProcessEntity, ProcessEntityData, Seq]
- Attributes
- protected
- Definition Classes
- ProcessDBQueryRepository
-
implicit
def
processTypeMapper: JdbcType[ProcessType] with BaseTypedType[ProcessType]
- Definition Classes
- ProcessEntityFactory
-
val
processVersionsTable: slick.jdbc.JdbcProfile.API.TableQuery[ProcessVersionEntity]
- Definition Classes
- ProcessVersionEntityFactory
-
val
processVersionsTableNoJson: slick.jdbc.JdbcProfile.API.TableQuery[ProcessVersionEntityNoJson]
- Definition Classes
- ProcessVersionEntityFactory
-
def
processVersionsTableQuery(implicit fetchShape: ProcessShapeFetchStrategy[_]): slick.jdbc.JdbcProfile.API.TableQuery[BaseProcessVersionEntity]
- Attributes
- protected
- Definition Classes
- ProcessDBQueryRepository
-
val
processesTable: TableQuery[ProcessEntity]
- Definition Classes
- ProcessEntityFactory
-
lazy val
profile: JdbcProfile
- Attributes
- protected
- Definition Classes
- Repository
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
val
tagsTable: TableQuery[TagsEntity]
- Definition Classes
- TagsEntityFactory
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.