repository

package

Go to main page

Versions in this module

v0

v0.7.2

Aug 26, 2024

v0.7.2-rc.0

Jul 11, 2024

v0.7.1

Jul 10, 2024

Changes in this version

type UserModel

+ RequestEmailId string

v0.7.0

Jun 7, 2024

Changes in this version

type UserRepository

+ CheckIfTokenExistsByTokenNameAndVersion func(tokenName string, tokenVersion int) (bool, error)

type UserRepositoryImpl

+ func (impl UserRepositoryImpl) CheckIfTokenExistsByTokenNameAndVersion(tokenName string, tokenVersion int) (bool, error)

v0.6.29

Apr 13, 2024

Changes in this version

type RoleGroupRepository

+ CommitATransaction func(tx *pg.Tx) error

+ DeleteRoleGroupRoleMappingByIds func(ids []int, tx *pg.Tx) error

+ GetAllExecutingQuery func(query string) ([]*RoleGroup, error)

+ GetCasbinNamesById func(ids []int32) ([]string, error)

+ GetRoleGroupRoleMappingIdsByGroupIds func(groupIds []int32) ([]int, error)

+ GetRoleGroupRoleMappingIdsByRoleGroupId func(roleGroupId int32) ([]int, error)

+ GetRolesByRoleGroupIds func(roleGroupIds []int32) ([]*RoleModel, error)

+ StartATransaction func() (*pg.Tx, error)

+ UpdateToInactiveByIds func(ids []int32, tx *pg.Tx, loggedInUserId int32) error

type RoleGroupRepositoryImpl

+ func (impl RoleGroupRepositoryImpl) CommitATransaction(tx *pg.Tx) error

+ func (impl RoleGroupRepositoryImpl) DeleteRoleGroupRoleMappingByIds(ids []int, tx *pg.Tx) error

