biz

package
v1.1.37 Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2024 License: MIT Imports: 34 Imported by: 0

README

Biz

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ProviderSetBiz = wire.NewSet(
	NewUserBiz,
	NewCaptchaBiz,
	NewAuthorizationBiz,
	NewResourceBiz,
	NewTeamBiz,
	NewTeamRoleBiz,
	NewMenuBiz,
	NewDatasourceBiz,
	NewStrategyBiz,
	NewStrategyGroupBiz,
	NewStrategyCountBiz,
	NewMetricBiz,
	NewDictBiz,
	NewTemplateBiz,
	NewAlarmBiz,
	NewDashboardBiz,
	NewAlarmGroupBiz,
	NewAlarmPageBiz,
	NewSubscriptionStrategyBiz,
	NewAlarmHookBiz,
	NewAlarmHistoryBiz,
	NewInviteBiz,
	NewUserMessageBiz,
	NewServerRegisterBiz,
	NewFileBiz,
	NewSystemBiz,
	NewAlarmSendBiz,
	NewMqDataSourceBiz,
)

ProviderSetBiz is biz providers.

View Source 
var RuntimeCache repository.Cache

RuntimeCache 运行时缓存

Functions

This section is empty.

Types

type AlarmBiz 

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

AlarmBiz 告警相关业务逻辑

func NewAlarmBiz 

func NewAlarmBiz(
	alarmRepository repository.Alarm,
	alarmRawRepository repository.AlarmRaw,
	strategyRepository repository.Strategy,
	datasourceRepository repository.Datasource,
	historyRepository repository.HistoryRepository,
	sendAlert microrepository.SendAlert,
) *AlarmBiz

NewAlarmBiz 创建告警相关业务逻辑

func (*AlarmBiz) CreateAlarmInfo added in v1.1.0 

func (b *AlarmBiz) CreateAlarmInfo(ctx context.Context, params *bo.CreateAlarmHookRawParams) error

CreateAlarmInfo 创建告警信息

func (*AlarmBiz) CreateAlarmRawInfo added in v1.1.0 

func (b *AlarmBiz) CreateAlarmRawInfo(ctx context.Context, param *bo.CreateAlarmHookRawParams) ([]*alarmmodel.AlarmRaw, error)

CreateAlarmRawInfo 创建告警原始信息

func (*AlarmBiz) GetRealTimeAlarm 

func (b *AlarmBiz) GetRealTimeAlarm(ctx context.Context, params *bo.GetRealTimeAlarmParams) (*alarmmodel.RealtimeAlarm, error)

GetRealTimeAlarm 获取实时告警明细

func (*AlarmBiz) ListRealTimeAlarms 

func (b *AlarmBiz) ListRealTimeAlarms(ctx context.Context, params *bo.GetRealTimeAlarmsParams) ([]*alarmmodel.RealtimeAlarm, error)

ListRealTimeAlarms 获取实时告警列表

func (*AlarmBiz) SaveAlarmInfoDB added in v1.1.0 

func (b *AlarmBiz) SaveAlarmInfoDB(ctx context.Context, params *bo.CreateAlarmInfoParams) error

SaveAlarmInfoDB 保存告警信息db(告警历史、实时告警)

func (*AlarmBiz) SaveAlertQueue added in v1.1.0 

func (b *AlarmBiz) SaveAlertQueue(param *bo.CreateAlarmHookRawParams) error

SaveAlertQueue 保存告警队列

func (*AlarmBiz) SendAlertMsg added in v1.1.0 

func (b *AlarmBiz) SendAlertMsg(ctx context.Context, params *bo.SendMsg)

SendAlertMsg 发送告警消息

type AlarmGroupBiz 

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

AlarmGroupBiz 告警分组业务

func NewAlarmGroupBiz 

func NewAlarmGroupBiz(strategy repository.AlarmGroup) *AlarmGroupBiz

NewAlarmGroupBiz 创建告警分组业务

func (*AlarmGroupBiz) CreateAlarmGroup 

func (s *AlarmGroupBiz) CreateAlarmGroup(ctx context.Context, params *bo.CreateAlarmNoticeGroupParams) (*bizmodel.AlarmNoticeGroup, error)

CreateAlarmGroup 创建告警分组

func (*AlarmGroupBiz) DeleteAlarmGroup 

func (s *AlarmGroupBiz) DeleteAlarmGroup(ctx context.Context, alarmID uint32) error

DeleteAlarmGroup 删除告警分组

func (*AlarmGroupBiz) GetAlarmGroupDetail 

func (s *AlarmGroupBiz) GetAlarmGroupDetail(ctx context.Context, groupID uint32) (*bizmodel.AlarmNoticeGroup, error)

GetAlarmGroupDetail 获取告警分组详情

func (*AlarmGroupBiz) ListPage 

func (s *AlarmGroupBiz) ListPage(ctx context.Context, params *bo.QueryAlarmNoticeGroupListParams) ([]*bizmodel.AlarmNoticeGroup, error)

ListPage 分页查询告警分组

func (*AlarmGroupBiz) MyAlarmGroups 

func (s *AlarmGroupBiz) MyAlarmGroups(ctx context.Context, params *bo.MyAlarmGroupListParams) ([]*bizmodel.AlarmNoticeGroup, error)

MyAlarmGroups 查询我的告警分组

func (*AlarmGroupBiz) UpdateAlarmGroup 

func (s *AlarmGroupBiz) UpdateAlarmGroup(ctx context.Context, params *bo.UpdateAlarmNoticeGroupParams) error

UpdateAlarmGroup 更新告警分组

func (*AlarmGroupBiz) UpdateStatus 

func (s *AlarmGroupBiz) UpdateStatus(ctx context.Context, params *bo.UpdateAlarmNoticeGroupStatusParams) error

UpdateStatus 更新告警分组状态

type AlarmHistoryBiz added in v1.1.0 

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

AlarmHistoryBiz 告警历史相关业务逻辑

func NewAlarmHistoryBiz added in v1.1.0 

func NewAlarmHistoryBiz(historyRepository repository.HistoryRepository) *AlarmHistoryBiz

