ironhawk

package

v1.0.10 Latest Latest Go to latest Published: Apr 30, 2025 License: BSD-3-Clause Imports: 17 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrMaxClientsReached = errors.New("maximum number of clients reached")
	ErrIOThreadNotFound  = errors.New("io-thread not found")
)

This section is empty.

type IOThread struct {
	ClientID string
	Mode     string
	Session  *auth.Session
	// contains filtered or unexported fields
}

func NewIOThread(clientFD int) (*IOThread, error)

func (t *IOThread) Start(ctx context.Context, shardManager *shardmanager.ShardManager, watchManager *WatchManager) error

func (t *IOThread) Stop() error

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

func NewIOThreadManager() *IOThreadManager

func (m *IOThreadManager) IOThreadCount() uint32

func (m *IOThreadManager) RegisterIOThread(ioThread *IOThread) error

func (m *IOThreadManager) UnregisterIOThread(id string) error

type Server struct {
	Host string
	Port int
	// contains filtered or unexported fields
}

func NewServer(shardManager *shardmanager.ShardManager, ioThreadManager *IOThreadManager, watchManager *WatchManager) *Server

func (s *Server) AcceptConnectionRequests(ctx context.Context, wg *sync.WaitGroup) error

func (s *Server) BindAndListen() error

func (s *Server) Run(ctx context.Context) (err error)

func (s *Server) Shutdown()

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

func NewWatchManager() *WatchManager

func (w *WatchManager) CleanupThreadWatchSubscriptions(t *IOThread)

func (w *WatchManager) HandleUnwatch(c *cmd.Cmd, t *IOThread)

func (w *WatchManager) HandleWatch(c *cmd.Cmd, t *IOThread)

func (w *WatchManager) NotifyWatchers(c *cmd.Cmd, shardManager *shardmanager.ShardManager, t *IOThread)

func (w *WatchManager) RegisterThread(t *IOThread)