+ func (impl RoleGroupRepositoryImpl) GetAllExecutingQuery(query string) ([]*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetCasbinNamesById(ids []int32) ([]string, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMappingIdsByGroupIds(groupIds []int32) ([]int, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMappingIdsByRoleGroupId(roleGroupId int32) ([]int, error)

+ func (impl RoleGroupRepositoryImpl) GetRolesByRoleGroupIds(roleGroupIds []int32) ([]*RoleModel, error)

+ func (impl RoleGroupRepositoryImpl) StartATransaction() (*pg.Tx, error)

+ func (impl RoleGroupRepositoryImpl) UpdateToInactiveByIds(ids []int32, tx *pg.Tx, loggedInUserId int32) error

type UserAuthRepository

+ DeleteUserRoleMappingByIds func(urmIds []int, tx *pg.Tx) error

+ GetUserRoleMappingIdsByUserId func(userId int32) ([]int, error)

+ GetUserRoleMappingIdsByUserIds func(userIds []int32) ([]int, error)

type UserAuthRepositoryImpl

+ func (impl UserAuthRepositoryImpl) DeleteUserRoleMappingByIds(urmIds []int, tx *pg.Tx) error

+ func (impl UserAuthRepositoryImpl) GetUserRoleMappingIdsByUserId(userId int32) ([]int, error)

+ func (impl UserAuthRepositoryImpl) GetUserRoleMappingIdsByUserIds(userIds []int32) ([]int, error)

type UserModel

+ UserAudit *UserAudit

type UserRepository

+ GetAllExecutingQuery func(query string) ([]UserModel, error)

+ GetCountExecutingQuery func(query string) (int, error)

+ GetEmailByIds func(ids []int32) ([]string, error)

+ UpdateToInactiveByIds func(ids []int32, tx *pg.Tx, loggedInUserId int32) error

type UserRepositoryImpl

+ func (impl UserRepositoryImpl) GetAllExecutingQuery(query string) ([]UserModel, error)

+ func (impl UserRepositoryImpl) GetCountExecutingQuery(query string) (int, error)

+ func (impl UserRepositoryImpl) GetEmailByIds(ids []int32) ([]string, error)

+ func (impl UserRepositoryImpl) UpdateToInactiveByIds(ids []int32, tx *pg.Tx, loggedInUserId int32) error

v0.6.28

Mar 13, 2024

Changes in this version

+ const EMPTY_PLACEHOLDER_FOR_QUERY

+ type ClusterRolePolicyDetails struct

+ Cluster string

+ ClusterObj string

+ Entity string

+ Group string

+ GroupObj string

+ Kind string

+ KindObj string

+ Namespace string

+ NamespaceObj string

+ Resource string

+ ResourceObj string

+ type DefaultAuthPolicy struct

+ Id int

+ Policy string

+ RoleType string

+ TableName struct{}

+ type DefaultAuthPolicyRepository interface

+ CreatePolicy func(policy *DefaultAuthPolicy) (*DefaultAuthPolicy, error)

+ GetPolicyByRoleTypeAndEntity func(roleType bean.RoleType, accessType string, entity string) (policy string, err error)

+ UpdatePolicyByRoleType func(policy string, roleType bean.RoleType) (*DefaultAuthPolicy, error)

+ type DefaultAuthPolicyRepositoryImpl struct

+ func NewDefaultAuthPolicyRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *DefaultAuthPolicyRepositoryImpl

+ func (impl DefaultAuthPolicyRepositoryImpl) CreatePolicy(policy *DefaultAuthPolicy) (*DefaultAuthPolicy, error)

+ func (impl DefaultAuthPolicyRepositoryImpl) GetPolicyByRoleTypeAndEntity(roleType bean.RoleType, accessType string, entity string) (policy string, err error)

+ func (impl DefaultAuthPolicyRepositoryImpl) UpdatePolicyByRoleType(policy string, roleType bean.RoleType) (*DefaultAuthPolicy, error)

+ type DefaultAuthRole struct

+ Id int

+ Role string

+ RoleType string

+ TableName struct{}

+ type DefaultAuthRoleRepository interface

+ CreateRole func(role *DefaultAuthRole) (*DefaultAuthRole, error)

+ GetRoleByRoleTypeAndEntityType func(roleType bean.RoleType, accessType string, entity string) (role string, err error)

+ UpdateRole func(role *DefaultAuthRole) (*DefaultAuthRole, error)

+ type DefaultAuthRoleRepositoryImpl struct

+ func NewDefaultAuthRoleRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *DefaultAuthRoleRepositoryImpl

+ func (impl DefaultAuthRoleRepositoryImpl) CreateRole(role *DefaultAuthRole) (*DefaultAuthRole, error)

+ func (impl DefaultAuthRoleRepositoryImpl) GetRoleByRoleTypeAndEntityType(roleType bean.RoleType, accessType string, entity string) (role string, err error)

+ func (impl DefaultAuthRoleRepositoryImpl) UpdateRole(role *DefaultAuthRole) (*DefaultAuthRole, error)

+ type PValDetailObj struct

+ IndexKeyMap map[int]PValUpdateKey

+ Value string

+ type PValUpdateKey string

+ const AppObjPValUpdateKey

+ const AppPValUpdateKey

+ const ClusterObjPValUpdateKey

+ const ClusterPValUpdateKey

+ const EntityNamePValUpdateKey

+ const EntityPValUpdateKey

+ const EnvObjPValUpdateKey

+ const EnvPValUpdateKey

+ const GroupObjPValUpdateKey

+ const GroupPValUpdateKey

+ const KindObjPValUpdateKey

+ const KindPValUpdateKey

+ const NamespaceObjPValUpdateKey

+ const NamespacePValUpdateKey

+ const ResourceObjPValUpdateKey

+ const ResourcePValUpdateKey

+ const TeamObjPValUpdateKey

+ const TeamPValUpdateKey

+ const WorkflowObjPValUpdateKey

+ const WorkflowPValUpdateKey

+ type PolicyCacheDetailObj struct

+ ResActObjSet []ResActObj

+ Sub PValDetailObj

+ Type PValDetailObj

+ type RbacDataCacheFactory interface

+ GetDefaultRoleDataAndPolicyByEntityAccessTypeAndRoleType func(entity, accessType, roleType string) (RoleCacheDetailObj, PolicyCacheDetailObj, error)

+ SyncPolicyCache func()

+ SyncRoleDataCache func()

+ type RbacDataCacheFactoryImpl struct

+ func NewRbacDataCacheFactoryImpl(logger *zap.SugaredLogger, ...) *RbacDataCacheFactoryImpl

+ func (impl *RbacDataCacheFactoryImpl) GetDefaultRoleDataAndPolicyByEntityAccessTypeAndRoleType(entity, accessType, roleType string) (RoleCacheDetailObj, PolicyCacheDetailObj, error)

+ func (impl *RbacDataCacheFactoryImpl) SyncPolicyCache()

+ func (impl *RbacDataCacheFactoryImpl) SyncRoleDataCache()

+ type RbacPolicyData struct

+ AccessType string

+ Deleted bool

+ Entity string

+ Id int

+ IsPresetRole bool

+ PolicyData string

+ Role string

+ TableName struct{}

+ type RbacPolicyDataRepository interface

+ CreateNewPolicyDataForRoleWithTxn func(model *RbacPolicyData, tx *pg.Tx) (*RbacPolicyData, error)

+ GetPolicyDataForAllRoles func() ([]*RbacPolicyData, error)

+ UpdatePolicyDataForRoleWithTxn func(model *RbacPolicyData, tx *pg.Tx) (*RbacPolicyData, error)

+ type RbacPolicyDataRepositoryImpl struct

+ func NewRbacPolicyDataRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *RbacPolicyDataRepositoryImpl

+ func (repo *RbacPolicyDataRepositoryImpl) CreateNewPolicyDataForRoleWithTxn(model *RbacPolicyData, tx *pg.Tx) (*RbacPolicyData, error)

+ func (repo *RbacPolicyDataRepositoryImpl) GetPolicyDataForAllRoles() ([]*RbacPolicyData, error)

+ func (repo *RbacPolicyDataRepositoryImpl) UpdatePolicyDataForRoleWithTxn(model *RbacPolicyData, tx *pg.Tx) (*RbacPolicyData, error)

+ type RbacRoleData struct

+ AccessType string

+ Deleted bool

+ Entity string

+ Id int

+ IsPresetRole bool

+ Role string

+ RoleData string

+ RoleDescription string

+ RoleDisplayName string

+ TableName struct{}

+ type RbacRoleDataRepository interface

+ CreateNewRoleDataForRoleWithTxn func(model *RbacRoleData, tx *pg.Tx) (*RbacRoleData, error)

+ GetRoleDataForAllRoles func() ([]*RbacRoleData, error)

+ UpdateRoleDataForRoleWithTxn func(model *RbacRoleData, tx *pg.Tx) (*RbacRoleData, error)

+ type RbacRoleDataRepositoryImpl struct

+ func NewRbacRoleDataRepositoryImpl(logger *zap.SugaredLogger, dbConnection *pg.DB) *RbacRoleDataRepositoryImpl

+ func (repo *RbacRoleDataRepositoryImpl) CreateNewRoleDataForRoleWithTxn(model *RbacRoleData, tx *pg.Tx) (*RbacRoleData, error)

+ func (repo *RbacRoleDataRepositoryImpl) GetRoleDataForAllRoles() ([]*RbacRoleData, error)

+ func (repo *RbacRoleDataRepositoryImpl) UpdateRoleDataForRoleWithTxn(model *RbacRoleData, tx *pg.Tx) (*RbacRoleData, error)

+ type ResActObj struct

+ Act PValDetailObj

+ Obj PValDetailObj

+ Res PValDetailObj

+ type RoleCacheDetailObj struct

+ AccessType PValDetailObj

+ Action PValDetailObj

+ Cluster PValDetailObj

+ Entity PValDetailObj

+ EntityName PValDetailObj

+ Environment PValDetailObj

+ Group PValDetailObj

+ Kind PValDetailObj

+ Namespace PValDetailObj

+ Resource PValDetailObj

+ Role PValDetailObj

+ Team PValDetailObj

+ Workflow PValDetailObj

+ type RoleGroup struct

+ Active bool

+ CasbinName string

+ Description string

+ Id int32

+ Name string

+ TableName struct{}

+ type RoleGroupRepository interface

+ CheckRoleGroupExistByCasbinName func(name string) (bool, error)

+ CreateRoleGroup func(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error)

+ CreateRoleGroupRoleMapping func(model *RoleGroupRoleMapping, tx *pg.Tx) (*RoleGroupRoleMapping, error)

+ DeleteRoleGroupRoleMapping func(model *RoleGroupRoleMapping, tx *pg.Tx) (bool, error)

+ DeleteRoleGroupRoleMappingByRoleId func(roleId int, tx *pg.Tx) error

+ DeleteRoleGroupRoleMappingByRoleIds func(roleId []int, tx *pg.Tx) error

+ GetAllRoleGroup func() ([]*RoleGroup, error)

+ GetConnection func() (dbConnection *pg.DB)

+ GetRoleGroupById func(id int32) (*RoleGroup, error)

+ GetRoleGroupByName func(name string) (*RoleGroup, error)

+ GetRoleGroupListByCasbinNames func(name []string) ([]*RoleGroup, error)

+ GetRoleGroupListByName func(name string) ([]*RoleGroup, error)

+ GetRoleGroupListByNames func(groupNames []string) ([]*RoleGroup, error)

+ GetRoleGroupRoleMapping func(model int32) (*RoleGroupRoleMapping, error)

+ GetRoleGroupRoleMappingByRoleGroupId func(roleGroupId int32) ([]*RoleGroupRoleMapping, error)

+ GetRoleGroupRoleMappingByRoleGroupIds func(roleGroupIds []int32) ([]*RoleModel, error)

+ GetRolesByGroupCasbinName func(groupName string) ([]*RoleModel, error)

+ GetRolesByGroupCasbinNames func(groupCasbinNames []string) ([]*RoleModel, error)

+ GetRolesByGroupNames func(groupNames []string) ([]*RoleModel, error)

+ GetRolesByGroupNamesAndEntity func(groupNames []string, entity string) ([]*RoleModel, error)

+ UpdateRoleGroup func(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error)

+ UpdateRoleGroupIdForRoleGroupMappings func(roleId int, newRoleId int) (*RoleGroupRoleMapping, error)

+ type RoleGroupRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewRoleGroupRepositoryImpl(dbConnection *pg.DB, Logger *zap.SugaredLogger) *RoleGroupRepositoryImpl

+ func (impl *RoleGroupRepositoryImpl) GetConnection() (dbConnection *pg.DB)

+ func (impl RoleGroupRepositoryImpl) CheckRoleGroupExistByCasbinName(name string) (bool, error)

+ func (impl RoleGroupRepositoryImpl) CreateRoleGroup(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) CreateRoleGroupRoleMapping(model *RoleGroupRoleMapping, tx *pg.Tx) (*RoleGroupRoleMapping, error)

+ func (impl RoleGroupRepositoryImpl) DeleteRoleGroupRoleMapping(model *RoleGroupRoleMapping, tx *pg.Tx) (bool, error)

+ func (impl RoleGroupRepositoryImpl) DeleteRoleGroupRoleMappingByRoleId(roleId int, tx *pg.Tx) error

+ func (impl RoleGroupRepositoryImpl) DeleteRoleGroupRoleMappingByRoleIds(roleIds []int, tx *pg.Tx) error

+ func (impl RoleGroupRepositoryImpl) GetAllRoleGroup() ([]*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupById(id int32) (*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupByName(name string) (*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupListByCasbinNames(names []string) ([]*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupListByName(name string) ([]*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupListByNames(groupNames []string) ([]*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMapping(userRoleModelId int32) (*RoleGroupRoleMapping, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMappingByRoleGroupId(roleGroupId int32) ([]*RoleGroupRoleMapping, error)

+ func (impl RoleGroupRepositoryImpl) GetRoleGroupRoleMappingByRoleGroupIds(roleGroupIds []int32) ([]*RoleModel, error)

+ func (impl RoleGroupRepositoryImpl) GetRolesByGroupCasbinName(groupName string) ([]*RoleModel, error)

+ func (impl RoleGroupRepositoryImpl) GetRolesByGroupCasbinNames(groupCasbinNames []string) ([]*RoleModel, error)

+ func (impl RoleGroupRepositoryImpl) GetRolesByGroupNames(groupNames []string) ([]*RoleModel, error)

+ func (impl RoleGroupRepositoryImpl) GetRolesByGroupNamesAndEntity(groupNames []string, entity string) ([]*RoleModel, error)

+ func (impl RoleGroupRepositoryImpl) UpdateRoleGroup(model *RoleGroup, tx *pg.Tx) (*RoleGroup, error)

+ func (impl RoleGroupRepositoryImpl) UpdateRoleGroupIdForRoleGroupMappings(roleId int, newRoleId int) (*RoleGroupRoleMapping, error)

+ type RoleGroupRoleMapping struct

+ Id int

+ RoleGroupId int32

+ RoleId int

+ TableName struct{}

+ type RoleModel struct

+ AccessType string

+ Action string

+ Cluster string

+ Entity string

+ EntityName string

+ Environment string

+ Group string

+ Id int

+ Kind string

+ Namespace string

+ Resource string

+ Role string

+ TableName struct{}

+ Team string

+ Workflow string

+ type RolePolicyDetails struct

+ App string

+ AppObj string

+ Approver bool

+ Cluster string

+ ClusterObj string

+ Entity string

+ EntityName string

+ Env string

+ EnvObj string

+ Group string

+ GroupObj string

+ Kind string

+ KindObj string

+ Namespace string

+ NamespaceObj string

+ Resource string

+ ResourceObj string

+ Team string

+ TeamObj string

+ type SelfRegistrationRoles struct

+ Role string

+ TableName struct{}

+ type SelfRegistrationRolesRepository interface

+ GetAll func() ([]SelfRegistrationRoles, error)

+ type SelfRegistrationRolesRepositoryImpl struct

+ func NewSelfRegistrationRolesRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *SelfRegistrationRolesRepositoryImpl

+ func (impl *SelfRegistrationRolesRepositoryImpl) GetAll() ([]SelfRegistrationRoles, error)

+ type UserAudit struct

+ ClientIp string

+ CreatedOn time.Time

+ Id int32

+ TableName struct{}

+ UpdatedOn time.Time

+ UserId int32

+ type UserAuditRepository interface

+ GetLatestByUserId func(userId int32) (*UserAudit, error)

+ GetLatestUser func() (*UserAudit, error)

+ Save func(userAudit *UserAudit) error

+ Update func(userAudit *UserAudit) error

+ type UserAuditRepositoryImpl struct

+ func NewUserAuditRepositoryImpl(dbConnection *pg.DB) *UserAuditRepositoryImpl

+ func (impl UserAuditRepositoryImpl) GetLatestByUserId(userId int32) (*UserAudit, error)

+ func (impl UserAuditRepositoryImpl) GetLatestUser() (*UserAudit, error)

+ func (impl UserAuditRepositoryImpl) Save(userAudit *UserAudit) error

+ func (impl UserAuditRepositoryImpl) Update(userAudit *UserAudit) error

+ type UserAuthRepository interface

+ CreateDefaultPoliciesForAllTypes func(...) (bool, error, []casbin2.Policy)

+ CreateRole func(role *RoleModel) (*RoleModel, error)

+ CreateRoleForSuperAdminIfNotExists func(tx *pg.Tx, UserId int32) (bool, error)

+ CreateRoleWithTxn func(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error)

+ CreateRolesWithAccessTypeAndEntity func(...) (bool, error)

+ CreateUserRoleMapping func(userRoleModel *UserRoleModel, tx *pg.Tx) (*UserRoleModel, error)

+ DeleteRole func(role *RoleModel, tx *pg.Tx) error

+ DeleteRolesByIds func(roleIds []int, tx *pg.Tx) error

+ DeleteUserRoleByRoleId func(roleId int, tx *pg.Tx) error

+ DeleteUserRoleByRoleIds func(roleIds []int, tx *pg.Tx) error

+ DeleteUserRoleMapping func(userRoleModel *UserRoleModel, tx *pg.Tx) (bool, error)

+ GetAllRole func() ([]RoleModel, error)

+ GetRoleByFilterForAllTypes func(...) (RoleModel, error)

+ GetRoleById func(id int) (*RoleModel, error)

+ GetRoleByRoles func(roles []string) ([]RoleModel, error)

+ GetRoleForChartGroupEntity func(entity, app, act, accessType string) (RoleModel, error)

+ GetRoleForClusterEntity func(cluster, namespace, group, kind, resource, action string) (RoleModel, error)

+ GetRoleForJobsEntity func(entity, team, app, env, act string, workflow string) (RoleModel, error)

+ GetRoleForOtherEntity func(team, app, env, act, accessType string, oldValues bool) (RoleModel, error)

+ GetRolesByActionAndAccessType func(action string, accessType string) ([]RoleModel, error)

+ GetRolesByGroupId func(userId int32) ([]*RoleModel, error)

+ GetRolesByIds func(ids []int) ([]RoleModel, error)

+ GetRolesByUserId func(userId int32) ([]RoleModel, error)

+ GetRolesByUserIdAndEntityType func(userId int32, entityType string) ([]*RoleModel, error)

+ GetRolesForApp func(appName string) ([]*RoleModel, error)

+ GetRolesForChartGroup func(chartGroupName string) ([]*RoleModel, error)

+ GetRolesForEnvironment func(envName, envIdentifier string) ([]*RoleModel, error)

+ GetRolesForProject func(teamName string) ([]*RoleModel, error)

+ GetRolesForWorkflow func(workflow, entityName string) ([]*RoleModel, error)

+ GetUserRoleMappingByUserId func(userId int32) ([]*UserRoleModel, error)

+ SyncOrchestratorToCasbin func(team string, entityName string, env string, tx *pg.Tx) (bool, error)

+ UpdateTriggerPolicyForTerminalAccess func() error

+ type UserAuthRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewUserAuthRepositoryImpl(dbConnection *pg.DB, Logger *zap.SugaredLogger, ...) *UserAuthRepositoryImpl

+ func (impl UserAuthRepositoryImpl) CreateDefaultPoliciesForAllTypes(...) (bool, error, []casbin2.Policy)

+ func (impl UserAuthRepositoryImpl) CreateRole(role *RoleModel) (*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) CreateRoleForSuperAdminIfNotExists(tx *pg.Tx, UserId int32) (bool, error)

+ func (impl UserAuthRepositoryImpl) CreateRoleWithTxn(userModel *RoleModel, tx *pg.Tx) (*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) CreateRolesWithAccessTypeAndEntity(...) (bool, error)

+ func (impl UserAuthRepositoryImpl) CreateUserRoleMapping(userRoleModel *UserRoleModel, tx *pg.Tx) (*UserRoleModel, error)

+ func (impl UserAuthRepositoryImpl) DeleteRole(role *RoleModel, tx *pg.Tx) error

+ func (impl UserAuthRepositoryImpl) DeleteRolesByIds(roleIds []int, tx *pg.Tx) error

+ func (impl UserAuthRepositoryImpl) DeleteUserRoleByRoleId(roleId int, tx *pg.Tx) error

+ func (impl UserAuthRepositoryImpl) DeleteUserRoleByRoleIds(roleIds []int, tx *pg.Tx) error

+ func (impl UserAuthRepositoryImpl) DeleteUserRoleMapping(userRoleModel *UserRoleModel, tx *pg.Tx) (bool, error)

+ func (impl UserAuthRepositoryImpl) GetAllRole() ([]RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetDefaultPolicyByRoleType(roleType bean2.RoleType) (policy string, err error)

+ func (impl UserAuthRepositoryImpl) GetDiffBetweenPolicies(oldPolicy string, newPolicy string) (addedPolicies []casbin2.Policy, deletedPolicies []casbin2.Policy, err error)

+ func (impl UserAuthRepositoryImpl) GetRole(role string) (*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRoleByFilterForAllTypes(...) (RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRoleById(id int) (*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRoleByRoles(roles []string) ([]RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRoleForChartGroupEntity(entity, app, act, accessType string) (RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRoleForClusterEntity(cluster, namespace, group, kind, resource, action string) (RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRoleForJobsEntity(entity, team, app, env, act string, workflow string) (RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRoleForOtherEntity(team, app, env, act, accessType string, oldValues bool) (RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesByActionAndAccessType(action string, accessType string) ([]RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesByGroupId(roleGroupId int32) ([]*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesByIds(ids []int) ([]RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesByUserId(userId int32) ([]RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesByUserIdAndEntityType(userId int32, entityType string) ([]*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesForApp(appName string) ([]*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesForChartGroup(chartGroupName string) ([]*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesForEnvironment(envName, envIdentifier string) ([]*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesForProject(teamName string) ([]*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetRolesForWorkflow(workflow, entityName string) ([]*RoleModel, error)

+ func (impl UserAuthRepositoryImpl) GetUpdatedAddedOrDeletedPolicies(policies []casbin2.Policy, rolePolicyDetails RolePolicyDetails) (bean.PolicyRequest, error)

+ func (impl UserAuthRepositoryImpl) GetUserRoleMappingByUserId(userId int32) ([]*UserRoleModel, error)

+ func (impl UserAuthRepositoryImpl) SyncOrchestratorToCasbin(team string, entityName string, env string, tx *pg.Tx) (bool, error)

+ func (impl UserAuthRepositoryImpl) UpdateDefaultPolicyByRoleType(newPolicy string, roleType bean2.RoleType) (err error)

+ func (impl UserAuthRepositoryImpl) UpdateTriggerPolicyForTerminalAccess() (err error)

+ type UserModel struct

+ AccessToken string

+ Active bool

+ EmailId string

+ Id int32

+ TableName struct{}

+ UserType string

+ type UserRepository interface

+ CreateUser func(userModel *UserModel, tx *pg.Tx) (*UserModel, error)

+ FetchActiveOrDeletedUserByEmail func(email string) (*UserModel, error)

+ FetchActiveUserByEmail func(email string) (bean.UserInfo, error)

+ FetchUserDetailByEmail func(email string) (bean.UserInfo, error)

+ FetchUserMatchesByEmailIdExcludingApiTokenUser func(email string) ([]UserModel, error)

+ GetAllExcludingApiTokenUser func() ([]UserModel, error)

+ GetById func(id int32) (*UserModel, error)

+ GetByIdIncludeDeleted func(id int32) (*UserModel, error)

+ GetByIds func(ids []int32) ([]UserModel, error)

+ GetConnection func() (dbConnection *pg.DB)

+ UpdateRoleIdForUserRolesMappings func(roleId int, newRoleId int) (*UserRoleModel, error)

+ UpdateUser func(userModel *UserModel, tx *pg.Tx) (*UserModel, error)

+ type UserRepositoryImpl struct

+ Logger *zap.SugaredLogger

+ func NewUserRepositoryImpl(dbConnection *pg.DB, logger *zap.SugaredLogger) *UserRepositoryImpl

+ func (impl *UserRepositoryImpl) GetConnection() (dbConnection *pg.DB)

+ func (impl UserRepositoryImpl) CreateUser(userModel *UserModel, tx *pg.Tx) (*UserModel, error)

+ func (impl UserRepositoryImpl) FetchActiveOrDeletedUserByEmail(email string) (*UserModel, error)

+ func (impl UserRepositoryImpl) FetchActiveUserByEmail(email string) (bean.UserInfo, error)

+ func (impl UserRepositoryImpl) FetchUserDetailByEmail(email string) (bean.UserInfo, error)

+ func (impl UserRepositoryImpl) FetchUserMatchesByEmailIdExcludingApiTokenUser(email string) ([]UserModel, error)

+ func (impl UserRepositoryImpl) GetAllExcludingApiTokenUser() ([]UserModel, error)

+ func (impl UserRepositoryImpl) GetById(id int32) (*UserModel, error)

+ func (impl UserRepositoryImpl) GetByIdIncludeDeleted(id int32) (*UserModel, error)

+ func (impl UserRepositoryImpl) GetByIds(ids []int32) ([]UserModel, error)

+ func (impl UserRepositoryImpl) UpdateRoleIdForUserRolesMappings(roleId int, newRoleId int) (*UserRoleModel, error)

+ func (impl UserRepositoryImpl) UpdateUser(userModel *UserModel, tx *pg.Tx) (*UserModel, error)

+ type UserRoleModel struct

+ Id int

+ RoleId int

+ TableName struct{}

+ User UserModel

+ UserId int32

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL