repository

package
v0.0.29 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2024 License: MIT Imports: 10 Imported by: 0

README

repository

用于表达repository, 底层实现, 上层使用

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AlarmInterveneRepo 

type AlarmInterveneRepo interface {
	// contains filtered or unexported methods
}

type AlarmRealtimeRepo 

type AlarmRealtimeRepo interface {
	GetRealtimeDetailById(ctx context.Context, id uint32, scopes ...basescopes.ScopeMethod) (*bo.AlarmRealtimeBO, error)
	GetRealtimeList(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.AlarmRealtimeBO, error)
	AlarmIntervene(ctx context.Context, realtimeAlarmID uint32, req *bo.AlarmInterveneBO) error
	AlarmUpgrade(ctx context.Context, realtimeAlarmID uint32, req *bo.AlarmUpgradeBO) error
	AlarmSuppress(ctx context.Context, realtimeAlarmID uint32, req *bo.AlarmSuppressBO) error
	// AppendAlarmBeenNotifyMembers 添加发送记录-通知成员
	AppendAlarmBeenNotifyMembers(ctx context.Context, realtimeAlarmID uint32, req *bo.AlarmBeenNotifyMemberBO) error
	// AppendAlarmBeenNotifyChatGroups 添加发送记录-通知群组
	AppendAlarmBeenNotifyChatGroups(ctx context.Context, realtimeAlarmID uint32, req *bo.PromAlarmBeenNotifyChatGroupBO) error
	// GetRealtimeCount 统计相关
	GetRealtimeCount(ctx context.Context, scopes ...basescopes.ScopeMethod) (int64, error)
	// Create 创建实时告警信息, 并缓存
	Create(ctx context.Context, req ...*bo.AlarmRealtimeBO) ([]*bo.AlarmRealtimeBO, error)
	// CacheByHistoryId 缓存
	CacheByHistoryId(ctx context.Context, req ...*bo.AlarmRealtimeBO) error
	// DeleteCacheByHistoryId 删除
	DeleteCacheByHistoryId(ctx context.Context, historyId ...uint32) error
	// CountRealtimeAlarmByStrategyIds 统计
	CountRealtimeAlarmByStrategyIds(ctx context.Context, strategyIds ...uint32) (map[uint32]int64, error)
	// contains filtered or unexported methods
}

type AlarmSuppressRepo 

type AlarmSuppressRepo interface {
	// contains filtered or unexported methods
}

type AlarmUpgradeRepo 

type AlarmUpgradeRepo interface {
	// contains filtered or unexported methods
}

type ApiRepo 

type ApiRepo interface {

	// Create 创建api
	Create(ctx context.Context, apiBOList ...*bo.ApiBO) ([]*bo.ApiBO, error)
	// Get 获取api
	Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*bo.ApiBO, error)
	// Find 查询api
	Find(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*bo.ApiBO, error)
	// List 获取api列表
	List(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.ApiBO, error)
	// Delete 删除api
	Delete(ctx context.Context, scopes ...basescopes.ScopeMethod) error
	// Update 更新api
	Update(ctx context.Context, apiBO *bo.ApiBO, scopes ...basescopes.ScopeMethod) (*bo.ApiBO, error)
	// UpdateAll 更新所有api
	UpdateAll(ctx context.Context, apiBO *bo.ApiBO, scopes ...basescopes.ScopeMethod) error
	// contains filtered or unexported methods
}

type CacheRepo 

type CacheRepo interface {
	Client() (cache.GlobalCache, error)
	Set(ctx context.Context, key string, value []byte, expiration time.Duration) error
	// contains filtered or unexported methods
}

type CaptchaRepo 

type CaptchaRepo interface {

	// CreateCaptcha 创建验证码
	CreateCaptcha(ctx context.Context, captcha *bo.CaptchaBO) error
	// GetCaptchaById 通过id获取验证码详情
	GetCaptchaById(ctx context.Context, id string) (*bo.CaptchaBO, error)
	// contains filtered or unexported methods
}

type ChartRepo 

type ChartRepo interface {
	// Create 创建图表
	Create(ctx context.Context, chart *do.MyChart) (*do.MyChart, error)
	// Get 获取图表
	Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*do.MyChart, error)
	// Find 查询图表
	Find(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*do.MyChart, error)
	// List 获取图表列表
	List(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*do.MyChart, error)
	// Delete 删除图表
	Delete(ctx context.Context, scopes ...basescopes.ScopeMethod) error
	// Update 更新图表
	Update(ctx context.Context, chart *do.MyChart, scopes ...basescopes.ScopeMethod) (*do.MyChart, error)
}

type ChatGroupRepo 

type ChatGroupRepo interface {
	Create(ctx context.Context, chatGroup *bo.ChatGroupBO) (*bo.ChatGroupBO, error)
	Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*bo.ChatGroupBO, error)
	Find(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*bo.ChatGroupBO, error)
	Update(ctx context.Context, chatGroup *bo.ChatGroupBO, scopes ...basescopes.ScopeMethod) error
	Delete(ctx context.Context, scopes ...basescopes.ScopeMethod) error
	List(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.ChatGroupBO, error)
	// contains filtered or unexported methods
}

