Documentation
¶
Index ¶
- func DeleteSession(payload DeleteSessionPayload)
- type CloseSessionPayload
- type DeleteSessionPayload
- type GetSessionPayload
- type NewSessionPayload
- type PLUGIN_IN_STREAM_EVENT
- type Session
- func (s *Session) BackwardsInvocation() dify_invocation.BackwardsInvocation
- func (s *Session) BindBackwardsInvocation(backwardsInvocation dify_invocation.BackwardsInvocation)
- func (s *Session) BindRuntime(runtime plugin_entities.PluginLifetime)
- func (s *Session) Close(payload CloseSessionPayload)
- func (s *Session) Message(event PLUGIN_IN_STREAM_EVENT, data any) []byte
- func (s *Session) Runtime() plugin_entities.PluginLifetime
- func (s *Session) Write(event PLUGIN_IN_STREAM_EVENT, action access_types.PluginAccessAction, data any) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteSession ¶
func DeleteSession(payload DeleteSessionPayload)
Types ¶
type CloseSessionPayload ¶
type CloseSessionPayload struct {
IgnoreCache bool `json:"ignore_cache"`
}
type DeleteSessionPayload ¶
type GetSessionPayload ¶
type NewSessionPayload ¶
type NewSessionPayload struct {
TenantID string `json:"tenant_id"`
UserID string `json:"user_id"`
PluginUniqueIdentifier plugin_entities.PluginUniqueIdentifier `json:"plugin_unique_identifier"`
ClusterID string `json:"cluster_id"`
InvokeFrom access_types.PluginAccessType `json:"invoke_from"`
Action access_types.PluginAccessAction `json:"action"`
Declaration *plugin_entities.PluginDeclaration `json:"declaration"`
BackwardsInvocation dify_invocation.BackwardsInvocation `json:"backwards_invocation"`
IgnoreCache bool `json:"ignore_cache"`
ConversationID *string `json:"conversation_id"`
MessageID *string `json:"message_id"`
AppID *string `json:"app_id"`
EndpointID *string `json:"endpoint_id"`
}
type PLUGIN_IN_STREAM_EVENT ¶
type PLUGIN_IN_STREAM_EVENT string
const ( PLUGIN_IN_STREAM_EVENT_REQUEST PLUGIN_IN_STREAM_EVENT = "request" PLUGIN_IN_STREAM_EVENT_RESPONSE PLUGIN_IN_STREAM_EVENT = "backwards_response" )
type Session ¶
type Session struct {
ID string `json:"id"`
TenantID string `json:"tenant_id"`
UserID string `json:"user_id"`
PluginUniqueIdentifier plugin_entities.PluginUniqueIdentifier `json:"plugin_unique_identifier"`
ClusterID string `json:"cluster_id"`
InvokeFrom access_types.PluginAccessType `json:"invoke_from"`
Action access_types.PluginAccessAction `json:"action"`
Declaration *plugin_entities.PluginDeclaration `json:"declaration"`
// information about incoming request
ConversationID *string `json:"conversation_id"`
MessageID *string `json:"message_id"`
AppID *string `json:"app_id"`
EndpointID *string `json:"endpoint_id"`
// contains filtered or unexported fields
}
session need to implement the backwards_invocation.BackwardsInvocationWriter interface
func GetSession ¶
func GetSession(payload GetSessionPayload) *Session
func NewSession ¶
func NewSession(payload NewSessionPayload) *Session
func (*Session) BackwardsInvocation ¶
func (s *Session) BackwardsInvocation() dify_invocation.BackwardsInvocation
func (*Session) BindBackwardsInvocation ¶
func (s *Session) BindBackwardsInvocation(backwardsInvocation dify_invocation.BackwardsInvocation)
func (*Session) BindRuntime ¶
func (s *Session) BindRuntime(runtime plugin_entities.PluginLifetime)
func (*Session) Close ¶
func (s *Session) Close(payload CloseSessionPayload)
func (*Session) Runtime ¶
func (s *Session) Runtime() plugin_entities.PluginLifetime
func (*Session) Write ¶
func (s *Session) Write(event PLUGIN_IN_STREAM_EVENT, action access_types.PluginAccessAction, data any) error
Click to show internal directories.
Click to hide internal directories.