session

Jan 27, 2026

Changes in this version

+ const PulsarSessionManagerKey

+ const UserTokenHashKey

+ func ExtractBearerToken(r *http.Request) string

+ func GetUserTokenHash(ctx context.Context) string

+ func WithPulsarSessionManager(ctx context.Context, manager *PulsarSessionManager) context.Context

+ func WithUserTokenHash(ctx context.Context, hash string) context.Context

+ type CachedSession struct

+ CreatedAt time.Time

+ LastAccess time.Time

+ Session *pulsar.Session

+ TokenHash string

+ type PulsarSessionManager struct

+ func GetPulsarSessionManager(ctx context.Context) *PulsarSessionManager

+ func NewPulsarSessionManager(config *PulsarSessionManagerConfig, globalSession *pulsar.Session, ...) *PulsarSessionManager

+ func (m *PulsarSessionManager) GetOrCreateSession(_ context.Context, token string) (*pulsar.Session, error)

+ func (m *PulsarSessionManager) HashTokenForLog(token string) string

+ func (m *PulsarSessionManager) SessionCount() int

+ func (m *PulsarSessionManager) Stop()

+ type PulsarSessionManagerConfig struct

+ BaseContext pulsar.PulsarContext

+ CleanupInterval time.Duration

+ MaxSessions int

+ SessionTTL time.Duration

+ func DefaultPulsarSessionManagerConfig() *PulsarSessionManagerConfig