Versions in this module Expand all Collapse all v1 v1.1.0 Feb 11, 2026 v1.0.0 Feb 8, 2026 Changes in this version + type DAGResultStore struct + func NewDAGResultStore() *DAGResultStore + func (s *DAGResultStore) ClearJobSnapshot(job workerpool.Job) + func (s *DAGResultStore) Get(key string) (any, bool) + func (s *DAGResultStore) GetSnapshotInProgress() map[string]*Snapshot + func (s *DAGResultStore) Set(key string, value any) + func (s *DAGResultStore) SetJobSnapshot(job workerpool.Job, id int) + type MockStore struct + func NewMockStore(ctrl *gomock.Controller) *MockStore + func (m *MockStore) ClearJobSnapshot(arg0 workerpool.Job) + func (m *MockStore) EXPECT() *MockStoreMockRecorder + func (m *MockStore) Get(key string) (any, bool) + func (m *MockStore) GetSnapshotInProgress() map[string]*Snapshot + func (m *MockStore) Set(key string, value any) + func (m *MockStore) SetJobSnapshot(arg0 workerpool.Job, arg1 int) + type MockStoreMockRecorder struct + func (mr *MockStoreMockRecorder) ClearJobSnapshot(arg0 any) *gomock.Call + func (mr *MockStoreMockRecorder) Get(key any) *gomock.Call + func (mr *MockStoreMockRecorder) GetSnapshotInProgress() *gomock.Call + func (mr *MockStoreMockRecorder) Set(key, value any) *gomock.Call + func (mr *MockStoreMockRecorder) SetJobSnapshot(arg0, arg1 any) *gomock.Call + type Snapshot struct + Job workerpool.Job + WorkerID int + type Store interface + ClearJobSnapshot func(workerpool.Job) + Get func(key string) (any, bool) + GetSnapshotInProgress func() map[string]*Snapshot + Set func(key string, value any) + SetJobSnapshot func(workerpool.Job, int)
Go to main page