store

Documentation

Overview

Package store is a generated GoMock package.

Index

• type DAGResultStore
  • 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
  • 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
  • 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
• type Store

Types

type DAGResultStore

type DAGResultStore struct {
	// contains filtered or unexported fields
}

func NewDAGResultStore

func NewDAGResultStore() *DAGResultStore

func (*DAGResultStore) ClearJobSnapshot

func (s *DAGResultStore) ClearJobSnapshot(job workerpool.Job)

func (*DAGResultStore) Get

func (s *DAGResultStore) Get(key string) (any, bool)

func (*DAGResultStore) GetSnapshotInProgress

func (s *DAGResultStore) GetSnapshotInProgress() map[string]*Snapshot

func (*DAGResultStore) Set

func (s *DAGResultStore) Set(key string, value any)

func (*DAGResultStore) SetJobSnapshot

func (s *DAGResultStore) SetJobSnapshot(job workerpool.Job, id int)

type MockStore

type MockStore struct {
	// contains filtered or unexported fields
}

MockStore is a mock of Store interface.

func NewMockStore

func NewMockStore(ctrl *gomock.Controller) *MockStore

NewMockStore creates a new mock instance.

func (*MockStore) ClearJobSnapshot

func (m *MockStore) ClearJobSnapshot(arg0 workerpool.Job)

ClearJobSnapshot mocks base method.

func (*MockStore) EXPECT

func (m *MockStore) EXPECT() *MockStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStore) Get

func (m *MockStore) Get(key string) (any, bool)

Get mocks base method.

func (*MockStore) GetSnapshotInProgress

func (m *MockStore) GetSnapshotInProgress() map[string]*Snapshot

GetSnapshotInProgress mocks base method.

func (*MockStore) Set

func (m *MockStore) Set(key string, value any)

Set mocks base method.

func (*MockStore) SetJobSnapshot

func (m *MockStore) SetJobSnapshot(arg0 workerpool.Job, arg1 int)

SetJobSnapshot mocks base method.

type MockStoreMockRecorder

type MockStoreMockRecorder struct {
	// contains filtered or unexported fields
}

MockStoreMockRecorder is the mock recorder for MockStore.

func (*MockStoreMockRecorder) ClearJobSnapshot

func (mr *MockStoreMockRecorder) ClearJobSnapshot(arg0 any) *gomock.Call

ClearJobSnapshot indicates an expected call of ClearJobSnapshot.

func (*MockStoreMockRecorder) Get

func (mr *MockStoreMockRecorder) Get(key any) *gomock.Call

Get indicates an expected call of Get.

func (*MockStoreMockRecorder) GetSnapshotInProgress

func (mr *MockStoreMockRecorder) GetSnapshotInProgress() *gomock.Call

GetSnapshotInProgress indicates an expected call of GetSnapshotInProgress.

func (*MockStoreMockRecorder) Set

func (mr *MockStoreMockRecorder) Set(key, value any) *gomock.Call

Set indicates an expected call of Set.

func (*MockStoreMockRecorder) SetJobSnapshot

func (mr *MockStoreMockRecorder) SetJobSnapshot(arg0, arg1 any) *gomock.Call

SetJobSnapshot indicates an expected call of SetJobSnapshot.

type Snapshot

type Snapshot struct {
	WorkerID int
	Job      workerpool.Job
}

type Store

type Store interface {
	Set(key string, value any)
	Get(key string) (any, bool)
	SetJobSnapshot(workerpool.Job, int)
	ClearJobSnapshot(workerpool.Job)
	GetSnapshotInProgress() map[string]*Snapshot
}

Store thread safe key value store