NewAlarmHistoryBiz 创建告警历史业务逻辑

func (*AlarmHistoryBiz) GetAlarmHistory added in v1.1.0 

func (a *AlarmHistoryBiz) GetAlarmHistory(ctx context.Context, param *bo.GetAlarmHistoryParams) (*alarmmodel.AlarmHistory, error)

GetAlarmHistory 获取告警历史

func (*AlarmHistoryBiz) ListAlarmHistories added in v1.1.0 

func (a *AlarmHistoryBiz) ListAlarmHistories(ctx context.Context, param *bo.QueryAlarmHistoryListParams) ([]*alarmmodel.AlarmHistory, error)

ListAlarmHistories 获取告警历史列表

type AlarmHookBiz 

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

AlarmHookBiz is a greeter service.

func NewAlarmHookBiz 

func NewAlarmHookBiz(alarmHook repository.AlarmHook) *AlarmHookBiz

NewAlarmHookBiz new AlarmHookBiz

func (*AlarmHookBiz) CreateAlarmHook 

func (s *AlarmHookBiz) CreateAlarmHook(ctx context.Context, params *bo.CreateAlarmHookParams) (*bizmodel.AlarmHook, error)

CreateAlarmHook create alarm hook

func (*AlarmHookBiz) DeleteAlarmHook 

func (s *AlarmHookBiz) DeleteAlarmHook(ctx context.Context, ID uint32) error

DeleteAlarmHook delete alarm hook

func (*AlarmHookBiz) GetAlarmHook 

func (s *AlarmHookBiz) GetAlarmHook(ctx context.Context, ID uint32) (*bizmodel.AlarmHook, error)

GetAlarmHook get alarm hook

func (*AlarmHookBiz) ListPage 

func (s *AlarmHookBiz) ListPage(ctx context.Context, params *bo.QueryAlarmHookListParams) ([]*bizmodel.AlarmHook, error)

ListPage list alarm hook page

func (*AlarmHookBiz) UpdateAlarmHook 

func (s *AlarmHookBiz) UpdateAlarmHook(ctx context.Context, params *bo.UpdateAlarmHookParams) error

UpdateAlarmHook update alarm hook

func (*AlarmHookBiz) UpdateStatus 

func (s *AlarmHookBiz) UpdateStatus(ctx context.Context, params *bo.UpdateAlarmHookStatusParams) error

UpdateStatus update alarm hook status

type AlarmPageBiz 

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

AlarmPageBiz 告警页面管理功能

func NewAlarmPageBiz 

func NewAlarmPageBiz(alarmPageRepository repository.AlarmPage) *AlarmPageBiz

NewAlarmPageBiz 创建告警页面管理功能

func (*AlarmPageBiz) GetAlertCounts added in v1.1.0 

func (b *AlarmPageBiz) GetAlertCounts(ctx context.Context, pageIDs []uint32) map[int32]int64

GetAlertCounts 获取告警数量

func (*AlarmPageBiz) ListAlarmPage 

func (b *AlarmPageBiz) ListAlarmPage(ctx context.Context, userID uint32) ([]*bizmodel.AlarmPageSelf, error)

ListAlarmPage 告警页面列表

func (*AlarmPageBiz) UpdateAlarmPage 

func (b *AlarmPageBiz) UpdateAlarmPage(ctx context.Context, userID uint32, alarmPageIDs []uint32) error

UpdateAlarmPage 更新告警页面

type AlarmSendBiz added in v1.1.31 

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

AlarmSendBiz 告警发送相关业务

func NewAlarmSendBiz added in v1.1.31 

func NewAlarmSendBiz(alarmSendRepository repository.AlarmSendRepository) *AlarmSendBiz

NewAlarmSendBiz 创建告警发送相关业务

func (*AlarmSendBiz) GetAlarmSendDetail added in v1.1.31 

func (a *AlarmSendBiz) GetAlarmSendDetail(ctx context.Context, param *bo.GetAlarmSendHistoryParams) (*alarmmodel.AlarmSendHistory, error)

GetAlarmSendDetail 获取告警发送详情

func (*AlarmSendBiz) ListAlarmSendHistories added in v1.1.31 

func (a *AlarmSendBiz) ListAlarmSendHistories(ctx context.Context, param *bo.QueryAlarmSendHistoryListParams) ([]*alarmmodel.AlarmSendHistory, error)

ListAlarmSendHistories 获取告警发送历史列表

func (*AlarmSendBiz) RetryAlarmSend added in v1.1.31 

func (a *AlarmSendBiz) RetryAlarmSend(ctx context.Context, param *bo.RetryAlarmSendParams) error

RetryAlarmSend 重试告警发送

type AuthorizationBiz 

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

AuthorizationBiz 授权业务

func NewAuthorizationBiz 

func NewAuthorizationBiz(
	bc *palaceconf.Bootstrap,
	userRepo repository.User,
	teamRepo repository.Team,
	cacheRepo repository.Cache,
	teamRoleRepo repository.TeamRole,
	resourceRepo repository.Resource,
	teamResourceRepo repository.TeamResource,
	oAuthRepo repository.OAuth,
) *AuthorizationBiz

NewAuthorizationBiz 创建授权业务

func (*AuthorizationBiz) CheckPermission 

func (b *AuthorizationBiz) CheckPermission(ctx context.Context, req *bo.CheckPermissionParams) error

CheckPermission 检查用户是否有该资源权限

func (*AuthorizationBiz) CheckToken 

func (b *AuthorizationBiz) CheckToken(ctx context.Context, req *bo.CheckTokenParams) (*model.SysUser, error)

CheckToken 检查token

func (*AuthorizationBiz) EmailLoginVerifyEmail added in v1.1.27 

func (b *AuthorizationBiz) EmailLoginVerifyEmail(ctx context.Context, req *auth.EmailLoginParams) error

EmailLoginVerifyEmail 验证邮箱

func (*AuthorizationBiz) GetOAuthConf 

func (b *AuthorizationBiz) GetOAuthConf(provider vobj.OAuthAPP) *oauth2.Config

GetOAuthConf 获取oauth配置

func (*AuthorizationBiz) Login 

