data

package
v0.0.0-...-96f2668 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2024 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ProviderSet = wire.NewSet(

	NewDiscovery,

	NewData,

	NewEntClient,

	NewRedisClient,

	NewMeilisearchClient,

	NewSnowflake,

	NewAuthzCasbinClient,

	NewAuthorized,

	NewAuthRepo,

	NewUserRepo,

	NewRoleRepo,

	NewPostRepo,

	NewDeptRepo,

	NewMenuRepo,
)

ProviderSet is data providers.

Functions

func NewAuthorized 

func NewAuthorized(enforcer *casbin.SyncedEnforcer, logger log.Logger) authz.Authorized

NewAuthorized 创建鉴权

func NewAuthzCasbinClient 

func NewAuthzCasbinClient(cfg *conf.Bootstrap, logger log.Logger) *casbin.SyncedEnforcer

NewAuthzCasbinClient 创建Casbin客户端

func NewDiscovery 

func NewDiscovery(cfg *conf.Bootstrap, logger log.Logger) registry.Discovery

NewDiscovery 创建服务发现客户端

func NewEntClient 

func NewEntClient(cfg *conf.Bootstrap, logger log.Logger) *ent.Client

NewEntClient .

func NewGormClient 

func NewGormClient(cfg *conf.Bootstrap, logger log.Logger, models []interface{}) *gorm.DB

NewGormClient 创建数据库客户端

func NewMeilisearchClient 

func NewMeilisearchClient(cfg *conf.Bootstrap, logger log.Logger) *meilisearch.Client

NewMeilisearchClient 创建Meilisearch客户端

func NewRedisClient 

func NewRedisClient(cfg *conf.Bootstrap, logger log.Logger) *redis.Client

NewRedisClient 创建Redis客户端

func NewSecurityUser 

func NewSecurityUser(logger log.Logger, data *Data) authn.SecurityUserCreator

func NewSnowflake 

func NewSnowflake(logger log.Logger) *snowflake.Node

NewSnowflake 生成雪花算法id

Types

type AuthRepo 

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

func NewAuthRepo 

func NewAuthRepo(data *Data, authorized authz.Authorized, logger log.Logger) *AuthRepo

NewAuthRepo .

func (*AuthRepo) IsAuthorized 

func (r *AuthRepo) IsAuthorized(ctx context.Context, pb *v1.IsAuthorizedRequest) (*v1.IsAuthorizedResponse, error)

func (*AuthRepo) Register 

func (r *AuthRepo) Register(ctx context.Context, pb *v1.RegisterRequest) (*v1.RegisterResponse, error)

type Data 

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

Data .

func NewData 

func NewData(logger log.Logger, cfg *conf.Bootstrap, db *ent.Client, rdb *redis.Client, sdb *meilisearch.Client, sf *snowflake.Node) (*Data, func(), error)

NewData .

func (*Data) DB 

func (d *Data) DB(ctx context.Context) *ent.Client

func (*Data) InTx 

func (d *Data) InTx(ctx context.Context, fn func(ctx context.Context) error) error

InTx 执行事务

type DeptRepo 

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

func NewDeptRepo 

func NewDeptRepo(data *Data, logger log.Logger) *DeptRepo

NewDeptRepo .

func (*DeptRepo) Count 

func (r *DeptRepo) Count(ctx context.Context, whereCond []func(s *sql.Selector)) (int, error)

func (*DeptRepo) CreateDept 

func (r *DeptRepo) CreateDept(ctx context.Context, req *v1.CreateDeptRequest) (*v1.CreateDeptResponse, error)

func (*DeptRepo) DeleteDept 

func (r *DeptRepo) DeleteDept(ctx context.Context, req *v1.DeleteDeptRequest) (*v1.DeleteDeptResponse, error)

func (*DeptRepo) GetDept 

func (r *DeptRepo) GetDept(ctx context.Context, req *v1.GetDeptRequest) (*v1.Dept, error)

func (*DeptRepo) ListDept 

func (r *DeptRepo) ListDept(ctx context.Context, req *pagination.PagingRequest) (*v1.ListDeptResponse, error)

func (*DeptRepo) UpdateDept 

func (r *DeptRepo) UpdateDept(ctx context.Context, req *v1.UpdateDeptRequest) (*v1.UpdateDeptResponse, error)
type MenuRepo struct {
	// contains filtered or unexported fields
}

func NewMenuRepo 

func NewMenuRepo(data *Data, logger log.Logger) *MenuRepo

NewMenuRepo . 

