service

package
v0.0.0-...-2828958 Latest Latest
Warning

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

Go to latest
Published: May 22, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdminLoginRepo

type AdminLoginRepo interface {
	GetAdmin(*do.AdminLogin, *gin.Context) (*do.AdminLogin, error)
}

AdminLoginRepo 存储接口

type AdminLoginUseCase

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

AdminLoginUseCase is .

func NewAdminLoginUseCase

func NewAdminLoginUseCase(repo AdminLoginRepo) *AdminLoginUseCase

func (*AdminLoginUseCase) LoginCheck

func (useCase *AdminLoginUseCase) LoginCheck(loginDo *do.AdminLogin, c *gin.Context) (admin *do.AdminLogin, err error)

AdminLogin 进行登录验证

type AdminRepo

type AdminRepo interface {
	GetAdmin(int, *gin.Context) (*do.AdminLogin, error)
	UpdatePassword(*do.AdminLogin, *gin.Context) error
}

type AdminUseCase

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

func NewAdminUseCase

func NewAdminUseCase(repo AdminRepo) *AdminUseCase

func (*AdminUseCase) ChangePwd

func (a *AdminUseCase) ChangePwd(changePwdDo *do.ChangePwd, c *gin.Context) (err error)

type AppRepo

type AppRepo interface {
	GetAppList(string, int, int, *gin.Context) ([]*po.App, int64, error)
	GetAppDetailByID(int64, *gin.Context) (*po.App, error)
	DeleteAppByID(int64, *gin.Context) error
	InsertApp(*po.App, *gin.Context) (int64, error)
	GetAppDetailByAppID(string, *gin.Context) (*po.App, error)
	UpdateApp(*po.App, *gin.Context) error
}

type AppUseCase

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

func NewAppUseCase

func NewAppUseCase(repo AppRepo) *AppUseCase

func (*AppUseCase) AppAdd

func (useCase *AppUseCase) AppAdd(appAddInput *dto.AppAddInput, c *gin.Context) (err error)

AppAdd 添加一个租户

func (*AppUseCase) AppDelete

func (useCase *AppUseCase) AppDelete(appDeleteInput *dto.AppDeleteInput, c *gin.Context) (err error)

AppDelete 删除租户

func (*AppUseCase) AppDetail

func (useCase *AppUseCase) AppDetail(appDetailInput *dto.AppDetailInput, c *gin.Context) (outPut *dto.AppDetailOutput, err error)

AppDetail 获取租户详细信息

func (*AppUseCase) AppList

func (useCase *AppUseCase) AppList(appListInput *dto.AppListInput, c *gin.Context) (outPutList *dto.AppListOutput, err error)

AppList 获取租户列表

func (*AppUseCase) AppStat

func (useCase *AppUseCase) AppStat(ID int64, c *gin.Context) (todayList, yesterdayList []int64, err error)

AppStat 获取租户流量统计信息

func (*AppUseCase) AppUpdate

func (useCase *AppUseCase) AppUpdate(appUpdateInput *dto.AppUpdateInput, c *gin.Context) (err error)

AppUpdate 更改租户信息

type DashboardRepo

type DashboardRepo interface {
	GetServiceNum(*gin.Context) (int64, error)
	GetAppNum(*gin.Context) (int64, error)
	GetServiceStat(*gin.Context) ([]*do.DashboardServiceStat, error)
}

type DashboardUseCase

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

func NewDashboardUseCase

func NewDashboardUseCase(repo DashboardRepo) *DashboardUseCase

func (*DashboardUseCase) GetServiceStat

func (useCase *DashboardUseCase) GetServiceStat(c *gin.Context) (serviceStatList []*do.DashboardServiceStat, err error)

func (*DashboardUseCase) PanelGroupData

func (useCase *DashboardUseCase) PanelGroupData(c *gin.Context) (serviceNum, appNum int64, err error)

PanelGroupData 获取大盘的服务数和租户数指标

type OauthUseCase

type OauthUseCase struct {
}

func NewOauthUseCase

func NewOauthUseCase() *OauthUseCase

type ServiceRepo