type DashboardRepo 

type DashboardRepo interface {
	// Create 创建dashboard
	Create(ctx context.Context, dashboard *bo.CreateMyDashboardBO) (*do.MyDashboardConfig, error)
	// Get 获取dashboard
	Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*do.MyDashboardConfig, error)
	// Find 查询dashboard
	Find(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*do.MyDashboardConfig, error)
	// List 获取dashboard列表
	List(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*do.MyDashboardConfig, error)
	// Delete 删除dashboard
	Delete(ctx context.Context, scopes ...basescopes.ScopeMethod) error
	// Update 更新dashboard
	Update(ctx context.Context, dashboard *bo.UpdateMyDashboardBO, scopes ...basescopes.ScopeMethod) (*do.MyDashboardConfig, error)
}

type DataRepo 

type DataRepo interface {
	DB() (*gorm.DB, error)
	Cache() (cache.GlobalCache, error)
	// contains filtered or unexported methods
}

type EndpointRepo 

type EndpointRepo interface {
	Append(ctx context.Context, endpoint *bo.CreateEndpointReq) (*bo.EndpointBO, error)
	Update(ctx context.Context, endpoint *bo.EndpointBO) (*bo.EndpointBO, error)
	UpdateStatus(ctx context.Context, ids []uint32, status vobj.Status) error
	Delete(ctx context.Context, ids []uint32) error
	List(ctx context.Context, pagination bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.EndpointBO, error)
	Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*bo.EndpointBO, error)
	GetByParams(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*bo.EndpointBO, error)
	// contains filtered or unexported methods
}

type HistoryRepo 

type HistoryRepo interface {

	// GetHistoryById 通过id获取历史详情
	GetHistoryById(ctx context.Context, id uint32) (*bo.AlarmHistoryBO, error)
	// ListHistory 获取历史列表
	ListHistory(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.AlarmHistoryBO, error)
	// StorageHistory 创建历史
	StorageHistory(ctx context.Context, historyBO ...*bo.AlarmHistoryBO) ([]*bo.AlarmHistoryBO, error)
	// UpdateHistoryById 通过id更新历史
	UpdateHistoryById(ctx context.Context, id uint32, historyBO *bo.AlarmHistoryBO) (*bo.AlarmHistoryBO, error)
	// contains filtered or unexported methods
}

HistoryRepo .

type MsgRepo 

type MsgRepo interface {

	// SendAlarm 发送告警消息
	SendAlarm(ctx context.Context, req ...*bo.AlarmMsgBo) error

	SendAlarmToMember(ctx context.Context, members []*bo.NotifyMemberBO, memberTemplateMap map[vobj.NotifyType]string, alarmInfo *bo.AlertBo) error
	// contains filtered or unexported methods
}

type NotifyRepo 

type NotifyRepo interface {

	// Get 获取通知详情
	Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*bo.NotifyBO, error)
	// Find 获取通知列表
	Find(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*bo.NotifyBO, error)
	// Count 获取通知总数
	Count(ctx context.Context, scopes ...basescopes.ScopeMethod) (int64, error)
	// List 获取通知列表
	List(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.NotifyBO, error)
	// Create 创建通知
	Create(ctx context.Context, notify *bo.NotifyBO) (*bo.NotifyBO, error)
	// Update 更新通知
	Update(ctx context.Context, notify *bo.NotifyBO, scopes ...basescopes.ScopeMethod) error
	// Delete 删除通知
	Delete(ctx context.Context, scopes ...basescopes.ScopeMethod) error
	// contains filtered or unexported methods
}

type NotifyTemplateRepo 

type NotifyTemplateRepo interface {

	// Get 获取通知模板详情
	Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*bo.NotifyTemplateBO, error)
	// Find 获取通知模板列表
	Find(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*bo.NotifyTemplateBO, error)
	// Count 获取通知模板总数
	Count(ctx context.Context, scopes ...basescopes.ScopeMethod) (int64, error)
	// List 获取通知模板列表
	List(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.NotifyTemplateBO, error)
	// Create 创建通知模板
	Create(ctx context.Context, notifyTemplate *bo.NotifyTemplateBO) (*bo.NotifyTemplateBO, error)
	// Update 更新通知模板
	Update(ctx context.Context, notifyTemplate *bo.NotifyTemplateBO, scopes ...basescopes.ScopeMethod) error
	// Delete 删除通知模板
	Delete(ctx context.Context, scopes ...basescopes.ScopeMethod) error
	// contains filtered or unexported methods
}

type PageRepo 

