Versions in this module Expand all Collapse all v1 v1.0.4 Mar 17, 2026 Changes in this version + func CreateTestChunks(contents ...string) []*entity.Chunk + func NewTestChunk(content string, metadata map[string]interface{}) *entity.Chunk + func NewTestDocument(id, content, docType string) *entity.Document + func NewTestPipelineState() *entity.PipelineState + func NewTestQuery(text string, metadata map[string]interface{}) *entity.Query + func WithAnswer(state *entity.PipelineState, answer string) *entity.PipelineState + func WithQuery(state *entity.PipelineState, query *entity.Query) *entity.PipelineState + func WithRetrievedChunks(state *entity.PipelineState, chunks ...[]*entity.Chunk) *entity.PipelineState + type CountRecord struct + Labels map[string]string + Operation string + Status string + Time time.Time + type DurationRecord struct + Duration time.Duration + Labels map[string]string + Operation string + Time time.Time + type LogEntry struct + Fields map[string]interface{} + Message string + type MetricRecord struct + Labels map[string]string + Name string + Time time.Time + Value float64 + type MockCollector struct + func NewMockCollector() *MockCollector + func (m *MockCollector) AssertCountRecorded(operation, status string) bool + func (m *MockCollector) AssertDurationRecorded(operation string) bool + func (m *MockCollector) CountCounts() int + func (m *MockCollector) CountDurations() int + func (m *MockCollector) CountValues() int + func (m *MockCollector) GetCounts() []CountRecord + func (m *MockCollector) GetDurations() []DurationRecord + func (m *MockCollector) GetValues() []MetricRecord + func (m *MockCollector) LastCountStatus() string + func (m *MockCollector) LastDuration() time.Duration + func (m *MockCollector) LastOperation() string + func (m *MockCollector) RecordCount(operation string, status string, labels map[string]string) + func (m *MockCollector) RecordDuration(operation string, duration time.Duration, labels map[string]string) + func (m *MockCollector) RecordValue(metricName string, value float64, labels map[string]string) + func (m *MockCollector) Reset() + func (m *MockCollector) TotalDuration(operation string) time.Duration + type MockLogger struct + func NewMockLogger() *MockLogger + func (m *MockLogger) AssertErrorContains(substring string) bool + func (m *MockLogger) AssertInfoContains(substring string) bool + func (m *MockLogger) CountErrors() int + func (m *MockLogger) CountInfos() int + func (m *MockLogger) Debug(message string, fields ...map[string]interface{}) + func (m *MockLogger) Error(message string, err error, fields ...map[string]interface{}) + func (m *MockLogger) GetDebugs() []LogEntry + func (m *MockLogger) GetErrors() []LogEntry + func (m *MockLogger) GetInfos() []LogEntry + func (m *MockLogger) GetWarns() []LogEntry + func (m *MockLogger) Info(message string, fields ...map[string]interface{}) + func (m *MockLogger) LastInfo() string + func (m *MockLogger) Reset() + func (m *MockLogger) Warn(message string, fields ...map[string]interface{})