mongo

Oct 18, 2021

Changes in this version

+ const IdxExpiry

+ func NewExpiryIndex(name string, key string, expireAfter int) (model mongo.IndexModel)

type Config

+ Compressors []string

+ TokenTTL uint32

type RequestManager

+ func (r *RequestManager) ConfigureExpiryWithTTL(ctx context.Context, ttl int) error

Sep 24, 2021

Changes in this version

+ func NewIndex(name string, keys ...string) (model mongo.IndexModel)

+ func NewUniqueIndex(name string, keys ...string) mongo.IndexModel

Sep 1, 2020

Changes in this version

+ type DB struct

Aug 27, 2020

Changes in this version

+ func ContextToTransaction(ctx context.Context) (sess mongo.Session, ok bool)

+ func TransactionToContext(ctx context.Context, session mongo.Session) context.Context

type Store

+ func (s *Store) BeginTX(ctx context.Context) (context context.Context, err error)

+ func (s *Store) Commit(ctx context.Context) error

+ func (s *Store) Rollback(ctx context.Context) error

Jul 2, 2020

Changes in this version

+ const IdxExpires

type ClientManager

+ DeniedJTIs storage.DeniedJTIStorer

+ func (c *ClientManager) ClientAssertionJWTValid(ctx context.Context, jti string) error

+ func (c *ClientManager) SetClientAssertionJWT(ctx context.Context, jti string, exp time.Time) (err error)

type Config

+ PoolMaxSize uint64

+ PoolMinSize uint64

+ type DeniedJtiManager struct

+ DB *mongo.Database

+ func (d *DeniedJtiManager) Configure(ctx context.Context) (err error)

+ func (d *DeniedJtiManager) Create(ctx context.Context, deniedJTI storage.DeniedJTI) (result storage.DeniedJTI, err error)

+ func (d *DeniedJtiManager) Delete(ctx context.Context, jti string) (err error)

+ func (d *DeniedJtiManager) DeleteBefore(ctx context.Context, expBefore int64) (err error)

+ func (d *DeniedJtiManager) Get(ctx context.Context, signature string) (result storage.DeniedJTI, err error)

Jun 25, 2020

Changes in this version

+ func ContextToSession(ctx context.Context) (sess mongo.Session, ok bool)

+ func SessionToContext(ctx context.Context, session mongo.Session) context.Context

Nov 7, 2018

Changes in this version

+ const IdxCacheRequestID

+ const IdxClientID

+ const IdxSessionID

+ const IdxSignatureID

+ const IdxUserID

Oct 15, 2018

Changes in this version

+ const IdxCacheRequestId

+ const IdxCacheRequestSignature

+ const IdxClientId

+ const IdxCompoundRequester

+ const IdxSessionId

+ const IdxSignatureId

+ const IdxUserId

+ const IdxUsername

+ func Connect(cfg *Config) (*mgo.Database, error)

+ func ConnectionInfo(cfg *Config) *mgo.DialInfo

+ func ContextToMgoSession(ctx context.Context) (sess *mgo.Session, ok bool)

+ func MgoSessionToContext(ctx context.Context, session *mgo.Session) context.Context

+ func SetDebug(isDebug bool)

+ func SetLogger(log *logrus.Logger)

+ type CacheManager struct

+ DB *mgo.Database

+ func (c *CacheManager) Configure(ctx context.Context) error

+ func (c *CacheManager) Create(ctx context.Context, entityName string, cacheObject storage.SessionCache) (result storage.SessionCache, err error)

+ func (c *CacheManager) Delete(ctx context.Context, entityName string, key string) error

+ func (c *CacheManager) DeleteByValue(ctx context.Context, entityName string, value string) error

+ func (c *CacheManager) Get(ctx context.Context, entityName string, key string) (result storage.SessionCache, err error)

+ func (c *CacheManager) Update(ctx context.Context, entityName string, ...) (result storage.SessionCache, err error)

+ type ClientManager struct

+ DB *mgo.Database

+ Hasher fosite.Hasher

+ func (c *ClientManager) Authenticate(ctx context.Context, clientID string, secret string) (result storage.Client, err error)

+ func (c *ClientManager) AuthenticateMigration(ctx context.Context, currentAuth storage.AuthClientFunc, clientID string, ...) (result storage.Client, err error)

+ func (c *ClientManager) Configure(ctx context.Context) error

+ func (c *ClientManager) Create(ctx context.Context, client storage.Client) (result storage.Client, err error)

+ func (c *ClientManager) Delete(ctx context.Context, clientID string) error

+ func (c *ClientManager) Get(ctx context.Context, clientID string) (result storage.Client, err error)

+ func (c *ClientManager) GetClient(ctx context.Context, clientID string) (fosite.Client, error)

+ func (c *ClientManager) GrantScopes(ctx context.Context, clientID string, scopes []string) (result storage.Client, err error)

+ func (c *ClientManager) List(ctx context.Context, filter storage.ListClientsRequest) (results []storage.Client, err error)

+ func (c *ClientManager) RemoveScopes(ctx context.Context, clientID string, scopes []string) (result storage.Client, err error)

+ func (c *ClientManager) Update(ctx context.Context, clientID string, updatedClient storage.Client) (result storage.Client, err error)

+ func (u *ClientManager) Migrate(ctx context.Context, migratedClient storage.Client) (result storage.Client, err error)

+ type Config struct

+ AuthDB string

+ DatabaseName string

+ Hostnames []string

+ Password string

+ Port uint16

+ Replset string

+ SSL bool

+ TLSConfig *tls.Config

