waiter

type Callback interface {
	Notify(data map[string][]byte, isTimeout bool) error
	GetType() CallbackType
}

type CallbackType string

type WaitService interface {
	WaitOn(ctx context.Context, cb CallbackType, notifyIds ...string) error

	Done(ctx context.Context, notifyId string, data interface{}) error

	RegisterCallback(cb Callback) error
}