user

package

Go to main page

Versions in this module

v0

v0.7.3

Oct 2, 2024

v0.7.2

Aug 26, 2024

v0.7.2-rc.0

Jul 11, 2024

v0.7.1

Jul 10, 2024

v0.7.0

Jun 7, 2024

Changes in this version

type RoleGroupService

+ FetchRolesForUserRoleGroups func(userRoleGroups []bean.UserRoleGroup) ([]*bean.RoleFilter, error)

type RoleGroupServiceImpl

+ func (impl RoleGroupServiceImpl) FetchRolesForUserRoleGroups(userRoleGroups []bean.UserRoleGroup) ([]*bean.RoleFilter, error)

type UserService

+ CheckIfTokenIsValid func(email string, version string) error

+ GetEmailAndVersionFromToken func(token string) (string, string, error)

+ GetRoleFiltersByUserRoleGroups func(userRoleGroups []bean.UserRoleGroup) ([]bean.RoleFilter, error)

type UserServiceImpl

+ func (impl *UserServiceImpl) CheckIfTokenIsValid(email string, version string) error

+ func (impl *UserServiceImpl) GetEmailAndVersionFromToken(token string) (string, string, error)

+ func (impl *UserServiceImpl) GetRoleFiltersByUserRoleGroups(userRoleGroups []bean.UserRoleGroup) ([]bean.RoleFilter, error)

v0.6.29

Apr 13, 2024

Changes in this version

type RoleGroupService

+ BulkDeleteRoleGroups func(request *bean.BulkDeleteRequest) (bool, error)

+ FetchRoleGroupsV2 func(req *bean.ListingRequest) (*bean.RoleGroupListingResponse, error)

+ FetchRoleGroupsWithFilters func(request *bean.ListingRequest) (*bean.RoleGroupListingResponse, error)

type RoleGroupServiceImpl

+ func (impl RoleGroupServiceImpl) BulkDeleteRoleGroups(request *bean.BulkDeleteRequest) (bool, error)

+ func (impl RoleGroupServiceImpl) FetchRoleGroupsV2(req *bean.ListingRequest) (*bean.RoleGroupListingResponse, error)

+ func (impl RoleGroupServiceImpl) FetchRoleGroupsWithFilters(request *bean.ListingRequest) (*bean.RoleGroupListingResponse, error)

type UserCommonService

+ DeleteRoleForUserFromCasbin func(mappings map[string][]string) bool

+ DeleteUserForRoleFromCasbin func(mappings map[string][]string) bool

+ SetDefaultValuesIfNotPresent func(request *bean.ListingRequest, isRoleGroup bool)

type UserCommonServiceImpl

+ func (impl UserCommonServiceImpl) DeleteRoleForUserFromCasbin(mappings map[string][]string) bool

+ func (impl UserCommonServiceImpl) DeleteUserForRoleFromCasbin(mappings map[string][]string) bool

+ func (impl UserCommonServiceImpl) SetDefaultValuesIfNotPresent(request *bean.ListingRequest, isRoleGroup bool)

type UserService

+ BulkDeleteUsers func(request *bean.BulkDeleteRequest) (bool, error)

+ GetAllWithFilters func(request *bean.ListingRequest) (*bean.UserListingResponse, error)

type UserServiceImpl

+ func (impl *UserServiceImpl) BulkDeleteUsers(request *bean.BulkDeleteRequest) (bool, error)

+ func (impl UserServiceImpl) GetAllWithFilters(request *bean.ListingRequest) (*bean.UserListingResponse, error)

v0.6.28

Mar 13, 2024

Changes in this version

+ const AllEnvironment

+ const AllGroup

+ const AllKind

+ const AllNamespace

+ const AllResource

+ const AllWorkflow

+ const ConcurrentRequestLockError

+ const ConcurrentRequestUnlockError

+ var Claims struct

+ var CookieExpirationTime int

+ var JwtExpirationTime int

+ func WhitelistChecker(url string) bool

+ type CheckResponse struct

+ Enabled bool

+ Roles []string

+ type DexConfig struct

+ CStoreKey string

+ ClientID string

+ ClientSecret string

+ CookieExpirationTime int

+ DexJwtKey string

+ DexURL string

+ JwtExpirationTime int

+ RedirectURL string

+ func GetConfig() (*DexConfig, error)

+ type RbacRoleService interface

+ GetAllDefaultRoles func() ([]*bean.RbacRoleDto, error)

+ type RbacRoleServiceImpl struct

+ func NewRbacRoleServiceImpl(logger *zap.SugaredLogger, ...) *RbacRoleServiceImpl

