Documentation
¶
Index ¶
- Constants
- type MockPrometheus
- type MongoTestDB
- func (m *MongoTestDB) ArchiveConversation(ctx context.Context, conversationID string, days int) error
- func (m *MongoTestDB) ArchiveConversationOnly(ctx context.Context, conversationID string, days int) error
- func (m *MongoTestDB) ClaimReadyTasks(ctx context.Context, limit int) ([]cucumber.TaskRow, error)
- func (m *MongoTestDB) ClearAll(ctx context.Context) error
- func (m *MongoTestDB) CountTasks(ctx context.Context) (int, error)
- func (m *MongoTestDB) CreateFailedTask(ctx context.Context, id, taskType, body string) error
- func (m *MongoTestDB) CreateTask(ctx context.Context, id, taskType, body string) error
- func (m *MongoTestDB) DeleteAllTasks(ctx context.Context) error
- func (m *MongoTestDB) DeleteTask(ctx context.Context, id string) error
- func (m *MongoTestDB) ExecMongoQuery(ctx context.Context, query string) ([]map[string]interface{}, error)
- func (m *MongoTestDB) ExecSQL(_ context.Context, _ string) ([]map[string]interface{}, error)
- func (m *MongoTestDB) FailTask(ctx context.Context, id, errMsg string) error
- func (m *MongoTestDB) GetTask(ctx context.Context, id string) (*cucumber.TaskRow, error)
- func (m *MongoTestDB) ResolveGroupID(ctx context.Context, conversationID string) (string, error)
- type PostgresTestDB
- func (p *PostgresTestDB) ArchiveConversation(ctx context.Context, conversationID string, days int) error
- func (p *PostgresTestDB) ArchiveConversationOnly(ctx context.Context, conversationID string, days int) error
- func (p *PostgresTestDB) ClaimReadyTasks(ctx context.Context, limit int) ([]cucumber.TaskRow, error)
- func (p *PostgresTestDB) ClearAll(ctx context.Context) error
- func (p *PostgresTestDB) CountTasks(ctx context.Context) (int, error)
- func (p *PostgresTestDB) CreateFailedTask(ctx context.Context, id, taskType, body string) error
- func (p *PostgresTestDB) CreateTask(ctx context.Context, id, taskType, body string) error
- func (p *PostgresTestDB) DeleteAllTasks(ctx context.Context) error
- func (p *PostgresTestDB) DeleteTask(ctx context.Context, id string) error
- func (p *PostgresTestDB) ExecMongoQuery(_ context.Context, _ string) ([]map[string]interface{}, error)
- func (p *PostgresTestDB) ExecSQL(ctx context.Context, query string) ([]map[string]interface{}, error)
- func (p *PostgresTestDB) FailTask(ctx context.Context, id, errMsg string) error
- func (p *PostgresTestDB) GetTask(ctx context.Context, id string) (*cucumber.TaskRow, error)
- func (p *PostgresTestDB) ResolveGroupID(ctx context.Context, conversationID string) (string, error)
- type SQLiteTestDB
- func (s *SQLiteTestDB) ArchiveConversation(ctx context.Context, conversationID string, days int) error
- func (s *SQLiteTestDB) ArchiveConversationOnly(ctx context.Context, conversationID string, days int) error
- func (s *SQLiteTestDB) ClaimReadyTasks(ctx context.Context, limit int) ([]cucumber.TaskRow, error)
- func (s *SQLiteTestDB) ClearAll(ctx context.Context) error
- func (s *SQLiteTestDB) CountTasks(ctx context.Context) (int, error)
- func (s *SQLiteTestDB) CreateFailedTask(ctx context.Context, id, taskType, body string) error
- func (s *SQLiteTestDB) CreateTask(ctx context.Context, id, taskType, body string) error
- func (s *SQLiteTestDB) DeleteAllTasks(ctx context.Context) error
- func (s *SQLiteTestDB) DeleteTask(ctx context.Context, id string) error
- func (s *SQLiteTestDB) ExecMongoQuery(_ context.Context, _ string) ([]map[string]interface{}, error)
- func (s *SQLiteTestDB) ExecSQL(ctx context.Context, query string) ([]map[string]interface{}, error)
- func (s *SQLiteTestDB) FailTask(ctx context.Context, id, errMsg string) error
- func (s *SQLiteTestDB) GetTask(ctx context.Context, id string) (*cucumber.TaskRow, error)
- func (s *SQLiteTestDB) ResolveGroupID(ctx context.Context, conversationID string) (string, error)
Constants ¶
View Source
const OIDCTokenProviderExtraKey = "oidcTokenProvider"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockPrometheus ¶
MockPrometheus is a controllable mock Prometheus server for BDD tests.
func NewMockPrometheus ¶
func NewMockPrometheus(t *testing.T) *MockPrometheus
NewMockPrometheus creates a mock Prometheus that returns canned time-series responses.
func (*MockPrometheus) SetAvailable ¶
func (m *MockPrometheus) SetAvailable(value bool)
SetAvailable toggles whether mock Prometheus returns success or 503.
type MongoTestDB ¶
type MongoTestDB struct {
DBURL string
}
MongoTestDB implements cucumber.TestDB for MongoDB.
func (*MongoTestDB) ArchiveConversation ¶
func (*MongoTestDB) ArchiveConversationOnly ¶
func (*MongoTestDB) ClaimReadyTasks ¶
func (*MongoTestDB) CountTasks ¶
func (m *MongoTestDB) CountTasks(ctx context.Context) (int, error)
func (*MongoTestDB) CreateFailedTask ¶
func (m *MongoTestDB) CreateFailedTask(ctx context.Context, id, taskType, body string) error
func (*MongoTestDB) CreateTask ¶
func (m *MongoTestDB) CreateTask(ctx context.Context, id, taskType, body string) error
func (*MongoTestDB) DeleteAllTasks ¶
func (m *MongoTestDB) DeleteAllTasks(ctx context.Context) error
func (*MongoTestDB) DeleteTask ¶
func (m *MongoTestDB) DeleteTask(ctx context.Context, id string) error
func (*MongoTestDB) ExecMongoQuery ¶
func (*MongoTestDB) FailTask ¶
func (m *MongoTestDB) FailTask(ctx context.Context, id, errMsg string) error
func (*MongoTestDB) ResolveGroupID ¶
type PostgresTestDB ¶
type PostgresTestDB struct {
DBURL string
}
PostgresTestDB implements cucumber.TestDB for Postgres.
func (*PostgresTestDB) ArchiveConversation ¶
func (*PostgresTestDB) ArchiveConversationOnly ¶
func (*PostgresTestDB) ClaimReadyTasks ¶
func (*PostgresTestDB) CountTasks ¶
func (p *PostgresTestDB) CountTasks(ctx context.Context) (int, error)
func (*PostgresTestDB) CreateFailedTask ¶
func (p *PostgresTestDB) CreateFailedTask(ctx context.Context, id, taskType, body string) error
func (*PostgresTestDB) CreateTask ¶
func (p *PostgresTestDB) CreateTask(ctx context.Context, id, taskType, body string) error
func (*PostgresTestDB) DeleteAllTasks ¶
func (p *PostgresTestDB) DeleteAllTasks(ctx context.Context) error
func (*PostgresTestDB) DeleteTask ¶
func (p *PostgresTestDB) DeleteTask(ctx context.Context, id string) error
func (*PostgresTestDB) ExecMongoQuery ¶
func (*PostgresTestDB) FailTask ¶
func (p *PostgresTestDB) FailTask(ctx context.Context, id, errMsg string) error
func (*PostgresTestDB) ResolveGroupID ¶
type SQLiteTestDB ¶
type SQLiteTestDB struct {
DBURL string
// contains filtered or unexported fields
}
SQLiteTestDB implements cucumber.TestDB for SQLite.
func (*SQLiteTestDB) ArchiveConversation ¶
func (*SQLiteTestDB) ArchiveConversationOnly ¶
func (*SQLiteTestDB) ClaimReadyTasks ¶
func (*SQLiteTestDB) CountTasks ¶
func (s *SQLiteTestDB) CountTasks(ctx context.Context) (int, error)
func (*SQLiteTestDB) CreateFailedTask ¶
func (s *SQLiteTestDB) CreateFailedTask(ctx context.Context, id, taskType, body string) error
func (*SQLiteTestDB) CreateTask ¶
func (s *SQLiteTestDB) CreateTask(ctx context.Context, id, taskType, body string) error
func (*SQLiteTestDB) DeleteAllTasks ¶
func (s *SQLiteTestDB) DeleteAllTasks(ctx context.Context) error
func (*SQLiteTestDB) DeleteTask ¶
func (s *SQLiteTestDB) DeleteTask(ctx context.Context, id string) error
func (*SQLiteTestDB) ExecMongoQuery ¶
func (*SQLiteTestDB) FailTask ¶
func (s *SQLiteTestDB) FailTask(ctx context.Context, id, errMsg string) error
func (*SQLiteTestDB) ResolveGroupID ¶
Source Files
¶
- feature_selection.go
- mock_prometheus.go
- steps_admin.go
- steps_admin_stats.go
- steps_attachments.go
- steps_auth.go
- steps_cache.go
- steps_cleanup_serial.go
- steps_clustering.go
- steps_conversations.go
- steps_domain_assertions.go
- steps_entries.go
- steps_eviction.go
- steps_grpc.go
- steps_mcp.go
- steps_memberships.go
- steps_mongo.go
- steps_oidc.go
- steps_query_assertions.go
- steps_sql.go
- steps_sse_events.go
- steps_sse_events_grpc.go
- steps_taskqueue.go
- steps_turn_traces.go
- testdb_mongo.go
- testdb_postgres.go
- testdb_sqlite.go
Click to show internal directories.
Click to hide internal directories.