object LogRotatorSink
- Alphabetic
- By Inheritance
- LogRotatorSink
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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(triggerGeneratorCreator: () => (ByteString) => Option[Path], fileOpenOptions: Set[OpenOption] = Set(StandardOpenOption.APPEND, StandardOpenOption.CREATE)): Sink[ByteString, Future[Done]]
Sink directing the incoming
ByteStrings to new files whenevertriggerGeneratorreturns a value.Sink directing the incoming
ByteStrings to new files whenevertriggerGeneratorreturns a value.- triggerGeneratorCreator
creates a function that triggers rotation by returning a value
- fileOpenOptions
file options for file creation
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def withSinkFactory[C, R](triggerGeneratorCreator: () => (ByteString) => Option[C], sinkFactory: (C) => Sink[ByteString, Future[R]]): Sink[ByteString, Future[Done]]
Sink directing the incoming
ByteStrings to a newSinkcreated bysinkFactorywhenevertriggerGeneratorreturns a value.Sink directing the incoming
ByteStrings to a newSinkcreated bysinkFactorywhenevertriggerGeneratorreturns a value.- C
criterion type (for files a
Path)- R
result type in materialized futures of
sinkFactory- triggerGeneratorCreator
creates a function that triggers rotation by returning a value
- sinkFactory
creates sinks for
ByteStrings from the value returned bytriggerGenerator
- def withTypedSinkFactory[T, C, R](triggerGeneratorCreator: () => (T) => Option[C], sinkFactory: (C) => Sink[T, Future[R]]): Sink[T, Future[Done]]
Sink directing the incoming
Ts to a newSinkcreated bysinkFactorywhenevertriggerGeneratorreturns a value.Sink directing the incoming
Ts to a newSinkcreated bysinkFactorywhenevertriggerGeneratorreturns a value.- T
stream and sink data type
- C
criterion type (for files a
Path)- R
result type in materialized futures of
sinkFactory- triggerGeneratorCreator
creates a function that triggers rotation by returning a value
- sinkFactory
creates sinks for
Ts from the value returned bytriggerGenerator