func (b *AuthorizationBiz) Login(ctx context.Context, req *bo.LoginParams) (*bo.LoginReply, error)

Login 登录

func (*AuthorizationBiz) Logout 

func (b *AuthorizationBiz) Logout(ctx context.Context, params *bo.LogoutParams) error

Logout 登出

func (*AuthorizationBiz) OAuthLogin 

func (b *AuthorizationBiz) OAuthLogin(ctx context.Context, provider vobj.OAuthAPP, code string) (string, error)

OAuthLogin oauth登录

func (*AuthorizationBiz) OAuthLoginVerifyEmail 

func (b *AuthorizationBiz) OAuthLoginVerifyEmail(ctx context.Context, e string) error

OAuthLoginVerifyEmail 验证邮箱

func (*AuthorizationBiz) OAuthLoginWithEmail added in v1.1.0 

func (b *AuthorizationBiz) OAuthLoginWithEmail(ctx context.Context, oauthParams *auth.OauthLoginParams) (*bo.RefreshTokenReply, error)

OAuthLoginWithEmail oauth登录并绑定邮箱

func (*AuthorizationBiz) RefreshToken 

func (b *AuthorizationBiz) RefreshToken(ctx context.Context, req *bo.RefreshTokenParams) (*bo.RefreshTokenReply, error)

RefreshToken 刷新token

func (*AuthorizationBiz) RegisterWithEmail added in v1.1.27 

func (b *AuthorizationBiz) RegisterWithEmail(ctx context.Context, req *auth.RegisterWithEmailParams) (*bo.RefreshTokenReply, error)

RegisterWithEmail 邮箱注册

type CaptchaBiz 

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

CaptchaBiz 验证码业务

func NewCaptchaBiz 

func NewCaptchaBiz(captchaRepo repository.Captcha) *CaptchaBiz

NewCaptchaBiz 创建验证码业务

func (*CaptchaBiz) GenerateCaptcha 

func (l *CaptchaBiz) GenerateCaptcha(ctx context.Context, params *bo.GenerateCaptchaParams) (*bo.CaptchaItem, error)

GenerateCaptcha 生成验证码

func (*CaptchaBiz) VerifyCaptcha 

func (l *CaptchaBiz) VerifyCaptcha(ctx context.Context, params *bo.ValidateCaptchaParams) error

VerifyCaptcha 验证验证码

type DashboardBiz 

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

DashboardBiz 仪表盘业务

func NewDashboardBiz 

func NewDashboardBiz(dashboardRepository repository.Dashboard) *DashboardBiz

NewDashboardBiz 创建仪表盘业务

func (*DashboardBiz) BatchUpdateDashboardStatus added in v1.1.0 

func (b *DashboardBiz) BatchUpdateDashboardStatus(ctx context.Context, params *bo.BatchUpdateDashboardStatusParams) error

BatchUpdateDashboardStatus 批量更新仪表盘状态

func (*DashboardBiz) CreateDashboard 

func (b *DashboardBiz) CreateDashboard(ctx context.Context, req *bo.AddDashboardParams) error

CreateDashboard 创建仪表盘

func (*DashboardBiz) DeleteDashboard 

func (b *DashboardBiz) DeleteDashboard(ctx context.Context, req *bo.DeleteDashboardParams) error

DeleteDashboard 删除仪表盘

func (*DashboardBiz) GetDashboard 

func (b *DashboardBiz) GetDashboard(ctx context.Context, id uint32) (*bizmodel.Dashboard, error)

GetDashboard 获取仪表盘

func (*DashboardBiz) ListDashboard 

func (b *DashboardBiz) ListDashboard(ctx context.Context, params *bo.ListDashboardParams) ([]*bizmodel.Dashboard, error)

ListDashboard 获取仪表盘列表

func (*DashboardBiz) UpdateDashboard 

func (b *DashboardBiz) UpdateDashboard(ctx context.Context, req *bo.UpdateDashboardParams) error

UpdateDashboard 更新仪表盘

type DatasourceBiz 

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

DatasourceBiz 数据源业务

func NewDatasourceBiz 

func NewDatasourceBiz(
	datasourceRepository repository.Datasource,
	datasourceMetricRepository repository.DatasourceMetric,
	datasourceMetricMicroRepository microrepository.DatasourceMetric,
	lock repository.Lock,
) *DatasourceBiz

NewDatasourceBiz 创建数据源业务

func (*DatasourceBiz) CreateDatasource 

func (b *DatasourceBiz) CreateDatasource(ctx context.Context, datasource *bo.CreateDatasourceParams) (*bizmodel.Datasource, error)

CreateDatasource 创建数据源

func (*DatasourceBiz) DeleteDatasource 

func (b *DatasourceBiz) DeleteDatasource(ctx context.Context, id uint32) error

DeleteDatasource 删除数据源

func (*DatasourceBiz) GetDatasource 

func (b *DatasourceBiz) GetDatasource(ctx context.Context, id uint32) (*bizmodel.Datasource, error)

GetDatasource 获取数据源详情

func (*DatasourceBiz) GetDatasourceSelect 

func (b *DatasourceBiz) GetDatasourceSelect(ctx context.Context, params *bo.QueryDatasourceListParams) ([]*bo.SelectOptionBo, error)

GetDatasourceSelect 获取数据源下拉列表

func (*DatasourceBiz) ListDatasource 

func (b *DatasourceBiz) ListDatasource(ctx context.Context, params *bo.QueryDatasourceListParams) ([]*bizmodel.Datasource, error)

ListDatasource 获取数据源列表

func (*DatasourceBiz) Query 

func (b *DatasourceBiz) Query(ctx context.Context, params *bo.DatasourceQueryParams) ([]*bo.MetricQueryData, error)

Query 查询数据

func (*DatasourceBiz) SyncDatasourceMetaV2 

func (b *DatasourceBiz) SyncDatasourceMetaV2(ctx context.Context, id uint32) (err error)

SyncDatasourceMetaV2 同步数据源元数据

func (*DatasourceBiz) UpdateDatasourceBaseInfo 