type PageRepo interface {

	// GetStrategyIds 获取策略id列表
	GetStrategyIds(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]uint32, error)
	GetPromStrategyAlarmPage(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*do.PromStrategyAlarmPage, error)
	// UserPageList 获取用户页面列表
	UserPageList(ctx context.Context, userId uint32) ([]*bo.DictBO, error)
	// BindUserPages 绑定用户页面
	BindUserPages(ctx context.Context, userId uint32, pageIds []uint32) error
	// contains filtered or unexported methods
}

type PingRepo 

type PingRepo interface {
	Ping(ctx context.Context, g *bo.Ping) (*bo.Ping, error)
	// contains filtered or unexported methods
}

PingRepo is a Greater repo.

type PromDictRepo 

type PromDictRepo interface {

	// CreateDict 创建字典
	CreateDict(ctx context.Context, dict *bo.DictBO) (*bo.DictBO, error)
	// UpdateDictById 通过id更新字典
	UpdateDictById(ctx context.Context, id uint32, dict *bo.DictBO) (*bo.DictBO, error)
	// BatchUpdateDictStatusByIds 通过id批量更新字典状态
	BatchUpdateDictStatusByIds(ctx context.Context, status vobj.Status, ids []uint32) error
	// DeleteDictByIds 通过id删除字典
	DeleteDictByIds(ctx context.Context, id ...uint32) error
	// GetDictById 通过id获取字典详情
	GetDictById(ctx context.Context, id uint32) (*bo.DictBO, error)
	GetDictByIds(ctx context.Context, ids ...uint32) ([]*bo.DictBO, error)
	// ListDict 获取字典列表
	ListDict(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.DictBO, error)
	// contains filtered or unexported methods
}

type RoleRepo 

type RoleRepo interface {
	Create(ctx context.Context, role *bo.RoleBO) (*bo.RoleBO, error)
	Update(ctx context.Context, role *bo.RoleBO, scopes ...basescopes.ScopeMethod) (*bo.RoleBO, error)
	UpdateAll(ctx context.Context, role *bo.RoleBO, scopes ...basescopes.ScopeMethod) error
	Delete(ctx context.Context, scopes ...basescopes.ScopeMethod) error
	Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*bo.RoleBO, error)
	Find(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*bo.RoleBO, error)
	List(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.RoleBO, error)
	RelateApi(ctx context.Context, roleId uint32, apiList []*bo.ApiBO) error
	// contains filtered or unexported methods
}

type StrategyGroupRepo 

type StrategyGroupRepo interface {
	Create(ctx context.Context, strategyGroup *bo.StrategyGroupBO) (*bo.StrategyGroupBO, error)
	UpdateById(ctx context.Context, id uint32, strategyGroup *bo.StrategyGroupBO) (*bo.StrategyGroupBO, error)
	BatchUpdateStatus(ctx context.Context, status vobj.Status, ids []uint32) error
	DeleteByIds(ctx context.Context, ids ...uint32) error
	GetById(ctx context.Context, id uint32) (*bo.StrategyGroupBO, error)
	GetByParams(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*bo.StrategyGroupBO, error)
	List(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.StrategyGroupBO, error)
	ListAllLimit(ctx context.Context, limit int, scopes ...basescopes.ScopeMethod) ([]*bo.StrategyGroupBO, error)
	UpdateStrategyCount(ctx context.Context, ids ...uint32) error
	UpdateEnableStrategyCount(ctx context.Context, ids ...uint32) error
	BatchCreate(ctx context.Context, strategyGroups []*bo.StrategyGroupBO) ([]*bo.StrategyGroupBO, error)
	// contains filtered or unexported methods
}

type StrategyRepo 

type StrategyRepo interface {

	// CreateStrategy 创建策略
	CreateStrategy(ctx context.Context, strategy *bo.StrategyBO) (*bo.StrategyBO, error)
	// UpdateStrategyById 通过id更新策略
	UpdateStrategyById(ctx context.Context, id uint32, strategy *bo.StrategyBO) (*bo.StrategyBO, error)
	// BatchUpdateStrategyStatusByIds 通过id批量更新策略状态
	BatchUpdateStrategyStatusByIds(ctx context.Context, status vobj.Status, ids []uint32) error
	// DeleteStrategyByIds 通过id删除策略
	DeleteStrategyByIds(ctx context.Context, id ...uint32) error
	// GetStrategyById 通过id获取策略详情
	GetStrategyById(ctx context.Context, id uint32, wheres ...basescopes.ScopeMethod) (*bo.StrategyBO, error)
	// ListStrategy 获取策略列表
	ListStrategy(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.StrategyBO, error)
	// ListStrategyByIds 通过id列表获取策略列表
	ListStrategyByIds(ctx context.Context, ids []uint32) ([]*bo.StrategyBO, error)
	// List 获取策略列表
	List(ctx context.Context, wheres ...basescopes.ScopeMethod) ([]*bo.StrategyBO, error)
	// BindStrategyNotifyObject 绑定策略和通知对象
	BindStrategyNotifyObject(ctx context.Context, strategyBo *bo.StrategyBO, notifyBo []*bo.NotifyBO) error
	// contains filtered or unexported methods
}

