Documentation
¶
Index ¶
- func CloseConnections()
- func ExecuteCommand(ctx context.Context, dbType, connStr, command string) (interface{}, error)
- func ExecuteQuery(ctx context.Context, dbType, connStr, query string) (interface{}, error)
- func GetSchema(ctx context.Context, dbType, connStr string) (interface{}, error)
- func NaturalLanguageToSQL(ctx context.Context, question, dbType string) (string, error)
- func TestConnection(ctx context.Context, dbType, connStr string) error
- type DragonflyAdapter
- func (a *DragonflyAdapter) Close() error
- func (a *DragonflyAdapter) Execute(ctx context.Context, command string) (interface{}, error)
- func (a *DragonflyAdapter) GetSchema(ctx context.Context) (interface{}, error)
- func (a *DragonflyAdapter) Query(ctx context.Context, command string) (interface{}, error)
- type RAGflowAdapter
- func (a *RAGflowAdapter) Close() error
- func (a *RAGflowAdapter) Execute(ctx context.Context, command string) (interface{}, error)
- func (a *RAGflowAdapter) GetSchema(ctx context.Context) (interface{}, error)
- func (a *RAGflowAdapter) GetVectorSearch(ctx context.Context, tableName, vectorColumn, whereClause string, ...) (interface{}, error)
- func (a *RAGflowAdapter) Query(ctx context.Context, query string) (interface{}, error)
- type RocketMQAdapter
- type RocketMQClient
- type SupabaseAdapter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseConnections ¶
func CloseConnections()
func ExecuteCommand ¶
func ExecuteQuery ¶
func NaturalLanguageToSQL ¶
Types ¶
type DragonflyAdapter ¶
type DragonflyAdapter struct {
// contains filtered or unexported fields
}
func NewDragonflyAdapter ¶
func NewDragonflyAdapter(connStr string) (*DragonflyAdapter, error)
func (*DragonflyAdapter) Close ¶
func (a *DragonflyAdapter) Close() error
func (*DragonflyAdapter) Execute ¶
func (a *DragonflyAdapter) Execute(ctx context.Context, command string) (interface{}, error)
type RAGflowAdapter ¶
type RAGflowAdapter struct {
// contains filtered or unexported fields
}
func NewRAGflowAdapter ¶
func NewRAGflowAdapter(connStr string) (*RAGflowAdapter, error)
func (*RAGflowAdapter) Close ¶
func (a *RAGflowAdapter) Close() error
func (*RAGflowAdapter) Execute ¶
func (a *RAGflowAdapter) Execute(ctx context.Context, command string) (interface{}, error)
func (*RAGflowAdapter) GetSchema ¶
func (a *RAGflowAdapter) GetSchema(ctx context.Context) (interface{}, error)
func (*RAGflowAdapter) GetVectorSearch ¶
type RocketMQAdapter ¶
type RocketMQAdapter struct {
// contains filtered or unexported fields
}
func NewRocketMQAdapter ¶
func NewRocketMQAdapter(connStr string) (*RocketMQAdapter, error)
func (*RocketMQAdapter) Close ¶
func (a *RocketMQAdapter) Close() error
func (*RocketMQAdapter) Execute ¶
func (a *RocketMQAdapter) Execute(ctx context.Context, command string) (interface{}, error)
type RocketMQClient ¶
type RocketMQClient interface {
CreateTopic(ctx context.Context, topic string) error
DeleteTopic(ctx context.Context, topic string) error
ListTopics(ctx context.Context) ([]string, error)
SendMessage(ctx context.Context, topic, message string) error
ConsumeMessages(ctx context.Context, topic, group string, count int) ([]string, error)
GetTopicStats(ctx context.Context, topic string) (map[string]interface{}, error)
}
type SupabaseAdapter ¶
type SupabaseAdapter struct {
// contains filtered or unexported fields
}
func NewSupabaseAdapter ¶
func NewSupabaseAdapter(connStr string) (*SupabaseAdapter, error)
func (*SupabaseAdapter) Close ¶
func (a *SupabaseAdapter) Close() error
func (*SupabaseAdapter) Execute ¶
func (a *SupabaseAdapter) Execute(ctx context.Context, command string) (interface{}, error)
Source Files
Click to show internal directories.
Click to hide internal directories.