+ func (impl *RbacRoleServiceImpl) GetAllDefaultRoles() ([]*bean.RbacRoleDto, error)

+ type RoleGroupService interface

+ CreateRoleGroup func(request *bean.RoleGroup) (*bean.RoleGroup, error)

+ DeleteRoleGroup func(model *bean.RoleGroup) (bool, error)

+ FetchDetailedRoleGroups func() ([]*bean.RoleGroup, error)

+ FetchRoleGroups func() ([]*bean.RoleGroup, error)

+ FetchRoleGroupsById func(id int32) (*bean.RoleGroup, error)

+ FetchRoleGroupsByName func(name string) ([]*bean.RoleGroup, error)

+ FetchRolesForGroups func(groupNames []string) ([]*bean.RoleFilter, error)

+ UpdateRoleGroup func(request *bean.RoleGroup, token string, ...) (*bean.RoleGroup, error)

+ type RoleGroupServiceImpl struct

+ func NewRoleGroupServiceImpl(userAuthRepository repository.UserAuthRepository, logger *zap.SugaredLogger, ...) *RoleGroupServiceImpl

+ func (impl RoleGroupServiceImpl) CreateOrUpdateRoleGroupForClusterEntity(roleFilter bean.RoleFilter, userId int32, model *repository.RoleGroup, ...) ([]casbin2.Policy, error)

+ func (impl RoleGroupServiceImpl) CreateOrUpdateRoleGroupForJobsEntity(roleFilter bean.RoleFilter, userId int32, model *repository.RoleGroup, ...) ([]casbin2.Policy, error)

+ func (impl RoleGroupServiceImpl) CreateOrUpdateRoleGroupForOtherEntity(roleFilter bean.RoleFilter, request *bean.RoleGroup, ...) ([]casbin2.Policy, error)

+ func (impl RoleGroupServiceImpl) CreateRoleGroup(request *bean.RoleGroup) (*bean.RoleGroup, error)

+ func (impl RoleGroupServiceImpl) DeleteRoleGroup(bean *bean.RoleGroup) (bool, error)

+ func (impl RoleGroupServiceImpl) FetchDetailedRoleGroups() ([]*bean.RoleGroup, error)

+ func (impl RoleGroupServiceImpl) FetchRoleGroups() ([]*bean.RoleGroup, error)

+ func (impl RoleGroupServiceImpl) FetchRoleGroupsById(id int32) (*bean.RoleGroup, error)

+ func (impl RoleGroupServiceImpl) FetchRoleGroupsByName(name string) ([]*bean.RoleGroup, error)

+ func (impl RoleGroupServiceImpl) FetchRolesForGroups(groupNames []string) ([]*bean.RoleFilter, error)

+ func (impl RoleGroupServiceImpl) UpdateRoleGroup(request *bean.RoleGroup, token string, ...) (*bean.RoleGroup, error)

+ type User struct

+ type UserAudit struct

+ ClientIp string

+ CreatedOn time.Time

+ UpdatedOn time.Time

+ UserId int32

+ type UserAuditService interface

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

+ GetLatestUser func() (*UserAudit, error)

+ Save func(userAudit *UserAudit) error

+ Update func(userAudit *UserAudit) error

+ type UserAuditServiceImpl struct

+ func NewUserAuditServiceImpl(logger *zap.SugaredLogger, userAuditRepository repository2.UserAuditRepository) *UserAuditServiceImpl

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

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

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

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

+ type UserAuthService interface

+ AuthVerification func(r *http.Request) (bool, error)

+ CreateRole func(roleData *bean.RoleData) (bool, error)

+ DeleteRoles func(entityType string, entityName string, tx *pg.Tx, envIdentifier string, ...) error

+ HandleDexCallback func(w http.ResponseWriter, r *http.Request)

+ HandleLogin func(username string, password string) (string, error)

+ HandleLoginWithClientIp func(ctx context.Context, username, password, clientIp string) (string, error)

+ HandleRefresh func(w http.ResponseWriter, r *http.Request)

+ type UserAuthServiceImpl struct

+ func NewUserAuthServiceImpl(userAuthRepository repository.UserAuthRepository, ...) *UserAuthServiceImpl

+ func (impl UserAuthServiceImpl) AuthVerification(r *http.Request) (bool, error)

+ func (impl UserAuthServiceImpl) CreateRole(roleData *bean.RoleData) (bool, error)

+ func (impl UserAuthServiceImpl) DeleteRoles(entityType string, entityName string, tx *pg.Tx, envIdentifier string, ...) (err error)

