Documentation ¶
Index ¶
- Constants
- Variables
- func GetMaxEventId(db *sql.DB) (int, error)
- func Init(connectionUrl string) ([]interface{}, *sql.DB, error)
- type City
- type ClusterEventDao
- type Country
- type Domain
- type FiledNameFormat
- type Group
- type GroupPoolRef
- type GroupServerRef
- type Idc
- type ParamsEnums
- type Pool
- type Province
- type Region
- type Route
- type Service
- type UpgradeCtrl
- type User
- type Version
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 ¶
启动时,先获取最大的id,让后加载数据库,最后从最大id为起始点,开始拉取事件。来避免事件被丢失,和重复加载, 事件重复加载应该是允许的。
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 ¶
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 ¶
type Domain ¶
type Domain interface { Create(host, group string) error GetAll() (res []*models.Domain, err error) }
func NewDomainDao ¶
type FiledNameFormat ¶
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 ¶
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 // 删除 }
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 }
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 ¶
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 ¶
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 ¶
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 ¶
type UpgradeCtrl ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.