cbcheck

Documentation

Index

• type CircuitBreakCallBack
  • 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
  • func NewCircuitBreakRealTimeCallBack(callBack *CircuitBreakCallBack, task *RealTimeLimitTask) *CircuitBreakRealTimeCallBack
  • func (c *CircuitBreakRealTimeCallBack) Process()
• type RealTimeLimitTask

Types

type CircuitBreakCallBack

type CircuitBreakCallBack struct {
	// contains filtered or unexported fields
}

CircuitBreakCallBack 定时熔断任务回调

func NewCircuitBreakCallBack

func NewCircuitBreakCallBack(cfg config.Configuration, supplier plugin.Supplier) (*CircuitBreakCallBack, error)

NewCircuitBreakCallBack 创建定时熔断任务回调

func (*CircuitBreakCallBack) OnTaskEvent

func (c *CircuitBreakCallBack) OnTaskEvent(event model.TaskEvent)

OnTaskEvent 任务事件回调

func (*CircuitBreakCallBack) Process

func (c *CircuitBreakCallBack) Process(
	taskKey interface{}, taskValue interface{}, lastProcessTime time.Time) model.TaskResult

Process 执行任务

type CircuitBreakRealTimeCallBack

type CircuitBreakRealTimeCallBack struct {
	// contains filtered or unexported fields
}

CircuitBreakRealTimeCallBack 实时熔断任务回调

func NewCircuitBreakRealTimeCallBack

func NewCircuitBreakRealTimeCallBack(
	callBack *CircuitBreakCallBack, task *RealTimeLimitTask) *CircuitBreakRealTimeCallBack

NewCircuitBreakRealTimeCallBack 创建实时熔断任务

func (*CircuitBreakRealTimeCallBack) Process

func (c *CircuitBreakRealTimeCallBack) Process()

Process 处理实时任务

type RealTimeLimitTask

type RealTimeLimitTask struct {
	// 服务信息
	SvcKey model.ServiceKey
	// 实例ID
	InstID string
	// 机器IP
	Host string
	// 端口号
	Port int
	// 熔断器名字
	CbName string
}

RealTimeLimitTask 实时熔断任务