@Test void build() throws IOException, NoSuchFieldException, IllegalAccessException { try (Fluency fluency = new FluencyBuilderForTreasureData().build(APIKEY)) { assertBuffer(fluency.getBuffer()); assertFlusher(fluency.getFlusher()); assertDefaultFluentdSender( (TreasureDataSender) fluency.getFlusher().getIngester().getSender(), "api-import.treasuredata.com", true); } }
public Fluency build(String apikey, String endpoint) { return buildFromIngester( buildRecordFormatter(), buildIngester(createSenderConfig(endpoint, apikey))); }
FluencyBuilderForTreasureData extends org.komamitsu.fluency.FluencyBuilder { public Fluency build(String apikey, String endpoint) { return buildFromIngester( buildRecordFormatter(), buildIngester(createSenderConfig(endpoint, apikey))); } }
FluencyBuilderForTreasureData extends org.komamitsu.fluency.FluencyBuilder { public Fluency build(String apikey, String endpoint) { return buildFromIngester( buildRecordFormatter(), buildIngester(createSenderConfig(endpoint, apikey))); } FluencyBuilderForTreasureData(); }
FluencyBuilderForTreasureData extends org.komamitsu.fluency.FluencyBuilder { public Fluency build(String apikey, String endpoint) { return buildFromIngester( buildRecordFormatter(), buildIngester(createSenderConfig(endpoint, apikey))); } FluencyBuilderForTreasureData(); Integer getSenderRetryMax(); void setSenderRetryMax(Integer senderRetryMax); Integer getSenderRetryIntervalMillis(); void setSenderRetryIntervalMillis(Integer senderRetryIntervalMillis); Integer getSenderMaxRetryIntervalMillis(); void setSenderMaxRetryIntervalMillis(Integer senderMaxRetryIntervalMillis); Float getSenderRetryFactor(); void setSenderRetryFactor(Float senderRetryFactor); Integer getSenderWorkBufSize(); void setSenderWorkBufSize(Integer senderWorkBufSize); Fluency build(String apikey, String endpoint); Fluency build(String apikey); @Override String toString(); }
FluencyBuilderForTreasureData extends org.komamitsu.fluency.FluencyBuilder { public Fluency build(String apikey, String endpoint) { return buildFromIngester( buildRecordFormatter(), buildIngester(createSenderConfig(endpoint, apikey))); } FluencyBuilderForTreasureData(); Integer getSenderRetryMax(); void setSenderRetryMax(Integer senderRetryMax); Integer getSenderRetryIntervalMillis(); void setSenderRetryIntervalMillis(Integer senderRetryIntervalMillis); Integer getSenderMaxRetryIntervalMillis(); void setSenderMaxRetryIntervalMillis(Integer senderMaxRetryIntervalMillis); Float getSenderRetryFactor(); void setSenderRetryFactor(Float senderRetryFactor); Integer getSenderWorkBufSize(); void setSenderWorkBufSize(Integer senderWorkBufSize); Fluency build(String apikey, String endpoint); Fluency build(String apikey); @Override String toString();  }