+ Timeout uint

+ Username string

+ func DefaultConfig() *Config

+ type RequestManager struct

+ Cache storage.CacheStorer

+ Clients storage.ClientStorer

+ DB *mgo.Database

+ Users storage.UserStorer

+ func (r *RequestManager) Authenticate(ctx context.Context, username string, secret string) error

+ func (r *RequestManager) Configure(ctx context.Context) error

+ func (r *RequestManager) Create(ctx context.Context, entityName string, request storage.Request) (result storage.Request, err error)

+ func (r *RequestManager) CreateAccessTokenSession(ctx context.Context, signature string, request fosite.Requester) (err error)

+ func (r *RequestManager) CreateAuthorizeCodeSession(ctx context.Context, code string, request fosite.Requester) (err error)

+ func (r *RequestManager) CreateOpenIDConnectSession(ctx context.Context, authorizeCode string, request fosite.Requester) error

+ func (r *RequestManager) CreatePKCERequestSession(ctx context.Context, signature string, request fosite.Requester) error

+ func (r *RequestManager) CreateRefreshTokenSession(ctx context.Context, signature string, request fosite.Requester) (err error)

+ func (r *RequestManager) Delete(ctx context.Context, entityName string, requestID string) error

+ func (r *RequestManager) DeleteAccessTokenSession(ctx context.Context, signature string) (err error)

+ func (r *RequestManager) DeleteBySignature(ctx context.Context, entityName string, signature string) error

+ func (r *RequestManager) DeleteOpenIDConnectSession(ctx context.Context, authorizeCode string) error

+ func (r *RequestManager) DeletePKCERequestSession(ctx context.Context, signature string) error

+ func (r *RequestManager) DeleteRefreshTokenSession(ctx context.Context, signature string) (err error)

+ func (r *RequestManager) Get(ctx context.Context, entityName string, requestID string) (result storage.Request, err error)

+ func (r *RequestManager) GetAccessTokenSession(ctx context.Context, signature string, session fosite.Session) (request fosite.Requester, err error)

+ func (r *RequestManager) GetAuthorizeCodeSession(ctx context.Context, code string, session fosite.Session) (request fosite.Requester, err error)

+ func (r *RequestManager) GetBySignature(ctx context.Context, entityName string, signature string) (result storage.Request, err error)

+ func (r *RequestManager) GetOpenIDConnectSession(ctx context.Context, authorizeCode string, requester fosite.Requester) (fosite.Requester, error)

+ func (r *RequestManager) GetPKCERequestSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error)

+ func (r *RequestManager) GetRefreshTokenSession(ctx context.Context, signature string, session fosite.Session) (request fosite.Requester, err error)

+ func (r *RequestManager) InvalidateAuthorizeCodeSession(ctx context.Context, code string) (err error)

+ func (r *RequestManager) List(ctx context.Context, entityName string, filter storage.ListRequestsRequest) (results []storage.Request, err error)

+ func (r *RequestManager) RevokeAccessToken(ctx context.Context, requestID string) error

+ func (r *RequestManager) RevokeRefreshToken(ctx context.Context, requestID string) error

+ func (r *RequestManager) Update(ctx context.Context, entityName string, requestID string, ...) (result storage.Request, err error)

+ type Store struct

+ DB *mgo.Database

+ Hasher fosite.Hasher

+ func New(cfg *Config, hashee fosite.Hasher) (*Store, error)

+ func NewDefaultStore() (*Store, error)

+ func (m *Store) Close()

+ func (m *Store) NewSession() (session *mgo.Session)

+ type UserManager struct

+ DB *mgo.Database

+ Hasher fosite.Hasher

+ func (u *UserManager) Authenticate(ctx context.Context, username string, password string) (result storage.User, err error)

+ func (u *UserManager) AuthenticateByID(ctx context.Context, userID string, password string) (result storage.User, err error)

+ func (u *UserManager) AuthenticateByUsername(ctx context.Context, username string, password string) (result storage.User, err error)

+ func (u *UserManager) AuthenticateMigration(ctx context.Context, currentAuth storage.AuthUserFunc, userID string, ...) (result storage.User, err error)

+ func (u *UserManager) Configure(ctx context.Context) error

+ func (u *UserManager) Create(ctx context.Context, user storage.User) (result storage.User, err error)

+ func (u *UserManager) Delete(ctx context.Context, userID string) error

+ func (u *UserManager) Get(ctx context.Context, userID string) (result storage.User, err error)

+ func (u *UserManager) GetByUsername(ctx context.Context, username string) (result storage.User, err error)

+ func (u *UserManager) GrantScopes(ctx context.Context, userID string, scopes []string) (result storage.User, err error)

+ func (u *UserManager) List(ctx context.Context, filter storage.ListUsersRequest) (results []storage.User, err error)

+ func (u *UserManager) Migrate(ctx context.Context, migratedUser storage.User) (result storage.User, err error)

+ func (u *UserManager) RemoveScopes(ctx context.Context, userID string, scopes []string) (result storage.User, err error)

+ func (u *UserManager) Update(ctx context.Context, userID string, updatedUser storage.User) (result storage.User, err error)

Jun 1, 2017

Changes in this version

+ const CollectionAuthorizationCodes

May 31, 2017

Changes in this version

+ const CollectionAccessTokens

+ const CollectionAuthorizationCode

+ const CollectionCacheAccessTokens

+ const CollectionCacheRefreshTokens

+ const CollectionClients

+ const CollectionOpenIDSessions

+ const CollectionRefreshTokens

+ const CollectionUsers