Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SessionManager ¶
type SessionManager struct {
// contains filtered or unexported fields
}
SessionManager manages TSS protocol sessions and handles incoming messages.
func NewSessionManager ¶
func NewSessionManager( eventStore *eventstore.Store, coord *coordinator.Coordinator, keyshareManager *keyshare.Manager, send SendFunc, partyID string, sessionExpiryTime time.Duration, logger zerolog.Logger, voteHandler *vote.Handler, ) *SessionManager
NewSessionManager creates a new session manager.
func (*SessionManager) HandleIncomingMessage ¶
func (sm *SessionManager) HandleIncomingMessage(ctx context.Context, peerID string, data []byte) error
HandleIncomingMessage handles an incoming message. peerID: The peer ID of the sender data: The raw message bytes (should be JSON-encoded coordinator.Message)
func (*SessionManager) StartExpiryChecker ¶
func (sm *SessionManager) StartExpiryChecker(ctx context.Context, checkInterval time.Duration, blockDelay uint64)
StartExpiryChecker starts a background goroutine that periodically checks for expired sessions.
Source Files
Click to show internal directories.
Click to hide internal directories.