Closed xiekeyang closed 6 years ago
This introduce a workqueue structure from k8s client, which support thread safety object adding and polling reading.
unit test and bundle test pass through.
This only refactor invocation package. Next we will consider to do it in workflow package also, and remove self implementation state heap.
fixed from log.Fatal to log.Error, thanks.
log.Fatal
log.Error
@erwinvaneyk You really propose a nice way. Fixed it.
LGTM 👍 Will merge into the eval-heap branch so we can run CI properly
This introduce a workqueue structure from k8s client, which support thread safety object adding and polling reading.
unit test and bundle test pass through.
This only refactor invocation package. Next we will consider to do it in workflow package also, and remove self implementation state heap.