func (b *DatasourceBiz) UpdateDatasourceBaseInfo(ctx context.Context, datasource *bo.UpdateDatasourceBaseInfoParams) error

UpdateDatasourceBaseInfo 更新数据源

func (*DatasourceBiz) UpdateDatasourceConfig 

func (b *DatasourceBiz) UpdateDatasourceConfig(ctx context.Context, datasource *bo.UpdateDatasourceConfigParams) error

UpdateDatasourceConfig 更新数据源配置

func (*DatasourceBiz) UpdateDatasourceStatus 

func (b *DatasourceBiz) UpdateDatasourceStatus(ctx context.Context, status vobj.Status, ids ...uint32) error

UpdateDatasourceStatus 更新数据源状态

type DictBiz 

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

DictBiz 字典业务

func NewDictBiz 

func NewDictBiz(dictRepo repository.Dict, teamDictRepo repository.TeamDict) *DictBiz

NewDictBiz 创建字典业务

func (*DictBiz) CreateDict 

func (b *DictBiz) CreateDict(ctx context.Context, dictParam *bo.CreateDictParams) (imodel.IDict, error)

CreateDict 创建字典

func (*DictBiz) DeleteDictByID 

func (b *DictBiz) DeleteDictByID(ctx context.Context, id uint32) error

DeleteDictByID 删除字典

func (*DictBiz) GetDict 

func (b *DictBiz) GetDict(ctx context.Context, id uint32) (imodel.IDict, error)

GetDict 获取字典

func (*DictBiz) ListDict 

func (b *DictBiz) ListDict(ctx context.Context, listParam *bo.QueryDictListParams) ([]imodel.IDict, error)

ListDict 列表字典

func (*DictBiz) UpdateDict 

func (b *DictBiz) UpdateDict(ctx context.Context, updateParam *bo.UpdateDictParams) error

UpdateDict 更新字典

func (*DictBiz) UpdateDictStatusByIds 

func (b *DictBiz) UpdateDictStatusByIds(ctx context.Context, updateParams *bo.UpdateDictStatusParams) error

UpdateDictStatusByIds 更新字典状态

type FileBiz added in v1.1.0 

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

FileBiz file 业务

func NewFileBiz added in v1.1.0 

func NewFileBiz(fileRepo repository.FileRepository) *FileBiz

NewFileBiz new file biz

func (*FileBiz) DownLoadFile added in v1.1.0 

func (y *FileBiz) DownLoadFile(ctx context.Context, param *bo.DownLoadFileParams) (io.ReadCloser, error)

DownLoadFile 下载本地文件

func (*FileBiz) UploadFile added in v1.1.0 

func (y *FileBiz) UploadFile(ctx context.Context, param *bo.ConvertFileParams) (string, error)

UploadFile 解析上传文件

type InviteBiz added in v1.0.2 

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

InviteBiz 邀请业务对象

func NewInviteBiz added in v1.0.2 

func NewInviteBiz(
	inviteRepo repository.TeamInvite,
	userRepo repository.User,
	teamRepo repository.Team,
	teamRoleRepo repository.TeamRole,
	userMessageRepo repository.UserMessage,
) *InviteBiz

NewInviteBiz 创建邀请业务对象

func (*InviteBiz) DeleteInvite added in v1.0.2 

func (i *InviteBiz) DeleteInvite(ctx context.Context, inviteID uint32) error

DeleteInvite 删除邀请记录

func (*InviteBiz) GetTeamMapByIds added in v1.0.2 

func (i *InviteBiz) GetTeamMapByIds(ctx context.Context, teamIds []uint32) map[uint32]*model.SysTeam

GetTeamMapByIds 根据ID获取团队信息

func (*InviteBiz) GetTeamRoles added in v1.0.2 

func (i *InviteBiz) GetTeamRoles(ctx context.Context, teamID uint32, roleIds []uint32) []*bizmodel.SysTeamRole

GetTeamRoles 获取团队角色

func (*InviteBiz) InviteUser added in v1.0.2 

func (i *InviteBiz) InviteUser(ctx context.Context, params *bo.InviteUserParams) error

InviteUser 邀请用户

func (*InviteBiz) TeamInviteDetail added in v1.0.2 

func (i *InviteBiz) TeamInviteDetail(ctx context.Context, inviteID uint32) (*model.SysTeamInvite, error)

TeamInviteDetail 团队邀请记录详情

func (*InviteBiz) UpdateInviteStatus added in v1.0.2 

func (i *InviteBiz) UpdateInviteStatus(ctx context.Context, params *bo.UpdateInviteStatusParams) error

UpdateInviteStatus 更新邀请状态

func (*InviteBiz) UserInviteList added in v1.0.2 

func (i *InviteBiz) UserInviteList(ctx context.Context, params *bo.QueryInviteListParams) ([]*model.SysTeamInvite, error)

UserInviteList 当前用户邀请列表 

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

MenuBiz 菜单业务

func NewMenuBiz 

func NewMenuBiz(teamMenuRepo repository.TeamMenu, msgRepo repository.Msg, menuRepo repository.Menu) *MenuBiz

NewMenuBiz 菜单业务 

func (b *MenuBiz) BatchCreateMenu(ctx context.Context, params []*bo.CreateMenuParams) error

BatchCreateMenu 批量创建菜单 

func (b *MenuBiz) DeleteMenu(ctx context.Context, menuID uint32) error

DeleteMenu 删除菜单 

func (b *MenuBiz) GetMenu(ctx context.Context, menuID uint32) (*model.SysMenu, error)

GetMenu 获取菜单详情 

func (b *MenuBiz) ListMenuPage(ctx context.Context, params *bo.QueryMenuListParams) ([]*model.SysMenu, error)

ListMenuPage 分页菜单列表 

func (b *MenuBiz) MenuAllList(ctx context.Context) ([]*model.SysMenu, error)

MenuAllList 获取所有菜单 

func (b *MenuBiz) MenuList(ctx context.Context) ([]*bizmodel.SysTeamMenu, error)

MenuList 菜单列表 

func (b *MenuBiz) UpdateMenu(ctx context.Context, params *bo.UpdateMenuParams) error

UpdateMenu 更新菜单 

