core

package
v0.0.49 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ProviderSet = wire.NewSet(
	NewAPIStoreAdapter,
	wire.Bind(new(data.APIStore), new(*APIStoreAdapter)),
	NewJobStoreAdapter,
	wire.Bind(new(data.JobStore), new(*JobStoreAdapter)),
	NewLogStoreAdapter,
	wire.Bind(new(data.LogStore), new(*LogStoreAdapter)),
	NewPermissionStoreAdapter,
	wire.Bind(new(data.PermissionStore), new(*PermissionStoreAdapter)),
	NewTransaction,
)

ProviderSet 提供 Core 所需的 Admin 数据适配器。

Functions

func NewTransaction 

func NewTransaction(databases map[string]*gorm.Client) (coredata.Transaction, error)

NewTransaction 从数据库客户端创建事务接口，各适配器通过同一数据包的上下文键复用事务查询。

Types

type APIStoreAdapter 

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

APIStoreAdapter 将 Admin 的 API 生成仓储适配为 Core 资源接口。

func NewAPIStoreAdapter 

func NewAPIStoreAdapter(databases map[string]*gorm.Client) (*APIStoreAdapter, error)

NewAPIStoreAdapter 使用数据库客户端创建一次内部仓储，供 Core 复用 API 资源存储。

func (*APIStoreAdapter) ListForPolicy 

func (s *APIStoreAdapter) ListForPolicy(ctx context.Context) ([]*coredata.APIPolicyRecord, error)

ListForPolicy 查询权限重建所需的 API 字段。

func (*APIStoreAdapter) ReplaceAll 

func (s *APIStoreAdapter) ReplaceAll(ctx context.Context, items []*coredata.APIRecord) error

ReplaceAll 替换 API 快照并保留已有工具运行时配置。

func (*APIStoreAdapter) ReplaceAllTranslations 

func (s *APIStoreAdapter) ReplaceAllTranslations(ctx context.Context, items []*coredata.APITranslationRecord) error

ReplaceAllTranslations 替换 API 多语言快照。

type JobStoreAdapter 

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

JobStoreAdapter 将 Admin 的任务生成仓储适配为 Core 任务接口。

func NewJobStoreAdapter 

func NewJobStoreAdapter(databases map[string]*gorm.Client) (*JobStoreAdapter, error)

NewJobStoreAdapter 使用数据库客户端创建一次内部仓储，供 Core 复用任务存储。

func (*JobStoreAdapter) CreateLog 

func (s *JobStoreAdapter) CreateLog(ctx context.Context, item coredata.JobLogRecord) error

CreateLog 写入 Core 产生的任务执行日志。

func (*JobStoreAdapter) FindByID 

func (s *JobStoreAdapter) FindByID(ctx context.Context, id int64) (coredata.JobRecord, error)

FindByID 按编号查询 Core 调度所需的任务字段。

func (*JobStoreAdapter) List 

func (s *JobStoreAdapter) List(ctx context.Context) ([]coredata.JobRecord, error)

List 查询 Core 调度所需的任务字段。

func (*JobStoreAdapter) UpdateEntryID 

func (s *JobStoreAdapter) UpdateEntryID(ctx context.Context, id int64, entryID int32) error

UpdateEntryID 更新任务的 Cron 入口编号。

type LogStoreAdapter 

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

LogStoreAdapter 将 Admin 的日志生成仓储适配为 Core 审计日志接口。

func NewLogStoreAdapter 

func NewLogStoreAdapter(databases map[string]*kitgorm.Client) (*LogStoreAdapter, error)

NewLogStoreAdapter 使用数据库客户端创建一次内部仓储，供 Core 复用审计日志存储。

func (*LogStoreAdapter) CreateAPI 

func (s *LogStoreAdapter) CreateAPI(ctx context.Context, item coredata.APILogRecord) error

CreateAPI 写入 API 访问日志。

func (*LogStoreAdapter) CreatePolicyEvaluation 

func (s *LogStoreAdapter) CreatePolicyEvaluation(ctx context.Context, item coredata.PolicyEvaluationLogRecord) error

CreatePolicyEvaluation 写入策略评估日志。

func (*LogStoreAdapter) ExistsAPI 

func (s *LogStoreAdapter) ExistsAPI(ctx context.Context, id int64) (bool, error)

ExistsAPI 判断 API 访问日志是否已写入。

func (*LogStoreAdapter) ExistsPolicyEvaluation 

func (s *LogStoreAdapter) ExistsPolicyEvaluation(ctx context.Context, id int64) (bool, error)

ExistsPolicyEvaluation 判断策略评估日志是否已写入。

type PermissionStoreAdapter 

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

PermissionStoreAdapter 将 Admin 的权限生成仓储适配为 Core 权限资源接口。

func NewPermissionStoreAdapter 

func NewPermissionStoreAdapter(databases map[string]*gorm.Client) (*PermissionStoreAdapter, error)

NewPermissionStoreAdapter 使用数据库客户端创建一次内部仓储，供 Core 复用权限资源存储。

func (*PermissionStoreAdapter) FindRoleByTenantIDAndCode 

func (s *PermissionStoreAdapter) FindRoleByTenantIDAndCode(ctx context.Context, tenantID int64, code string) (coredata.RoleRecord, error)

FindRoleByTenantIDAndCode 按租户和角色编码查询角色权限字段。

func (*PermissionStoreAdapter) FindTenantByCode 

func (s *PermissionStoreAdapter) FindTenantByCode(ctx context.Context, code string) (coredata.TenantRecord, error)

FindTenantByCode 按编码查询租户权限字段。

func (*PermissionStoreAdapter) ListMenusByIDs 

func (s *PermissionStoreAdapter) ListMenusByIDs(ctx context.Context, ids []int64) ([]coredata.MenuRecord, error)

ListMenusByIDs 查询权限重建所需的菜单字段。

func (*PermissionStoreAdapter) ListPolicies 

func (s *PermissionStoreAdapter) ListPolicies(ctx context.Context) ([]coredata.PolicyRecord, error)

ListPolicies 查询全部 Casbin 规则字段。

func (*PermissionStoreAdapter) ListRoles 

func (s *PermissionStoreAdapter) ListRoles(ctx context.Context) ([]coredata.RoleRecord, error)

ListRoles 查询权限重建所需的全部角色字段。

func (*PermissionStoreAdapter) ListRolesByCode 

func (s *PermissionStoreAdapter) ListRolesByCode(ctx context.Context, code string) ([]coredata.RoleRecord, error)

ListRolesByCode 查询指定编码的全部角色字段。

func (*PermissionStoreAdapter) ListTenants 

func (s *PermissionStoreAdapter) ListTenants(ctx context.Context) ([]coredata.TenantRecord, error)

ListTenants 查询权限重建所需的全部租户字段。

func (*PermissionStoreAdapter) ReplacePolicies 

func (s *PermissionStoreAdapter) ReplacePolicies(ctx context.Context, items []coredata.PolicyRecord) error

ReplacePolicies 替换全部 Casbin 规则。

func (*PermissionStoreAdapter) UpdateRoleMenus 

func (s *PermissionStoreAdapter) UpdateRoleMenus(ctx context.Context, item coredata.RoleRecord) error

UpdateRoleMenus 更新角色的菜单列表。

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.