mirror of
https://github.com/langgenius/dify-plugin-daemon.git
synced 2026-07-22 09:45:27 -04:00
Byron.wang
ca3d00229e
* use slog instead of log package and format to new log schema * update the environment name to LOG_OUTPUT_FORMAT * add the env to .env.example * fix log reference error * change the order of milldlewares * delete unused code * fix the concurrently session potential race condition * fix the log format in tests * update the duplicate code * refactor: convert log functions to slog structured format - Change log.Error/Info/Warn/Debug/Panic to accept msg + key-value pairs - Remove printf-style formatting from log functions - Update log calls in internal/cluster, internal/db, internal/core/session_manager - Remove unused 'initialized' variable from log package - Remaining files will be updated in follow-up commits 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * refactor: update all log call sites to use slog structured format Convert all log.Error, log.Info, log.Warn, log.Debug, and log.Panic calls from printf-style formatting to slog key-value pairs. Before: log.Error("failed to do something: %s", err.Error()) After: log.Error("failed to do something", "error", err) 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * refactor: update cmd/ log calls to use slog structured format 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> * feat: implement GnetLogger for structured logging in gnet * refactor: remove deprecated log visibility functions and related calls * feat: enhance session management with trace and identity context propagation * feat: implement serverless transaction handler and writer for plugin runtime * refactor: rename context field to traceCtx in RealBackwardsInvocation --------- Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com> Co-authored-by: Yeuoly <admin@srmxy.cn>
50 lines
2.2 KiB
Go
50 lines
2.2 KiB
Go
package dify_invocation
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/langgenius/dify-plugin-daemon/pkg/entities/model_entities"
|
|
"github.com/langgenius/dify-plugin-daemon/pkg/entities/tool_entities"
|
|
"github.com/langgenius/dify-plugin-daemon/pkg/utils/stream"
|
|
)
|
|
|
|
type BackwardsInvocation interface {
|
|
SetContext(ctx context.Context)
|
|
Context() context.Context
|
|
// InvokeLLM
|
|
InvokeLLM(payload *InvokeLLMRequest) (*stream.Stream[model_entities.LLMResultChunk], error)
|
|
// InvokeLLMWithStructuredOutput
|
|
InvokeLLMWithStructuredOutput(payload *InvokeLLMWithStructuredOutputRequest) (
|
|
*stream.Stream[model_entities.LLMResultChunkWithStructuredOutput], error)
|
|
// InvokeTextEmbedding
|
|
InvokeTextEmbedding(payload *InvokeTextEmbeddingRequest) (*model_entities.TextEmbeddingResult, error)
|
|
// InvokeMultimodalEmbedding
|
|
InvokeMultimodalEmbedding(payload *InvokeMultimodalEmbeddingRequest) (*model_entities.MultimodalEmbeddingResult, error)
|
|
// InvokeRerank
|
|
InvokeRerank(payload *InvokeRerankRequest) (*model_entities.RerankResult, error)
|
|
// InvokeMultimodalRerank
|
|
InvokeMultimodalRerank(payload *InvokeMultimodalRerankRequest) (*model_entities.MultimodalRerankResult, error)
|
|
// InvokeTTS
|
|
InvokeTTS(payload *InvokeTTSRequest) (*stream.Stream[model_entities.TTSResult], error)
|
|
// InvokeSpeech2Text
|
|
InvokeSpeech2Text(payload *InvokeSpeech2TextRequest) (*model_entities.Speech2TextResult, error)
|
|
// InvokeModeration
|
|
InvokeModeration(payload *InvokeModerationRequest) (*model_entities.ModerationResult, error)
|
|
// InvokeTool
|
|
InvokeTool(payload *InvokeToolRequest) (*stream.Stream[tool_entities.ToolResponseChunk], error)
|
|
// InvokeApp
|
|
InvokeApp(payload *InvokeAppRequest) (*stream.Stream[map[string]any], error)
|
|
// InvokeParameterExtractor
|
|
InvokeParameterExtractor(payload *InvokeParameterExtractorRequest) (*InvokeNodeResponse, error)
|
|
// InvokeQuestionClassifier
|
|
InvokeQuestionClassifier(payload *InvokeQuestionClassifierRequest) (*InvokeNodeResponse, error)
|
|
// InvokeEncrypt
|
|
InvokeEncrypt(payload *InvokeEncryptRequest) (map[string]any, error)
|
|
// InvokeSummary
|
|
InvokeSummary(payload *InvokeSummaryRequest) (*InvokeSummaryResponse, error)
|
|
// UploadFile
|
|
UploadFile(payload *UploadFileRequest) (*UploadFileResponse, error)
|
|
// FetchApp
|
|
FetchApp(payload *FetchAppRequest) (map[string]any, error)
|
|
}
|