Versions in this module Expand all Collapse all v0 v0.0.4 Mar 6, 2025 v0.0.3 Mar 6, 2025 Changes in this version + const CONNECTION_KEY_EXPIRE_TIME + const CONNECTION_KEY_LOCK + const CONNECTION_KEY_MANAGER_ID2KEY_PREFIX + const CONNECTION_KEY_MANAGER_KEY2ID_PREFIX + func ClearConnectionKey(tenant_id string) error + func GetConnectionKey(info ConnectionInfo) (string, error) + type ConnectionInfo struct + TenantId string + func GetConnectionInfo(key string) (*ConnectionInfo, error) + type DifyServer struct + func (s *DifyServer) OnBoot(c gnet.Engine) (action gnet.Action) + func (s *DifyServer) OnClose(c gnet.Conn, err error) (action gnet.Action) + func (s *DifyServer) OnOpen(c gnet.Conn) (out []byte, action gnet.Action) + func (s *DifyServer) OnShutdown(c gnet.Engine) + func (s *DifyServer) OnTraffic(c gnet.Conn) (action gnet.Action) + type Key struct + Key string + type RemotePluginRuntime struct + func (plugin *RemotePluginRuntime) Register() error + func (plugin *RemotePluginRuntime) Unregister() error + func (r *RemotePluginRuntime) Checksum() (string, error) + func (r *RemotePluginRuntime) Cleanup() + func (r *RemotePluginRuntime) Identity() (plugin_entities.PluginUniqueIdentifier, error) + func (r *RemotePluginRuntime) InitEnvironment() error + func (r *RemotePluginRuntime) Listen(session_id string) *entities.Broadcast[plugin_entities.SessionMessage] + func (r *RemotePluginRuntime) StartPlugin() error + func (r *RemotePluginRuntime) Stop() + func (r *RemotePluginRuntime) Stopped() bool + func (r *RemotePluginRuntime) Type() plugin_entities.PluginRuntimeType + func (r *RemotePluginRuntime) Wait() (<-chan bool, error) + func (r *RemotePluginRuntime) WaitStarted() <-chan bool + func (r *RemotePluginRuntime) WaitStopped() <-chan bool + func (r *RemotePluginRuntime) Write(session_id string, action access_types.PluginAccessAction, data []byte) + type RemotePluginServer struct + func NewRemotePluginServer(config *app.Config, media_transport *media_transport.MediaBucket) *RemotePluginServer + func (r *RemotePluginServer) Launch() error + func (r *RemotePluginServer) Next() bool + func (r *RemotePluginServer) Read() (plugin_entities.PluginFullDuplexLifetime, error) + func (r *RemotePluginServer) Stop() error + func (r *RemotePluginServer) Wrap(f func(plugin_entities.PluginFullDuplexLifetime)) + type RemotePluginServerInterface interface + Launch func() error + Next func() bool + Read func() (plugin_entities.PluginFullDuplexLifetime, error) + Stop func() error + Wrap func(f func(plugin_entities.PluginFullDuplexLifetime))
Go to main page