type SysLogRepo 

type SysLogRepo interface {

	// CreateSysLog 创建日志
	CreateSysLog(ctx context.Context, action vobj.Action, logInfo ...*bo.SysLogBo)
	// ListSysLog 获取日志列表
	ListSysLog(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.SysLogBo, error)
	// contains filtered or unexported methods
}

type UnimplementedAlarmInterveneRepo 

type UnimplementedAlarmInterveneRepo struct{}

type UnimplementedAlarmRealtimeRepo 

type UnimplementedAlarmRealtimeRepo struct{}

func (UnimplementedAlarmRealtimeRepo) AlarmIntervene 

func (UnimplementedAlarmRealtimeRepo) AlarmIntervene(_ context.Context, _ uint32, _ *bo.AlarmInterveneBO) error

func (UnimplementedAlarmRealtimeRepo) AlarmSuppress 

func (UnimplementedAlarmRealtimeRepo) AlarmSuppress(_ context.Context, _ uint32, _ *bo.AlarmSuppressBO) error

func (UnimplementedAlarmRealtimeRepo) AlarmUpgrade 

func (UnimplementedAlarmRealtimeRepo) AlarmUpgrade(_ context.Context, _ uint32, _ *bo.AlarmUpgradeBO) error

func (UnimplementedAlarmRealtimeRepo) AppendAlarmBeenNotifyChatGroups 

func (UnimplementedAlarmRealtimeRepo) AppendAlarmBeenNotifyChatGroups(_ context.Context, _ uint32, _ *bo.PromAlarmBeenNotifyChatGroupBO) error

func (UnimplementedAlarmRealtimeRepo) AppendAlarmBeenNotifyMembers 

func (UnimplementedAlarmRealtimeRepo) AppendAlarmBeenNotifyMembers(_ context.Context, _ uint32, _ *bo.AlarmBeenNotifyMemberBO) error

func (UnimplementedAlarmRealtimeRepo) CacheByHistoryId 

func (UnimplementedAlarmRealtimeRepo) CacheByHistoryId(_ context.Context, _ ...*bo.AlarmRealtimeBO) error

func (UnimplementedAlarmRealtimeRepo) CountRealtimeAlarmByStrategyIds 

func (UnimplementedAlarmRealtimeRepo) CountRealtimeAlarmByStrategyIds(_ context.Context, _ ...uint32) (map[uint32]int64, error)

func (UnimplementedAlarmRealtimeRepo) Create 

func (UnimplementedAlarmRealtimeRepo) Create(_ context.Context, _ ...*bo.AlarmRealtimeBO) ([]*bo.AlarmRealtimeBO, error)

func (UnimplementedAlarmRealtimeRepo) DeleteCacheByHistoryId 

func (UnimplementedAlarmRealtimeRepo) DeleteCacheByHistoryId(_ context.Context, _ ...uint32) error

func (UnimplementedAlarmRealtimeRepo) GetRealtimeCount 

func (UnimplementedAlarmRealtimeRepo) GetRealtimeCount(_ context.Context, _ ...basescopes.ScopeMethod) (int64, error)

func (UnimplementedAlarmRealtimeRepo) GetRealtimeDetailById 

func (UnimplementedAlarmRealtimeRepo) GetRealtimeDetailById(_ context.Context, _ uint32, _ ...basescopes.ScopeMethod) (*bo.AlarmRealtimeBO, error)

func (UnimplementedAlarmRealtimeRepo) GetRealtimeList 

func (UnimplementedAlarmRealtimeRepo) GetRealtimeList(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.AlarmRealtimeBO, error)

type UnimplementedAlarmSuppressRepo 

type UnimplementedAlarmSuppressRepo struct{}

type UnimplementedAlarmUpgradeRepo 

type UnimplementedAlarmUpgradeRepo struct{}

type UnimplementedApiRepo 

type UnimplementedApiRepo struct{}

func (UnimplementedApiRepo) Create 

func (UnimplementedApiRepo) Create(_ context.Context, _ ...*bo.ApiBO) ([]*bo.ApiBO, error)

func (UnimplementedApiRepo) Delete 

func (UnimplementedApiRepo) Delete(_ context.Context, _ ...basescopes.ScopeMethod) error

func (UnimplementedApiRepo) Find 

func (UnimplementedApiRepo) Find(_ context.Context, _ ...basescopes.ScopeMethod) ([]*bo.ApiBO, error)

func (UnimplementedApiRepo) Get 

func (UnimplementedApiRepo) Get(_ context.Context, _ ...basescopes.ScopeMethod) (*bo.ApiBO, error)

func (UnimplementedApiRepo) List 

func (UnimplementedApiRepo) List(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.ApiBO, error)

func (UnimplementedApiRepo) Update 

func (UnimplementedApiRepo) Update(_ context.Context, _ *bo.ApiBO, _ ...basescopes.ScopeMethod) (*bo.ApiBO, error)

