Function NewReAuthPoolHook

internal/auth/streaming/pool_hook.go:62–69

NewReAuthPoolHook creates a new re-authentication pool hook. Parameters: - poolSize: Maximum number of concurrent re-auth operations (typically matches pool size) - reAuthTimeout: Maximum time to wait for acquiring a connection for re-authentication The poolSize parameter is used to initialize the

(poolSize int, reAuthTimeout time.Duration)

// The poolSize parameter is used to initialize the worker semaphore, ensuring that
// re-auth operations don't exhaust the connection pool.
func NewReAuthPoolHook(poolSize int, reAuthTimeout time.Duration) *ReAuthPoolHook {
	return &ReAuthPoolHook{
		shouldReAuth:    make(map[uint64]func(error)),
		scheduledReAuth: make(map[uint64]bool),
		workers:         internal.NewFastSemaphore(int32(poolSize)),
		reAuthTimeout:   reAuthTimeout,
	}
}

// MarkForReAuth marks a connection for re-authentication.
//