server

type ObserverServer interface {
	Start() error
	Close()

	Monitors() dependents.MonitorDependentsManager
	GetAddr() string
	GetKey() string

	SetPushFirst(f func(ctx context.Context, req *msaObserver.RequestPushFirst) (*msaObserver.ResponsePushFirst, error))
	SetPushStats(f func(ctx context.Context, req *msaObserver.RequestPushStats) (*msaObserver.Response, error))
	SetPushStatus(f func(ctx context.Context, req *msaObserver.RequestPushStatus) (*msaObserver.Response, error))
	SetWho(f func(ctx context.Context, req *msaObserver.RequestWho) (*msaObserver.ResponseWho, error))
	SetRestartService(f func(ctx context.Context, req *msaObserver.RequestRestartService) (*msaObserver.Response, error))
}