Documentation
¶
Overview ¶
Package recovery is a generated GoMock package.
Index ¶
- func NewRecovery(modName string, accessor core.BackendAccessor) *recovery
- func ResyncedModule(wrappedModuleFactory core.ModuleFactory) core.ModuleFactory
- type Errors
- type MockStatePersister
- func (m *MockStatePersister) AckSubmit(arg0 uint)
- func (m *MockStatePersister) EXPECT() *MockStatePersisterMockRecorder
- func (m *MockStatePersister) Keys(arg0 string) []uint
- func (m *MockStatePersister) Persist(arg0 context.Context) error
- func (m *MockStatePersister) UseState(arg0 uint, arg1 string, arg2 interface{}) (SetState, bool, error)
- type MockStatePersisterMockRecorder
- func (mr *MockStatePersisterMockRecorder) AckSubmit(arg0 interface{}) *gomock.Call
- func (mr *MockStatePersisterMockRecorder) Keys(arg0 interface{}) *gomock.Call
- func (mr *MockStatePersisterMockRecorder) Persist(arg0 interface{}) *gomock.Call
- func (mr *MockStatePersisterMockRecorder) UseState(arg0, arg1, arg2 interface{}) *gomock.Call
- type PersistedMap
- type PersistedValue
- type SetState
- type StatePersister
- type T
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRecovery ¶
func NewRecovery(modName string, accessor core.BackendAccessor) *recovery
nolint:revive
func ResyncedModule ¶
func ResyncedModule(wrappedModuleFactory core.ModuleFactory) core.ModuleFactory
Types ¶
type MockStatePersister ¶
type MockStatePersister struct {
// contains filtered or unexported fields
}
MockStatePersister is a mock of StatePersister interface.
func NewMockStatePersister ¶
func NewMockStatePersister(ctrl *gomock.Controller) *MockStatePersister
NewMockStatePersister creates a new mock instance.
func (*MockStatePersister) AckSubmit ¶
func (m *MockStatePersister) AckSubmit(arg0 uint)
AckSubmit mocks base method.
func (*MockStatePersister) EXPECT ¶
func (m *MockStatePersister) EXPECT() *MockStatePersisterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStatePersister) Keys ¶
func (m *MockStatePersister) Keys(arg0 string) []uint
Keys mocks base method.
type MockStatePersisterMockRecorder ¶
type MockStatePersisterMockRecorder struct {
// contains filtered or unexported fields
}
MockStatePersisterMockRecorder is the mock recorder for MockStatePersister.
func (*MockStatePersisterMockRecorder) AckSubmit ¶
func (mr *MockStatePersisterMockRecorder) AckSubmit(arg0 interface{}) *gomock.Call
AckSubmit indicates an expected call of AckSubmit.
func (*MockStatePersisterMockRecorder) Keys ¶
func (mr *MockStatePersisterMockRecorder) Keys(arg0 interface{}) *gomock.Call
Keys indicates an expected call of Keys.
func (*MockStatePersisterMockRecorder) Persist ¶
func (mr *MockStatePersisterMockRecorder) Persist(arg0 interface{}) *gomock.Call
Persist indicates an expected call of Persist.
func (*MockStatePersisterMockRecorder) UseState ¶
func (mr *MockStatePersisterMockRecorder) UseState(arg0, arg1, arg2 interface{}) *gomock.Call
UseState indicates an expected call of UseState.
type PersistedMap ¶
type PersistedMap interface {
Get(apiID uint) (PersistedValue, error)
Keys() []uint
}
func NewPersistedMap ¶
func NewPersistedMap(sp StatePersister, name string, valType reflect.Type) PersistedMap
type PersistedValue ¶
type StatePersister ¶
type StatePersister interface {
UseState(apiID uint, name string, val interface{}) (setFn SetState, found bool, err error)
Keys(name string) []uint
Persist(ctx context.Context) error
AckSubmit(eventID uint)
}
func NewStatePersister ¶
func NewStatePersister(ctx context.Context, accessor core.BackendAccessor, modName string, persistInterval time.Duration) StatePersister
Source Files
Click to show internal directories.
Click to hide internal directories.