io.micronaut.configuration.hystrix.stream

Class HystrixStreamController

java.lang.Object

io.micronaut.configuration.hystrix.stream.HystrixStreamController

@Controller(value="${hystrix.stream.path:/hystrix.stream}")
 @Requires(classes={com.netflix.hystrix.serial.SerialHystrixDashboardData.class,io.reactivex.Flowable.class}) @Requires(property="hystrix.stream.enabled",value="true",defaultValue="false")
public class HystrixStreamController
extends java.lang.Object

A controller that produces a hystrix event stream as Server Sent events.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
HystrixStreamController() Constructor.
HystrixStreamController(java.time.Duration interval) Constructor.

Method Summary

Modifier and Type	Method and Description
io.reactivex.Flowable<io.micronaut.http.sse.Event<java.lang.String>>	hystrixStream() Hystrix stream endpoint.

Methods inherited from class java.lang.Object

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

Constructor Detail

HystrixStreamController

@Inject
public HystrixStreamController(@Value(value="${hystrix.stream.interval:1s}")
                                       java.time.Duration interval)

Constructor.

Parameters:

interval - interval value injected

HystrixStreamController

public HystrixStreamController()

Constructor.

Method Detail

hystrixStream

@Get(value="/",
     produces="text/event-stream")
public io.reactivex.Flowable<io.micronaut.http.sse.Event<java.lang.String>> hystrixStream()

Hystrix stream endpoint.

Returns:

hystrix stream as an event