Documentation
¶
Index ¶
- type CommonConversationManager
- type ConversationManagerOptions
- func WithConversationID(conversationId string) ConversationManagerOptions
- func WithMessageID(msgId string) ConversationManagerOptions
- func WithPersistence(customAdapter ConversationPersistenceAdapter) ConversationManagerOptions
- func WithSummarizer(summarizer core.HistorySummarizer) ConversationManagerOptions
- type ConversationPersistenceAdapter
- type ConversationRunManager
- func (cm *ConversationRunManager) AddMessages(ctx context.Context, messages []responses.InputMessageUnion, ...)
- func (cm *ConversationRunManager) GetMessageID() string
- func (cm *ConversationRunManager) GetMessages(ctx context.Context) ([]responses.InputMessageUnion, error)
- func (cm *ConversationRunManager) GetMeta() map[string]any
- func (cm *ConversationRunManager) LoadMessages(ctx context.Context, namespace string, previousMessageID string) ([]responses.InputMessageUnion, error)
- func (cm *ConversationRunManager) SaveMessages(ctx context.Context, meta map[string]any) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommonConversationManager ¶
type CommonConversationManager struct {
ConversationPersistenceAdapter ConversationPersistenceAdapter
// contains filtered or unexported fields
}
func NewConversationManager ¶
func NewConversationManager(p ConversationPersistenceAdapter, opts ...ConversationManagerOptions) *CommonConversationManager
func (*CommonConversationManager) NewRun ¶
func (cm *CommonConversationManager) NewRun() *ConversationRunManager
type ConversationManagerOptions ¶
type ConversationManagerOptions func(*ConversationRunManager)
func WithConversationID ¶
func WithConversationID(conversationId string) ConversationManagerOptions
func WithMessageID ¶
func WithMessageID(msgId string) ConversationManagerOptions
func WithPersistence ¶
func WithPersistence(customAdapter ConversationPersistenceAdapter) ConversationManagerOptions
func WithSummarizer ¶
func WithSummarizer(summarizer core.HistorySummarizer) ConversationManagerOptions
type ConversationPersistenceAdapter ¶
type ConversationPersistenceAdapter interface {
LoadMessages(ctx context.Context, namespace string, previousMessageID string) ([]conversation.ConversationMessage, error)
SaveMessages(ctx context.Context, namespace, msgId, previousMsgId, conversationId string, messages []responses.InputMessageUnion, meta map[string]any) error
SaveSummary(ctx context.Context, namespace string, summary conversation.Summary) error
}
type ConversationRunManager ¶
type ConversationRunManager struct {
ConversationPersistenceAdapter
// contains filtered or unexported fields
}
func (*ConversationRunManager) AddMessages ¶
func (cm *ConversationRunManager) AddMessages(ctx context.Context, messages []responses.InputMessageUnion, usage *responses.Usage)
func (*ConversationRunManager) GetMessageID ¶
func (cm *ConversationRunManager) GetMessageID() string
GetMessageID returns the current run id
func (*ConversationRunManager) GetMessages ¶
func (cm *ConversationRunManager) GetMessages(ctx context.Context) ([]responses.InputMessageUnion, error)
func (*ConversationRunManager) GetMeta ¶
func (cm *ConversationRunManager) GetMeta() map[string]any
GetMeta returns the meta from the most recent message
func (*ConversationRunManager) LoadMessages ¶
func (cm *ConversationRunManager) LoadMessages(ctx context.Context, namespace string, previousMessageID string) ([]responses.InputMessageUnion, error)
func (*ConversationRunManager) SaveMessages ¶
Click to show internal directories.
Click to hide internal directories.