realtime

Documentation

Index

• type RealtimeService
  • func NewRealtimeService(ctx context.Context) *RealtimeService
  • func (s *RealtimeService) CloseAll()
  • func (s *RealtimeService) ConnectAll() error

Types

type RealtimeService

type RealtimeService struct {
	Market *rtds.RTDSClient
	User   *rtds.RTDSClient
}

RealtimeService manages centralized WebSocket connections (Market & User channels)

func NewRealtimeService

func NewRealtimeService(ctx context.Context) *RealtimeService

func (*RealtimeService) CloseAll

func (s *RealtimeService) CloseAll()

CloseAll closes all connections

func (*RealtimeService) ConnectAll

func (s *RealtimeService) ConnectAll() error

ConnectAll connects both market and user clients