db

Documentation

Index

• Variables
• func NewChService(cfg *config.Config, log *xlog.XLog) store.DbStoreInterface
• type CacheService
  • func NewCacheService(cfgs []*config.Chain, x *xlog.XLog) *CacheService
  • func (s *CacheService) GetMonitorAddress(blockChain int64) ([]string, error)
  • func (s *CacheService) SetMonitorAddress(blockChain int64, addrList []*store.MonitorAddress) error
• type ClickhouseDb
  • func (m *ClickhouseDb) AddMonitorAddress(blockchain int64, address *store.MonitorAddress) error
  • func (m *ClickhouseDb) DelMonitorAddress(blockchain int64, token string, address string) error
  • func (m *ClickhouseDb) DelSubFilter(id int64) error
  • func (m *ClickhouseDb) DelSubFilter2(filter *store.SubFilter) error
  • func (m *ClickhouseDb) GetAddressByToken(blockchain int64, token string) ([]*store.MonitorAddress, error)
  • func (m *ClickhouseDb) GetAddressByToken2(token string) ([]*store.MonitorAddress, error)
  • func (m *ClickhouseDb) GetAddressByToken3(blockchain int64) ([]*store.MonitorAddress, error)
  • func (m *ClickhouseDb) GetNodeTokenByEmail(email string) (*store.NodeToken, error)
  • func (m *ClickhouseDb) GetNodeTokenByToken(token string) (*store.NodeToken, error)
  • func (m *ClickhouseDb) GetSubFilter(token string, blockChain int64, txCode string) ([]*store.SubFilter, error)
  • func (m *ClickhouseDb) NewBackupTx(blockchain int64, txs []*store.BackupTx) error
  • func (m *ClickhouseDb) NewBlock(blockchain int64, blocks []*store.Block) error
  • func (m *ClickhouseDb) NewReceipt(blockchain int64, receipts []*store.Receipt) error
  • func (m *ClickhouseDb) NewSubFilter(filters []*store.SubFilter) (err error)
  • func (m *ClickhouseDb) NewSubTx(blockchain int64, txs []*store.SubTx) error
  • func (m *ClickhouseDb) NewToken(token *store.NodeToken) error
  • func (m *ClickhouseDb) NewTx(blockchain int64, txs []*store.Tx) error
  • func (m *ClickhouseDb) UpdateToken(token string, nodeToken *store.NodeToken) error

Variables

var (
	MonitorKey = "monitorAddress_%v"
)

Functions

func NewChService

func NewChService(cfg *config.Config, log *xlog.XLog) store.DbStoreInterface

Types

type CacheService

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

func NewCacheService

func NewCacheService(cfgs []*config.Chain, x *xlog.XLog) *CacheService

func (*CacheService) GetMonitorAddress

func (s *CacheService) GetMonitorAddress(blockChain int64) ([]string, error)

func (*CacheService) SetMonitorAddress

func (s *CacheService) SetMonitorAddress(blockChain int64, addrList []*store.MonitorAddress) error

type ClickhouseDb

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

func (*ClickhouseDb) AddMonitorAddress

func (m *ClickhouseDb) AddMonitorAddress(blockchain int64, address *store.MonitorAddress) error

func (*ClickhouseDb) DelMonitorAddress

func (m *ClickhouseDb) DelMonitorAddress(blockchain int64, token string, address string) error

func (*ClickhouseDb) DelSubFilter

func (m *ClickhouseDb) DelSubFilter(id int64) error

func (*ClickhouseDb) DelSubFilter2

func (m *ClickhouseDb) DelSubFilter2(filter *store.SubFilter) error

func (*ClickhouseDb) GetAddressByToken

func (m *ClickhouseDb) GetAddressByToken(blockchain int64, token string) ([]*store.MonitorAddress, error)

func (*ClickhouseDb) GetAddressByToken2

func (m *ClickhouseDb) GetAddressByToken2(token string) ([]*store.MonitorAddress, error)

func (*ClickhouseDb) GetAddressByToken3

func (m *ClickhouseDb) GetAddressByToken3(blockchain int64) ([]*store.MonitorAddress, error)

func (*ClickhouseDb) GetNodeTokenByEmail

func (m *ClickhouseDb) GetNodeTokenByEmail(email string) (*store.NodeToken, error)

func (*ClickhouseDb) GetNodeTokenByToken

func (m *ClickhouseDb) GetNodeTokenByToken(token string) (*store.NodeToken, error)

func (*ClickhouseDb) GetSubFilter

func (m *ClickhouseDb) GetSubFilter(token string, blockChain int64, txCode string) ([]*store.SubFilter, error)

func (*ClickhouseDb) NewBackupTx

func (m *ClickhouseDb) NewBackupTx(blockchain int64, txs []*store.BackupTx) error

func (*ClickhouseDb) NewBlock

func (m *ClickhouseDb) NewBlock(blockchain int64, blocks []*store.Block) error

func (*ClickhouseDb) NewReceipt

func (m *ClickhouseDb) NewReceipt(blockchain int64, receipts []*store.Receipt) error

func (*ClickhouseDb) NewSubFilter

func (m *ClickhouseDb) NewSubFilter(filters []*store.SubFilter) (err error)

func (*ClickhouseDb) NewSubTx

func (m *ClickhouseDb) NewSubTx(blockchain int64, txs []*store.SubTx) error

func (*ClickhouseDb) NewToken

func (m *ClickhouseDb) NewToken(token *store.NodeToken) error

func (*ClickhouseDb) NewTx

func (m *ClickhouseDb) NewTx(blockchain int64, txs []*store.Tx) error

func (*ClickhouseDb) UpdateToken

func (m *ClickhouseDb) UpdateToken(token string, nodeToken *store.NodeToken) error