+ func (impl UserAuthServiceImpl) HandleDexCallback(w http.ResponseWriter, r *http.Request)

+ func (impl UserAuthServiceImpl) HandleLogin(username string, password string) (string, error)

+ func (impl UserAuthServiceImpl) HandleLoginWithClientIp(ctx context.Context, username, password, clientIp string) (string, error)

+ func (impl UserAuthServiceImpl) HandleRefresh(w http.ResponseWriter, r *http.Request)

+ type UserCommonService interface

+ BuildRoleFilterForAllTypes func(roleFilterMap map[string]*bean.RoleFilter, role repository.RoleModel, ...)

+ BuildRoleFilterKeyForCluster func(roleFilterMap map[string]*bean.RoleFilter, role repository.RoleModel, ...)

+ BuildRoleFilterKeyForJobs func(roleFilterMap map[string]*bean.RoleFilter, role repository.RoleModel, ...)

+ BuildRoleFilterKeyForOtherEntity func(roleFilterMap map[string]*bean.RoleFilter, role repository.RoleModel, ...)

+ CheckRbacForClusterEntity func(cluster, namespace, group, kind, resource, token string, ...) bool

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

+ GetCapacityForRoleFilter func(roleFilters []bean.RoleFilter) (int, map[int]int)

+ GetUniqueKeyForAllEntity func(role repository.RoleModel) string

+ RemoveRolesAndReturnEliminatedPolicies func(userInfo *bean.UserInfo, existingRoleIds map[int]repository.UserRoleModel, ...) ([]casbin.Policy, error)

+ RemoveRolesAndReturnEliminatedPoliciesForGroups func(request *bean.RoleGroup, ...) ([]casbin.Policy, error)

+ type UserCommonServiceImpl struct

+ func NewUserCommonServiceImpl(userAuthRepository repository.UserAuthRepository, logger *zap.SugaredLogger, ...) *UserCommonServiceImpl

+ func (impl UserCommonServiceImpl) BuildRoleFilterForAllTypes(roleFilterMap map[string]*bean.RoleFilter, role repository.RoleModel, ...)

+ func (impl UserCommonServiceImpl) BuildRoleFilterKeyForCluster(roleFilterMap map[string]*bean.RoleFilter, role repository.RoleModel, ...)

+ func (impl UserCommonServiceImpl) BuildRoleFilterKeyForJobs(roleFilterMap map[string]*bean.RoleFilter, role repository.RoleModel, ...)

+ func (impl UserCommonServiceImpl) BuildRoleFilterKeyForOtherEntity(roleFilterMap map[string]*bean.RoleFilter, role repository.RoleModel, ...)

+ func (impl UserCommonServiceImpl) CheckRbacForClusterEntity(cluster, namespace, group, kind, resource, token string, ...) bool

+ func (impl UserCommonServiceImpl) CreateDefaultPoliciesForAllTypes(...) (bool, error, []casbin.Policy)

+ func (impl UserCommonServiceImpl) CreateDefaultPoliciesForAllTypesV2(...) (bool, error, []casbin.Policy)

+ func (impl UserCommonServiceImpl) GetCapacityForRoleFilter(roleFilters []bean.RoleFilter) (int, map[int]int)

+ func (impl UserCommonServiceImpl) GetUniqueKeyForAllEntity(role repository.RoleModel) string

+ func (impl UserCommonServiceImpl) RemoveRolesAndReturnEliminatedPolicies(userInfo *bean.UserInfo, existingRoleIds map[int]repository.UserRoleModel, ...) ([]casbin.Policy, error)

+ func (impl UserCommonServiceImpl) RemoveRolesAndReturnEliminatedPoliciesForGroups(request *bean.RoleGroup, ...) ([]casbin.Policy, error)

+ type UserRbacConfig struct

+ UseRbacCreationV2 bool

+ type UserSelfRegistrationService interface

+ CheckAndCreateUserIfConfigured func(claims jwt.MapClaims) bool

+ CheckSelfRegistrationRoles func() (CheckResponse, error)

+ SelfRegister func(emailId string) (*bean.UserInfo, error)

+ type UserSelfRegistrationServiceImpl struct

+ func NewUserSelfRegistrationServiceImpl(logger *zap.SugaredLogger, ...) *UserSelfRegistrationServiceImpl

+ func (impl *UserSelfRegistrationServiceImpl) CheckAndCreateUserIfConfigured(claims jwt.MapClaims) bool

+ func (impl *UserSelfRegistrationServiceImpl) CheckSelfRegistrationRoles() (CheckResponse, error)