func (b *MenuBiz) UpdateMenuStatus(ctx context.Context, params *bo.UpdateMenuStatusParams) error

UpdateMenuStatus 更新菜单状态 

func (b *MenuBiz) UpdateMenuTypes(ctx context.Context, params *bo.UpdateMenuTypeParams) error

UpdateMenuTypes 更新菜单类型

type MetricBiz 

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

MetricBiz 指标业务

func NewMetricBiz 

func NewMetricBiz(metricRepository repository.Metric, lock repository.Lock) *MetricBiz

NewMetricBiz 创建指标业务

func (*MetricBiz) CreateMetric 

func (b *MetricBiz) CreateMetric(ctx context.Context, params *bo.CreateMetricParams) error

CreateMetric 创建指标信息

func (*MetricBiz) DeleteMetricByID 

func (b *MetricBiz) DeleteMetricByID(ctx context.Context, id uint32) error

DeleteMetricByID 通过ID删除指标信息

func (*MetricBiz) GetMetricByID 

func (b *MetricBiz) GetMetricByID(ctx context.Context, params *bo.GetMetricParams) (detail *bizmodel.DatasourceMetric, err error)

GetMetricByID 通过ID获取指标信息

func (*MetricBiz) GetMetricLabelCount 

func (b *MetricBiz) GetMetricLabelCount(ctx context.Context, metricID uint32) (uint32, error)

GetMetricLabelCount 获取指标标签数量

func (*MetricBiz) ListMetric 

func (b *MetricBiz) ListMetric(ctx context.Context, params *bo.QueryMetricListParams) ([]*bizmodel.DatasourceMetric, error)

ListMetric 获取指标列表

func (*MetricBiz) SelectMetric 

func (b *MetricBiz) SelectMetric(ctx context.Context, params *bo.QueryMetricListParams) ([]*bo.SelectOptionBo, error)

SelectMetric 获取指标列表

func (*MetricBiz) UpdateMetricByID 

func (b *MetricBiz) UpdateMetricByID(ctx context.Context, params *bo.UpdateMetricParams) error

UpdateMetricByID 通过ID修改指标信息

type MqDataSourceBiz added in v1.1.37 

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

MqDataSourceBiz mq datasource biz

func NewMqDataSourceBiz added in v1.1.37 

func NewMqDataSourceBiz(datasourceRepo repository.MQDataSource) *MqDataSourceBiz

NewMqDataSourceBiz 创建 mq 数据源业务

func (*MqDataSourceBiz) CreateMqDataSource added in v1.1.37 

func (m *MqDataSourceBiz) CreateMqDataSource(ctx context.Context, params *bo.CreateMqDatasourceParams) error

CreateMqDataSource 创建 mq 数据源

func (*MqDataSourceBiz) DeleteMqDatasource added in v1.1.37 

func (m *MqDataSourceBiz) DeleteMqDatasource(ctx context.Context, id uint32) error

DeleteMqDatasource 删除 mq 数据源

func (*MqDataSourceBiz) GetMqDataSource added in v1.1.37 

func (m *MqDataSourceBiz) GetMqDataSource(ctx context.Context, ID uint32) (*bizmodel.MqDatasource, error)

GetMqDataSource 获取 mq 数据源详情

func (*MqDataSourceBiz) GetMqDatasourceSelect added in v1.1.37 

func (m *MqDataSourceBiz) GetMqDatasourceSelect(ctx context.Context, param *bo.QueryMqDatasourceListParams) ([]*bizmodel.MqDatasource, error)

GetMqDatasourceSelect 获取 mq 数据源选择列表

func (*MqDataSourceBiz) MqDataSourceList added in v1.1.37 

func (m *MqDataSourceBiz) MqDataSourceList(ctx context.Context, params *bo.QueryMqDatasourceListParams) ([]*bizmodel.MqDatasource, error)

MqDataSourceList 获取 mq 数据源列表

func (*MqDataSourceBiz) UpdateMqDataSource added in v1.1.37 

func (m *MqDataSourceBiz) UpdateMqDataSource(ctx context.Context, param *bo.UpdateMqDatasourceParams) error

UpdateMqDataSource 更新 mq 数据源

func (*MqDataSourceBiz) UpdateMqDataSourceStatus added in v1.1.37 

func (m *MqDataSourceBiz) UpdateMqDataSourceStatus(ctx context.Context, params *bo.UpdateMqDatasourceStatusParams) error

UpdateMqDataSourceStatus 更新 mq 数据源状态

type ResourceBiz 

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

ResourceBiz 资源业务

func NewResourceBiz 

func NewResourceBiz(resourceRepo repository.Resource, teamResourceRepo repository.TeamResource) *ResourceBiz

NewResourceBiz 创建资源业务

func (*ResourceBiz) GetResource 

func (b *ResourceBiz) GetResource(ctx context.Context, id uint32) (imodel.IResource, error)

GetResource 获取资源详情

func (*ResourceBiz) GetResourceSelectList 

func (b *ResourceBiz) GetResourceSelectList(ctx context.Context, params *bo.QueryResourceListParams) ([]*bo.SelectOptionBo, error)

GetResourceSelectList 获取资源下拉列表

func (*ResourceBiz) ListResource 

func (b *ResourceBiz) ListResource(ctx context.Context, params *bo.QueryResourceListParams) ([]imodel.IResource, error)

ListResource 获取资源列表

func (*ResourceBiz) UpdateResourceStatus 

func (b *ResourceBiz) UpdateResourceStatus(ctx context.Context, status vobj.Status, ids ...uint32) error

UpdateResourceStatus 更新资源状态

type ServerRegisterBiz added in v1.1.0 

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

ServerRegisterBiz 服务器注册业务对象

func NewServerRegisterBiz added in v1.1.0 

func NewServerRegisterBiz(serverRegisterRepository microrepository.ServerRegister) *ServerRegisterBiz

NewServerRegisterBiz 创建服务器注册业务对象

func (*ServerRegisterBiz) GetServerList added in v1.1.29 

func (s *ServerRegisterBiz) GetServerList(ctx context.Context, request *api.GetServerListRequest) (*api.GetServerListReply, error)