func (UnimplementedApiRepo) UpdateAll 

func (UnimplementedApiRepo) UpdateAll(_ context.Context, _ *bo.ApiBO, _ ...basescopes.ScopeMethod) error

type UnimplementedCacheRepo 

type UnimplementedCacheRepo struct{}

func (UnimplementedCacheRepo) Client 

func (UnimplementedCacheRepo) Client() (cache.GlobalCache, error)

func (UnimplementedCacheRepo) Set 

func (UnimplementedCacheRepo) Set(_ context.Context, _ string, _ []byte, _ time.Duration) error

type UnimplementedCaptchaRepo 

type UnimplementedCaptchaRepo struct{}

func (UnimplementedCaptchaRepo) CreateCaptcha 

func (UnimplementedCaptchaRepo) CreateCaptcha(_ context.Context, _ *bo.CaptchaBO) error

func (UnimplementedCaptchaRepo) GetCaptchaById 

func (UnimplementedCaptchaRepo) GetCaptchaById(_ context.Context, _ string) (*bo.CaptchaBO, error)

type UnimplementedChatGroupRepo 

type UnimplementedChatGroupRepo struct{}

func (UnimplementedChatGroupRepo) Create 

func (UnimplementedChatGroupRepo) Create(_ context.Context, _ *bo.ChatGroupBO) (*bo.ChatGroupBO, error)

func (UnimplementedChatGroupRepo) Delete 

func (UnimplementedChatGroupRepo) Delete(_ context.Context, _ ...basescopes.ScopeMethod) error

func (UnimplementedChatGroupRepo) Find 

func (UnimplementedChatGroupRepo) Find(_ context.Context, _ ...basescopes.ScopeMethod) ([]*bo.ChatGroupBO, error)

func (UnimplementedChatGroupRepo) Get 

func (UnimplementedChatGroupRepo) Get(_ context.Context, _ ...basescopes.ScopeMethod) (*bo.ChatGroupBO, error)

func (UnimplementedChatGroupRepo) List 

func (UnimplementedChatGroupRepo) List(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.ChatGroupBO, error)

func (UnimplementedChatGroupRepo) Update 

func (UnimplementedChatGroupRepo) Update(_ context.Context, _ *bo.ChatGroupBO, _ ...basescopes.ScopeMethod) error

type UnimplementedDataRepo 

type UnimplementedDataRepo struct{}

func (UnimplementedDataRepo) Cache 

func (UnimplementedDataRepo) Cache() (cache.GlobalCache, error)

func (UnimplementedDataRepo) DB 

func (UnimplementedDataRepo) DB() (*gorm.DB, error)

type UnimplementedEndpointRepo 

type UnimplementedEndpointRepo struct{}

func (UnimplementedEndpointRepo) Append 

func (UnimplementedEndpointRepo) Append(_ context.Context, _ *bo.CreateEndpointReq) (*bo.EndpointBO, error)

func (UnimplementedEndpointRepo) Delete 

func (UnimplementedEndpointRepo) Delete(_ context.Context, _ []uint32) error

func (UnimplementedEndpointRepo) Get 

func (r UnimplementedEndpointRepo) Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*bo.EndpointBO, error)

func (UnimplementedEndpointRepo) GetByParams 

func (UnimplementedEndpointRepo) GetByParams(_ context.Context, _ ...basescopes.ScopeMethod) ([]*bo.EndpointBO, error)

func (UnimplementedEndpointRepo) List 

func (UnimplementedEndpointRepo) List(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.EndpointBO, error)

func (UnimplementedEndpointRepo) Update 

func (UnimplementedEndpointRepo) Update(_ context.Context, _ *bo.EndpointBO) (*bo.EndpointBO, error)

func (UnimplementedEndpointRepo) UpdateStatus 

func (UnimplementedEndpointRepo) UpdateStatus(_ context.Context, _ []uint32, _ vobj.Status) error

type UnimplementedHistoryRepo 

type UnimplementedHistoryRepo struct{}

func (UnimplementedHistoryRepo) GetHistoryById 

func (UnimplementedHistoryRepo) GetHistoryById(_ context.Context, _ uint32) (*bo.AlarmHistoryBO, error)

func (UnimplementedHistoryRepo) ListHistory 

func (UnimplementedHistoryRepo) ListHistory(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.AlarmHistoryBO, error)

func (UnimplementedHistoryRepo) StorageHistory 

func (UnimplementedHistoryRepo) StorageHistory(_ context.Context, _ ...*bo.AlarmHistoryBO) ([]*bo.AlarmHistoryBO, error)

func (UnimplementedHistoryRepo) UpdateHistoryById 

func (UnimplementedHistoryRepo) UpdateHistoryById(_ context.Context, _ uint32, _ *bo.AlarmHistoryBO) (*bo.AlarmHistoryBO, error)

type UnimplementedMsgRepo 

type UnimplementedMsgRepo struct{}