func (r *MenuRepo) Count(ctx context.Context, whereCond []func(s *sql.Selector)) (int, error)
func (r *MenuRepo) CreateMenu(ctx context.Context, req *v1.CreateMenuRequest) (*v1.CreateMenuResponse, error)
func (r *MenuRepo) DeleteMenu(ctx context.Context, req *v1.DeleteMenuRequest) (*v1.DeleteMenuResponse, error)
func (r *MenuRepo) GetMenu(ctx context.Context, req *v1.GetMenuRequest) (*v1.Menu, error)
func (r *MenuRepo) ListMenu(ctx context.Context, req *pagination.PagingRequest) (*v1.ListMenuResponse, error)
func (r *MenuRepo) UpdateMenu(ctx context.Context, req *v1.UpdateMenuRequest) (*v1.UpdateMenuResponse, error)

type PostRepo 

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

func NewPostRepo 

func NewPostRepo(data *Data, logger log.Logger) *PostRepo

NewPostRepo .

func (*PostRepo) Count 

func (r *PostRepo) Count(ctx context.Context, whereCond []func(s *sql.Selector)) (int, error)

func (*PostRepo) CreatePost 

func (r *PostRepo) CreatePost(ctx context.Context, req *v1.CreatePostRequest) (*v1.CreatePostResponse, error)

func (*PostRepo) DeletePost 

func (r *PostRepo) DeletePost(ctx context.Context, req *v1.DeletePostRequest) (*v1.DeletePostResponse, error)

func (*PostRepo) GetPost 

func (r *PostRepo) GetPost(ctx context.Context, req *v1.GetPostRequest) (*v1.Post, error)

func (*PostRepo) ListPost 

func (r *PostRepo) ListPost(ctx context.Context, req *pagination.PagingRequest) (*v1.ListPostResponse, error)

func (*PostRepo) UpdatePost 

func (r *PostRepo) UpdatePost(ctx context.Context, req *v1.UpdatePostRequest) (*v1.UpdatePostResponse, error)

type RoleRepo 

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

func NewRoleRepo 

func NewRoleRepo(data *Data, logger log.Logger) *RoleRepo

NewRoleRepo .

func (*RoleRepo) Count 

func (r *RoleRepo) Count(ctx context.Context, whereCond []func(s *sql.Selector)) (int, error)

func (*RoleRepo) CreateRole 

func (r *RoleRepo) CreateRole(ctx context.Context, req *v1.CreateRoleRequest) (*v1.CreateRoleResponse, error)

func (*RoleRepo) DeleteRole 

func (r *RoleRepo) DeleteRole(ctx context.Context, req *v1.DeleteRoleRequest) (*v1.DeleteRoleResponse, error)

func (*RoleRepo) GetRole 

func (r *RoleRepo) GetRole(ctx context.Context, req *v1.GetRoleRequest) (*v1.Role, error)

func (*RoleRepo) ListRole 

func (r *RoleRepo) ListRole(ctx context.Context, req *pagination.PagingRequest) (*v1.ListRoleResponse, error)

func (*RoleRepo) UpdateRole 

func (r *RoleRepo) UpdateRole(ctx context.Context, req *v1.UpdateRoleRequest) (*v1.UpdateRoleResponse, error)

type SecurityOptions 

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

type UserRepo 

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

func NewUserRepo 

func NewUserRepo(data *Data, logger log.Logger) *UserRepo

NewUserRepo .

func (*UserRepo) Count 

func (r *UserRepo) Count(ctx context.Context, whereCond []func(s *sql.Selector)) (int, error)

func (*UserRepo) CreateUser 

func (r *UserRepo) CreateUser(ctx context.Context, req *v1.CreateUserRequest) (*v1.CreateUserResponse, error)

func (*UserRepo) DeleteUser 

func (r *UserRepo) DeleteUser(ctx context.Context, req *v1.DeleteUserRequest) (*v1.DeleteUserResponse, error)

func (*UserRepo) GetUser 

func (r *UserRepo) GetUser(ctx context.Context, req *v1.GetUserRequest) (*v1.User, error)

func (*UserRepo) GetUserByName 

func (r *UserRepo) GetUserByName(ctx context.Context, req *v1.GetUserByNameRequest) (*v1.User, error)

func (*UserRepo) ListUser 

func (r *UserRepo) ListUser(ctx context.Context, req *pagination.PagingRequest) (*v1.ListUserResponse, error)

func (*UserRepo) UpdateUser 

func (r *UserRepo) UpdateUser(ctx context.Context, req *v1.UpdateUserRequest) (*v1.UpdateUserResponse, error)

func (*UserRepo) UserExists 

func (r *UserRepo) UserExists(ctx context.Context, req *v1.UserExistsRequest) (*v1.UserExistsResponse, error)

func (*UserRepo) VerifyPassword 

func (r *UserRepo) VerifyPassword(ctx context.Context, req *v1.VerifyPasswordRequest) (*v1.VerifyPasswordResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
ent
dept
enttest
hook
member
menu
migrate
post
predicate
privacy
role
runtime
schema
tenant
user

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.