eventstore

package
v1.83.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 25, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AuthRequestRepo 

type AuthRequestRepo struct {
	Command      *command.Commands
	Query        *query.Queries
	AuthRequests cache.AuthRequestCache
	View         *view.View
	Eventstore   v1.Eventstore

	LabelPolicyProvider       labelPolicyProvider
	UserSessionViewProvider   userSessionViewProvider
	UserViewProvider          userViewProvider
	UserCommandProvider       userCommandProvider
	UserEventProvider         userEventProvider
	OrgViewProvider           orgViewProvider
	LoginPolicyViewProvider   loginPolicyViewProvider
	LockoutPolicyViewProvider lockoutPolicyViewProvider
	PrivacyPolicyProvider     privacyPolicyProvider
	IDPProviderViewProvider   idpProviderViewProvider
	UserGrantProvider         userGrantProvider
	ProjectProvider           projectProvider
	ApplicationProvider       applicationProvider

	IdGenerator id.Generator

	PasswordCheckLifeTime      time.Duration
	ExternalLoginCheckLifeTime time.Duration
	MFAInitSkippedLifeTime     time.Duration
	SecondFactorCheckLifeTime  time.Duration
	MultiFactorCheckLifeTime   time.Duration

	IAMID string
}

func (*AuthRequestRepo) AuthRequestByCode added in v0.20.0 

func (repo *AuthRequestRepo) AuthRequestByCode(ctx context.Context, code string) (_ *domain.AuthRequest, err error)

func (*AuthRequestRepo) AuthRequestByID 

func (repo *AuthRequestRepo) AuthRequestByID(ctx context.Context, id, userAgentID string) (_ *domain.AuthRequest, err error)

func (*AuthRequestRepo) AuthRequestByIDCheckLoggedIn added in v0.20.0 

func (repo *AuthRequestRepo) AuthRequestByIDCheckLoggedIn(ctx context.Context, id, userAgentID string) (_ *domain.AuthRequest, err error)

func (*AuthRequestRepo) AutoRegisterExternalUser added in v0.87.0 

func (repo *AuthRequestRepo) AutoRegisterExternalUser(ctx context.Context, registerUser *domain.Human, externalIDP *domain.UserIDPLink, orgMemberRoles []string, authReqID, userAgentID, resourceOwner string, metadatas []*domain.Metadata, info *domain.BrowserInfo) (err error)

func (*AuthRequestRepo) BeginMFAU2FLogin added in v0.108.0 

func (repo *AuthRequestRepo) BeginMFAU2FLogin(ctx context.Context, userID, resourceOwner, authRequestID, userAgentID string) (login *domain.WebAuthNLogin, err error)

func (*AuthRequestRepo) BeginPasswordlessInitCodeSetup added in v1.29.0 

func (repo *AuthRequestRepo) BeginPasswordlessInitCodeSetup(ctx context.Context, userID, resourceOwner, codeID, verificationCode string, preferredPlatformType domain.AuthenticatorAttachment) (login *domain.WebAuthNToken, err error)

func (*AuthRequestRepo) BeginPasswordlessLogin added in v0.108.0 

func (repo *AuthRequestRepo) BeginPasswordlessLogin(ctx context.Context, userID, resourceOwner, authRequestID, userAgentID string) (login *domain.WebAuthNLogin, err error)

func (*AuthRequestRepo) BeginPasswordlessSetup added in v1.29.0 

func (repo *AuthRequestRepo) BeginPasswordlessSetup(ctx context.Context, userID, resourceOwner string, authenticatorPlatform domain.AuthenticatorAttachment) (login *domain.WebAuthNToken, err error)

func (*AuthRequestRepo) CheckExternalUserLogin added in v0.87.0 

func (repo *AuthRequestRepo) CheckExternalUserLogin(ctx context.Context, authReqID, userAgentID string, externalUser *domain.ExternalUser, info *domain.BrowserInfo) (err error)

func (*AuthRequestRepo) CheckLoginName added in v0.29.1 

func (repo *AuthRequestRepo) CheckLoginName(ctx context.Context, id, loginName, userAgentID string) (err error)

func (*AuthRequestRepo) CreateAuthRequest 

func (repo *AuthRequestRepo) CreateAuthRequest(ctx context.Context, request *domain.AuthRequest) (_ *domain.AuthRequest, err error)

func (*AuthRequestRepo) DeleteAuthRequest added in v0.20.0 

func (repo *AuthRequestRepo) DeleteAuthRequest(ctx context.Context, id string) (err error)

func (*AuthRequestRepo) GetPrivacyPolicy added in v1.82.0 

func (repo *AuthRequestRepo) GetPrivacyPolicy(ctx context.Context, orgID string) (*domain.PrivacyPolicy, error)

func (*AuthRequestRepo) Health 

func (repo *AuthRequestRepo) Health(ctx context.Context) error

func (*AuthRequestRepo) LinkExternalUsers added in v0.87.0 

func (repo *AuthRequestRepo) LinkExternalUsers(ctx context.Context, authReqID, userAgentID string, info *domain.BrowserInfo) (err error)

func (*AuthRequestRepo) ResetLinkingUsers added in v0.88.5 

func (repo *AuthRequestRepo) ResetLinkingUsers(ctx context.Context, authReqID, userAgentID string) error

func (*AuthRequestRepo) SaveAuthCode added in v0.20.0 

func (repo *AuthRequestRepo) SaveAuthCode(ctx context.Context, id, code, userAgentID string) (err error)

func (*AuthRequestRepo) SelectExternalIDP added in v0.87.0 

func (repo *AuthRequestRepo) SelectExternalIDP(ctx context.Context, authReqID, idpConfigID, userAgentID string) (err error)

