eventstore

package
v1.8.4 Latest Latest
Warning

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

 Go to latest Published: May 26, 2021 License: Apache-2.0 Imports: 41 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
	View     *view.View
}

func (*ApplicationRepo) ApplicationByClientID added in v0.20.0 

func (a *ApplicationRepo) ApplicationByClientID(ctx context.Context, clientID string) (*model.ApplicationView, error)

func (*ApplicationRepo) AuthorizeClientIDSecret added in v0.116.8 

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

func (*ApplicationRepo) ProjectRolesByProjectID added in v0.94.0 

func (a *ApplicationRepo) ProjectRolesByProjectID(projectID string) ([]*model.ProjectRoleView, error)

type AuthRequestRepo 

type AuthRequestRepo struct {
	Command      *command.Commands
	AuthRequests cache.AuthRequestCache
	View         *view.View

	UserSessionViewProvider userSessionViewProvider
	UserViewProvider        userViewProvider
	UserCommandProvider     userCommandProvider
	UserEventProvider       userEventProvider
	OrgViewProvider         orgViewProvider
	LoginPolicyViewProvider loginPolicyViewProvider
	IDPProviderViewProvider idpProviderViewProvider
	UserGrantProvider       userGrantProvider

	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.ExternalIDP, orgMemberRoles []string, authReqID, userAgentID, resourceOwner string, 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) 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) 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) 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)

type FeaturesRepo added in v0.119.0 

type FeaturesRepo struct {
	Eventstore v1.Eventstore

	View *auth_view.View
}

func (*FeaturesRepo) GetDefaultFeatures added in v0.119.0 

func (repo *FeaturesRepo) GetDefaultFeatures(ctx context.Context) (*features_model.FeaturesView, error)

func (*FeaturesRepo) GetOrgFeatures added in v0.119.0 

func (repo *FeaturesRepo) GetOrgFeatures(ctx context.Context, orgID string) (*features_model.FeaturesView, error)

type IAMRepository added in v0.77.0 

type IAMRepository struct {
	IAMID string

	IAMV2QuerySide *query.Queries
}

func (*IAMRepository) GetIAM added in v0.77.0 

func (repo *IAMRepository) GetIAM(ctx context.Context) (*model.IAM, 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

	View           *auth_view.View
	SystemDefaults systemdefaults.SystemDefaults
}

func (*OrgRepository) GetDefaultOrgIAMPolicy added in v0.92.0 

func (repo *OrgRepository) GetDefaultOrgIAMPolicy(ctx context.Context) (*iam_model.OrgIAMPolicyView, error)

func (*OrgRepository) GetIDPConfigByID added in v0.87.0 

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

func (*OrgRepository) GetMyPasswordComplexityPolicy added in v0.92.0 

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

func (*OrgRepository) GetOrgIAMPolicy added in v0.92.0 

func (repo *OrgRepository) GetOrgIAMPolicy(ctx context.Context, orgID string) (*iam_model.OrgIAMPolicyView, error)

func (*OrgRepository) OrgByPrimaryDomain added in v0.115.0 

func (repo *OrgRepository) OrgByPrimaryDomain(primaryDomain string) (*org_model.OrgView, error)

func (*OrgRepository) SearchOrgs added in v0.20.0 

func (repo *OrgRepository) SearchOrgs(ctx context.Context, request *org_model.OrgSearchRequest) (*org_model.OrgSearchResult, error)

type ProjectRepo added in v0.94.0 

type ProjectRepo struct {
	View *view.View
}

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
}

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
}

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) 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.