syncer

Documentation

Index

• func WithAppManager(appMgr *applications.SupbApplications) option
• func WithRecorder(recorder supbapis.Recorder) option
• func WithStrategyManager(stMgr *strategies.SupbStrategies) option
• type CreateAssume
  • func (r *CreateAssume) Cancel()
  • func (r *CreateAssume) Done() uint64
• type SyncMod
  • func NewSyncMod(ctx context.Context, prefix string) *SyncMod
  • func (r *SyncMod) ApplicationDelInformer(app *m2.SupbApplicationBaseInfo)
  • func (r *SyncMod) ApplicationPutInformer(app *m2.SupbApplicationBaseInfo)
  • func (r *SyncMod) Close() error
  • func (r *SyncMod) CreateLinkSyncAssume(appType string, appKey types.SupbApplicationKey, strategyType string, ...)
  • func (r *SyncMod) Initialize(opts ...option)
  • func (r *SyncMod) OptionConfig(opts ...option)
  • func (r *SyncMod) StrategyDelInformer(strategy *m1.SupbStrategyBaseInfo)
  • func (r *SyncMod) StrategyPutInformer(strategy *m1.SupbStrategyBaseInfo)

Functions

func WithAppManager

func WithAppManager(appMgr *applications.SupbApplications) option

func WithRecorder

func WithRecorder(recorder supbapis.Recorder) option

func WithStrategyManager

func WithStrategyManager(stMgr *strategies.SupbStrategies) option

Types

type CreateAssume

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

func (*CreateAssume) Cancel

func (r *CreateAssume) Cancel()

func (*CreateAssume) Done

func (r *CreateAssume) Done() uint64

type SyncMod

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

func NewSyncMod

func NewSyncMod(ctx context.Context, prefix string) *SyncMod

func (*SyncMod) ApplicationDelInformer

func (r *SyncMod) ApplicationDelInformer(app *m2.SupbApplicationBaseInfo)

func (*SyncMod) ApplicationPutInformer

func (r *SyncMod) ApplicationPutInformer(app *m2.SupbApplicationBaseInfo)

func (*SyncMod) Close

func (r *SyncMod) Close() error

func (*SyncMod) CreateLinkSyncAssume

func (r *SyncMod) CreateLinkSyncAssume(appType string, appKey types.SupbApplicationKey, strategyType string, strategyKey types.SupbStrategyKey)

func (*SyncMod) Initialize

func (r *SyncMod) Initialize(opts ...option)

func (*SyncMod) OptionConfig

func (r *SyncMod) OptionConfig(opts ...option)

func (*SyncMod) StrategyDelInformer

func (r *SyncMod) StrategyDelInformer(strategy *m1.SupbStrategyBaseInfo)

func (*SyncMod) StrategyPutInformer

func (r *SyncMod) StrategyPutInformer(strategy *m1.SupbStrategyBaseInfo)