Lines Matching defs:wsClient

1247 type wsClient struct {  struct
1248 	sync.Mutex
1251 	server *rpcServer
1254 	conn *websocket.Conn
1258 	disconnected bool
1261 	addr string
1265 	authenticated bool
1269 	isAdmin bool
1274 	sessionID uint64
1278 	verboseTxUpdates bool
1283 	addrRequests map[string]struct{}
1288 	spentRequests map[wire.OutPoint]struct{}
1293 	filterData *wsClientFilter
1296 	serviceRequestSem semaphore
1297 	ntfnChan          chan []byte
1298 	sendChan          chan wsResponse
1299 	quit              chan struct{}
1300 	wg                sync.WaitGroup
1305 func (c *wsClient) inHandler() {
1484 func (c *wsClient) serviceRequest(r *parsedRPCCmd) {
1513 func (c *wsClient) notificationQueueHandler() {
1584 func (c *wsClient) outHandler() {
1628 func (c *wsClient) SendMessage(marshalledJSON []byte, doneChan chan bool) {
1653 func (c *wsClient) QueueNotification(marshalledJSON []byte) error {
1664 func (c *wsClient) Disconnected() bool {
1673 func (c *wsClient) Disconnect() {
1689 func (c *wsClient) Start() {
1701 func (c *wsClient) WaitForShutdown() {
1737 func handleWebsocketHelp(wsc *wsClient, icmd interface{}) (interface{}, error) {
1787 func handleLoadTxFilter(wsc *wsClient, icmd interface{}) (interface{}, error) {
1830 func handleNotifyBlocks(wsc *wsClient, icmd interface{}) (interface{}, error) {
1837 func handleSession(wsc *wsClient, icmd interface{}) (interface{}, error) {
1843 func handleStopNotifyBlocks(wsc *wsClient, icmd interface{}) (interface{}, error) {
1850 func handleNotifySpent(wsc *wsClient, icmd interface{}) (interface{}, error) {
1867 func handleNotifyNewTransactions(wsc *wsClient, icmd interface{}) (interface{}, error) {
1880 func handleStopNotifyNewTransactions(wsc *wsClient, icmd interface{}) (interface{}, error) {
1887 func handleNotifyReceived(wsc *wsClient, icmd interface{}) (interface{}, error) {
1906 func handleStopNotifySpent(wsc *wsClient, icmd interface{}) (interface{}, error) {
1926 func handleStopNotifyReceived(wsc *wsClient, icmd interface{}) (interface{}, error) {
2005 func rescanBlock(wsc *wsClient, lookups *rescanKeys, blk *btcutil.Block) {
2213 func handleRescanBlocks(wsc *wsClient, icmd interface{}) (interface{}, error) {
2328 func scanBlockChunks(wsc *wsClient, cmd *btcjson.RescanCmd, lookups *rescanKeys, minBlock,
2526 func handleRescan(wsc *wsClient, icmd interface{}) (interface{}, error) {