class EntityActions extends LazyLogger
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- EntityActions
- LazyLogger
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new EntityActions(context: DynamicsContext)
Value Members
-
def
count(): Action
Convert to function: RetrieveTotalRecordCount if possible.
- implicit val decoder: EntityDecoder[IO, Dynamic]
- val deleteByQuery: Action
-
def
deleteFromQuery(query: String, primaryId: String, esname: String, concurrency: Int): Stream[IO, (String, Long)]
Return a query that deletes and returns 1 for each delete.
- def export(outputpath: String, inputs: Stream[IO, Object], wrap: Boolean = false, drops: Long = 0, take: Long = Long.MaxValue, transform: (Object) ⇒ Object = identity): IO[Long]
- def export(): Action
- def exportAll(config: AppConfig, q: QuerySpec): IO[Unit]
- val exportFromQuery: Action
- def exportOne(config: AppConfig, q: QuerySpec): IO[Unit]
- def fromEntityNames(entityNames: Seq[String]): Stream[IO, Stream[IO, (String, Long)]]
- def fromFunction(entityNames: Seq[String]): Stream[IO, Stream[IO, (String, Long)]]
- def fromJsonFile(file: String): Stream[Pure, Stream[IO, (String, Long)]]
- def fromMap(queries: Map[String, String]): Stream[Pure, Stream[IO, (String, Long)]]
- def get(command: String): Action
-
def
getAllColumnNames(config: AppConfig, q: QuerySpec): IO[Seq[String]]
Get column names by retrieving a single record.
- def getCountFromFunctionForEntity(entitySet: Seq[String] = Nil): IO[RetrieveTotalRecordCountResponse]
-
lazy val
logger: Logger
- Definition Classes
- LazyLogger
- def mkCountingStreamForEntity(e: String, pk: String): Stream[IO, (String, Long)]