providers

package
v1.4.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 26, 2025 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetGlobalTransport added in v1.4.7 

func GetGlobalTransport() *http.Transport

func GetPooledHTTPClient added in v1.4.7 

func GetPooledHTTPClient() *http.Client

Types

type ConnectionPoolConfig added in v1.4.7 

type ConnectionPoolConfig struct {
	MaxSize     int
	IdleTimeout time.Duration
	DialTimeout time.Duration
	KeepAlive   time.Duration
}

func DefaultConnectionPoolConfig added in v1.4.7 

func DefaultConnectionPoolConfig() ConnectionPoolConfig

type LangChainLLMProvider 

type LangChainLLMProvider struct {
	// contains filtered or unexported fields
}

LangChainLLMProvider LangChain LLM provider

func NewLangChainLLMProvider 

func NewLangChainLLMProvider(model llms.Model, modelName string) *LangChainLLMProvider

NewLangChainLLMProvider creates a new LangChain LLM provider

func (*LangChainLLMProvider) Chat 

func (p *LangChainLLMProvider) Chat(messages []types.Message) (types.Message, error)

Chat basic chat functionality

func (*LangChainLLMProvider) ChatStream 

func (p *LangChainLLMProvider) ChatStream(messages []types.Message) (<-chan types.StreamMessage, error)

ChatStream streaming chat functionality

func (*LangChainLLMProvider) ChatWithTools 

func (p *LangChainLLMProvider) ChatWithTools(messages []types.Message, tools []types.Tool) (types.Message, error)

ChatWithTools chat with tools functionality

func (*LangChainLLMProvider) ChatWithToolsStream 

func (p *LangChainLLMProvider) ChatWithToolsStream(messages []types.Message, tools []types.Tool) (<-chan types.StreamMessage, error)

ChatWithToolsStream streaming chat with tools functionality

func (*LangChainLLMProvider) GetModelMetadata 

func (p *LangChainLLMProvider) GetModelMetadata() types.ModelMetadata

GetModelMetadata gets the model metadata

func (*LangChainLLMProvider) GetModelName 

func (p *LangChainLLMProvider) GetModelName() string

GetModelName gets the model name

func (*LangChainLLMProvider) SetMaxRetries added in v1.4.2 

func (p *LangChainLLMProvider) SetMaxRetries(maxRetries int)

SetMaxRetries sets maximum retry attempts

func (*LangChainLLMProvider) SetRetryDelay added in v1.4.2 

func (p *LangChainLLMProvider) SetRetryDelay(delay time.Duration)

SetRetryDelay sets retry delay duration

type MessageDocument added in v1.1.0 

type MessageDocument struct {
	ID        primitive.ObjectID `bson:"_id,omitempty"`
	SessionID string             `bson:"session_id"`
	Role      string             `bson:"role"`
	Content   string             `bson:"content"`
	Name      string             `bson:"name,omitempty"`
	CreatedAt time.Time          `bson:"created_at"`
}

type MongoDBMemoryProvider added in v1.1.0 

type MongoDBMemoryProvider struct {
	// contains filtered or unexported fields
}

func NewMongoDBMemoryProvider added in v1.1.0 

func NewMongoDBMemoryProvider(client *mongodb.Client, sessionID string) *MongoDBMemoryProvider

func NewMongoDBMemoryProviderWithLimit added in v1.1.0 

func NewMongoDBMemoryProviderWithLimit(client *mongodb.Client, sessionID string, maxHistoryMessages int) *MongoDBMemoryProvider

func (*MongoDBMemoryProvider) AddMessage added in v1.1.0 

func (p *MongoDBMemoryProvider) AddMessage(ctx context.Context, message types.Message) error

func (*MongoDBMemoryProvider) Clear added in v1.1.0 

func (p *MongoDBMemoryProvider) Clear() error

func (*MongoDBMemoryProvider) CompressMemory added in v1.4.3 

func (p *MongoDBMemoryProvider) CompressMemory(llm types.LLMProvider, maxMessages int) error

CompressMemory compresses old messages into a summary (implements MemoryProvider interface)

func (*MongoDBMemoryProvider) GetChatHistory added in v1.1.0 

func (p *MongoDBMemoryProvider) GetChatHistory() ([]types.Message, error)

func (*MongoDBMemoryProvider) GetMessages added in v1.1.0 

func (p *MongoDBMemoryProvider) GetMessages(ctx context.Context, limit int) ([]types.Message, error)

func (*MongoDBMemoryProvider) LoadMemoryVariables added in v1.1.0 

func (p *MongoDBMemoryProvider) LoadMemoryVariables() (map[string]interface{}, error)

func (*MongoDBMemoryProvider) SaveContext added in v1.1.0 

func (p *MongoDBMemoryProvider) SaveContext(input, output map[string]interface{}) error

func (*MongoDBMemoryProvider) SetCollectionName added in v1.1.0 

func (p *MongoDBMemoryProvider) SetCollectionName(name string)

