gopgsession

Oct 7, 2024

Changes in this version

type Session

+ CreatedAt time.Time

Oct 2, 2024

Changes in this version

type CreateSessionOption

+ func WithCreateExpiresAt(expiresAt time.Time) CreateSessionOption

+ func WithCreateGroupID(groupID uuid.UUID) CreateSessionOption

+ func WithCreateIncludeInactivity(include bool) CreateSessionOption

type Session

+ IncludeInactivity bool

type SessionOption

+ func WithGetDoNotUpdateSessionLastAccess() SessionOption

+ func WithGetForceRefresh() SessionOption

type UpdateAttributeOption

+ func WithUpdateAttExpiresAt(expiresAt time.Time) UpdateAttributeOption

type UpdateSessionOption

+ func WithUpdateCheckAttributeVersion() UpdateSessionOption

+ func WithUpdateCheckVersion() UpdateSessionOption

+ func WithUpdateDoNotNotify() UpdateSessionOption

+ func WithUpdateExpiresAt(expiresAt time.Time) UpdateSessionOption

+ func WithUpdateIncludeInactivity(include bool) UpdateSessionOption

type UpdateSessionOptions

+ ExpiresAt *time.Time

+ IncludeInactivity *bool

Aug 26, 2024

Changes in this version

type Session

+ func (s *Session) Invalidate()

+ func (s *Session) IsInvalidated() bool

Aug 24, 2024

Changes in this version

type Config

+ Logger Logger

+ type Logger interface

+ Error func(msg string, args ...any)

+ Warn func(msg string, args ...any)

Aug 23, 2024

Changes in this version

+ const NotificationTypeClearEntireCache

+ const NotificationTypeGroupSessionsRemovalFromCache

type Config

+ MaxSessionLifetimeInCache time.Duration

+ type CreateSessionOption func(*Session)

+ func WithGroupID(groupID uuid.UUID) CreateSessionOption

type Session

+ GroupID *uuid.UUID

+ func (s *Session) IsModified() bool

type SessionManager

+ func (sm *SessionManager) ClearEntireCache(ctx context.Context) error

+ func (sm *SessionManager) DeleteAllSessionsByGroupID(ctx context.Context, groupID uuid.UUID) error

+ func (sm *SessionManager) DeleteAttributeFromAllUserSessions(ctx context.Context, userID uuid.UUID, attributeKey string) error

Aug 19, 2024

Changes in this version

+ type UpdateAttributeOption func(*UpdateAttributeOptions)

+ func WithExpiresAt(expiresAt time.Time) UpdateAttributeOption

+ type UpdateAttributeOptions struct

+ ExpiresAt *time.Time

Aug 19, 2024

Changes in this version

type HMACSHA256SignerPool

+ func (s *HMACSHA256SignerPool) SignAndEncode(message string) (string, error)

+ func (s *HMACSHA256SignerPool) VerifyAndDecode(signedMessage string) (bool, string, error)

Aug 19, 2024

Changes in this version

+ var DefaultDistributedLockConfig = DistributedLockConfig

+ var ErrLockAlreadyHeld = errors.New("lock is already held by another node")

+ var ErrLockExpired = errors.New("lock has expired")

+ var ErrLockNotHeld = errors.New("lock is not held by this node")

type Config

+ NotifyOnFailedUpdates bool

+ type DistributedLock struct

+ func (dl *DistributedLock) ExtendLease(ctx context.Context, extension time.Duration) error

+ func (dl *DistributedLock) Lock(ctx context.Context) error

+ func (dl *DistributedLock) Unlock(ctx context.Context) error

+ type DistributedLockConfig struct

+ HeartbeatInterval time.Duration

+ LeaseTime time.Duration

+ MaxRetries int

+ RetryDelay time.Duration

+ type LockInfo struct

+ ExpiresAt time.Time

+ LastHeartbeat time.Time

+ NodeID uuid.UUID

+ Resource string

type SessionAttributeRecord

+ Version int

type SessionAttributeValue

+ Version int

type SessionManager

+ func (sm *SessionManager) NewDistributedLock(sessionID uuid.UUID, resource string, config *DistributedLockConfig) *DistributedLock

type UpdateSessionOption

+ func WithCheckAttributeVersion() UpdateSessionOption

type UpdateSessionOptions

+ CheckAttributeVersion bool

Aug 16, 2024

Changes in this version

+ var ErrAttributeNotFound = errors.New("attribute not found")

Aug 16, 2024

Changes in this version

type Session

+ func (s *Session) IsFromCache() bool

+ type SessionOption func(*GetSessionOptions)

