Skip to main content

Crate data_connector

Crate data_connector 

Source
Expand description

Data connector module for response storage and conversation storage.

Provides storage backends for:

  • Conversations
  • Conversation items
  • Responses

Supported backends:

  • Memory (default)
  • None (no-op)
  • Oracle ATP
  • Postgres
  • Redis

Re-exports§

pub use config::HistoryBackend;
pub use config::OracleConfig;
pub use config::PostgresConfig;
pub use config::RedisConfig;
pub use context::current_extra_columns;
pub use context::current_request_context;
pub use context::with_extra_columns;
pub use context::with_request_context;
pub use context::RequestContext;
pub use hooks::BeforeHookResult;
pub use hooks::ExtraColumns;
pub use hooks::HookError;
pub use hooks::StorageHook;
pub use hooks::StorageOperation;
pub use schema::ColumnDef;
pub use schema::SchemaConfig;
pub use schema::TableConfig;

Modules§

config
Storage backend configuration types.
context
Per-request context and hook data bridge for storage hooks.
hooks
Storage hook trait and supporting types.
schema
Schema configuration for storage backends.

Structs§

Conversation
Stored conversation data structure
ConversationId
ConversationItem
ConversationItemId
ConversationMemoryId
ListParams
MemoryConversationItemStorage
MemoryConversationStorage
In-memory conversation storage used for development and tests
MemoryResponseStorage
In-memory implementation of response storage
NewConversation
Input payload for creating a conversation
NewConversationItem
NewConversationMemory
Insert-only payload for creating a new conversation memory row.
ResponseId
Response identifier
StorageFactoryConfig
Configuration for creating storage backends
StoredResponse
Stored response data

Enums§

ConversationMemoryStatus
ConversationMemoryStorageError
ConversationMemoryType
ResponseStorageError
Error type for response storage operations
SortOrder

Traits§

ConversationItemStorage
ConversationMemoryWriter
ConversationStorage
Trait describing the CRUD interface for conversation storage backends
ResponseStorage
Trait for response storage

Functions§

create_storage
Create all three storage backends based on configuration.

Type Aliases§

ConversationMemoryResult