+ func (impl *UserSelfRegistrationServiceImpl) GetAllSelfRegistrationRoles() ([]string, error)

+ func (impl *UserSelfRegistrationServiceImpl) SelfRegister(emailId string) (*bean.UserInfo, error)

+ type UserService interface

+ CheckUserRoles func(id int32) ([]string, error)

+ CreateUser func(userInfo *bean.UserInfo, token string, ...) ([]*bean.UserInfo, error)

+ DeleteUser func(userInfo *bean.UserInfo) (bool, error)

+ GetAll func() ([]bean.UserInfo, error)

+ GetAllDetailedUsers func() ([]bean.UserInfo, error)

+ GetById func(id int32) (*bean.UserInfo, error)

+ GetByIdIncludeDeleted func(id int32) (*bean.UserInfo, error)

+ GetByIds func(ids []int32) ([]bean.UserInfo, error)

+ GetEmailById func(userId int32) (string, error)

+ GetEmailFromToken func(token string) (string, error)

+ GetLoggedInUser func(r *http.Request) (int32, error)

+ GetRoleFiltersByGroupNames func(groupNames []string) ([]bean.RoleFilter, error)

+ GetUserByToken func(context context.Context, token string) (int32, string, error)

+ SaveLoginAudit func(emailId, clientIp string, id int32)

+ SelfRegisterUserIfNotExists func(userInfo *bean.UserInfo) ([]*bean.UserInfo, error)

+ SyncOrchestratorToCasbin func() (bool, error)

+ UpdateTriggerPolicyForTerminalAccess func() (err error)

+ UpdateUser func(userInfo *bean.UserInfo, token string, ...) (*bean.UserInfo, bool, bool, []string, error)

+ UserExists func(emailId string) bool

+ type UserServiceImpl struct

+ func NewUserServiceImpl(userAuthRepository repository.UserAuthRepository, logger *zap.SugaredLogger, ...) *UserServiceImpl

+ func (impl *UserServiceImpl) CheckUserRoles(id int32) ([]string, error)

+ func (impl *UserServiceImpl) CreateOrUpdateUserRolesForAllTypes(roleFilter bean.RoleFilter, userId int32, model *repository.UserModel, ...) ([]casbin2.Policy, bool, error)

+ func (impl *UserServiceImpl) CreateUser(userInfo *bean.UserInfo, token string, ...) ([]*bean.UserInfo, error)

+ func (impl *UserServiceImpl) DeleteUser(bean *bean.UserInfo) (bool, error)

+ func (impl *UserServiceImpl) GetAll() ([]bean.UserInfo, error)

+ func (impl *UserServiceImpl) GetAllDetailedUsers() ([]bean.UserInfo, error)

+ func (impl *UserServiceImpl) GetById(id int32) (*bean.UserInfo, error)

+ func (impl *UserServiceImpl) GetByIdIncludeDeleted(id int32) (*bean.UserInfo, error)

+ func (impl *UserServiceImpl) GetByIds(ids []int32) ([]bean.UserInfo, error)

+ func (impl *UserServiceImpl) GetEmailById(userId int32) (string, error)

+ func (impl *UserServiceImpl) GetEmailFromToken(token string) (string, error)

+ func (impl *UserServiceImpl) GetLoggedInUser(r *http.Request) (int32, error)

+ func (impl *UserServiceImpl) GetRoleFiltersByGroupNames(groupNames []string) ([]bean.RoleFilter, error)

+ func (impl *UserServiceImpl) GetUserByEmail(emailId string) (*bean.UserInfo, error)

+ func (impl *UserServiceImpl) GetUserByToken(context context.Context, token string) (int32, string, error)

+ func (impl *UserServiceImpl) IsSuperAdmin(userId int) (bool, error)

+ func (impl *UserServiceImpl) SaveLoginAudit(emailId, clientIp string, id int32)

+ func (impl *UserServiceImpl) SelfRegisterUserIfNotExists(userInfo *bean.UserInfo) ([]*bean.UserInfo, error)

+ func (impl *UserServiceImpl) SyncOrchestratorToCasbin() (bool, error)

+ func (impl *UserServiceImpl) UpdateTriggerPolicyForTerminalAccess() (err error)

+ func (impl *UserServiceImpl) UpdateUser(userInfo *bean.UserInfo, token string, ...) (*bean.UserInfo, bool, bool, []string, error)

+ func (impl *UserServiceImpl) UserExists(emailId string) bool

+ type WebhookToken struct

+ WebhookToken string

+ func GetWebhookToken() (*WebhookToken, error)

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