GetServerList 获取服务器列表

func (*ServerRegisterBiz) Heartbeat added in v1.1.0 

func (s *ServerRegisterBiz) Heartbeat(ctx context.Context, request *api.HeartbeatRequest) error

Heartbeat 心跳

type StrategyBiz 

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

StrategyBiz 策略业务

func NewStrategyBiz 

func NewStrategyBiz(dictRepo repository.Strategy, strategyRPCRepo microrepository.Strategy) *StrategyBiz

NewStrategyBiz 创建策略业务

func (*StrategyBiz) CopyStrategy 

func (b *StrategyBiz) CopyStrategy(ctx context.Context, strategyID uint32) (*bizmodel.Strategy, error)

CopyStrategy 复制策略

func (*StrategyBiz) CreateStrategy 

func (b *StrategyBiz) CreateStrategy(ctx context.Context, param *bo.CreateStrategyParams) (*bizmodel.Strategy, error)

CreateStrategy 创建策略

func (*StrategyBiz) DeleteByID 

func (b *StrategyBiz) DeleteByID(ctx context.Context, strategyID uint32) error

DeleteByID 删除策略

func (*StrategyBiz) Eval 

func (b *StrategyBiz) Eval(ctx context.Context, strategy *bo.Strategy) (*bo.Alarm, error)

Eval 策略评估

func (*StrategyBiz) GetStrategy 

func (b *StrategyBiz) GetStrategy(ctx context.Context, strategyID uint32) (*bizmodel.Strategy, error)

GetStrategy 获取策略

func (*StrategyBiz) PushStrategy 

func (b *StrategyBiz) PushStrategy(ctx context.Context, strategies *strategyapi.PushStrategyRequest) error

PushStrategy 推送策略

func (*StrategyBiz) StrategyPage 

func (b *StrategyBiz) StrategyPage(ctx context.Context, param *bo.QueryStrategyListParams) ([]*bizmodel.Strategy, error)

StrategyPage 获取策略分页

func (*StrategyBiz) SyncStrategy added in v1.1.0 

func (b *StrategyBiz) SyncStrategy(ctx context.Context, id uint32) error

SyncStrategy 同步策略

func (*StrategyBiz) UpdateByID 

func (b *StrategyBiz) UpdateByID(ctx context.Context, param *bo.UpdateStrategyParams) error

UpdateByID 更新策略

func (*StrategyBiz) UpdateStatus 

func (b *StrategyBiz) UpdateStatus(ctx context.Context, param *bo.UpdateStrategyStatusParams) error

UpdateStatus 更新策略状态

type StrategyCountBiz 

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

StrategyCountBiz 策略计数业务

func NewStrategyCountBiz 

func NewStrategyCountBiz(strategyCount repository.StrategyCountRepo) *StrategyCountBiz

NewStrategyCountBiz 创建策略计数业务

func (*StrategyCountBiz) StrategyCount 

func (b *StrategyCountBiz) StrategyCount(ctx context.Context, params *bo.GetStrategyCountParams) []*bo.StrategyCountModel

StrategyCount 策略分组关联策略总数

type StrategyGroupBiz 

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

StrategyGroupBiz 策略分组业务

func NewStrategyGroupBiz 

func NewStrategyGroupBiz(strategy repository.StrategyGroup) *StrategyGroupBiz

NewStrategyGroupBiz 创建策略分组业务

func (*StrategyGroupBiz) CreateStrategyGroup 

func (s *StrategyGroupBiz) CreateStrategyGroup(ctx context.Context, params *bo.CreateStrategyGroupParams) (*bizmodel.StrategyGroup, error)

CreateStrategyGroup 创建策略分组

func (*StrategyGroupBiz) DeleteStrategyGroup 

func (s *StrategyGroupBiz) DeleteStrategyGroup(ctx context.Context, params *bo.DelStrategyGroupParams) error

DeleteStrategyGroup 删除策略分组

func (*StrategyGroupBiz) GetStrategyGroupDetail 

func (s *StrategyGroupBiz) GetStrategyGroupDetail(ctx context.Context, groupID uint32) (*bizmodel.StrategyGroup, error)

GetStrategyGroupDetail 获取策略分组详情

func (*StrategyGroupBiz) ListPage 

func (s *StrategyGroupBiz) ListPage(ctx context.Context, params *bo.QueryStrategyGroupListParams) ([]*bizmodel.StrategyGroup, error)

ListPage 分页查询策略分组

func (*StrategyGroupBiz) UpdateStatus 

func (s *StrategyGroupBiz) UpdateStatus(ctx context.Context, params *bo.UpdateStrategyGroupStatusParams) error

UpdateStatus 更新策略分组状态

func (*StrategyGroupBiz) UpdateStrategyGroup 

func (s *StrategyGroupBiz) UpdateStrategyGroup(ctx context.Context, params *bo.UpdateStrategyGroupParams) error

UpdateStrategyGroup 更新策略分组

type SubscriberBiz 

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

SubscriberBiz 订阅相关业务

func NewSubscriptionStrategyBiz 

func NewSubscriptionStrategyBiz(strategyRepo repository.SubscriberStrategy) *SubscriberBiz

NewSubscriptionStrategyBiz 创建订阅相关业务

func (*SubscriberBiz) StrategySubscribersList 

func (s *SubscriberBiz) StrategySubscribersList(ctx context.Context, params *bo.QueryStrategySubscriberParams) ([]*bizmodel.StrategySubscriber, error)

StrategySubscribersList 策略订阅用户列表

func (*SubscriberBiz) UnSubscriptionStrategy 

func (s *SubscriberBiz) UnSubscriptionStrategy(ctx context.Context, params *bo.UnSubscriberStrategyParams) error

UnSubscriptionStrategy 取消订阅策略

func (*SubscriberBiz) UserSubscriptionStrategy 

func (s *SubscriberBiz) UserSubscriptionStrategy(ctx context.Context, params *bo.SubscriberStrategyParams) error

UserSubscriptionStrategy 当前用户订阅策略

func (*SubscriberBiz) UserSubscriptionStrategyList 

