dao

package
v0.0.0-...-ecf5411 Latest Latest
Warning

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

Go to latest
Published: Jan 12, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TableIdc             = "t_idc"
	TableServer          = "t_server"
	TableGroup           = "t_group"
	TableServerGroupRef  = "t_server_group_ref"
	TablePool            = "t_pool"
	TableGroupPoolRef    = "t_group_pool_ref"
	TableRoute           = "t_route"
	TableService         = "t_service"
	TableCity            = "t_city"
	TableProvince        = "t_province"
	TableRegion          = "t_region"
	TableCountry         = "t_country"
	TableParamValueEnums = "t_custom_param_enum"
	TableUser            = "t_user"
)
View Source
const (
	EventCreate = "create"
	EventUpdate = "update"
	EventDelete = "delete"
)
View Source
const (
	ChannelIdc         = "idc"
	ChannelServer      = "server"
	ChannelGroup       = "group"
	ChannelGroupServer = "group_server_ref"
	ChannelPool        = "pool"
	ChannelPoolGroup   = "pool_group_ref"
	ChannelRoute       = "route"
	ChannelService     = "service"
	ChannelRegion      = "region"
	ChannelProvince    = "province"
	ChannelCity        = "city"
	ChannelCountry     = "country"
	ChannelParams      = "parameters"
)

Variables

View Source
var NoElemError = errors.New("no elem found")

Functions

func GetMaxEventId

func GetMaxEventId(db *sql.DB) (int, error)

启动时,先获取最大的id,让后加载数据库,最后从最大id为起始点,开始拉取事件。来避免事件被丢失,和重复加载, 事件重复加载应该是允许的。

func Init

func Init(connectionUrl string) ([]interface{}, *sql.DB, error)

Types

type City

type City interface {
	Create(c *models.City) (err error)
	GetByCode(code int) (city *models.City, err error)
	GetById(id string) (city *models.City, err error)
	GetProvinceCities(provCode int) (city []*models.City, err error)
	GetList() (res []*models.City, err error)
	Delete(code int) error
	Update(code int, c *models.City) (err error)
	IfReferenceIdc(idcId string) (bool, error)
	Init() error
}

func NewCityDao

func NewCityDao(db *sql.DB) City

type ClusterEventDao

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

func NewClusterEventDao

func NewClusterEventDao(db *sql.DB) *ClusterEventDao

func (*ClusterEventDao) ClearEvents

func (c *ClusterEventDao) ClearEvents() error

func (*ClusterEventDao) GetMaxEventId

func (c *ClusterEventDao) GetMaxEventId() (int, error)

func (*ClusterEventDao) PullNewEvent

func (c *ClusterEventDao) PullNewEvent(fromId int) (res []*models.ClusterEvent, err error)

type Country

type Country interface {
	GetByCode(code int) (res *models.Country, err error)
	GetList() (res []*models.Country, err error)
	Create(c *models.Country) error
	Delete(code int) error
	Init() error
}

func NewCountryDao

func NewCountryDao(db *sql.DB) Country

type Domain

type Domain interface {
	Create(host, group string) error
	GetAll() (res []*models.Domain, err error)
}

func NewDomainDao

func NewDomainDao(db *sql.DB) Domain

type FiledNameFormat

type FiledNameFormat func(s string) string

type Group

type Group interface {
	GetById(id string) (*models.Group, error)                     // 通过id 获取
	GetByName(name string) (*models.Group, error)                 // 通过名称获取
	GetByIdOrName(idOrName string) (idc *models.Group, err error) // 通过名称或者id获取
	GetList() (srvs []*models.Group, err error)                   //获取列表
	Create(srv *models.Group) error                               // 新增
	Update(id string, srv *models.Group) error                    // 更新
	Delete(id string) error                                       // 删除
	Patch(id string, group map[string]interface{}) error
}

func NewGroupImp

func NewGroupImp(db *sql.DB) Group

type GroupPoolRef

type GroupPoolRef interface {
	GetById(id string) (res *models.GroupPoolRef, err error) // 通过id 获取
	GetList() (refs []*models.GroupPoolRef, err error)       //获取列表
	Create(ref *models.GroupPoolRef) error                   // 新增
	Update(id string, srv *models.GroupPoolRef) error        // 更新
	Delete(id string) error
	Patch(id string, pool map[string]interface{}) error
	GetPoolGroupRef(poolId, groupId string) (ref *models.GroupPoolRef, err error)
	GetPoolGroups(poolId string) (refs []*models.GroupPoolRef, err error)
}

func NewGroupPoolRef

func NewGroupPoolRef(db *sql.DB) GroupPoolRef

type GroupServerRef