func (UnimplementedMsgRepo) SendAlarm 

func (UnimplementedMsgRepo) SendAlarm(_ context.Context, _ ...*bo.AlarmMsgBo) error

func (UnimplementedMsgRepo) SendAlarmToMember 

func (UnimplementedMsgRepo) SendAlarmToMember(_ context.Context, _ []*bo.NotifyMemberBO, _ map[vobj.NotifyType]string, _ *bo.AlertBo) error

type UnimplementedNotifyRepo 

type UnimplementedNotifyRepo struct{}

func (UnimplementedNotifyRepo) Count 

func (UnimplementedNotifyRepo) Count(_ context.Context, _ ...basescopes.ScopeMethod) (int64, error)

func (UnimplementedNotifyRepo) Create 

func (UnimplementedNotifyRepo) Create(_ context.Context, _ *bo.NotifyBO) (*bo.NotifyBO, error)

func (UnimplementedNotifyRepo) Delete 

func (UnimplementedNotifyRepo) Delete(_ context.Context, _ ...basescopes.ScopeMethod) error

func (UnimplementedNotifyRepo) Find 

func (UnimplementedNotifyRepo) Find(_ context.Context, _ ...basescopes.ScopeMethod) ([]*bo.NotifyBO, error)

func (UnimplementedNotifyRepo) Get 

func (UnimplementedNotifyRepo) Get(_ context.Context, _ ...basescopes.ScopeMethod) (*bo.NotifyBO, error)

func (UnimplementedNotifyRepo) List 

func (UnimplementedNotifyRepo) List(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.NotifyBO, error)

func (UnimplementedNotifyRepo) Update 

func (UnimplementedNotifyRepo) Update(_ context.Context, _ *bo.NotifyBO, _ ...basescopes.ScopeMethod) error

type UnimplementedNotifyTemplateRepo 

type UnimplementedNotifyTemplateRepo struct{}

func (UnimplementedNotifyTemplateRepo) Count 

func (UnimplementedNotifyTemplateRepo) Count(_ context.Context, _ ...basescopes.ScopeMethod) (int64, error)

func (UnimplementedNotifyTemplateRepo) Create 

func (UnimplementedNotifyTemplateRepo) Create(_ context.Context, _ *bo.NotifyTemplateBO) (*bo.NotifyTemplateBO, error)

func (UnimplementedNotifyTemplateRepo) Delete 

func (UnimplementedNotifyTemplateRepo) Delete(_ context.Context, _ ...basescopes.ScopeMethod) error

func (UnimplementedNotifyTemplateRepo) Find 

func (UnimplementedNotifyTemplateRepo) Find(_ context.Context, _ ...basescopes.ScopeMethod) ([]*bo.NotifyTemplateBO, error)

func (UnimplementedNotifyTemplateRepo) Get 

func (UnimplementedNotifyTemplateRepo) Get(_ context.Context, _ ...basescopes.ScopeMethod) (*bo.NotifyTemplateBO, error)

func (UnimplementedNotifyTemplateRepo) List 

func (UnimplementedNotifyTemplateRepo) List(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.NotifyTemplateBO, error)

func (UnimplementedNotifyTemplateRepo) Update 

func (UnimplementedNotifyTemplateRepo) Update(_ context.Context, _ *bo.NotifyTemplateBO, _ ...basescopes.ScopeMethod) error

type UnimplementedPageRepo 

type UnimplementedPageRepo struct{}

func (UnimplementedPageRepo) BindUserPages 

func (UnimplementedPageRepo) BindUserPages(_ context.Context, _ uint32, _ []uint32) error

func (UnimplementedPageRepo) GetPromStrategyAlarmPage 

func (UnimplementedPageRepo) GetPromStrategyAlarmPage(_ context.Context, _ ...basescopes.ScopeMethod) ([]*do.PromStrategyAlarmPage, error)

func (UnimplementedPageRepo) GetStrategyIds 

func (UnimplementedPageRepo) GetStrategyIds(_ context.Context, _ ...basescopes.ScopeMethod) ([]uint32, error)

func (UnimplementedPageRepo) UserPageList 

func (UnimplementedPageRepo) UserPageList(_ context.Context, _ uint32) ([]*bo.DictBO, error)

type UnimplementedPingRepo 

type UnimplementedPingRepo struct{}

func (UnimplementedPingRepo) Ping 

func (UnimplementedPingRepo) Ping(_ context.Context, _ *bo.Ping) (*bo.Ping, error)

type UnimplementedPromDictRepo 

type UnimplementedPromDictRepo struct{}

func (UnimplementedPromDictRepo) BatchUpdateDictStatusByIds 

func (UnimplementedPromDictRepo) BatchUpdateDictStatusByIds(_ context.Context, _ vobj.Status, _ []uint32) error

func (UnimplementedPromDictRepo) CreateDict 

func (UnimplementedPromDictRepo) CreateDict(_ context.Context, _ *bo.DictBO) (*bo.DictBO, error)

