Documentation
¶
Index ¶
- Constants
- type HttpHandler
- func (s *HttpHandler) AddSubFilter(c *gin.Context)
- func (s *HttpHandler) DelMonitorAddress(c *gin.Context)
- func (s *HttpHandler) DelSubFilter(c *gin.Context)
- func (s *HttpHandler) Error(c *gin.Context, path string, err string)
- func (s *HttpHandler) GetMonitorAddress(c *gin.Context)
- func (s *HttpHandler) MonitorAddress(c *gin.Context)
- func (s *HttpHandler) NewToken(c *gin.Context)
- func (s *HttpHandler) QuerySubFilter(c *gin.Context)
- func (s *HttpHandler) Success(c *gin.Context, resp interface{}, path string)
- type StoreHandler
- func (s *StoreHandler) ReadBackupTxFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
- func (s *StoreHandler) ReadBlockFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
- func (s *StoreHandler) ReadReceiptFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
- func (s *StoreHandler) ReadSubTxFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
- func (s *StoreHandler) ReadTxFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
- func (s *StoreHandler) Start(ctx context.Context)
- type TokenAddress
- type WsHandler
- func (ws *WsHandler) Start(kafkaCtx context.Context)
- func (ws *WsHandler) Sub(w http.ResponseWriter, r *http.Request, token string)
- func (ws *WsHandler) Sub2(ctx *gin.Context, w http.ResponseWriter, r *http.Request)
- func (ws *WsHandler) TxEngine(filters map[string][]*store.SubFilter, monitorAddress map[string]*TokenAddress, ...) map[string]int64
Constants ¶
View Source
const ( SUCCESS = 0 FAIL = 1 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HttpHandler ¶
type HttpHandler struct {
// contains filtered or unexported fields
}
func NewHttpHandler ¶
func NewHttpHandler(cfg *config.Config, log *xlog.XLog) *HttpHandler
func (*HttpHandler) AddSubFilter ¶ added in v0.5.1
func (s *HttpHandler) AddSubFilter(c *gin.Context)
func (*HttpHandler) DelMonitorAddress ¶
func (s *HttpHandler) DelMonitorAddress(c *gin.Context)
func (*HttpHandler) DelSubFilter ¶ added in v0.5.1
func (s *HttpHandler) DelSubFilter(c *gin.Context)
func (*HttpHandler) GetMonitorAddress ¶
func (s *HttpHandler) GetMonitorAddress(c *gin.Context)
func (*HttpHandler) MonitorAddress ¶
func (s *HttpHandler) MonitorAddress(c *gin.Context)
func (*HttpHandler) NewToken ¶
func (s *HttpHandler) NewToken(c *gin.Context)
func (*HttpHandler) QuerySubFilter ¶ added in v0.5.1
func (s *HttpHandler) QuerySubFilter(c *gin.Context)
type StoreHandler ¶
type StoreHandler struct {
// contains filtered or unexported fields
}
func NewStoreHandler ¶
func NewStoreHandler(config *config.Config, log *xlog.XLog) *StoreHandler
func (*StoreHandler) ReadBackupTxFromKafka ¶ added in v0.5.1
func (s *StoreHandler) ReadBackupTxFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
func (*StoreHandler) ReadBlockFromKafka ¶
func (s *StoreHandler) ReadBlockFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
func (*StoreHandler) ReadReceiptFromKafka ¶
func (s *StoreHandler) ReadReceiptFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
func (*StoreHandler) ReadSubTxFromKafka ¶
func (s *StoreHandler) ReadSubTxFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
func (*StoreHandler) ReadTxFromKafka ¶
func (s *StoreHandler) ReadTxFromKafka(blockChain int64, kafkaCfg map[string]*config.KafkaConfig, ctx context.Context)
func (*StoreHandler) Start ¶
func (s *StoreHandler) Start(ctx context.Context)
type TokenAddress ¶
type TokenAddress struct {
Token string
List map[string]*store.MonitorAddress
}
Source Files
Click to show internal directories.
Click to hide internal directories.