Versions in this module Expand all Collapse all v1 v1.5.4 Oct 26, 2023 Changes in this version + type CircuitBreakCallBack struct + func NewCircuitBreakCallBack(cfg config.Configuration, supplier plugin.Supplier) (*CircuitBreakCallBack, error) + func (c *CircuitBreakCallBack) OnTaskEvent(event model.TaskEvent) + func (c *CircuitBreakCallBack) Process(taskKey interface{}, taskValue interface{}, lastProcessTime time.Time) model.TaskResult + type CircuitBreakRealTimeCallBack struct + func NewCircuitBreakRealTimeCallBack(callBack *CircuitBreakCallBack, task *RealTimeLimitTask) *CircuitBreakRealTimeCallBack + func (c *CircuitBreakRealTimeCallBack) Process() + type RealTimeLimitTask struct + CbName string + Host string + InstID string + Port int + SvcKey model.ServiceKey
Go to main page