breaker

Documentation

Index

• func ClientBreakInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
• func WithServerBreakerInterceptor() grpc.UnaryServerInterceptor
• type Breaker
• type Group
  • func NewSreBreakerGroup(opts ...sre.Option) Group
• type SreBreakerGroup
  • func (g *SreBreakerGroup) Get(key string) Breaker

Functions

func ClientBreakInterceptor

func ClientBreakInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn,
	invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

ClientBreakInterceptor 客户端熔断器

func WithServerBreakerInterceptor

func WithServerBreakerInterceptor() grpc.UnaryServerInterceptor

WithServerBreakerInterceptor rpc 服务端熔断器

Types

type Breaker

type Breaker interface {
	Allow() error
	MarkSuccess()
	MarkFailed()
}

type Group

type Group interface {
	Get(string) Breaker
	// contains filtered or unexported methods
}

func NewSreBreakerGroup

func NewSreBreakerGroup(opts ...sre.Option) Group

type SreBreakerGroup

type SreBreakerGroup struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*SreBreakerGroup) Get

func (g *SreBreakerGroup) Get(key string) Breaker