type GroupServerRef interface {
	GetById(id string) (*models.ServerGroupRef, error)   // 通过id 获取
	GetList() (srvs []*models.ServerGroupRef, err error) //获取列表
	Create(srv *models.ServerGroupRef) error             // 新增
	Update(id string, srv *models.ServerGroupRef) error  // 更新
	Delete(id string) error
	GetByRef(serverId, groupId string) (res *models.ServerGroupRef, err error)
	GetGroupServers(groupId string) (res []*models.ServerGroupRef, err error)
}

func NewGroupServerRef

func NewGroupServerRef(db *sql.DB) GroupServerRef

type Idc

type Idc interface {
	GetById(id string) (*models.Idc, error)                     // 通过id 获取
	GetByName(name string) (*models.Idc, error)                 // 通过名称获取
	GetByIdOrName(idOrName string) (idc *models.Idc, err error) // 通过名称或者id获取
	GetList() (idcs []*models.Idc, err error)                   //获取列表
	Create(idc *models.Idc) error                               // 新增
	Update(id string, idc *models.Idc) error                    // 更新
	Delete(id string) error                                     // 删除
}

func NewIdcImp

func NewIdcImp(db *sql.DB) Idc

type ParamsEnums

type ParamsEnums interface {
	Create(enum *models.CustomParamEnum) (err error)
	Delete(paraName, paramValue string) (err error)
	GetValues(paramName string) (res []*models.CustomParamEnum, err error)
	GetParamList() ([]*models.CustomParamEnum, error)
	Init() error
}

func NewParamDao

func NewParamDao(db *sql.DB) ParamsEnums

type Pool

type Pool interface {
	GetById(id string) (*models.Pool, error) // 通过id 获取
	GetByName(name string) (pool *models.Pool, err error)
	GetByIdOrName(idOrName string) (idc *models.Pool, err error) // 通过名称或者id获取
	GetList() (pools []*models.Pool, err error)                  //获取列表
	Create(pool *models.Pool) error                              // 新增
	Update(id string, srv *models.Pool) error                    // 更新
	Delete(id string) error
	Patch(id string, pool map[string]interface{}) error
}

func NewPool

func NewPool(db *sql.DB) Pool

type Province

type Province interface {
	GetByCode(code int) (res *models.Province, err error)
	GetList() (res []*models.Province, err error)
	GetById(id string) (res *models.Province, err error)
	GeProvinceByRegionCode(regionCode int) (res []*models.Province, err error)
	Delete(code int) error
	Create(p *models.Province) (err error)
	IfReferenceIdc(idcId string) (bool, error)
	Update(code int, p *models.Province) (err error)
	Init() error
}

func NewProvinceDao

func NewProvinceDao(db *sql.DB) Province

type Region

type Region interface {
	GetByCode(code int) (res *models.Region, err error)
	GetById(id string) (res *models.Region, err error)
	GetList() (res []*models.Region, err error)
	Create(region *models.Region) error
	Update(id string, region *models.Region) error
	Delete(code int) error
	IfReferenceIdc(idcId string) (bool, error)
	Init() error
}

func NewRegionDao

func NewRegionDao(db *sql.DB) Region

type Route

type Route interface {
	GetById(id string) (res *models.Route, err error) // 通过id 获取
	GetList() (refs []*models.Route, err error)       //获取列表
	Create(ref *models.Route) error                   // 新增
	Update(id string, srv *models.Route) error        // 更新
	Delete(id string) error
	Patch(id string, pool map[string]interface{}) error
	GetServiceRoutes(serviceId string) (res []*models.Route, err error)
	QueryRoutes(host, rule string) (res []*models.Route, err error) // 模糊查询
	QueryRoutesByRuleCond(conds string) (res []*models.Route, err error)
}

func NewRouteDao

func NewRouteDao(db *sql.DB) Route

type Service

type Service interface {
	GetById(id string) (*models.Service, error) // 通过id 获取
	GetByName(name string) (pool *models.Service, err error)
	GetByIdOrName(idOrName string) (pool *models.Service, err error) // 通过名称或者id获取
	GetList() (pools []*models.Service, err error)                   //获取列表
	Create(pool *models.Service) error                               // 新增
	Update(id string, srv *models.Service) error                     // 更新
	Delete(id string) error
	Patch(id string, pool map[string]interface{}) error
}

func NewServiceDao

func NewServiceDao(db *sql.DB) Service

type UpgradeCtrl

type UpgradeCtrl struct {
	From string
	To   string
	Func upgradeFunc
}

type User

type User interface {
	Get(username string) (*models.User, error)
	GetCount() (int, error)
	Create(m *models.User) error
}

func NewUserDao

func NewUserDao(db *sql.DB) User

type Version

type Version struct {
	Version string
}

Jump to

Keyboard shortcuts

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