MCPcopy Create free account
hub / github.com/actiontech/dtle / Get

Method Get

driver/state.go:26–31  ·  view source on GitHub ↗
(id string)

Source from the content-addressed store, hash-verified

24}
25
26func (ts *taskStore) Get(id string) (*taskHandle, bool) {
27 ts.lock.RLock()
28 defer ts.lock.RUnlock()
29 t, ok := ts.store[id]
30 return t, ok
31}
32
33func (ts *taskStore) Delete(id string) {
34 ts.lock.Lock()

Callers 15

RecoverTaskMethod · 0.80
StartTaskMethod · 0.80
WaitTaskMethod · 0.80
StopTaskMethod · 0.80
DestroyTaskMethod · 0.80
InspectTaskMethod · 0.80
SignalTaskMethod · 0.80
ExecTaskMethod · 0.80
GetGtidForJobMethod · 0.80
GetConfigMethod · 0.80
GetNatsIfExistMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected