object Item extends Serializable
- Alphabetic
- By Inheritance
- Item
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
sealed
trait
ItemFsmError extends AnyRef
Common violations of FSM-nature of Item
- final case class OrderedRecords(nel: NonEmptyList[Record]) extends Product with Serializable
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
-
def
apply(unordered: NonEmptyList[Record]): Item
Constructor, ensuring that final
Itemalways contains sortedRecordsConstructor, ensuring that final
Itemalways contains sortedRecords- unordered
non-empty list (probably) received without particular order
- returns
Itemwith sameRecords, but ordered by timestamp
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
final
def
canBeProcessedBy(requester: Application)(item: Item): Boolean
Check if list of applications extracted from SKIPPED record are blocking current app
-
final
def
checkItemId(item: List[Record]): Either[String, Unit]
Check that
Itemhas a consistent state, e.g.Check that
Itemhas a consistent state, e.g. it has a single id -
final
def
checkStateConsistency(item: List[Record]): Either[NonEmptyList[String], Unit]
Primary FSM-checking state, validating that no records refer to unexpected previous records, e.g.
Primary FSM-checking state, validating that no records refer to unexpected previous records, e.g. NEW is always first and FAILED always refers to some PROCESSING
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
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
- implicit final val itemShow: Show[Item]
-
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()
- final def processedBy(application: Application, record: Record): Boolean
-
final
def
processedBy(application: Application, item: Item): Boolean
Check that
Itemwas already processed byApplicationDoes not do any validations onItem, e.g.Check that
Itemwas already processed byApplicationDoes not do any validations onItem, e.g. inconsistent state ids won't make result different. Assumes that item withApplication(_, _, None, _)coversApplication(_, _, Some(a), _)andApplication(_, _, Some(b), _), making safe double-processing (e.g. loading to two storage targets) by same rdb-loader -
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( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- object ItemFsmError