session_manager

package
v0.0.3 Latest Latest
Warning

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

Go to latest
Published: Mar 6, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

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 DeleteSessionPayload struct {
	ID          string `json:"id"`
	IgnoreCache bool   `json:"ignore_cache"`
}

type GetSessionPayload

type GetSessionPayload struct {
	ID          string `json:"id"`
	IgnoreCache bool   `json:"ignore_cache"`
}

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) Message

func (s *Session) Message(event PLUGIN_IN_STREAM_EVENT, data any) []byte

func (*Session) Runtime

func (s *Session) Runtime() plugin_entities.PluginLifetime

func (*Session) Write

Jump to

Keyboard shortcuts

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