composite

Jan 21, 2025

Changes in this version

+ type CompositeCircuitBreaker struct

+ func (c *CompositeCircuitBreaker) CheckResource(res model.Resource) model.CircuitBreakerStatus

+ func (c *CompositeCircuitBreaker) Destroy() error

+ func (c *CompositeCircuitBreaker) Init(ctx *plugin.InitContext) error

+ func (c *CompositeCircuitBreaker) Name() string

+ func (c *CompositeCircuitBreaker) OnEvent(event *common.PluginEvent) error

+ func (c *CompositeCircuitBreaker) Report(stat *model.ResourceStat) error

+ func (c *CompositeCircuitBreaker) Start() error

+ func (c *CompositeCircuitBreaker) Type() common.Type

+ type CountersBucket struct

+ type HealthCheckersBucket struct

+ type ProtocolInstance struct

+ type ResourceCounters struct

+ func (rc *ResourceCounters) CloseToOpen(breaker string)

+ func (rc *ResourceCounters) CurrentActiveRule() *fault_tolerance.CircuitBreakerRule

+ func (rc *ResourceCounters) CurrentCircuitBreakerStatus() model.CircuitBreakerStatus

+ func (rc *ResourceCounters) HalfOpenToClose()

+ func (rc *ResourceCounters) HalfOpenToOpen()

+ func (rc *ResourceCounters) OpenToHalfOpen()

+ func (rc *ResourceCounters) Report(stat *model.ResourceStat)

+ type ResourceHealthChecker struct

+ func NewResourceHealthChecker(res model.Resource, faultDetector *fault_tolerance.FaultDetector, ...) *ResourceHealthChecker

+ type RuleContainer struct

+ type TaskExecutor struct

+ func (e *TaskExecutor) AffinityDelayExecute(key string, delay time.Duration, f func())

+ func (e *TaskExecutor) AffinityExecute(key string, f func())

+ func (e *TaskExecutor) DelayExecute(delay time.Duration, f func())

+ func (e *TaskExecutor) Execute(f func())

+ func (e *TaskExecutor) IntervalExecute(interval time.Duration, f func())

+ func (e *TaskExecutor) Stop()