func (UnimplementedPromDictRepo) DeleteDictByIds 

func (UnimplementedPromDictRepo) DeleteDictByIds(_ context.Context, _ ...uint32) error

func (UnimplementedPromDictRepo) GetDictById 

func (UnimplementedPromDictRepo) GetDictById(_ context.Context, _ uint32) (*bo.DictBO, error)

func (UnimplementedPromDictRepo) GetDictByIds 

func (UnimplementedPromDictRepo) GetDictByIds(_ context.Context, _ ...uint32) ([]*bo.DictBO, error)

func (UnimplementedPromDictRepo) ListDict 

func (UnimplementedPromDictRepo) ListDict(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.DictBO, error)

func (UnimplementedPromDictRepo) UpdateDictById 

func (UnimplementedPromDictRepo) UpdateDictById(_ context.Context, _ uint32, _ *bo.DictBO) (*bo.DictBO, error)

type UnimplementedRoleRepo 

type UnimplementedRoleRepo struct{}

func (UnimplementedRoleRepo) Create 

func (UnimplementedRoleRepo) Create(_ context.Context, _ *bo.RoleBO) (*bo.RoleBO, error)

func (UnimplementedRoleRepo) Delete 

func (UnimplementedRoleRepo) Delete(_ context.Context, _ ...basescopes.ScopeMethod) error

func (UnimplementedRoleRepo) Find 

func (UnimplementedRoleRepo) Find(_ context.Context, _ ...basescopes.ScopeMethod) ([]*bo.RoleBO, error)

func (UnimplementedRoleRepo) Get 

func (UnimplementedRoleRepo) Get(_ context.Context, _ ...basescopes.ScopeMethod) (*bo.RoleBO, error)

func (UnimplementedRoleRepo) List 

func (UnimplementedRoleRepo) List(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.RoleBO, error)

func (UnimplementedRoleRepo) RelateApi 

func (UnimplementedRoleRepo) RelateApi(_ context.Context, _ uint32, _ []*bo.ApiBO) error

func (UnimplementedRoleRepo) Update 

func (UnimplementedRoleRepo) Update(_ context.Context, _ *bo.RoleBO, _ ...basescopes.ScopeMethod) (*bo.RoleBO, error)

func (UnimplementedRoleRepo) UpdateAll 

func (UnimplementedRoleRepo) UpdateAll(_ context.Context, _ *bo.RoleBO, _ ...basescopes.ScopeMethod) error

type UnimplementedStrategyGroupRepo 

type UnimplementedStrategyGroupRepo struct{}

func (UnimplementedStrategyGroupRepo) BatchCreate 

func (UnimplementedStrategyGroupRepo) BatchCreate(_ context.Context, _ []*bo.StrategyGroupBO) ([]*bo.StrategyGroupBO, error)

func (UnimplementedStrategyGroupRepo) BatchUpdateStatus 

func (UnimplementedStrategyGroupRepo) BatchUpdateStatus(_ context.Context, _ vobj.Status, _ []uint32) error

func (UnimplementedStrategyGroupRepo) Create 

func (UnimplementedStrategyGroupRepo) Create(_ context.Context, _ *bo.StrategyGroupBO) (*bo.StrategyGroupBO, error)

func (UnimplementedStrategyGroupRepo) DeleteByIds 

func (UnimplementedStrategyGroupRepo) DeleteByIds(_ context.Context, _ ...uint32) error

func (UnimplementedStrategyGroupRepo) GetById 

func (UnimplementedStrategyGroupRepo) GetById(_ context.Context, _ uint32) (*bo.StrategyGroupBO, error)

func (UnimplementedStrategyGroupRepo) GetByParams 

func (UnimplementedStrategyGroupRepo) GetByParams(_ context.Context, _ ...basescopes.ScopeMethod) ([]*bo.StrategyGroupBO, error)

func (UnimplementedStrategyGroupRepo) List 

func (UnimplementedStrategyGroupRepo) List(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.StrategyGroupBO, error)

func (UnimplementedStrategyGroupRepo) ListAllLimit 

func (UnimplementedStrategyGroupRepo) ListAllLimit(_ context.Context, _ int, _ ...basescopes.ScopeMethod) ([]*bo.StrategyGroupBO, error)

func (UnimplementedStrategyGroupRepo) UpdateById 

func (UnimplementedStrategyGroupRepo) UpdateById(_ context.Context, _ uint32, _ *bo.StrategyGroupBO) (*bo.StrategyGroupBO, error)

func (UnimplementedStrategyGroupRepo) UpdateEnableStrategyCount 

func (UnimplementedStrategyGroupRepo) UpdateEnableStrategyCount(_ context.Context, _ ...uint32) error

func (UnimplementedStrategyGroupRepo) UpdateStrategyCount 

func (UnimplementedStrategyGroupRepo) UpdateStrategyCount(_ context.Context, _ ...uint32) error

