concurrent

package

Go to main page

Versions in this module

v0

v0.9.1

Aug 22, 2026

v0.9.0

Aug 11, 2026

v0.8.0

Jul 22, 2026

v0.7.2

Jun 14, 2026

v0.7.1

May 31, 2026

v0.7.0

May 8, 2026

v0.6.1

May 6, 2026

v0.6.0

May 5, 2026

Changes in this version

+ type Clock interface

+ Now func() time.Time

+ Since func(time.Time) time.Duration

+ type FakeClock struct

+ func NewFakeClock(t time.Time) *FakeClock

+ func (fc *FakeClock) Add(d time.Duration)

+ func (fc *FakeClock) Now() time.Time

+ func (fc *FakeClock) Set(t time.Time)

+ func (fc *FakeClock) Since(t time.Time) time.Duration

type MultiServerRateLimiter

+ func (m *MultiServerRateLimiter) Close()

type RateLimiter

+ func (rl *RateLimiter) Close()

+ type RealClock struct

+ func (RealClock) Now() time.Time

+ func (RealClock) Since(t time.Time) time.Duration

v0.5.2

May 4, 2026

v0.5.1

May 4, 2026

v0.5.0

May 4, 2026

v0.4.1

May 3, 2026

v0.4.0

May 3, 2026

v0.3.0

May 3, 2026

v0.2.2

May 3, 2026

v0.2.1

May 3, 2026

v0.2.0

May 3, 2026

v0.1.4

May 2, 2026

v0.1.3

May 2, 2026

v0.1.2

May 2, 2026

v0.1.0

May 2, 2026

Changes in this version

+ const ErrCodeCircuitOpen

+ const ErrCodeInternalError

+ const ErrCodeRateLimited

+ const ErrCodeTimeout

+ type BatchConfig struct

+ EnableBatching bool

+ MaxBatchSize int

+ MaxWaitTime time.Duration

+ WindowMs int

+ type BatchProcessor interface

+ ProcessBatch func(ctx context.Context, serverName string, requests []Request) []Response

+ type BatchRequest struct

+ Arrived time.Time

+ ErrorCh chan error

+ Request Request

+ ResultCh chan *Response

+ type Batcher struct

+ func NewBatcher(config BatchConfig, logger *slog.Logger) *Batcher

+ func (b *Batcher) AddRequest(serverName string, req Request, resultCh chan *Response, errorCh chan error) bool

+ func (b *Batcher) Close()

+ func (b *Batcher) Flush(serverName string)

+ func (b *Batcher) GetPendingCount(serverName string) int

+ type CircuitBreaker struct

+ func NewCircuitBreaker(threshold int, cooldown time.Duration, halfOpenCooldown time.Duration) *CircuitBreaker

+ func (cb *CircuitBreaker) Allow() bool

+ func (cb *CircuitBreaker) GetMetrics() CircuitBreakerMetrics

+ func (cb *CircuitBreaker) RecordFailure()

+ func (cb *CircuitBreaker) RecordSuccess()

+ func (cb *CircuitBreaker) Reset()

+ func (cb *CircuitBreaker) State() CircuitState

+ type CircuitBreakerConfig struct

+ Cooldown time.Duration

+ HalfOpenMaxSuccess int

+ Threshold int

+ type CircuitBreakerGroup struct

+ func NewCircuitBreakerGroup() *CircuitBreakerGroup

+ func (g *CircuitBreakerGroup) Get(name string) *CircuitBreaker

+ func (g *CircuitBreakerGroup) Register(name string, cb *CircuitBreaker)

+ func (g *CircuitBreakerGroup) ResetAll()

+ type CircuitBreakerMetrics struct

+ Failures int32

+ LastFailure time.Time

+ State string

+ Threshold int

+ TotalFailures int32

+ TotalSuccesses int32

+ type CircuitState int

+ const StateClosed

+ const StateHalfOpen

+ const StateOpen

+ func (s CircuitState) String() string

+ type ConcurrentError struct

+ Code int

+ Data json.RawMessage

+ Message string

+ func (e *ConcurrentError) Error() string

+ type DefaultBatchProcessor struct

+ func NewDefaultBatchProcessor(logger *slog.Logger) *DefaultBatchProcessor

+ func (p *DefaultBatchProcessor) ProcessBatch(ctx context.Context, serverName string, requests []Request) []Response

+ type MultiServerRateLimiter struct

