hooks

package

v0.0.72 Latest Latest Go to latest Published: Sep 1, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/contenox/runtime

Links

Open Source Insights

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 NewMockHookRegistry() *MockHookRepo
type PersistentRepo
- func (p *PersistentRepo) Exec(ctx context.Context, startingTime time.Time, input any, ...) (any, error)
- func (p *PersistentRepo) Supports(ctx context.Context) ([]string, error)
type SimpleRepo
- func (m *SimpleRepo) Exec(ctx context.Context, startingTime time.Time, input any, ...) (any, error)
- func (m *SimpleRepo) Supports(ctx context.Context) ([]string, error)

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
}

HookCallRecord now only stores the arguments passed to the hook.

type HookResponse ¶

type HookResponse struct {
	Output any
}

HookResponse is simplified to only contain the direct output.

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 HookRepo interface.

func NewMockHookRegistry ¶

func NewMockHookRegistry() *MockHookRepo

NewMockHookRegistry returns a new instance of MockHookRepo.

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,
	args *taskengine.HookCall,
) (any, error)

Exec simulates execution of a hook call using the new simplified signature.

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 using the new simplified HookResponse.

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,
	args *taskengine.HookCall,
) (any, error)

Exec now implements the new, simplified HookRepo interface.

func (*PersistentRepo) Supports ¶

func (p *PersistentRepo) Supports(ctx context.Context) ([]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,
	args *taskengine.HookCall,
) (any, error)

Exec now implements the new, simplified HookRepo interface.

func (*SimpleRepo) Supports ¶

func (m *SimpleRepo) Supports(ctx context.Context) ([]string, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL