Searched refs:BinaryLogSink (Results 1 – 7 of 7) sorted by relevance
34 BinaryLogSink sink = mock(BinaryLogSink.class); in configStrNullTest()42 BinaryLogSink sink = mock(BinaryLogSink.class); in configStrEmptyTest()50 BinaryLogSink sink = mock(BinaryLogSink.class); in closeTest()
130 private final BinaryLogSink sink = mock(BinaryLogSink.class);1234 new SinkWriterImpl(mock(BinaryLogSink.class), maxHeaderBytes, maxMessageBytes)); in build()
32 private final BinaryLogSink sink;39 public BinaryLogProviderImpl(BinaryLogSink sink) throws IOException { in BinaryLogProviderImpl()49 BinaryLogProviderImpl(BinaryLogSink sink, String configStr) throws IOException { in BinaryLogProviderImpl()
27 public interface BinaryLogSink extends Closeable { interface
37 public static BinaryLog createBinaryLog(BinaryLogSink sink) throws IOException { in createBinaryLog()
32 class TempFileSink implements BinaryLogSink {
110 private final BinaryLogSink sink;114 SinkWriterImpl(BinaryLogSink sink, int maxHeaderBytes, int maxMessageBytes) { in SinkWriterImpl()500 FactoryImpl(BinaryLogSink sink, String configurationString) {595 static BinlogHelper createBinaryLog(BinaryLogSink sink, @Nullable String logConfig) {