+ func NewMultiServerRateLimiter(config RateLimiterConfig) *MultiServerRateLimiter

+ func (m *MultiServerRateLimiter) Allow(serverName string) bool

+ func (m *MultiServerRateLimiter) GetLimiter(serverName string) *RateLimiter

+ func (m *MultiServerRateLimiter) GetStats(serverName string) RateLimiterStats

+ func (m *MultiServerRateLimiter) Reset(serverName string)

+ func (m *MultiServerRateLimiter) ResetAll()

+ type PoolConfig struct

+ BatchWindowMs int

+ MaxConcurrent int

+ MaxQueueSize int

+ QueueTimeout time.Duration

+ RateLimitMax int

+ RateLimitWindow time.Duration

+ WorkerCount int

+ type PoolStats struct

+ ActiveRequests int64

+ AverageLatency time.Duration

+ FailedRequests int64

+ QueuedRequests int64

+ SuccessRequests int64

+ TotalRequests int64

+ type QueueManager struct

+ func NewQueueManager(maxSize int, timeout time.Duration) *QueueManager

+ func (qm *QueueManager) ClearQueue(serverName string)

+ func (qm *QueueManager) Enqueue(serverName string, req Request, resultCh chan *Response, errorCh chan error) error

+ func (qm *QueueManager) GetOrCreateQueue(serverName string) *RequestQueue

+ func (qm *QueueManager) GetOverflowCount() int64

+ func (qm *QueueManager) GetQueueSize(serverName string) int

+ type QueuedRequest struct

+ EnqueuedAt time.Time

+ ErrorCh chan error

+ Request Request

+ ResultCh chan *Response

+ type RateLimiter struct

+ func NewRateLimiter(max int, window time.Duration) *RateLimiter

+ func (rl *RateLimiter) Allow() bool

+ func (rl *RateLimiter) GetBlockedCount() int64

+ func (rl *RateLimiter) GetUsage() (current int, max int)

+ func (rl *RateLimiter) Reset()

+ type RateLimiterConfig struct

+ MaxRequests int

+ Window time.Duration

+ type RateLimiterStats struct

+ BlockedCount int64

+ CurrentRequests int

+ MaxRequests int

+ ServerName string

+ type Request struct

+ ErrorCh chan error

+ ID interface{}

+ Method string

+ Params json.RawMessage

+ ResultCh chan *Response

+ ServerName string

+ Timeout time.Duration

+ type RequestHandler interface

+ Handle func(ctx context.Context, req *Request) (*Response, error)

+ type RequestQueue struct

+ type Response struct

+ Error *ConcurrentError

+ ID interface{}

+ Result json.RawMessage

+ type ServerHandle struct

+ AvgLatencyMs float64

+ CurrentBackoff time.Duration

+ CurrentLoad int32

+ ErrorCount int64

+ LastRequestAt time.Time

+ MaxConcurrent int

+ Name string

+ RequestCount int64

+ RestartCount int

+ State ServerState

+ type ServerState string

+ const StateBusy

+ const StateError

+ const StateIdle

+ const StateRunning

+ const StateStopped

+ const StateStopping

+ type StdioPool struct

+ func NewStdioPool(config PoolConfig, logger *slog.Logger) *StdioPool

+ func (p *StdioPool) Close() error

+ func (p *StdioPool) GetPoolStats() PoolStats

+ func (p *StdioPool) GetServerStats(serverName string) (*ServerHandle, error)

+ func (p *StdioPool) RegisterServer(name string, maxConcurrent int)

+ func (p *StdioPool) SendRequest(ctx context.Context, serverName string, req *Request) (*Response, error)

+ func (p *StdioPool) ServerCount() int

+ type WorkerPool struct

+ func NewWorkerPool(workers, queueSize int, logger *slog.Logger) *WorkerPool

+ func (p *WorkerPool) GetActiveWorkers() int

+ func (p *WorkerPool) GetQueueCapacity() int

+ func (p *WorkerPool) Metrics() WorkerPoolMetrics

+ func (p *WorkerPool) QueueSize() int

+ func (p *WorkerPool) Shutdown()

+ func (p *WorkerPool) Submit(req Request, resultCh chan *Response, errorCh chan error) error

+ type WorkerPoolMetrics struct

+ AverageWaitTime time.Duration

+ CompletedTasks int64

+ FailedTasks int64

+ QueuedTasks int64

+ RejectedTasks int64

+ SubmittedTasks int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL