repositories

package
v0.1.3 Latest Latest
Warning

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

Go to latest
Published: Aug 26, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BanRepository

type BanRepository struct {
	DBLayer models.DBLayer
}

func (*BanRepository) AddBannedUser

func (b *BanRepository) AddBannedUser(bannedUser models.BannedUser) error

func (*BanRepository) GetBannedUserByEmail

func (b *BanRepository) GetBannedUserByEmail(userEmail string) (models.BannedUser, error)

func (*BanRepository) GetBannedUsers

func (b *BanRepository) GetBannedUsers() ([]models.BannedUser, error)

func (*BanRepository) IsUserBanned

func (b *BanRepository) IsUserBanned(userEmail string) bool

func (*BanRepository) UnbanUser

func (b *BanRepository) UnbanUser(userEmail string) error

type BanRepositoryResult

type BanRepositoryResult struct {
	dig.Out
	BanRepository *BanRepository
}

func ProvideBanRepository

func ProvideBanRepository(db models.DBLayer) BanRepositoryResult

type DomainRepository

type DomainRepository struct {
	DBLayer models.DBLayer
}

func (*DomainRepository) CreateDomain

func (d *DomainRepository) CreateDomain(domain models.TicketDomain) error

func (*DomainRepository) DeleteDomain

func (d *DomainRepository) DeleteDomain(domainPath string) error

func (*DomainRepository) DoesTicketDomainExist

func (d *DomainRepository) DoesTicketDomainExist(domainPath string) bool

func (*DomainRepository) GetDomain

func (d *DomainRepository) GetDomain(domainPath string) (models.TicketDomain, error)

func (*DomainRepository) ListDomains

func (d *DomainRepository) ListDomains() ([]models.TicketDomain, error)

type DomainRepositoryResult

type DomainRepositoryResult struct {
	dig.Out
	DomainRepository *DomainRepository
}

func ProvideDomainRepository

func ProvideDomainRepository(db models.DBLayer) DomainRepositoryResult

type GroupRepository

type GroupRepository struct {
	DBLayer models.DBLayer
}

func (*GroupRepository) AddMemberToGroup

func (g *GroupRepository) AddMemberToGroup(newMember string, groupName string, changedBy string) error

func (*GroupRepository) CreateGroup

func (g *GroupRepository) CreateGroup(group models.TicketGroup) error

func (*GroupRepository) DelMemberFromGroup

func (g *GroupRepository) DelMemberFromGroup(memberToDelete string, groupName string, changedBy string) error

func (*GroupRepository) DeleteGroup

func (g *GroupRepository) DeleteGroup(groupName string) error

func (*GroupRepository) DoesGroupExist

func (g *GroupRepository) DoesGroupExist(groupName string) bool

func (*GroupRepository) GetAllGroups

func (g *GroupRepository) GetAllGroups() ([]models.TicketGroup, error)

func (*GroupRepository) GetGroup

func (g *GroupRepository) GetGroup(groupName string) (models.TicketGroup, error)

func (*GroupRepository) IsUserInTikiadmins

func (g *GroupRepository) IsUserInTikiadmins(userEmail string) bool

func (*GroupRepository) IsUserMemberOfGroup

func (g *GroupRepository) IsUserMemberOfGroup(member string, groupName string) bool

type GroupRepositoryResult

type GroupRepositoryResult struct {
	dig.Out
	GroupRepository *GroupRepository
}

func ProvideGroupRepository

func ProvideGroupRepository(db models.DBLayer) GroupRepositoryResult

type IMORepository

type IMORepository struct {
	// contains filtered or unexported fields
}

func (*IMORepository) FillSessionsIntoCache added in v0.1.2

func (imo *IMORepository) FillSessionsIntoCache(scanType string, sessions []models.Session) error

func (*IMORepository) GetCacheObject added in v0.1.2

func (imo *IMORepository) GetCacheObject(objname string) (*hazelcast.Map, error)

func (*IMORepository) GetHZClient added in v0.1.2

func (imo *IMORepository) GetHZClient() *hazelcast.Client

func (*IMORepository) GetSessionsFromCache added in v0.1.2

func (imo *IMORepository) GetSessionsFromCache(scanType string) ([]models.Session, error)

func (*IMORepository) InitHazelcast added in v0.1.2

func (imo *IMORepository) InitHazelcast() (*hazelcast.Client, error)

