logic

Documentation

Index

• Constants
• func UpdateToSlaveCache(configCache ConfigCache)
• type AutoLogic
  • func NewAutoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AutoLogic
  • func (a *AutoLogic) AutoCheckExist(table, uuidField, uuid string) (bool, error)
  • func (a *AutoLogic) AutoCreate(syncData *master.SyncData, v map[string]interface{}) error
  • func (a *AutoLogic) AutoUpdate(syncData *master.SyncData, v map[string]interface{}) error
• type ConfigCache
• type Configs
  • func GetConfigsCacheByRegion(region string) []*Configs
  • func GetMasterCacheByRegion(region string) []*Configs
• type Filters
• type RegionToConfigCacheLogic
  • func NewRegionToConfigCacheLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RegionToConfigCacheLogic
  • func (r *RegionToConfigCacheLogic) SetRegionToConfigsCache() error
• type SyncToMasterLogic
  • func NewSyncToMasterLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SyncToMasterLogic
  • func (l *SyncToMasterLogic) SyncToMaster(in *master.SyncData) (*master.UpdateVersions, error)
• type SyncToSlaveLogic
  • func NewSyncToSlaveLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SyncToSlaveLogic
  • func (l *SyncToSlaveLogic) SyncToSlave(in *master.UpdateVersions) (*master.SyncData, error)
• type TaskLogic
  • func NewTaskLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskLogic
  • func (t *TaskLogic) BuildTaskData(configJson *master.ConfigJson, offset string, filters []*Filters) ([]map[string]interface{}, error)
• type UpdateConfigsCacheLogic
  • func NewUpdateConfigsCacheLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateConfigsCacheLogic
  • func (l *UpdateConfigsCacheLogic) UpdateConfigsCache(in *master.Region) (*master.Configs, error)

Constants

const (
	BUILD_TASK_DATA = "[BuildTaskData]"
)

Functions

func UpdateToSlaveCache

func UpdateToSlaveCache(configCache ConfigCache)

UpdateToSlaveCache 更新同步到slave的缓存

Types

type AutoLogic

type AutoLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewAutoLogic

func NewAutoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AutoLogic

func (*AutoLogic) AutoCheckExist

func (a *AutoLogic) AutoCheckExist(table, uuidField, uuid string) (bool, error)

AutoCheckExist 检查指定的数据是否存在数据库

func (*AutoLogic) AutoCreate

func (a *AutoLogic) AutoCreate(syncData *master.SyncData, v map[string]interface{}) error

AutoCreate 灵活的添加指定数据结构的指定数据

func (*AutoLogic) AutoUpdate

func (a *AutoLogic) AutoUpdate(syncData *master.SyncData, v map[string]interface{}) error

AutoUpdate 灵活的更新指定数据结构的指定数据

type ConfigCache

type ConfigCache map[string][]*Configs

type Configs

type Configs model.Configs

func GetConfigsCacheByRegion

func GetConfigsCacheByRegion(region string) []*Configs

GetConfigsCacheByRegion 使用地域获取所有配置

func GetMasterCacheByRegion

func GetMasterCacheByRegion(region string) []*Configs

GetMasterCacheByRegion 从缓存获取指定region的master配置

type Filters

type Filters model.Filters

type RegionToConfigCacheLogic

type RegionToConfigCacheLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewRegionToConfigCacheLogic

func NewRegionToConfigCacheLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RegionToConfigCacheLogic

func (*RegionToConfigCacheLogic) SetRegionToConfigsCache

func (r *RegionToConfigCacheLogic) SetRegionToConfigsCache() error

SetRegionToConfigsCache 设置某个地域所需要同步的配置

type SyncToMasterLogic

type SyncToMasterLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewSyncToMasterLogic

func NewSyncToMasterLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SyncToMasterLogic

func (*SyncToMasterLogic) SyncToMaster

func (l *SyncToMasterLogic) SyncToMaster(in *master.SyncData) (*master.UpdateVersions, error)

从slave同步到master

type SyncToSlaveLogic

type SyncToSlaveLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewSyncToSlaveLogic

func NewSyncToSlaveLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SyncToSlaveLogic

func (*SyncToSlaveLogic) SyncToSlave

func (l *SyncToSlaveLogic) SyncToSlave(in *master.UpdateVersions) (*master.SyncData, error)

从master同步到slave

type TaskLogic

type TaskLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewTaskLogic

func NewTaskLogic(ctx context.Context, svcCtx *svc.ServiceContext) *TaskLogic

func (*TaskLogic) BuildTaskData

func (t *TaskLogic) BuildTaskData(configJson *master.ConfigJson, offset string, filters []*Filters) ([]map[string]interface{}, error)

type UpdateConfigsCacheLogic

type UpdateConfigsCacheLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewUpdateConfigsCacheLogic

func NewUpdateConfigsCacheLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateConfigsCacheLogic

func (*UpdateConfigsCacheLogic) UpdateConfigsCache

func (l *UpdateConfigsCacheLogic) UpdateConfigsCache(in *master.Region) (*master.Configs, error)

从master更新本地config缓存