执行器接口设计

    1. public interface HystrixObservable<R> extends HystrixInvokable<R> {
    3.     public Observable<R> observe();
    5.     public Observable<R> toObservable();
    7. }
    8. // 执行器
    9. public interface HystrixExecutable<R> extends HystrixInvokable<R> {
    11.     public R execute();
    13.     public Future<R> queue();
    15.     public Observable<R> observe();
    16. }

    熔断器配置信息接口

    1. public interface HystrixInvokableInfo<R> {
    3.     HystrixCommandGroupKey getCommandGroup();
    5.     HystrixCommandKey getCommandKey();
    7.     HystrixThreadPoolKey getThreadPoolKey();
    9.     String getPublicCacheKey(); //have to use public in the name, as there's already a protected {@link AbstractCommand#getCacheKey()} method.
    11.     HystrixCollapserKey getOriginatingCollapserKey();
    13.     HystrixCommandMetrics getMetrics();
    15.     HystrixCommandProperties getProperties();
    17.     boolean isCircuitBreakerOpen();
    19.     boolean isExecutionComplete();
    21.     boolean isExecutedInThread();
    23.     boolean isSuccessfulExecution();
    25.     boolean isFailedExecution();
    27.     Throwable getFailedExecutionException();
    29.     boolean isResponseFromFallback();
    31.     boolean isResponseTimedOut();
    33.     boolean isResponseShortCircuited();
    35.     boolean isResponseFromCache();
    37.     boolean isResponseRejected();
    39.     boolean isResponseSemaphoreRejected();
    41.     boolean isResponseThreadPoolRejected();
    43.     List<HystrixEventType> getExecutionEvents();
    45.     int getNumberEmissions();
    47.     int getNumberFallbackEmissions();
    49.     int getNumberCollapsed();
    51.     int getExecutionTimeInMilliseconds();
    53.     long getCommandRunStartTimeInNanos();
    55.     ExecutionResult.EventCounts getEventCounts();
    56. }

    抽象基础信息实现