io.micronaut.configurations.hystrix.stream

Class HystrixStreamController

java.lang.Object

io.micronaut.configurations.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 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(Duration interval) Constructor.

Method Summary

Modifier and Type	Method and Description
io.reactivex.Flowable<Event<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}")
                                       Duration interval)

Constructor.

Parameters:

interval - interval value injected

HystrixStreamController

public HystrixStreamController()

Constructor.

Method Detail

hystrixStream

@Get(uri="/",
     produces="text/event-stream")
public io.reactivex.Flowable<Event<String>> hystrixStream()

Hystrix stream endpoint.

Returns:

hystrix stream as an event