type ServiceRepo interface {
	GetServiceDetail(*po.ServiceInfo, *gin.Context) (*do.ServiceDetail, error)
	GetServiceInfoByID(int64, *gin.Context) (*po.ServiceInfo, error)
	GetServiceInfoByName(string, *gin.Context) (*po.ServiceInfo, error)
	DeleteServiceInfo(*po.ServiceInfo, *gin.Context) error
	GetServiceInfoList(string, int, int, *gin.Context) ([]*po.ServiceInfo, int64, error)
	InsertServiceInfo(*sqlx.Tx, *po.ServiceInfo, *gin.Context) (int64, error)
	UpdateServiceInfo(*sqlx.Tx, *po.ServiceInfo, *gin.Context) error

	AddHTTPDetail(*do.ServiceDetail, *gin.Context) error
	UpdateHTTPDetail(*do.ServiceDetail, *gin.Context) error
	UpdateHTTPRule(*sqlx.Tx, *po.ServiceHTTPRule, *gin.Context) error
	GetServiceHTTPRuleByID(int64, *gin.Context) (*po.ServiceHTTPRule, error)
	GetServiceHTTPRuleByRule(int, string, *gin.Context) (*po.ServiceHTTPRule, error)
	InsertServiceHTTPRule(*sqlx.Tx, *po.ServiceHTTPRule, *gin.Context) error

	GetServiceTCPRuleByID(int64, *gin.Context) (*po.ServiceTCPRule, error)
	InsertServiceTCPRule(*sqlx.Tx, *po.ServiceTCPRule, *gin.Context) error
	UpdateTCPRule(*sqlx.Tx, *po.ServiceTCPRule, *gin.Context) error
	GetServiceTCPRuleByPort(int, *gin.Context) (*po.ServiceTCPRule, error)
	AddTCPDetail(*do.ServiceDetail, *gin.Context) error
	UpdateTCPDetail(*do.ServiceDetail, *gin.Context) error

	GetServiceGRPCRuleByID(int64, *gin.Context) (*po.ServiceGRPCRule, error)
	InsertServiceGRPCRule(*sqlx.Tx, *po.ServiceGRPCRule, *gin.Context) error
	UpdateGRPCRule(*sqlx.Tx, *po.ServiceGRPCRule, *gin.Context) error
	GetServiceGRPCRuleByPort(int, *gin.Context) (*po.ServiceGRPCRule, error)
	AddGRPCDetail(*do.ServiceDetail, *gin.Context) error
	UpdateGrpcDetail(*do.ServiceDetail, *gin.Context) error

	GetServiceLoadBalanceByID(int64, *gin.Context) (*po.ServiceLoadBalance, error)
	InsertServiceHTTPLoadBalance(*sqlx.Tx, *po.ServiceLoadBalance, *gin.Context) error
	UpdateHTTPLoadBalance(*sqlx.Tx, *po.ServiceLoadBalance, *gin.Context) error
	InsertServiceGRPCTCPLoadBalance(*sqlx.Tx, *po.ServiceLoadBalance, *gin.Context) error
	UpdateGRPCTCPLoadBalance(*sqlx.Tx, *po.ServiceLoadBalance, *gin.Context) error

	GetServiceAccessControllerByID(int64, *gin.Context) (*po.ServiceAccessControl, error)
	InsertServiceHTTPAccessControl(*sqlx.Tx, *po.ServiceAccessControl, *gin.Context) error
	UpdateHTTPAccessControl(*sqlx.Tx, *po.ServiceAccessControl, *gin.Context) error
	InsertServiceGRPCTCPAccessControl(*sqlx.Tx, *po.ServiceAccessControl, *gin.Context) error
	UpdateGRPCTCPAccessControl(*sqlx.Tx, *po.ServiceAccessControl, *gin.Context) error
}

type ServiceUseCase

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

func NewServiceUseCase

func NewServiceUseCase(repo ServiceRepo) *ServiceUseCase

NewServiceUseCase 创建一个 Service 用例

func (*ServiceUseCase) AddGRPC

func (useCase *ServiceUseCase) AddGRPC(addGRPC *dto.ServiceAddGrpcInput, c *gin.Context) (err error)

func (*ServiceUseCase) AddHTTP

func (useCase *ServiceUseCase) AddHTTP(addHTTP *dto.ServiceAddHTTPInput, c *gin.Context) (err error)

AddHTTP 添加 HTTP 服务逻辑处理

func (*ServiceUseCase) AddTCP

func (useCase *ServiceUseCase) AddTCP(addTCP *dto.ServiceAddTcpInput, c *gin.Context) (err error)

func (*ServiceUseCase) DeleteServiceInfo

func (useCase *ServiceUseCase) DeleteServiceInfo(serviceDeleteInput *dto.ServiceDeleteInput, c *gin.Context) (err error)

DeleteServiceInfo 删除一个服务

func (*ServiceUseCase) GetServiceDetail

func (useCase *ServiceUseCase) GetServiceDetail(ID int64, c *gin.Context) (serviceDetail *do.ServiceDetail, err error)

GetServiceDetail 根据 ID 获取服务详情

func (*ServiceUseCase) GetServiceList

func (useCase *ServiceUseCase) GetServiceList(serviceDo *do.ServiceListInput, c *gin.Context,
) (serviceListOutput *dto.ServiceListOutput, err error)

GetServiceList 获取服务列表

func (*ServiceUseCase) ServiceStat

func (useCase *ServiceUseCase) ServiceStat(serviceID int64, c *gin.Context) (todayList, yesterdayList []int64, err error)

ServiceStat 获取流量统计信息

func (*ServiceUseCase) UpdateGRPC

func (useCase *ServiceUseCase) UpdateGRPC(updateGRPC *dto.ServiceUpdateGrpcInput, c *gin.Context) (err error)

func (*ServiceUseCase) UpdateHTTP

func (useCase *ServiceUseCase) UpdateHTTP(updateHTTP *dto.ServiceUpdateHTTPInput, c *gin.Context) (err error)

UpdateHTTP 更新 HTTP 服务

func (*ServiceUseCase) UpdateTCP

func (useCase *ServiceUseCase) UpdateTCP(updateTCP *dto.ServiceUpdateTcpInput, c *gin.Context) (err error)

Jump to

Keyboard shortcuts

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