Package org.springframework.cloud.appbroker.logging.streaming

Class LogCacheStreamPublisher

java.lang.Object

org.springframework.cloud.appbroker.logging.streaming.LogCacheStreamPublisher

All Implemented Interfaces:

LogStreamPublisher<org.cloudfoundry.dropsonde.events.Envelope>

public class LogCacheStreamPublisher
extends Object
implements LogStreamPublisher<org.cloudfoundry.dropsonde.events.Envelope>

Class to Stream LocCache Envelopes using the same pattern as the loc-cache-cli

Constructor Summary

Constructors

Constructor	Description
LogCacheStreamPublisher(org.cloudfoundry.client.CloudFoundryClient client, org.cloudfoundry.logcache.v1.LogCacheClient logCacheClient, ApplicationIdsProvider applicationIdsProvider)

Method Summary

Modifier and Type	Method	Description
protected reactor.core.publisher.Flux<org.cloudfoundry.dropsonde.events.Envelope>	createApplicationStreamer(String applicationId)
reactor.core.publisher.Flux<org.cloudfoundry.dropsonde.events.Envelope>	getLogStream(String serviceInstanceId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LogCacheStreamPublisher

public LogCacheStreamPublisher(org.cloudfoundry.client.CloudFoundryClient client,
 org.cloudfoundry.logcache.v1.LogCacheClient logCacheClient,
 ApplicationIdsProvider applicationIdsProvider)

Method Details

getLogStream

public reactor.core.publisher.Flux<org.cloudfoundry.dropsonde.events.Envelope> getLogStream(String serviceInstanceId)

Specified by:

getLogStream in interface LogStreamPublisher<org.cloudfoundry.dropsonde.events.Envelope>

createApplicationStreamer

protected reactor.core.publisher.Flux<org.cloudfoundry.dropsonde.events.Envelope> createApplicationStreamer(String applicationId)