type IMORepositoryResult

type IMORepositoryResult struct {
	dig.Out
	IMORepository *IMORepository
}

func ProvideIMORepository

func ProvideIMORepository(isCacheReady *bool, appconfig *appconfig.AppConfig, logger *logger.TikiLogger) IMORepositoryResult

type PermissionRepository

type PermissionRepository struct {
	DBLayer          models.DBLayer
	GroupRepository  GroupRepository
	TicketRepository TicketRepository
}

func (*PermissionRepository) CanUserAccessToTicket

func (pr *PermissionRepository) CanUserAccessToTicket(userEmail string, ticketPath string) bool

func (*PermissionRepository) CanUserPerformDomainOperation

func (pr *PermissionRepository) CanUserPerformDomainOperation(userEmail string, operation string) bool

func (*PermissionRepository) CanUserPerformGroupOperation

func (pr *PermissionRepository) CanUserPerformGroupOperation(userEmail string, operation string) bool

func (*PermissionRepository) CanUserPerformTicketOperation

func (pr *PermissionRepository) CanUserPerformTicketOperation(userEmail string, operation string) bool

func (*PermissionRepository) IsUserAllowedByDomainScope

func (pr *PermissionRepository) IsUserAllowedByDomainScope(userEmail string, ticketOrDomainPath string, domainScopeOperation string) bool

func (*PermissionRepository) IsUserInTikiadmins

func (pr *PermissionRepository) IsUserInTikiadmins(userEmail string) bool

type PermissionRepositoryResult

type PermissionRepositoryResult struct {
	dig.Out
	PermissionRepository *PermissionRepository
}

type SessionRepository

type SessionRepository struct {
	DBLayer models.DBLayer
	// contains filtered or unexported fields
}

func (*SessionRepository) CreateSession

func (sr *SessionRepository) CreateSession(session *models.Session) error

func (*SessionRepository) DeleteSession added in v0.1.2

func (sr *SessionRepository) DeleteSession(sessionID string, epoch int64) error

func (*SessionRepository) GetSessionByRefreshToken

func (sr *SessionRepository) GetSessionByRefreshToken(rtoken string) (models.Session, error)

func (*SessionRepository) GetSessionByToken added in v0.1.2

func (sr *SessionRepository) GetSessionByToken(token string) (models.Session, error)

func (*SessionRepository) GetSessions

func (sr *SessionRepository) GetSessions(scanType string) ([]models.Session, error)

func (*SessionRepository) GetSessionsByEmail added in v0.1.2

func (sr *SessionRepository) GetSessionsByEmail(email string) ([]models.Session, error)

func (*SessionRepository) UpdateSession

func (sr *SessionRepository) UpdateSession(prevToken string, currentToken string, currentTokenExpires int64, refreshToken string) bool

type SessionRepositoryResult

type SessionRepositoryResult struct {
	dig.Out
	SessionRepository *SessionRepository
}

func ProvideSessionRepository

func ProvideSessionRepository(isCacheReady *bool, logger *logger.TikiLogger, db models.DBLayer, imoRepository *IMORepository) SessionRepositoryResult

type TicketRepository

type TicketRepository struct {
	DBLayer models.DBLayer
}

func (*TicketRepository) CreateTicket

func (t *TicketRepository) CreateTicket(ticket models.Ticket) error

func (*TicketRepository) DeleteTicket

func (t *TicketRepository) DeleteTicket(ticketPath string, ticketType string) error

func (*TicketRepository) DoesTicketExist

func (t *TicketRepository) DoesTicketExist(ticketPath string) bool

func (*TicketRepository) GetAllTickets

func (t *TicketRepository) GetAllTickets() ([]models.Ticket, error)

func (*TicketRepository) GetTicketSecret

func (t *TicketRepository) GetTicketSecret(ticketPath string) (string, error)

func (*TicketRepository) QueryTicketByPath

func (t *TicketRepository) QueryTicketByPath(ticketPath string) (models.Ticket, error)

func (*TicketRepository) SetTicketSecret

func (t *TicketRepository) SetTicketSecret(ticketPath string, secretData string) error

type TicketRepositoryResult

type TicketRepositoryResult struct {
	dig.Out
	TicketRepository *TicketRepository
}

func ProvideTicketRepository

func ProvideTicketRepository(db models.DBLayer) TicketRepositoryResult

Jump to

Keyboard shortcuts

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