storage

package

Go to main page

Versions in this module

v0

v0.2.2

Apr 12, 2024

Changes in this version

type Conversation

+ Icon string

v0.2.1

Mar 24, 2024

Changes in this version

type Document

+ ConversationID string

+ Object string

type Message

+ Action string

+ Files []string

+ RawFiles string

+ func (m *Message) AfterFind(tx *gorm.DB) error

v0.2.0

Feb 28, 2024

Changes in this version

+ var ErrConversationNotFound = errors.New("conversation is not found")

+ type Conversation struct

+ AppName string

+ AppNamespace string

+ Debug bool

+ DeletedAt gorm.DeletedAt

+ ID string

+ Messages []Message

+ StartedAt time.Time

+ UpdatedAt time.Time

+ User string

+ func (Conversation) TableName() string

+ type ConversationStorage interface

+ Delete func(opts ...SearchOption) error

+ FindExistingConversation func(ID string, opts ...SearchOption) (*Conversation, error)

+ ListConversations func(opts ...SearchOption) ([]Conversation, error)

+ UpdateConversation func(*Conversation) error

+ type Document struct

+ ID string

+ MessageID string

+ Name string

+ Summary string

+ func (Document) TableName() string

+ type DocumentStorage interface

+ FindExistingDocument func(conversationID, messageID, documentID string, opts ...SearchOption) (*Document, error)

+ type MemoryStorage struct

+ func NewMemoryStorage() *MemoryStorage

+ func (m *MemoryStorage) CountMessages(appName, appNamespace string) (res int64, err error)

+ func (m *MemoryStorage) Delete(opts ...SearchOption) (err error)

+ func (m *MemoryStorage) FindExistingConversation(conversationID string, opt ...SearchOption) (*Conversation, error)

+ func (m *MemoryStorage) FindExistingDocument(conversationID string, messageID string, documentID string, ...) (*Document, error)

+ func (m *MemoryStorage) FindExistingMessage(conversationID string, messageID string, opts ...SearchOption) (*Message, error)

+ func (m *MemoryStorage) ListConversations(opts ...SearchOption) (conversations []Conversation, err error)

+ func (m *MemoryStorage) UpdateConversation(conversation *Conversation) error

+ type Message struct

+ Answer string

+ ConversationID string

+ Documents []Document

+ ID string

+ Latency int64

+ Query string

+ References References

+ func (Message) TableName() string

+ type MessageStorage interface

+ CountMessages func(appName, appNamespace string) (int64, error)

+ FindExistingMessage func(conversationID, messageID string, opts ...SearchOption) (*Message, error)

+ type PostgreSQLStorage struct

+ func NewPostgreSQLStorage(conn *pgx.Conn) (*PostgreSQLStorage, error)

+ func (p *PostgreSQLStorage) CountMessages(appName, appNamespace string) (int64, error)

+ func (p *PostgreSQLStorage) Delete(opts ...SearchOption) error

+ func (p *PostgreSQLStorage) FindExistingConversation(conversationID string, opts ...SearchOption) (*Conversation, error)

+ func (p *PostgreSQLStorage) FindExistingDocument(conversationID, messageID string, documentID string, opts ...SearchOption) (*Document, error)

+ func (p *PostgreSQLStorage) FindExistingMessage(conversationID string, messageID string, opts ...SearchOption) (*Message, error)

+ func (p *PostgreSQLStorage) ListConversations(opts ...SearchOption) ([]Conversation, error)

+ func (p *PostgreSQLStorage) UpdateConversation(conversation *Conversation) error

+ type References []retriever.Reference

+ func (r *References) Scan(value interface{}) error

+ func (r References) Value() (driver.Value, error)

+ type Search struct

+ AppName *string

+ AppNamespace *string

+ ConversationID *string

+ Debug *bool

+ MessageID *string

+ User *string

+ func NewSearchOptions(conversationID *string) *Search

+ type SearchOption func(options *Search)

+ func WithAppName(name string) SearchOption

+ func WithAppNamespace(name string) SearchOption

+ func WithConversationID(id string) SearchOption

+ func WithDebug(debug bool) SearchOption

+ func WithMessageID(id string) SearchOption

+ func WithUser(name string) SearchOption

+ type Storage interface

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