+ func WithDoNotUpdateSessionLastAccess() SessionOption

+ func WithForceRefresh() SessionOption

+ type UpdateSessionOption func(*UpdateSessionOptions)

+ func WithCheckVersion() UpdateSessionOption

+ func WithDoNotNotify() UpdateSessionOption

+ type UpdateSessionOptions struct

+ CheckVersion bool

+ DoNotNotify bool

Aug 14, 2024

Changes in this version

type Session

+ func (s *Session) GetAttributeAndRetainUnmarshaled(key string, v interface{}) (SessionAttributeValue, error)

type SessionAttributeValue

+ Marshaled bool

Aug 7, 2024

Changes in this version

+ const NotificationTypeSessionsRemovalFromCache

+ const NotificationTypeUserSessionsRemovalFromCache

+ var ErrSessionVersionIsOutdated = errors.New("session version is outdated")

type Config

+ ConnectionsMaxIdleTime time.Duration

+ ConnectionsMaxLifetime time.Duration

+ CustomPGLN *pgln.PGListenNotify

+ MaxIdleConnections int

+ MaxOpenConnections int

+ NotifyOnUpdates bool

+ type GetSessionOptions struct

+ DoNotUpdateSessionLastAccess bool

+ ForceRefresh bool

+ type HMACSHA256SignerPool struct

+ func NewHMACSHA256SignerPool(secret string, maxPoolSize int) *HMACSHA256SignerPool

+ func (s *HMACSHA256SignerPool) Sign(message string) (string, error)

+ func (s *HMACSHA256SignerPool) Verify(message, signature string) (bool, string, error)

type Session

+ Version int

+ func (s *Session) DeleteAttribute(key string)

+ type SessionAttributeRecord struct

+ ExpiresAt *time.Time

+ Key string

+ SessionID uuid.UUID

+ Value string

+ type SessionAttributeValue struct

+ ExpiresAt *time.Time

+ Value string

type SessionManager

+ func (sm *SessionManager) DeleteAllSessions(ctx context.Context) error

+ func (sm *SessionManager) EncodeSessionIDAndVersion(sessionID uuid.UUID, version int) string

+ func (sm *SessionManager) GetSessionWithOptions(ctx context.Context, sessionID uuid.UUID, opts GetSessionOptions) (*Session, error)

+ func (sm *SessionManager) GetSessionWithVersion(ctx context.Context, sessionID uuid.UUID, version int) (*Session, error)

+ func (sm *SessionManager) GetSessionWithVersionAndOptions(ctx context.Context, sessionID uuid.UUID, version int, opts GetSessionOptions) (*Session, error)

+ func (sm *SessionManager) ParseSessionIDAndVersion(encodedData string) (uuid.UUID, int, error)

+ func (sm *SessionManager) RemoveAllUserCachedSessionsFromAllNodes(userID uuid.UUID) error

Jul 31, 2024

Changes in this version

+ type Config struct

+ CacheSize int

+ CleanupInterval time.Duration

+ CreateSchemaIfMissing bool

+ InactivityDuration time.Duration

+ LastAccessUpdateBatchSize int

+ LastAccessUpdateInterval time.Duration

+ MaxAttributeLength int

+ MaxSessions int

+ SchemaName string

+ SessionExpiration time.Duration

+ TablePrefix string

+ func DefaultConfig() *Config

+ type Session struct

+ ExpiresAt time.Time

+ ID uuid.UUID

+ LastAccessed time.Time

+ UpdatedAt time.Time

+ UserID uuid.UUID

+ func (s *Session) GetAttribute(key string) (interface{}, bool)

+ func (s *Session) GetAttributes() map[string]interface{}

+ func (s *Session) UpdateAttribute(key string, value interface{}) error

+ type SessionManager struct

+ Config *Config

+ func NewSessionManager(cfg *Config, pgxConnectionString string) (*SessionManager, error)

+ func (sm *SessionManager) CreateSession(ctx context.Context, userID uuid.UUID, attributes map[string]interface{}) (uuid.UUID, error)

+ func (sm *SessionManager) DeleteAllUserSessions(ctx context.Context, userID uuid.UUID) error

+ func (sm *SessionManager) DeleteSession(ctx context.Context, sessionID uuid.UUID) error

+ func (sm *SessionManager) GetSession(ctx context.Context, sessionID uuid.UUID, updateSessionAccess bool) (*Session, error)

+ func (sm *SessionManager) Shutdown(ctx context.Context) error

+ func (sm *SessionManager) UpdateSession(ctx context.Context, session *Session) error