Documentation
¶
Index ¶
- Constants
- type Business
- type BusinessRepo
- type BusinessUseCase
- func (u *BusinessUseCase) Add(ctx kratosx.Context, business *Business) (uint32, error)
- func (u *BusinessUseCase) AllBusinessField(ctx kratosx.Context, sid uint32) ([]string, error)
- func (u *BusinessUseCase) AllBusinessValue(ctx kratosx.Context, bid uint32) ([]*BusinessValue, error)
- func (u *BusinessUseCase) CheckBusinessValue(ctx kratosx.Context, bid uint32, values string) error
- func (u *BusinessUseCase) Delete(ctx kratosx.Context, id uint32) error
- func (u *BusinessUseCase) Get(ctx kratosx.Context, id uint32) (*Business, error)
- func (u *BusinessUseCase) GetByKeyword(ctx kratosx.Context, keyword string) (*Business, error)
- func (u *BusinessUseCase) PageServerBusiness(ctx kratosx.Context, req *types.PageServerBusinessRequest) ([]*Business, uint32, error)
- func (u *BusinessUseCase) Update(ctx kratosx.Context, business *Business) error
- func (u *BusinessUseCase) UpdateBusinessValue(ctx kratosx.Context, rv *BusinessValue) error
- type BusinessValue
- type Configure
- type ConfigureRepo
- type ConfigureUseCase
- func (u *ConfigureUseCase) Add(ctx kratosx.Context, configure *Configure) (uint32, error)
- func (u *ConfigureUseCase) Compare(ctx kratosx.Context, req *types.CompareConfigureRequest) ([]*types.CompareConfigureReply, error)
- func (u *ConfigureUseCase) GetByEnvAndSrc(ctx kratosx.Context, envId, srvId uint32) (*Configure, error)
- func (u *ConfigureUseCase) Page(ctx kratosx.Context, page, pageSize uint32) ([]*Configure, uint32, error)
- func (u *ConfigureUseCase) SendWatcher(in *Configure)
- func (u *ConfigureUseCase) Update(ctx kratosx.Context, req *Configure) error
- func (u *ConfigureUseCase) Watch(ctx kratosx.Context, req *types.WatcherConfigRequest, ...) error
- type Env
- type EnvRepo
- type EnvUseCase
- func (e *EnvUseCase) Add(ctx kratosx.Context, env *Env) (uint32, error)
- func (e *EnvUseCase) All(ctx kratosx.Context) ([]*Env, error)
- func (e *EnvUseCase) Delete(ctx kratosx.Context, id uint32) error
- func (e *EnvUseCase) Get(ctx kratosx.Context, id uint32) (*Env, error)
- func (e *EnvUseCase) GetByIds(ctx kratosx.Context, ids []uint32) ([]*Env, error)
- func (e *EnvUseCase) GetByKeyword(ctx kratosx.Context, keyword string) (*Env, error)
- func (e *EnvUseCase) GetByToken(ctx kratosx.Context, token string) (*Env, error)
- func (e *EnvUseCase) ResetToken(ctx kratosx.Context, id uint32) (string, error)
- func (e *EnvUseCase) Update(ctx kratosx.Context, env *Env) error
- type Resource
- type ResourceRepo
- type ResourceServer
- type ResourceUseCase
- func (u *ResourceUseCase) Add(ctx kratosx.Context, resource *Resource) (uint32, error)
- func (u *ResourceUseCase) AllResourceServerIds(ctx kratosx.Context, rid uint32) ([]uint32, error)
- func (u *ResourceUseCase) AllResourceValue(ctx kratosx.Context, rid uint32) ([]*ResourceValue, error)
- func (u *ResourceUseCase) AllServerResourceField(ctx kratosx.Context, sid uint32) ([]string, error)
- func (u *ResourceUseCase) CheckResourceValue(ctx kratosx.Context, rid uint32, values string) error
- func (u *ResourceUseCase) Delete(ctx kratosx.Context, id uint32) error
- func (u *ResourceUseCase) Get(ctx kratosx.Context, id uint32) (*Resource, error)
- func (u *ResourceUseCase) GetByKeyword(ctx kratosx.Context, keyword string) (*Resource, error)
- func (u *ResourceUseCase) Page(ctx kratosx.Context, req *types.PageResourceRequest) ([]*Resource, uint32, error)
- func (u *ResourceUseCase) PageServerResource(ctx kratosx.Context, req *types.PageServerResourceRequest) ([]*Resource, uint32, error)
- func (u *ResourceUseCase) Update(ctx kratosx.Context, resource *Resource) error
- func (u *ResourceUseCase) UpdateResourceValue(ctx kratosx.Context, rv *ResourceValue) error
- type ResourceValue
- type Server
- type ServerRepo
- type ServerUseCase
- func (s *ServerUseCase) Add(ctx kratosx.Context, server *Server) (uint32, error)
- func (s *ServerUseCase) Delete(ctx kratosx.Context, id uint32) error
- func (s *ServerUseCase) Get(ctx kratosx.Context, id uint32) (*Server, error)
- func (s *ServerUseCase) GetByIds(ctx kratosx.Context, ids []uint32) ([]*Server, error)
- func (s *ServerUseCase) GetByKeyword(ctx kratosx.Context, keyword string) (*Server, error)
- func (s *ServerUseCase) Page(ctx kratosx.Context, req *types.PageServerRequest) ([]*Server, uint32, error)
- func (s *ServerUseCase) Update(ctx kratosx.Context, server *Server) error
- type Template
- type TemplateRepo
- type TemplateUseCase
- func (t *TemplateUseCase) Add(ctx kratosx.Context, template *Template) (uint32, error)
- func (t *TemplateUseCase) Compare(ctx kratosx.Context, req *types.CompareTemplateRequest) ([]*types.CompareTemplateReply, error)
- func (t *TemplateUseCase) Current(ctx kratosx.Context, srvId uint32) (*Template, error)
- func (t *TemplateUseCase) Delete(ctx kratosx.Context, id uint32) error
- func (t *TemplateUseCase) Get(ctx kratosx.Context, id uint32) (*Template, error)
- func (t *TemplateUseCase) PageServerTemplate(ctx kratosx.Context, req *types.PageTemplateRequest) ([]*Template, uint32, error)
- func (t *TemplateUseCase) Parse(ctx kratosx.Context, req *types.ParseRequest) (*types.ParseReply, error)
- func (t *TemplateUseCase) ParseByContent(ctx kratosx.Context, req *types.ParseByContentRequest) (string, error)
- func (t *TemplateUseCase) Switch(ctx kratosx.Context, srvId, tpId uint32) error
- func (t *TemplateUseCase) Update(ctx kratosx.Context, template *Template) error
- type UserUseCase
Constants ¶
const ( Regexp = `\$\{(\w|\.)+}` FormatJson = "json" FormatYaml = "yaml" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Business ¶
type Business struct {
ktypes.BaseModel
ServerID uint32 `json:"server_id" gorm:"not null;comment:服务id"`
Keyword string `json:"keyword" gorm:"not null;type:char(32) binary;comment:变量标识"`
Type string `json:"type" gorm:"not null;size:32;comment:变量类型"`
Description string `json:"description" gorm:"not null;size:128;comment:变量描述"`
Server *Server `json:"server" gorm:"constraint:onDelete:cascade"`
Values []*BusinessValue `json:"business_value" gorm:"constraint:onDelete:cascade"`
}
type BusinessRepo ¶
type BusinessRepo interface {
Get(ctx kratosx.Context, id uint32) (*Business, error)
GetByKeyword(ctx kratosx.Context, key string) (*Business, error)
PageServerBusiness(ctx kratosx.Context, req *types.PageServerBusinessRequest) ([]*Business, uint32, error)
AllServerBusiness(ctx kratosx.Context, id uint32) ([]*Business, error)
Create(ctx kratosx.Context, c *Business) (uint32, error)
Update(ctx kratosx.Context, c *Business) error
Delete(ctx kratosx.Context, uint322 uint32) error
GetValues(ctx kratosx.Context, bid uint32) ([]*BusinessValue, error)
GetEnvValues(ctx kratosx.Context, eid, sid uint32) ([]*BusinessValue, error)
UpdateValue(ctx kratosx.Context, rv *BusinessValue) error
}
type BusinessUseCase ¶
type BusinessUseCase struct {
// contains filtered or unexported fields
}
func NewBusinessUseCase ¶
func NewBusinessUseCase(config *config.Config, repo BusinessRepo) *BusinessUseCase
func (*BusinessUseCase) AllBusinessField ¶
AllBusinessField 获取指定服务业务变量的所有可用字段
func (*BusinessUseCase) AllBusinessValue ¶
func (u *BusinessUseCase) AllBusinessValue(ctx kratosx.Context, bid uint32) ([]*BusinessValue, error)
AllBusinessValue 获取指定业务变量的所有环境值
func (*BusinessUseCase) CheckBusinessValue ¶
CheckBusinessValue 检测业务变量值是否合法
func (*BusinessUseCase) Delete ¶
func (u *BusinessUseCase) Delete(ctx kratosx.Context, id uint32) error
Delete 删除业务变量信息
func (*BusinessUseCase) GetByKeyword ¶
GetByKeyword 获取指定标识的业务变量信息
func (*BusinessUseCase) PageServerBusiness ¶
func (u *BusinessUseCase) PageServerBusiness(ctx kratosx.Context, req *types.PageServerBusinessRequest) ([]*Business, uint32, error)
PageServerBusiness 获取指定服务的业务变量
func (*BusinessUseCase) Update ¶
func (u *BusinessUseCase) Update(ctx kratosx.Context, business *Business) error
Update 更新业务变量信息
func (*BusinessUseCase) UpdateBusinessValue ¶
func (u *BusinessUseCase) UpdateBusinessValue(ctx kratosx.Context, rv *BusinessValue) error
UpdateBusinessValue 更新指定业务变量的值
type BusinessValue ¶
type BusinessValue struct {
ktypes.BaseModel
EnvID uint32 `json:"env_id" gorm:"not null;comment:环境id"`
BusinessID uint32 `json:"business_id" gorm:"not null;comment:业务变量id"`
Value string `json:"value" gorm:"not null;type:text;comment:业务变量id"`
Env *Env `json:"env" gorm:"constraint:onDelete:cascade"`
Business *Business `json:"business" gorm:"constraint:onDelete:cascade"`
}
type Configure ¶
type Configure struct {
ktypes.BaseModel
ServerID uint32 `json:"server_id" gorm:"not null;comment:服务id"`
EnvID uint32 `json:"env_id" gorm:"not null;comment:环境id"`
Content string `json:"content" gorm:"not null;type:text;comment:配置内容"`
Version string `json:"version" gorm:"not null;size:32;comment:配置版本"`
Format string `json:"format" gorm:"not null;size:32;comment:配置格式"`
Description *string `json:"description" gorm:"size:128;comment:配置描述"`
Server *Server `json:"server" gorm:"constraint:onDelete:cascade"`
Env *Env `json:"env" gorm:"constraint:onDelete:cascade"`
}
type ConfigureRepo ¶
type ConfigureRepo interface {
Get(ctx kratosx.Context, id uint32) (*Configure, error)
GetByEnvAndSrv(ctx kratosx.Context, envId, srvId uint32) (*Configure, error)
Page(ctx kratosx.Context, options *ktypes.PageOptions) ([]*Configure, uint32, error)
Create(ctx kratosx.Context, c *Configure) (uint32, error)
Update(ctx kratosx.Context, c *Configure) error
}
type ConfigureUseCase ¶
type ConfigureUseCase struct {
// contains filtered or unexported fields
}
func NewConfigureUseCase ¶
func NewConfigureUseCase(config *config.Config, repo ConfigureRepo) *ConfigureUseCase
func (*ConfigureUseCase) Compare ¶
func (u *ConfigureUseCase) Compare(ctx kratosx.Context, req *types.CompareConfigureRequest) ([]*types.CompareConfigureReply, error)
Compare 对比配置
func (*ConfigureUseCase) GetByEnvAndSrc ¶
func (u *ConfigureUseCase) GetByEnvAndSrc(ctx kratosx.Context, envId, srvId uint32) (*Configure, error)
GetByEnvAndSrc 获取指定标识的配置信息
func (*ConfigureUseCase) Page ¶
func (u *ConfigureUseCase) Page(ctx kratosx.Context, page, pageSize uint32) ([]*Configure, uint32, error)
Page 获取分页配置信息
func (*ConfigureUseCase) SendWatcher ¶
func (u *ConfigureUseCase) SendWatcher(in *Configure)
func (*ConfigureUseCase) Update ¶
func (u *ConfigureUseCase) Update(ctx kratosx.Context, req *Configure) error
Update 更新模配置
func (*ConfigureUseCase) Watch ¶
func (u *ConfigureUseCase) Watch(ctx kratosx.Context, req *types.WatcherConfigRequest, reply types.WatcherConfigReplyFunc) error
type Env ¶
type Env struct {
types.BaseModel
Keyword string `json:"keyword" gorm:"not null;type:char(32) binary;comment:环境标识"`
Name string `json:"name" gorm:"not null;size:64;comment:环境名称"`
Description string `json:"description" gorm:"not null;size:128;comment:环境描述"`
Token string `json:"token,omitempty" gorm:"not null;size:128;comment:环境token"`
Status *bool `json:"status" gorm:"default:false;comment:环境状态"`
}
type EnvRepo ¶
type EnvRepo interface {
Get(ctx kratosx.Context, id uint32) (*Env, error)
GetByKeyword(ctx kratosx.Context, keyword string) (*Env, error)
GetByToken(ctx kratosx.Context, keyword string) (*Env, error)
GetByIds(ctx kratosx.Context, ids []uint32) ([]*Env, error)
All(ctx kratosx.Context) ([]*Env, error)
Create(ctx kratosx.Context, c *Env) (uint32, error)
Update(ctx kratosx.Context, c *Env) error
Delete(ctx kratosx.Context, uint322 uint32) error
}
type EnvUseCase ¶
type EnvUseCase struct {
// contains filtered or unexported fields
}
func NewEnvUseCase ¶
func NewEnvUseCase(config *config.Config, repo EnvRepo) *EnvUseCase
func (*EnvUseCase) Delete ¶
func (e *EnvUseCase) Delete(ctx kratosx.Context, id uint32) error
Delete 删除指定id的环境
func (*EnvUseCase) GetByKeyword ¶
GetByKeyword 通过关键词查找指定环境
func (*EnvUseCase) GetByToken ¶
GetByToken 通过token查找指定环境
func (*EnvUseCase) ResetToken ¶
ResetToken 重置环境token
type Resource ¶
type Resource struct {
ktypes.BaseModel
Keyword string `json:"keyword" gorm:"not null;type:char(32) binary;comment:变量标识"`
Description string `json:"description" gorm:"not null;size:128;comment:变量描述"`
Fields string `json:"fields" gorm:"not null;size:256;comment:变量字段集合"`
Tag string `json:"tag" gorm:"not null;size:32;comment:变量标签"`
Private *bool `json:"private" gorm:"default:false;comment:是否私有"`
ResourceServer []*ResourceServer `json:"resource_server" gorm:"constraint:onDelete:cascade"`
ResourceValue []*ResourceValue `json:"resource_value" gorm:"constraint:onDelete:cascade"`
}
type ResourceRepo ¶
type ResourceRepo interface {
Get(ctx kratosx.Context, id uint32) (*Resource, error)
GetByKeyword(ctx kratosx.Context, key string) (*Resource, error)
PageResource(ctx kratosx.Context, req *types.PageResourceRequest) ([]*Resource, uint32, error)
Create(ctx kratosx.Context, c *Resource) (uint32, error)
Update(ctx kratosx.Context, c *Resource) error
Delete(ctx kratosx.Context, uint322 uint32) error
GetValues(ctx kratosx.Context, rid uint32) ([]*ResourceValue, error)
GetEnvValues(ctx kratosx.Context, eid, sid uint32) ([]*ResourceValue, error)
UpdateValue(ctx kratosx.Context, rv *ResourceValue) error
PageServerResource(ctx kratosx.Context, id uint32, options *ktypes.PageOptions) ([]*Resource, uint32, error)
AllServerResource(ctx kratosx.Context, id uint32) ([]*Resource, error)
AllResourceServerId(ctx kratosx.Context, id uint32) ([]uint32, error)
}
type ResourceServer ¶
type ResourceServer struct {
ServerID uint32 `json:"server_id" gorm:"uniqueIndex:sr;not null;comment:服务id"`
ResourceID uint32 `json:"resource_id" gorm:"uniqueIndex:sr;not null;comment:资源id"`
Server *Server `json:"server" gorm:"constraint:onDelete:cascade"`
Resource *Resource `json:"resource" gorm:"constraint:onDelete:cascade"`
}
type ResourceUseCase ¶
type ResourceUseCase struct {
// contains filtered or unexported fields
}
func NewResourceUseCase ¶
func NewResourceUseCase(config *config.Config, rsRepo ResourceRepo) *ResourceUseCase
func (*ResourceUseCase) AllResourceServerIds ¶
AllResourceServerIds 获取指定资源的关联服务id
func (*ResourceUseCase) AllResourceValue ¶
func (u *ResourceUseCase) AllResourceValue(ctx kratosx.Context, rid uint32) ([]*ResourceValue, error)
AllResourceValue 获取指定资源的所有环境值
func (*ResourceUseCase) AllServerResourceField ¶
AllServerResourceField 获取指定服务资源的字段
func (*ResourceUseCase) CheckResourceValue ¶
CheckResourceValue 检测资源值是否合法
func (*ResourceUseCase) Delete ¶
func (u *ResourceUseCase) Delete(ctx kratosx.Context, id uint32) error
Delete 删除资源信息
func (*ResourceUseCase) GetByKeyword ¶
GetByKeyword 获取指定标识的资源信息
func (*ResourceUseCase) Page ¶
func (u *ResourceUseCase) Page(ctx kratosx.Context, req *types.PageResourceRequest) ([]*Resource, uint32, error)
Page 获取分页资源信息
func (*ResourceUseCase) PageServerResource ¶
func (u *ResourceUseCase) PageServerResource(ctx kratosx.Context, req *types.PageServerResourceRequest) ([]*Resource, uint32, error)
PageServerResource 获取指定服务的分页资源
func (*ResourceUseCase) Update ¶
func (u *ResourceUseCase) Update(ctx kratosx.Context, resource *Resource) error
Update 更新资源信息
func (*ResourceUseCase) UpdateResourceValue ¶
func (u *ResourceUseCase) UpdateResourceValue(ctx kratosx.Context, rv *ResourceValue) error
UpdateResourceValue 更新指定资源的值
type ResourceValue ¶
type ResourceValue struct {
ktypes.BaseModel
EnvID uint32 `json:"env_id" gorm:"uniqueIndex:er;not null;comment:环境id"`
ResourceID uint32 `json:"resource_id" gorm:"uniqueIndex:er;not null;comment:资源id"`
Value string `json:"value" gorm:"not null;type:text;comment:资源id"`
Env *Env `json:"env" gorm:"constraint:onDelete:cascade"`
Resource *Resource `json:"resource" gorm:"constraint:onDelete:cascade"`
}
type ServerRepo ¶
type ServerRepo interface {
Get(ctx kratosx.Context, id uint32) (*Server, error)
GetByKeyword(ctx kratosx.Context, key string) (*Server, error)
GetByIds(ctx kratosx.Context, ids []uint32) ([]*Server, error)
PageServer(ctx kratosx.Context, req *types.PageServerRequest) ([]*Server, uint32, error)
All(ctx kratosx.Context, options ktypes.Scopes) ([]*Server, error)
Create(ctx kratosx.Context, c *Server) (uint32, error)
Update(ctx kratosx.Context, c *Server) error
Delete(ctx kratosx.Context, uint322 uint32) error
}
type ServerUseCase ¶
type ServerUseCase struct {
// contains filtered or unexported fields
}
func NewServerUseCase ¶
func NewServerUseCase(config *config.Config, repo ServerRepo) *ServerUseCase
func (*ServerUseCase) Delete ¶
func (s *ServerUseCase) Delete(ctx kratosx.Context, id uint32) error
Delete 删除服务信息
func (*ServerUseCase) GetByKeyword ¶
GetByKeyword 获取指定标识的服务信息
func (*ServerUseCase) Page ¶
func (s *ServerUseCase) Page(ctx kratosx.Context, req *types.PageServerRequest) ([]*Server, uint32, error)
Page 获取分页服务信息
type Template ¶
type Template struct {
ktypes.BaseModel
ServerID uint32 `json:"server_id" gorm:"uniqueIndex:sv;not null;comment:模板id"`
Content string `json:"content" gorm:"not null;type:text;comment:模板内容"`
Version string `json:"version" gorm:"uniqueIndex:sv;not null;size:32;comment:模板版本"`
IsUse bool `json:"is_use" gorm:"default:false;comment:是否使用"`
Format string `json:"format" gorm:"not null;size:32;comment:模板格式"`
Description string `json:"description" gorm:"not null;size:128;comment:模板描述"`
Compare string `json:"compare" gorm:"not null;type:text;comment:变更详情"`
Server *Server `json:"server" gorm:"constraint:onDelete:cascade"`
}
type TemplateRepo ¶
type TemplateRepo interface {
Get(ctx kratosx.Context, id uint32) (*Template, error)
GetByVersion(ctx kratosx.Context, version string) (*Template, error)
Current(ctx kratosx.Context, srvId uint32) (*Template, error)
PageServerTemplate(ctx kratosx.Context, options *types.PageTemplateRequest) ([]*Template, uint32, error)
All(ctx kratosx.Context, options ktypes.Scopes) ([]*Template, error)
Create(ctx kratosx.Context, c *Template) (uint32, error)
Update(ctx kratosx.Context, c *Template) error
Use(ctx kratosx.Context, srvId, tpId uint32) error
Delete(ctx kratosx.Context, uint322 uint32) error
}
type TemplateUseCase ¶
type TemplateUseCase struct {
// contains filtered or unexported fields
}
func NewTemplateUseCase ¶
func NewTemplateUseCase(config *config.Config, tpRepo TemplateRepo, rsRepo ResourceRepo, bsRepo BusinessRepo) *TemplateUseCase
func (*TemplateUseCase) Compare ¶
func (t *TemplateUseCase) Compare(ctx kratosx.Context, req *types.CompareTemplateRequest) ([]*types.CompareTemplateReply, error)
Compare 对比变更细节
func (*TemplateUseCase) Delete ¶
func (t *TemplateUseCase) Delete(ctx kratosx.Context, id uint32) error
Delete 删除模板信息
func (*TemplateUseCase) PageServerTemplate ¶
func (t *TemplateUseCase) PageServerTemplate(ctx kratosx.Context, req *types.PageTemplateRequest) ([]*Template, uint32, error)
PageServerTemplate 获取分页模板信息
func (*TemplateUseCase) Parse ¶
func (t *TemplateUseCase) Parse(ctx kratosx.Context, req *types.ParseRequest) (*types.ParseReply, error)
Parse 使用指定版本配置
func (*TemplateUseCase) ParseByContent ¶
func (t *TemplateUseCase) ParseByContent(ctx kratosx.Context, req *types.ParseByContentRequest) (string, error)
ParseByContent 指定content生成配置预览
type UserUseCase ¶
type UserUseCase struct {
// contains filtered or unexported fields
}
func NewUserUseCase ¶
func NewUserUseCase(config *config.Config) *UserUseCase
func (*UserUseCase) RefreshToken ¶
func (uc *UserUseCase) RefreshToken(ctx kratosx.Context) (string, error)
RefreshToken 刷新用户token