circuitbreakerpool

Documentation

Index

• Variables
• type CircuitBreakerPool
  • func NewCircuitBreakerPool[K comparable](constructor func(key K) circuitbreaker.TwoStepCircuitBreaker) *CircuitBreakerPool[K]
  • func (p *CircuitBreakerPool[K]) Get(key K) circuitbreaker.TwoStepCircuitBreaker
• type OutboundQueueCircuitBreakerPool
  • func OutboundQueueCircuitBreakerPoolProvider(namespaceRegistry namespace.Registry, config *configs.Config) *OutboundQueueCircuitBreakerPool

Variables

var Module = fx.Options(
	fx.Provide(OutboundQueueCircuitBreakerPoolProvider),
)

Types

type CircuitBreakerPool

type CircuitBreakerPool[K comparable] struct {
	// contains filtered or unexported fields
}

func NewCircuitBreakerPool

func NewCircuitBreakerPool[K comparable](
	constructor func(key K) circuitbreaker.TwoStepCircuitBreaker,
) *CircuitBreakerPool[K]

func (*CircuitBreakerPool[K]) Get

func (p *CircuitBreakerPool[K]) Get(key K) circuitbreaker.TwoStepCircuitBreaker

type OutboundQueueCircuitBreakerPool

type OutboundQueueCircuitBreakerPool struct {
	*CircuitBreakerPool[tasks.TaskGroupNamespaceIDAndDestination]
}

func OutboundQueueCircuitBreakerPoolProvider

func OutboundQueueCircuitBreakerPoolProvider(
	namespaceRegistry namespace.Registry,
	config *configs.Config,
) *OutboundQueueCircuitBreakerPool