eventstore

package
v1.59.3 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2021 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApplicationRepo added in v0.20.0 

type ApplicationRepo struct {
	Commands *command.Commands
	Query    *query.Queries
}

func (*ApplicationRepo) AuthorizeClientIDSecret added in v0.116.8 

func (a *ApplicationRepo) AuthorizeClientIDSecret(ctx context.Context, clientID, secret string) (err error)

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

	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) 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 IAMRepository added in v0.77.0 

type IAMRepository struct {
	IAMID    string
	LoginDir http.FileSystem

	IAMV2QuerySide *query.Queries
	// contains filtered or unexported fields
}

func (*IAMRepository) GetIAM added in v0.77.0 

func (repo *IAMRepository) GetIAM(ctx context.Context) (*model.IAM, error)

func (*IAMRepository) Languages added in v1.22.0 

func (repo *IAMRepository) Languages(ctx context.Context) ([]language.Tag, error)

type KeyRepository added in v0.20.0 

type KeyRepository struct {
	Commands                 *command.Commands
	Eventstore               *eventstore.Eventstore
	View                     *view.View
	SigningKeyRotationCheck  time.Duration
	SigningKeyGracefulPeriod time.Duration
	KeyAlgorithm             crypto.EncryptionAlgorithm
	KeyChan                  <-chan *model.KeyView
	Locker                   spooler.Locker
	// contains filtered or unexported fields
}

func (*KeyRepository) GetKeySet added in v0.20.0 

func (k *KeyRepository) GetKeySet(ctx context.Context) (*jose.JSONWebKeySet, error)

func (*KeyRepository) GetSigningKey added in v0.20.0 

func (k *KeyRepository) GetSigningKey(ctx context.Context, keyCh chan<- jose.SigningKey, algorithm string)

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 UserGrantRepo added in v0.20.0 

type UserGrantRepo struct {
	SearchLimit     uint64
	View            *view.View
	IamID           string
	Auth            authz.Config
	AuthZRepo       *authz_repo.EsRepository
	PrefixAvatarURL string

	Query *query.Queries
}

func (*UserGrantRepo) IsIamAdmin added in v0.20.0 

func (repo *UserGrantRepo) IsIamAdmin(ctx context.Context) (bool, error)

func (*UserGrantRepo) SearchAdminOrgs added in v0.20.0 

func (repo *UserGrantRepo) SearchAdminOrgs(request *grant_model.UserGrantSearchRequest) (*grant_model.ProjectOrgSearchResponse, error)

func (*UserGrantRepo) SearchMyProjectOrgs added in v0.20.0 

func (repo *UserGrantRepo) SearchMyProjectOrgs(ctx context.Context, request *grant_model.UserGrantSearchRequest) (*grant_model.ProjectOrgSearchResponse, error)

func (*UserGrantRepo) SearchMyProjectPermissions added in v0.32.0 

func (repo *UserGrantRepo) SearchMyProjectPermissions(ctx context.Context) ([]string, error)

func (*UserGrantRepo) SearchMyUserGrants added in v0.20.0 

func (repo *UserGrantRepo) SearchMyUserGrants(ctx context.Context, request *grant_model.UserGrantSearchRequest) (*grant_model.UserGrantSearchResponse, error)

func (*UserGrantRepo) SearchMyUserMemberships added in v0.112.6 

func (repo *UserGrantRepo) SearchMyUserMemberships(ctx context.Context, request *user_model.UserMembershipSearchRequest) (*user_model.UserMembershipSearchResponse, error)

func (*UserGrantRepo) SearchMyZitadelPermissions added in v0.20.0 

func (repo *UserGrantRepo) SearchMyZitadelPermissions(ctx context.Context) ([]string, error)

func (*UserGrantRepo) UserGrantsByProjectAndUserID added in v0.54.5 

func (repo *UserGrantRepo) UserGrantsByProjectAndUserID(projectID, userID string) ([]*grant_model.UserGrantView, error)

type UserRepo 

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

func (*UserRepo) GetMyMetadataByKey added in v1.29.0 

func (repo *UserRepo) GetMyMetadataByKey(ctx context.Context, key string) (*domain.Metadata, error)

func (*UserRepo) GetMyPasswordless added in v0.109.4 

func (repo *UserRepo) GetMyPasswordless(ctx context.Context) ([]*model.WebAuthNView, error)

func (*UserRepo) Health 

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

func (*UserRepo) MachineKeyByID added in v0.85.3 

func (repo *UserRepo) MachineKeyByID(ctx context.Context, keyID string) (*key_model.AuthNKeyView, error)

func (*UserRepo) MyAddress 

func (repo *UserRepo) MyAddress(ctx context.Context) (*model.Address, error)

func (*UserRepo) MyEmail 

func (repo *UserRepo) MyEmail(ctx context.Context) (*model.Email, error)

func (*UserRepo) MyPhone 

func (repo *UserRepo) MyPhone(ctx context.Context) (*model.Phone, error)

func (*UserRepo) MyProfile 

func (repo *UserRepo) MyProfile(ctx context.Context) (*model.Profile, error)

func (*UserRepo) MyUser added in v0.30.1 

func (repo *UserRepo) MyUser(ctx context.Context) (*model.UserView, 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) MyUserMFAs added in v0.108.0 

func (repo *UserRepo) MyUserMFAs(ctx context.Context) ([]*model.MultiFactor, error)

func (*UserRepo) SearchMyExternalIDPs added in v0.87.0 

func (repo *UserRepo) SearchMyExternalIDPs(ctx context.Context, request *model.ExternalIDPSearchRequest) (*model.ExternalIDPSearchResponse, error)

func (*UserRepo) SearchMyMetadata added in v1.29.0 

func (repo *UserRepo) SearchMyMetadata(ctx context.Context, req *domain.MetadataSearchRequest) (*domain.MetadataSearchResponse, error)

func (*UserRepo) SearchUserMetadata added in v1.33.0 

func (repo *UserRepo) SearchUserMetadata(ctx context.Context, userID string) (*domain.MetadataSearchResponse, error)

func (*UserRepo) SearchUsers added in v1.6.1 

func (repo *UserRepo) SearchUsers(ctx context.Context, request *model.UserSearchRequest) (*model.UserSearchResponse, error)

func (*UserRepo) UserByID added in v0.20.0 

func (repo *UserRepo) UserByID(ctx context.Context, id string) (*model.UserView, error)

func (*UserRepo) UserByLoginName added in v0.119.0 

func (repo *UserRepo) UserByLoginName(ctx context.Context, loginname string) (*model.UserView, 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.