grpc_hystrix

Documentation

Index

• func StreamClientInterceptor(opts ...Option) grpc.StreamClientInterceptor
• func UnaryClientInterceptor(opts ...Option) grpc.UnaryClientInterceptor
• type Option
  • func WithCommandName(name string) Option
  • func WithErrorPercentThreshold(errorPercentThreshold int) Option
  • func WithHystrixTimeout(timeout time.Duration) Option
  • func WithMaxConcurrentRequests(maxConcurrentRequests int) Option
  • func WithRequestVolumeThreshold(requestVolumeThreshold int) Option
  • func WithSleepWindow(sleepWindow int) Option
• type Options

Functions

func StreamClientInterceptor

func StreamClientInterceptor(opts ...Option) grpc.StreamClientInterceptor

func UnaryClientInterceptor

func UnaryClientInterceptor(opts ...Option) grpc.UnaryClientInterceptor

Types

type Option

type Option func(opts *Options)

Option represents the hystrix client options

func WithCommandName

func WithCommandName(name string) Option

WithCommandName sets the hystrix command name

func WithErrorPercentThreshold

func WithErrorPercentThreshold(errorPercentThreshold int) Option

WithErrorPercentThreshold sets hystrix error percent threshold

func WithHystrixTimeout

func WithHystrixTimeout(timeout time.Duration) Option

WithHystrixTimeout sets hystrix timeout

func WithMaxConcurrentRequests

func WithMaxConcurrentRequests(maxConcurrentRequests int) Option

WithMaxConcurrentRequests sets hystrix max concurrent requests

func WithRequestVolumeThreshold

func WithRequestVolumeThreshold(requestVolumeThreshold int) Option

WithRequestVolumeThreshold sets hystrix request volume threshold

func WithSleepWindow

func WithSleepWindow(sleepWindow int) Option

WithSleepWindow sets hystrix sleep window

type Options

type Options struct {
	HystrixTimeout         time.Duration
	HystrixCommandName     string
	MaxConcurrentRequests  int
	RequestVolumeThreshold int
	SleepWindow            int
	ErrorPercentThreshold  int
}