session

package

v0.1.15 Latest Latest Go to latest Published: Apr 23, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager(detection func(ctx context.Context, sessionID string) error) *Manager

func (m *Manager) CloseAllSessions()

func (m *Manager) CloseSession(sessionID string)

func (m *Manager) CreateSession(sessionID string)

func (m *Manager) GetMessageForSend(ctx context.Context, sessionID string) ([]byte, error)

func (m *Manager) GetSession(sessionID string) (*State, bool)

func (m *Manager) IsEmpty() bool

func (m *Manager) IsExistSession(sessionID string) bool

func (m *Manager) RangeSessions(f func(sessionID string, state *State) bool)

func (m *Manager) SendMessage(ctx context.Context, sessionID string, message []byte) error

func (m *Manager) SetMaxIdleTime(d time.Duration)

func (m *Manager) StartHeartbeatAndCleanInvalidSessions()

func (m *Manager) StopHeartbeat()

func (m *Manager) UpdateSessionLastActiveAt(sessionID string)

type State struct {
	// contains filtered or unexported fields
}

func NewState() *State

func (s *State) Close()

func (s *State) GetReady() bool

func (s *State) GetReceivedInitRequest() bool

func (s *State) GetReqID2respChan() cmap.ConcurrentMap[string, chan *protocol.JSONRPCResponse]

func (s *State) GetSubscribedResources() cmap.ConcurrentMap[string, struct{}]

func (s *State) IncRequestID() int64

func (s *State) SetClientInfo(ClientInfo *protocol.Implementation, ClientCapabilities *protocol.ClientCapabilities)

func (s *State) SetReady()

func (s *State) SetReceivedInitRequest()