resilience.bulkhead — resilience-for-clojure 0.2.3

*bulkhead-name* clj

Contextual value represents bulkhead name

*creation-time* clj

Contextual value represents event create time

bulkhead clj

(bulkhead name)

(bulkhead name config)

Create a bulkhead with a name and a default or custom bulkhead configuration.

The name argument is only used to register this newly created bulkhead to a BulkheadRegistry. If you don't want to bind this bulkhead with a BulkheadRegistry, the name argument is ignored.

Please refer to bulkhead-config for allowed key value pairs within the bulkhead configurations map.

If you want to register this bulkhead to a BulkheadRegistry, you need to put :registry key with a BulkheadRegistry in the config argument. If you do not provide any other configurations, the newly created bulkhead will inherit bulkhead configurations from this provided BulkheadRegistry Example: (bulkhead my-bulkhead {:registry my-registry})

If you want to register this bulkhead to a BulkheadRegistry and you want to use new bulkhead configurations to overwrite the configurations inherited from the registered BulkheadRegistry, you need not only provide the :registry key with the BulkheadRegistry in config argument but also provide other bulkhead configurations you'd like to overwrite. Example: (bulkhead my-bulkhead {:registry my-registry :max-wait-millis 50})

If you only want to create a bulkhead and not register it to any BulkheadRegistry, you just need to provide bulkhead configurations in config argument. The name argument is ignored.

bulkhead-config clj

(bulkhead-config opts)

Create a BulkheadConfig.

Allowed options are:

• :max-concurrent-calls Configures the max amount of concurrent calls the bulkhead will support.

• :max-wait-millis Configures a maximum amount of time in ms the calling thread will wait to enter the bulkhead. If bulkhead has space available, entry is guaranteed and immediate. If bulkhead is full, calling threads will contest for space, if it becomes available. :max-wait-millis can be set to 0.

  Note: for threads running on an event-loop or equivalent (rx computation pool, etc), setting :max-wait-time to 0 is highly recommended. Blocking an event-loop thread will most likely have a negative effect on application throughput.

config clj

(config bulkhead)

Get the Metrics of this Bulkhead

defbulkhead clj macro

(defbulkhead name)

(defbulkhead name config)

Define a bulkhead under name with a default or custom configuration.

Please refer to bulkhead-config for allowed key value pairs within the bulkhead configuration.

If you want to register this bulkhead to a BulkheadRegistry, you need to put :registry key with a BulkheadRegistry in the config argument. If you do not provide any other configurations, the newly created bulkhead will inherit bulkhead configurations from this provided BulkheadRegistry Example: (defbulkhead my-bulkhead {:registry my-registry})

If you want to register this bulkhead to a BulkheadRegistry and you want to use new bulkhead configurations to overwrite the configurations inherited from the registered BulkheadRegistry, you need not only provide the :registry key with the BulkheadRegistry in config argument but also provide other bulkhead configurations you'd like to overwrite. Example: (defbulkhead my-bulkhead {:registry my-registry :max-wait-millis 50})

If you only want to create a bulkhead and not register it to any BulkheadRegistry, you just need to provide bulkhead configuration in config argument without :registry keyword.

defregistry clj macro

(defregistry name)

(defregistry name config)

Define a BulkheadRegistry under name with a defual or custom bulkhead configuration.

Please refer to bulkhead-config for allowed key value pairs within the bulkhead configuration map.

get-all-bulkheads clj

(get-all-bulkheads registry)

Get all bulkhead registered to this bulkhead registry instance

metrics clj

(metrics bulkhead)

Get the BulkheadConfig of this Bulkhead

name clj

(name bulkhead)

Get the name of this Bulkhead

on-complete clj

(on-complete bulkhead)

Records a completed call.

registry-with-config clj

(registry-with-config config)

Create a BulkheadRegistry with a bulkhead configurations map.

Please refer to bulkhead-config for allowed key value pairs within the bulkhead configuration map.

set-on-all-event-consumer! clj

(set-on-all-event-consumer! bulkhead consumer-fn-map)

set-on-call-finished-event-consumer! clj

(set-on-call-finished-event-consumer! bulkhead consumer-fn)

set-on-call-permitted-event-consumer! clj

(set-on-call-permitted-event-consumer! bulkhead consumer-fn)

set a consumer to consume on-call-permitted event which emitted when request permitted by bulkhead. consumer-fn accepts a function which takes no arguments.

Please note that in consumer-fn you can get the bulkhead name and the creation time of the consumed event by accessing *bulkhead-name* and *creation-time* under this namespace.

set-on-call-rejected-event-consumer! clj

(set-on-call-rejected-event-consumer! bulkhead consumer-fn)