object
HistoryMessageRepo
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
def
create(newMessages: Seq[HistoryMessage]): FixedSqlAction[Option[Int], slick.driver.JdbcProfile.API.NoStream, Write]
-
def
create(message: HistoryMessage): FixedSqlAction[Int, slick.driver.JdbcProfile.API.NoStream, Write]
-
def
delete(userId: Int, peer: Peer, randomIds: Set[Long]): slick.driver.PostgresDriver.DriverAction[Int, NoStream, Write]
-
def
deleteAll(userId: Int, peer: Peer): FixedSqlAction[Int, slick.driver.JdbcProfile.API.NoStream, Write]
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
finalize(): Unit
-
def
find(userId: Int, peer: Peer, randomIds: Set[Long]): FixedSqlStreamingAction[Seq[HistoryMessage], HistoryMessage, Read]
-
def
find(userId: Int, peer: Peer): FixedSqlStreamingAction[Seq[HistoryMessage], HistoryMessage, Read]
-
def
find(userId: Int, peer: Peer, dateOpt: Option[DateTime], limit: Int): FixedSqlStreamingAction[Seq[HistoryMessage], HistoryMessage, Read]
-
def
findBySender(senderUserId: Int, peer: Peer, randomId: Long): FixedSqlStreamingAction[Seq[HistoryMessage], HistoryMessage, Read]
-
def
findNewest(userId: Int, peer: Peer): SqlAction[Option[HistoryMessage], slick.driver.JdbcProfile.API.NoStream, Read]
-
def
findUserIds(peer: Peer, randomIds: Set[Long]): slick.driver.JdbcProfile.API.DBIO[Seq[Int]]
-
final
def
getClass(): Class[_]
-
def
getUnreadCount(userId: Int, peer: Peer, lastReadAt: DateTime, noServiceMessages: Boolean = false): FixedSqlAction[Int, slick.driver.JdbcProfile.API.NoStream, Read]
-
def
getUnreadTotal(userId: Int): slick.driver.JdbcProfile.API.DBIO[Int]
-
def
hashCode(): Int
-
def
haveMessagesBetween(userId: Int, peer: Peer, minDate: DateTime, maxDate: DateTime): slick.driver.PostgresDriver.DriverAction[Boolean, slick.driver.JdbcProfile.API.NoStream, Read]
-
final
def
isInstanceOf[T0]: Boolean
-
-
-
final
def
ne(arg0: AnyRef): Boolean
-
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
def
uniqueAsc(fromTs: Long, limit: Int): SqlStreamingAction[Vector[HistoryMessage], HistoryMessage, slick.driver.JdbcProfile.API.Effect]
-
def
updateContentAll(userIds: Set[Int], randomId: Long, peerType: PeerType, peerIds: Set[Int], messageContentHeader: Int, messageContentData: Array[Byte]): FixedSqlAction[Int, slick.driver.JdbcProfile.API.NoStream, Write]
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
-
Inherited from AnyRef
Inherited from Any