func (s *SubscriberBiz) UserSubscriptionStrategyList(ctx context.Context, params *bo.QueryUserSubscriberParams) ([]*bizmodel.StrategySubscriber, error)

UserSubscriptionStrategyList 当前用户订阅策略列表

type SystemBiz added in v1.1.0 

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

SystemBiz 系统业务对象

func NewSystemBiz added in v1.1.0 

func NewSystemBiz(systemRepository repository.System, teamRepository repository.Team) *SystemBiz

NewSystemBiz 创建系统业务对象

func (*SystemBiz) ResetTeam added in v1.1.0 

func (s *SystemBiz) ResetTeam(ctx context.Context, teamID uint32) (err error)

ResetTeam 重置团队数据信息

type TeamBiz 

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

TeamBiz 团队业务

func NewTeamBiz 

func NewTeamBiz(teamRepo repository.Team, cacheRepo repository.Cache) *TeamBiz

NewTeamBiz 创建团队业务

func (*TeamBiz) AddTeamMember 

func (t *TeamBiz) AddTeamMember(ctx context.Context, params *bo.AddTeamMemberParams) error

AddTeamMember 添加团队成员

func (*TeamBiz) CreateTeam 

func (t *TeamBiz) CreateTeam(ctx context.Context, params *bo.CreateTeamParams) (*model.SysTeam, error)

CreateTeam 创建团队

func (*TeamBiz) GetTeam 

func (t *TeamBiz) GetTeam(ctx context.Context, teamID uint32) (*model.SysTeam, error)

GetTeam 获取团队信息

func (*TeamBiz) GetTeamMailConfig added in v1.1.0 

func (t *TeamBiz) GetTeamMailConfig(ctx context.Context) (*model.SysTeamEmail, error)

GetTeamMailConfig 获取团队邮件配置

func (*TeamBiz) GetTeamMemberDetail added in v1.1.0 

func (t *TeamBiz) GetTeamMemberDetail(ctx context.Context, memberID uint32) (*bizmodel.SysTeamMember, error)

GetTeamMemberDetail 获取团队成员详情

func (*TeamBiz) GetUserTeamList 

func (t *TeamBiz) GetUserTeamList(ctx context.Context, userID uint32) ([]*model.SysTeam, error)

GetUserTeamList 获取用户团队列表

func (*TeamBiz) ListTeam 

func (t *TeamBiz) ListTeam(ctx context.Context, params *bo.QueryTeamListParams) ([]*model.SysTeam, error)

ListTeam 获取团队列表

func (*TeamBiz) ListTeamMember 

func (t *TeamBiz) ListTeamMember(ctx context.Context, params *bo.ListTeamMemberParams) ([]*bizmodel.SysTeamMember, error)

ListTeamMember 获取团队成员列表

func (*TeamBiz) RemoveTeamMember 

func (t *TeamBiz) RemoveTeamMember(ctx context.Context, params *bo.RemoveTeamMemberParams) error

RemoveTeamMember 移除团队成员

func (*TeamBiz) SetMemberRole 

func (t *TeamBiz) SetMemberRole(ctx context.Context, params *bo.SetMemberRoleParams) error

SetMemberRole 设置团队成员角色

func (*TeamBiz) SetTeamAdmin 

func (t *TeamBiz) SetTeamAdmin(ctx context.Context, params *bo.SetMemberAdminParams) error

SetTeamAdmin 设置团队管理员

func (*TeamBiz) SetTeamMailConfig 

func (t *TeamBiz) SetTeamMailConfig(ctx context.Context, params *bo.SetTeamMailConfigParams) error

SetTeamMailConfig 设置团队邮件配置

func (*TeamBiz) TransferTeamLeader 

func (t *TeamBiz) TransferTeamLeader(ctx context.Context, params *bo.TransferTeamLeaderParams) error

TransferTeamLeader 移交团队领导

func (*TeamBiz) UpdateTeam 

func (t *TeamBiz) UpdateTeam(ctx context.Context, team *bo.UpdateTeamParams) error

UpdateTeam 更新团队

func (*TeamBiz) UpdateTeamMemberStatus added in v1.1.0 

func (t *TeamBiz) UpdateTeamMemberStatus(ctx context.Context, status vobj.Status, ids ...uint32) error

UpdateTeamMemberStatus 更新团队成员状态

func (*TeamBiz) UpdateTeamStatus 

func (t *TeamBiz) UpdateTeamStatus(ctx context.Context, status vobj.Status, ids ...uint32) error

UpdateTeamStatus 更新团队状态

type TeamRoleBiz 

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

TeamRoleBiz 团队角色业务

func NewTeamRoleBiz 

func NewTeamRoleBiz(teamRoleRepo repository.TeamRole) *TeamRoleBiz

NewTeamRoleBiz 创建团队角色业务

func (*TeamRoleBiz) CreateTeamRole 

func (b *TeamRoleBiz) CreateTeamRole(ctx context.Context, teamRole *bo.CreateTeamRoleParams) (*bizmodel.SysTeamRole, error)

CreateTeamRole 创建团队角色

func (*TeamRoleBiz) DeleteTeamRole 

func (b *TeamRoleBiz) DeleteTeamRole(ctx context.Context, id uint32) error

DeleteTeamRole 删除团队角色

func (*TeamRoleBiz) GetTeamRole 

func (b *TeamRoleBiz) GetTeamRole(ctx context.Context, id uint32) (*bizmodel.SysTeamRole, error)

GetTeamRole 获取团队角色

func (*TeamRoleBiz) ListTeamRole 

func (b *TeamRoleBiz) ListTeamRole(ctx context.Context, params *bo.ListTeamRoleParams) ([]*bizmodel.SysTeamRole, error)

ListTeamRole 获取团队角色列表

func (*TeamRoleBiz) UpdateTeamRole 

func (b *TeamRoleBiz) UpdateTeamRole(ctx context.Context, teamRole *bo.UpdateTeamRoleParams) error

UpdateTeamRole 更新团队角色

func (*TeamRoleBiz) UpdateTeamRoleStatus 

func (b *TeamRoleBiz) UpdateTeamRoleStatus(ctx context.Context, status vobj.Status, ids ...uint32) error

