org.springframework.cloud.appbroker.logging.streaming

Class DopplerLogStreamPublisher

java.lang.Object

org.springframework.cloud.appbroker.logging.streaming.DopplerLogStreamPublisher

All Implemented Interfaces:

LogStreamPublisher<org.cloudfoundry.doppler.Envelope>

public class DopplerLogStreamPublisher
extends Object
implements LogStreamPublisher<org.cloudfoundry.doppler.Envelope>

Constructor Summary

Constructors

Constructor and Description
DopplerLogStreamPublisher(org.cloudfoundry.client.CloudFoundryClient client, org.cloudfoundry.doppler.DopplerClient dopplerClient, ApplicationIdsProvider applicationIdsProvider)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

DopplerLogStreamPublisher

public DopplerLogStreamPublisher(org.cloudfoundry.client.CloudFoundryClient client,
                                 org.cloudfoundry.doppler.DopplerClient dopplerClient,
                                 ApplicationIdsProvider applicationIdsProvider)

Method Detail

getLogStream

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

Specified by:

getLogStream in interface LogStreamPublisher<org.cloudfoundry.doppler.Envelope>

createApplicationStreamer

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