type UnimplementedStrategyRepo 

type UnimplementedStrategyRepo struct{}

func (UnimplementedStrategyRepo) BatchUpdateStrategyStatusByIds 

func (UnimplementedStrategyRepo) BatchUpdateStrategyStatusByIds(_ context.Context, _ vobj.Status, _ []uint32) error

func (UnimplementedStrategyRepo) BindStrategyNotifyObject 

func (UnimplementedStrategyRepo) BindStrategyNotifyObject(_ context.Context, _ *bo.StrategyBO, _ []*bo.NotifyBO) error

func (UnimplementedStrategyRepo) CreateStrategy 

func (UnimplementedStrategyRepo) CreateStrategy(_ context.Context, _ *bo.StrategyBO) (*bo.StrategyBO, error)

func (UnimplementedStrategyRepo) DeleteStrategyByIds 

func (UnimplementedStrategyRepo) DeleteStrategyByIds(_ context.Context, _ ...uint32) error

func (UnimplementedStrategyRepo) GetStrategyById 

func (UnimplementedStrategyRepo) GetStrategyById(_ context.Context, _ uint32, _ ...basescopes.ScopeMethod) (*bo.StrategyBO, error)

func (UnimplementedStrategyRepo) List 

func (UnimplementedStrategyRepo) List(_ context.Context, _ ...basescopes.ScopeMethod) ([]*bo.StrategyBO, error)

func (UnimplementedStrategyRepo) ListStrategy 

func (UnimplementedStrategyRepo) ListStrategy(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.StrategyBO, error)

func (UnimplementedStrategyRepo) ListStrategyByIds 

func (UnimplementedStrategyRepo) ListStrategyByIds(_ context.Context, _ []uint32) ([]*bo.StrategyBO, error)

func (UnimplementedStrategyRepo) UpdateStrategyById 

func (UnimplementedStrategyRepo) UpdateStrategyById(_ context.Context, _ uint32, _ *bo.StrategyBO) (*bo.StrategyBO, error)

type UnimplementedSysLogRepo 

type UnimplementedSysLogRepo struct{}

func (UnimplementedSysLogRepo) CreateSysLog 

func (UnimplementedSysLogRepo) CreateSysLog(_ context.Context, _ vobj.Action, _ ...*bo.SysLogBo)

func (UnimplementedSysLogRepo) ListSysLog 

func (UnimplementedSysLogRepo) ListSysLog(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.SysLogBo, error)

type UnimplementedUserRepo 

type UnimplementedUserRepo struct{}

func (UnimplementedUserRepo) Count 

func (UnimplementedUserRepo) Count(_ context.Context, _ ...basescopes.ScopeMethod) (int64, error)

func (UnimplementedUserRepo) Create 

func (UnimplementedUserRepo) Create(_ context.Context, _ *bo.UserBO) (*bo.UserBO, error)

func (UnimplementedUserRepo) Delete 

func (UnimplementedUserRepo) Delete(_ context.Context, _ ...basescopes.ScopeMethod) error

func (UnimplementedUserRepo) Find 

func (UnimplementedUserRepo) Find(_ context.Context, _ ...basescopes.ScopeMethod) ([]*bo.UserBO, error)

func (UnimplementedUserRepo) Get 

func (UnimplementedUserRepo) Get(_ context.Context, _ ...basescopes.ScopeMethod) (*bo.UserBO, error)

func (UnimplementedUserRepo) List 

func (UnimplementedUserRepo) List(_ context.Context, _ bo.Pagination, _ ...basescopes.ScopeMethod) ([]*bo.UserBO, error)

func (UnimplementedUserRepo) RelateRoles 

func (UnimplementedUserRepo) RelateRoles(_ context.Context, _ *bo.UserBO, _ []*bo.RoleBO) error

func (UnimplementedUserRepo) Update 

func (UnimplementedUserRepo) Update(_ context.Context, _ *bo.UserBO, _ ...basescopes.ScopeMethod) (*bo.UserBO, error)

type UserRepo 

type UserRepo interface {
	Get(ctx context.Context, scopes ...basescopes.ScopeMethod) (*bo.UserBO, error)
	Find(ctx context.Context, scopes ...basescopes.ScopeMethod) ([]*bo.UserBO, error)
	Count(ctx context.Context, scopes ...basescopes.ScopeMethod) (int64, error)
	List(ctx context.Context, pgInfo bo.Pagination, scopes ...basescopes.ScopeMethod) ([]*bo.UserBO, error)
	Create(ctx context.Context, user *bo.UserBO) (*bo.UserBO, error)
	Update(ctx context.Context, user *bo.UserBO, scopes ...basescopes.ScopeMethod) (*bo.UserBO, error)
	Delete(ctx context.Context, scopes ...basescopes.ScopeMethod) error
	RelateRoles(ctx context.Context, userBO *bo.UserBO, roleList []*bo.RoleBO) error
	// contains filtered or unexported methods
}

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.