model

Documentation

Index

• Constants
• Variables
• func UpdateVersion(version *Versions) error
• type ConfigCache
• type Configs
• type ConfigsModel
  • func NewConfigsModel(conn sqlx.SqlConn, c cache.CacheConf) ConfigsModel
• type Filters
• type FiltersModel
  • func NewFiltersModel(conn sqlx.SqlConn, c cache.CacheConf) FiltersModel
• type RegionConfigs
• type RegionConfigsModel
  • func NewRegionConfigsModel(conn sqlx.SqlConn, c cache.CacheConf) RegionConfigsModel
• type UuidToVersionCache
• type VersionCache
• type Versions
  • func GetVersion(region string) []*Versions
• type VersionsModel
  • func NewVersionsModel(conn sqlx.SqlConn, c cache.CacheConf) VersionsModel

Constants

const (
	SYNC_TO_SLAVE  = 1
	SYNC_TO_MASTER = 2
)

Variables

var ErrNotFound = sqlx.ErrNotFound

Functions

func UpdateVersion

func UpdateVersion(version *Versions) error

UpdateVersion 设置当前节点的偏移量

Types

type ConfigCache

type ConfigCache map[string][]*Configs

type Configs

type Configs struct {
	SyncType   sql.NullInt64 `db:"sync_type"`
	Id         int64         `db:"id"`
	Uuid       string        `db:"uuid"`
	ConfigJson string        `db:"config_json"`
	CreatedAt  sql.NullTime  `db:"created_at"`
	UpdatedAt  sql.NullTime  `db:"updated_at"`
	DeletedAt  sql.NullTime  `db:"deleted_at"`
}

type ConfigsModel

type ConfigsModel interface {
	Insert(data Configs) (sql.Result, error)
	FindOne(id int64) (*Configs, error)
	FindOneByUuid(uuid string) (*Configs, error)
	Update(data Configs) error
	Delete(id int64) error
	FindAllByUuids(uuids []string) ([]*Configs, error)
}

func NewConfigsModel

func NewConfigsModel(conn sqlx.SqlConn, c cache.CacheConf) ConfigsModel

type Filters

type Filters struct {
	Id             int64          `db:"id"`
	ConfigUuid     string         `db:"config_uuid"`
	Md5            sql.NullString `db:"md5"`
	RegionConfigId sql.NullInt64  `db:"region_config_id"`
	UpdatedAt      sql.NullTime   `db:"updated_at"`
	DeletedAt      sql.NullTime   `db:"deleted_at"`
	Key            string         `db:"key"`
	Value          string         `db:"value"`
	Region         string         `db:"region"`
	CreatedAt      sql.NullTime   `db:"created_at"`
}

type FiltersModel

type FiltersModel interface {
	Insert(data Filters) (sql.Result, error)
	FindOne(id int64) (*Filters, error)
	Update(data Filters) error
	Delete(id int64) error
	DeleteRevokeRegion(region, configUuid, md5 string) error
	GetFiltersByResionConfigId(regionConfigId uint) ([]*Filters, error)
	FirstOrInsert(filters *Filters) (*Filters, error)
}

func NewFiltersModel

func NewFiltersModel(conn sqlx.SqlConn, c cache.CacheConf) FiltersModel

type RegionConfigs

type RegionConfigs struct {
	Id         int64        `db:"id"`
	Region     string       `db:"region"`
	ConfigUuid string       `db:"config_uuid"`
	Needfilter int64        `db:"needfilter"`
	CreatedAt  sql.NullTime `db:"created_at"`
	UpdatedAt  sql.NullTime `db:"updated_at"`
	DeletedAt  sql.NullTime `db:"deleted_at"`
}

type RegionConfigsModel

type RegionConfigsModel interface {
	Insert(data RegionConfigs) (sql.Result, error)
	FindAll() ([]*RegionConfigs, error)
	FindOne(id int64) (*RegionConfigs, error)
	FindOneByConfigUuidRegion(configUuid string, region string) (*RegionConfigs, error)
	Update(data RegionConfigs) error
	Delete(id int64) error
	CreateRegionConfig(regionConfig RegionConfigs) (*RegionConfigs, error)
	CreateRegionConfigs(configUuid string, regions []string, needFilter int64) ([]*RegionConfigs, error)
}

func NewRegionConfigsModel

func NewRegionConfigsModel(conn sqlx.SqlConn, c cache.CacheConf) RegionConfigsModel

type UuidToVersionCache

type UuidToVersionCache map[string]*VersionCache

type VersionCache

type VersionCache struct {
	NeedUpdate bool
	Version    *Versions
}

type Versions

type Versions struct {
	CreatedAt  sql.NullTime `db:"created_at"`
	UpdatedAt  sql.NullTime `db:"updated_at"`
	DeletedAt  sql.NullTime `db:"deleted_at"`
	Id         int64        `db:"id"`
	ConfigUuid string       `db:"config_uuid"`
	Region     string       `db:"region"`
	Offset     sql.NullTime `db:"offset"`
}

func GetVersion

func GetVersion(region string) []*Versions

GetVersion 获取当前节点所有的偏移量

type VersionsModel

type VersionsModel interface {
	Insert(data Versions) (sql.Result, error)
	FindOne(id int64) (*Versions, error)
	FindOneByConfigUuidRegion(configUuid string, region string) (*Versions, error)
	Update(data Versions) error
	Delete(id int64) error
	InitVersionCache() error
	FlushVersionCaches() error
}

func NewVersionsModel

func NewVersionsModel(conn sqlx.SqlConn, c cache.CacheConf) VersionsModel