func (*MongoDBMemoryProvider) SetMaxHistoryMessages added in v1.1.0 

func (p *MongoDBMemoryProvider) SetMaxHistoryMessages(limit int)

type RedisMemoryProvider added in v1.1.0 

type RedisMemoryProvider struct {
	// contains filtered or unexported fields
}

func NewRedisMemoryProvider added in v1.1.0 

func NewRedisMemoryProvider(client *redis.Client, sessionID string) *RedisMemoryProvider

func NewRedisMemoryProviderWithLimit added in v1.1.0 

func NewRedisMemoryProviderWithLimit(client *redis.Client, sessionID string, maxHistoryMessages int) *RedisMemoryProvider

func (*RedisMemoryProvider) AddMessage added in v1.1.0 

func (p *RedisMemoryProvider) AddMessage(ctx context.Context, message types.Message) error

func (*RedisMemoryProvider) Clear added in v1.1.0 

func (p *RedisMemoryProvider) Clear() error

func (*RedisMemoryProvider) CompressMemory added in v1.4.3 

func (p *RedisMemoryProvider) CompressMemory(llm types.LLMProvider, maxMessages int) error

CompressMemory compresses old messages into a summary (implements MemoryProvider interface)

func (*RedisMemoryProvider) GetChatHistory added in v1.1.0 

func (p *RedisMemoryProvider) GetChatHistory() ([]types.Message, error)

func (*RedisMemoryProvider) GetMessages added in v1.1.0 

func (p *RedisMemoryProvider) GetMessages(ctx context.Context, limit int) ([]types.Message, error)

func (*RedisMemoryProvider) LoadMemoryVariables added in v1.1.0 

func (p *RedisMemoryProvider) LoadMemoryVariables() (map[string]interface{}, error)

func (*RedisMemoryProvider) SaveContext added in v1.1.0 

func (p *RedisMemoryProvider) SaveContext(input, output map[string]interface{}) error

func (*RedisMemoryProvider) SetKeyPrefix added in v1.1.0 

func (p *RedisMemoryProvider) SetKeyPrefix(prefix string)

func (*RedisMemoryProvider) SetMaxHistoryMessages added in v1.1.0 

func (p *RedisMemoryProvider) SetMaxHistoryMessages(limit int)

type SimpleMemoryProvider 

type SimpleMemoryProvider struct {
	// contains filtered or unexported fields
}

SimpleMemoryProvider simple memory provider implementation

func NewSimpleMemoryProvider 

func NewSimpleMemoryProvider() *SimpleMemoryProvider

NewSimpleMemoryProvider creates a new simple memory provider

func NewSimpleMemoryProviderWithLimit added in v1.1.0 

func NewSimpleMemoryProviderWithLimit(maxHistoryMessages int) *SimpleMemoryProvider

NewSimpleMemoryProviderWithLimit creates a new simple memory provider with max history limit

func (*SimpleMemoryProvider) AddMessage 

func (p *SimpleMemoryProvider) AddMessage(ctx context.Context, message types.Message) error

AddMessage adds a message

func (*SimpleMemoryProvider) Clear 

func (p *SimpleMemoryProvider) Clear() error

Clear clears memory (implements MemoryProvider interface)

func (*SimpleMemoryProvider) ClearWithContext added in v1.1.0 

func (p *SimpleMemoryProvider) ClearWithContext(ctx context.Context) error

ClearWithContext clears memory with context (for backward compatibility)

func (*SimpleMemoryProvider) CompressMemory added in v1.4.3 

func (p *SimpleMemoryProvider) CompressMemory(llm types.LLMProvider, maxMessages int) error

CompressMemory compresses old messages into a summary (implements MemoryProvider interface) Optimized to avoid holding lock during LLM call to prevent blocking other operations

func (*SimpleMemoryProvider) GetChatHistory added in v1.1.0 

func (p *SimpleMemoryProvider) GetChatHistory() ([]types.Message, error)

GetChatHistory gets chat history (implements MemoryProvider interface)

func (*SimpleMemoryProvider) GetMessages 

func (p *SimpleMemoryProvider) GetMessages(ctx context.Context, limit int) ([]types.Message, error)

GetMessages gets messages

func (*SimpleMemoryProvider) LoadMemoryVariables added in v1.1.0 

func (p *SimpleMemoryProvider) LoadMemoryVariables() (map[string]interface{}, error)

LoadMemoryVariables loads memory variables (implements MemoryProvider interface)

func (*SimpleMemoryProvider) SaveContext added in v1.1.0 

func (p *SimpleMemoryProvider) SaveContext(input, output map[string]interface{}) error

SaveContext saves context (implements MemoryProvider interface)

func (*SimpleMemoryProvider) SetMaxHistoryMessages added in v1.1.0 

func (p *SimpleMemoryProvider) SetMaxHistoryMessages(limit int)

SetMaxHistoryMessages sets the maximum history messages limit

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.