logic

Documentation

Index

• type SyncToMasterLogic
  • func NewSyncToMasterLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SyncToMasterLogic
  • func (l *SyncToMasterLogic) SyncToMaster(in *slave.SyncData) (*slave.UpdateVersions, error)
• type SyncToSlaveLogic
  • func NewSyncToSlaveLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SyncToSlaveLogic
  • func (l *SyncToSlaveLogic) SyncToSlave(in *slave.UpdateVersions) (*slave.SyncData, error)
• type UpdateConfigsCacheLogic
  • func NewUpdateConfigsCacheLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateConfigsCacheLogic
  • func (l *UpdateConfigsCacheLogic) UpdateConfigsCache(in *slave.Region) (*slave.Configs, error)

Types

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 *slave.SyncData) (*slave.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 *slave.UpdateVersions) (*slave.SyncData, error)

从master同步到slave

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 *slave.Region) (*slave.Configs, error)

从master更新本地config缓存