Skip to content

Commit 959239b

Browse files
New Manager now support error channel
1 parent 387f26e commit 959239b

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

internal/session/manager.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,15 +22,17 @@ type Manager struct {
2222
mutex sync.RWMutex
2323
redis redis.RedisClient
2424
archivalPQ *postgresql.Queries
25+
errCh chan<-error
2526
}
2627

2728
/* create a new session manager */
28-
func NewManager(redis redis.RedisClient, archivalPQ *postgresql.Queries) *Manager {
29+
func NewManager(redis redis.RedisClient, archivalPQ *postgresql.Queries, errCh chan<-error) *Manager {
2930
return &Manager{
3031
sessionsMap: make(map[string]*Session),
3132
sessionOrder: list.New(),
3233
redis: redis,
3334
archivalPQ: archivalPQ,
35+
errCh: errCh,
3436
}
3537
}
3638

0 commit comments

Comments
 (0)