circuitbreaker

Documentation

Index

• Variables
• func CallUsingCircuitBreaker(ctx context.Context, breakerName string, url string, method string) ([]byte, error)
• func ConfigureHystrix(commands []string, amqpClient messaging.IMessagingClient)
• func Deregister(amqpClient messaging.IMessagingClient)
• func PerformHTTPRequestCircuitBreaker(ctx context.Context, breakerName string, req *http.Request) ([]byte, error)
• type DiscoveryToken

Variables

var Client *http.Client

Client to do http requests with

Functions

func CallUsingCircuitBreaker

func CallUsingCircuitBreaker(ctx context.Context, breakerName string, url string, method string) ([]byte, error)

CallUsingCircuitBreaker performs a HTTP call inside a circuit breaker.

func ConfigureHystrix

func ConfigureHystrix(commands []string, amqpClient messaging.IMessagingClient)

ConfigureHystrix sets up hystrix circuit breakers.

func Deregister

func Deregister(amqpClient messaging.IMessagingClient)

Deregister publishes a Deregister token to Hystrix/Turbine

func PerformHTTPRequestCircuitBreaker

func PerformHTTPRequestCircuitBreaker(ctx context.Context, breakerName string, req *http.Request) ([]byte, error)

PerformHTTPRequestCircuitBreaker performs the supplied http.Request within a circuit breaker.

Types

type DiscoveryToken

type DiscoveryToken struct {
	State   string `json:"state"` // UP, RUNNING, DOWN ??
	Address string `json:"address"`
}

DiscoveryToken defines a struct for transmitting the state of a hystrix stream producer.