Documentation
¶
Index ¶
- func NewPersistentRepo(localHooks map[string]taskengine.HookRepo, dbInstance libdb.DBManager, ...) taskengine.HookRepo
- func NewSimpleProvider(hooks map[string]taskengine.HookRepo) taskengine.HookRepo
- type HookCallRecord
- type HookResponse
- type MockHookRepo
- func (m *MockHookRepo) CallCount() int
- func (m *MockHookRepo) Exec(ctx context.Context, startingTime time.Time, input any, ...) (any, taskengine.DataType, string, error)
- func (m *MockHookRepo) LastCall() *HookCallRecord
- func (m *MockHookRepo) Reset()
- func (m *MockHookRepo) Supports(ctx context.Context) ([]string, error)
- func (m *MockHookRepo) WithErrorSequence(errors ...error) *MockHookRepo
- func (m *MockHookRepo) WithResponse(hookType string, response HookResponse) *MockHookRepo
- type PersistentRepo
- type SimpleRepo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPersistentRepo ¶
func NewPersistentRepo( localHooks map[string]taskengine.HookRepo, dbInstance libdb.DBManager, httpClient *http.Client, ) taskengine.HookRepo
func NewSimpleProvider ¶
func NewSimpleProvider(hooks map[string]taskengine.HookRepo) taskengine.HookRepo
Types ¶
type HookCallRecord ¶
type HookCallRecord struct {
Args taskengine.HookCall
Input any
InputType taskengine.DataType
Transition string
}
type HookResponse ¶
type HookResponse struct {
Output any
OutputType taskengine.DataType
Transition string
}
type MockHookRepo ¶
type MockHookRepo struct {
Calls []HookCallRecord
ResponseMap map[string]HookResponse
DefaultResponse HookResponse
ErrorSequence []error
// contains filtered or unexported fields
}
MockHookRepo is a mock implementation of the HookProvider interface.
func NewMockHookRegistry ¶
func NewMockHookRegistry() *MockHookRepo
NewMockHookRegistry returns a new instance of MockHookProvider.
func (*MockHookRepo) CallCount ¶
func (m *MockHookRepo) CallCount() int
CallCount returns number of times Exec was called
func (*MockHookRepo) Exec ¶
func (m *MockHookRepo) Exec( ctx context.Context, startingTime time.Time, input any, inputType taskengine.DataType, transition string, args *taskengine.HookCall, ) (any, taskengine.DataType, string, error)
Exec simulates execution of a hook call.
func (*MockHookRepo) LastCall ¶
func (m *MockHookRepo) LastCall() *HookCallRecord
LastCall returns the most recent hook call
func (*MockHookRepo) Reset ¶
func (m *MockHookRepo) Reset()
Reset clears all recorded calls and resets counters
func (*MockHookRepo) Supports ¶
func (m *MockHookRepo) Supports(ctx context.Context) ([]string, error)
func (*MockHookRepo) WithErrorSequence ¶
func (m *MockHookRepo) WithErrorSequence(errors ...error) *MockHookRepo
WithErrorSequence sets a sequence of errors to return
func (*MockHookRepo) WithResponse ¶
func (m *MockHookRepo) WithResponse(hookType string, response HookResponse) *MockHookRepo
WithResponse configures a response for a specific hook type
type PersistentRepo ¶
type PersistentRepo struct {
// contains filtered or unexported fields
}
func (*PersistentRepo) Exec ¶
func (p *PersistentRepo) Exec( ctx context.Context, startingTime time.Time, input any, dataType taskengine.DataType, transition string, args *taskengine.HookCall, ) (any, taskengine.DataType, string, error)
type SimpleRepo ¶
type SimpleRepo struct {
// contains filtered or unexported fields
}
func (*SimpleRepo) Exec ¶
func (m *SimpleRepo) Exec(ctx context.Context, startingTime time.Time, input any, dataType taskengine.DataType, transition string, args *taskengine.HookCall) (any, taskengine.DataType, string, error)
Source Files
Click to show internal directories.
Click to hide internal directories.