UpdateTeamRoleStatus 更新团队角色状态

type TemplateBiz 

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

TemplateBiz 模板管理业务

func NewTemplateBiz 

func NewTemplateBiz(templateRepository repository.Template) *TemplateBiz

NewTemplateBiz 创建模板管理业务

func (*TemplateBiz) CreateTemplateStrategy 

func (b *TemplateBiz) CreateTemplateStrategy(ctx context.Context, templateStrategy *bo.CreateTemplateStrategyParams) error

CreateTemplateStrategy 创建模板策略

func (*TemplateBiz) DeleteTemplateStrategy 

func (b *TemplateBiz) DeleteTemplateStrategy(ctx context.Context, id uint32) error

DeleteTemplateStrategy 删除模板策略

func (*TemplateBiz) GetTemplateStrategy 

func (b *TemplateBiz) GetTemplateStrategy(ctx context.Context, id uint32) (*model.StrategyTemplate, error)

GetTemplateStrategy 获取模板策略详情

func (*TemplateBiz) ListTemplateStrategy 

func (b *TemplateBiz) ListTemplateStrategy(ctx context.Context, params *bo.QueryTemplateStrategyListParams) ([]*model.StrategyTemplate, error)

ListTemplateStrategy 获取模板策略列表

func (*TemplateBiz) UpdateTemplateStrategy 

func (b *TemplateBiz) UpdateTemplateStrategy(ctx context.Context, templateStrategy *bo.UpdateTemplateStrategyParams) error

UpdateTemplateStrategy 更新模板策略

func (*TemplateBiz) UpdateTemplateStrategyStatus 

func (b *TemplateBiz) UpdateTemplateStrategyStatus(ctx context.Context, params *bo.UpdateTemplateStrategyStatusParams) error

UpdateTemplateStrategyStatus 更新模板策略状态

type UserBiz 

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

UserBiz 用户业务

func NewUserBiz 

func NewUserBiz(userRepo repository.User) *UserBiz

NewUserBiz 创建用户业务

func (*UserBiz) BatchUpdateUserStatus 

func (b *UserBiz) BatchUpdateUserStatus(ctx context.Context, params *bo.BatchUpdateUserStatusParams) error

BatchUpdateUserStatus 批量更新用户状态

func (*UserBiz) CreateUser 

func (b *UserBiz) CreateUser(ctx context.Context, user *bo.CreateUserParams) (*model.SysUser, error)

CreateUser 创建用户

func (*UserBiz) DeleteUser 

func (b *UserBiz) DeleteUser(ctx context.Context, id uint32) error

DeleteUser 删除用户

func (*UserBiz) GetUser 

func (b *UserBiz) GetUser(ctx context.Context, id uint32) (*model.SysUser, error)

GetUser 获取用户

func (*UserBiz) GetUserSelectList 

func (b *UserBiz) GetUserSelectList(ctx context.Context, params *bo.QueryUserSelectParams) ([]*bo.SelectOptionBo, error)

GetUserSelectList 获取用户下拉列表

func (*UserBiz) ListUser 

func (b *UserBiz) ListUser(ctx context.Context, params *bo.QueryUserListParams) ([]*model.SysUser, error)

ListUser 获取用户列表

func (*UserBiz) ResetUserPasswordBySelf 

func (b *UserBiz) ResetUserPasswordBySelf(ctx context.Context, req *bo.ResetUserPasswordBySelfParams) error

ResetUserPasswordBySelf 重置自己的密码

func (*UserBiz) UpdateUser 

func (b *UserBiz) UpdateUser(ctx context.Context, user *bo.UpdateUserParams) error

UpdateUser 更新用户

func (*UserBiz) UpdateUserAvatar 

func (b *UserBiz) UpdateUserAvatar(ctx context.Context, req *bo.UpdateUserAvatarRequest) error

UpdateUserAvatar 更新用户头像

func (*UserBiz) UpdateUserBaseInfo 

func (b *UserBiz) UpdateUserBaseInfo(ctx context.Context, user *bo.UpdateUserBaseParams) error

UpdateUserBaseInfo 更新用户基础信息

func (*UserBiz) UpdateUserEmail 

func (b *UserBiz) UpdateUserEmail(ctx context.Context, req *bo.UpdateUserEmailRequest) error

UpdateUserEmail 更新用户邮箱

func (*UserBiz) UpdateUserPhone 

func (b *UserBiz) UpdateUserPhone(ctx context.Context, req *bo.UpdateUserPhoneRequest) error

UpdateUserPhone 更新用户手机号

type UserMessageBiz added in v1.0.2 

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

UserMessageBiz .

func NewUserMessageBiz added in v1.0.2 

func NewUserMessageBiz(userMessageRepository repository.UserMessage, inviteBiz *InviteBiz) *UserMessageBiz

NewUserMessageBiz .

func (*UserMessageBiz) CancelUserMessage added in v1.1.0 

func (b *UserMessageBiz) CancelUserMessage(ctx context.Context, id uint32) error

CancelUserMessage 取消用户通知消息

func (*UserMessageBiz) ConfirmUserMessage added in v1.1.0 

func (b *UserMessageBiz) ConfirmUserMessage(ctx context.Context, id uint32) error

ConfirmUserMessage 确认用户通知消息 

根据不同的业务类型，完成不同的业务动作

func (*UserMessageBiz) DeleteAllUserMessage added in v1.0.2 

func (b *UserMessageBiz) DeleteAllUserMessage(ctx context.Context) error

DeleteAllUserMessage 删除用户通知消息-所有

func (*UserMessageBiz) DeleteUserMessage added in v1.0.2 

func (b *UserMessageBiz) DeleteUserMessage(ctx context.Context, ids []uint32) error

DeleteUserMessage 删除用户通知消息

func (*UserMessageBiz) ListUserMessage added in v1.0.2 

func (b *UserMessageBiz) ListUserMessage(ctx context.Context, params *bo.QueryUserMessageListParams) ([]*model.SysUserMessage, error)

ListUserMessage 获取用户通知消息列表

Source Files

View all Source files

Directories

Path Synopsis
bo
auth

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.