func (*AuthRequestRepo) SelectUser added in v0.20.0 

func (repo *AuthRequestRepo) SelectUser(ctx context.Context, id, userID, userAgentID string) (err error)

func (*AuthRequestRepo) SetExternalUserLogin added in v1.29.0 

func (repo *AuthRequestRepo) SetExternalUserLogin(ctx context.Context, authReqID, userAgentID string, externalUser *domain.ExternalUser) (err error)

func (*AuthRequestRepo) VerifyMFAOTP added in v0.108.0 

func (repo *AuthRequestRepo) VerifyMFAOTP(ctx context.Context, authRequestID, userID, resourceOwner, code, userAgentID string, info *domain.BrowserInfo) (err error)

func (*AuthRequestRepo) VerifyMFAU2F added in v0.108.0 

func (repo *AuthRequestRepo) VerifyMFAU2F(ctx context.Context, userID, resourceOwner, authRequestID, userAgentID string, credentialData []byte, info *domain.BrowserInfo) (err error)

func (*AuthRequestRepo) VerifyPassword 

func (repo *AuthRequestRepo) VerifyPassword(ctx context.Context, id, userID, resourceOwner, password, userAgentID string, info *domain.BrowserInfo) (err error)

func (*AuthRequestRepo) VerifyPasswordless added in v0.108.0 

func (repo *AuthRequestRepo) VerifyPasswordless(ctx context.Context, userID, resourceOwner, authRequestID, userAgentID string, credentialData []byte, info *domain.BrowserInfo) (err error)

func (*AuthRequestRepo) VerifyPasswordlessInitCodeSetup added in v1.29.0 

func (repo *AuthRequestRepo) VerifyPasswordlessInitCodeSetup(ctx context.Context, userID, resourceOwner, userAgentID, tokenName, codeID, verificationCode string, credentialData []byte) (err error)

func (*AuthRequestRepo) VerifyPasswordlessSetup added in v1.29.0 

func (repo *AuthRequestRepo) VerifyPasswordlessSetup(ctx context.Context, userID, resourceOwner, userAgentID, tokenName string, credentialData []byte) (err error)

type OrgRepository added in v0.20.0 

type OrgRepository struct {
	SearchLimit uint64

	Eventstore     eventstore.Eventstore
	View           *auth_view.View
	SystemDefaults systemdefaults.SystemDefaults
	Query          *query.Queries
}

func (*OrgRepository) GetIDPConfigByID added in v0.87.0 

func (repo *OrgRepository) GetIDPConfigByID(ctx context.Context, idpConfigID string) (*iam_model.IDPConfigView, error)

func (*OrgRepository) GetLoginText added in v1.29.0 

func (repo *OrgRepository) GetLoginText(ctx context.Context, orgID string) ([]*domain.CustomText, error)

func (*OrgRepository) GetMyPasswordComplexityPolicy added in v0.92.0 

func (repo *OrgRepository) GetMyPasswordComplexityPolicy(ctx context.Context) (*iam_model.PasswordComplexityPolicyView, error)

type RefreshTokenRepo added in v1.8.0 

type RefreshTokenRepo struct {
	Eventstore   v1.Eventstore
	View         *view.View
	SearchLimit  uint64
	KeyAlgorithm crypto.EncryptionAlgorithm
}

func (*RefreshTokenRepo) RefreshTokenByID added in v1.8.0 

func (r *RefreshTokenRepo) RefreshTokenByID(ctx context.Context, refreshToken string) (*usr_model.RefreshTokenView, error)

func (*RefreshTokenRepo) SearchMyRefreshTokens added in v1.8.0 

func (r *RefreshTokenRepo) SearchMyRefreshTokens(ctx context.Context, userID string, request *usr_model.RefreshTokenSearchRequest) (*usr_model.RefreshTokenSearchResponse, error)

type TokenRepo 

type TokenRepo struct {
	Eventstore v1.Eventstore
	View       *view.View
}

func (*TokenRepo) IsTokenValid 

func (repo *TokenRepo) IsTokenValid(ctx context.Context, userID, tokenID string) (bool, error)

func (*TokenRepo) TokenByID added in v0.20.0 

func (repo *TokenRepo) TokenByID(ctx context.Context, userID, tokenID string) (*usr_model.TokenView, error)

type UserRepo 

type UserRepo struct {
	SearchLimit     uint64
	Eventstore      v1.Eventstore
	View            *view.View
	Query           *query.Queries
	SystemDefaults  systemdefaults.SystemDefaults
	PrefixAvatarURL string
}

func (*UserRepo) Health 

func (repo *UserRepo) Health(ctx context.Context) error

func (*UserRepo) MyUserChanges added in v0.42.0 

func (repo *UserRepo) MyUserChanges(ctx context.Context, lastSequence uint64, limit uint64, sortAscending bool, retention time.Duration) (*model.UserChanges, error)

func (*UserRepo) UserEventsByID added in v0.119.0 

func (repo *UserRepo) UserEventsByID(ctx context.Context, id string, sequence uint64) ([]*models.Event, error)

func (*UserRepo) UserSessionUserIDsByAgentID added in v0.119.0 

func (repo *UserRepo) UserSessionUserIDsByAgentID(ctx context.Context, agentID string) ([]string, error)

type UserSessionRepo added in v0.20.0 

type UserSessionRepo struct {
	View *view.View
}

func (*UserSessionRepo) ActiveUserSessionCount added in v0.107.0 

func (repo *UserSessionRepo) ActiveUserSessionCount() int64

func (*UserSessionRepo) GetMyUserSessions added in v0.20.0 

func (repo *UserSessionRepo) GetMyUserSessions(ctx context.Context) ([]*usr_model.UserSessionView, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.