db

Documentation

Index

• Constants
• type Service
  • func NewTaskService(taskDb *config.TaskDb, sourceDb *config.SourceDb, x *xlog.XLog) *Service
  • func (s *Service) AddNodeSource(source *service.NodeSource) error
  • func (s *Service) AddNodeSourceList(sources []*service.NodeSource) error
  • func (s *Service) AddNodeTask(list []*service.NodeTask) error
  • func (s *Service) GetNodeTaskByBlockHash(hash string, taskType int, blockChain int) (*service.NodeTask, error)
  • func (s *Service) GetNodeTaskByBlockNumber(number string, taskType int, blockChain int) (*service.NodeTask, error)
  • func (s *Service) GetNodeTaskWithTx(txHash string, taskType int, blockChain int, taskStatus int) (*service.NodeTask, error)
  • func (s *Service) GetNodeTaskWithTxs(txHash []string, taskType int, blockChain int, taskStatus int) ([]int64, error)
  • func (s *Service) GetTaskWithBlock(blockChain int, nodeId string) ([]*service.NodeTask, error)
  • func (s *Service) GetTaskWithReceipt(blockChain int, nodeId string) ([]*service.NodeTask, error)
  • func (s *Service) GetTaskWithTx(blockChain int, nodeId string) ([]*service.NodeTask, error)
  • func (s *Service) UpdateNodeTaskListStatusWithTx(txHashList []string, taskType int, blockChain int, taskStatus int) error
  • func (s *Service) UpdateNodeTaskStatus(id int64, status int) error
  • func (s *Service) UpdateNodeTaskStatusWithBatch(ids []int64, status int) error
  • func (s *Service) UpdateNodeTaskStatusWithBlockByHash(hash string, taskType int, blockChain int, taskStatus int) error
  • func (s *Service) UpdateNodeTaskStatusWithBlockByNumber(number string, taskType int, blockChain int, taskStatus int) error
  • func (s *Service) UpdateNodeTaskStatusWithTx(txHash string, taskType int, blockChain int, taskStatus int) error

Constants

const (
	DayFormat = "20060102"
)

Types

type Service

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

func NewTaskService

func NewTaskService(taskDb *config.TaskDb, sourceDb *config.SourceDb, x *xlog.XLog) *Service

func (*Service) AddNodeSource

func (s *Service) AddNodeSource(source *service.NodeSource) error

func (*Service) AddNodeSourceList

func (s *Service) AddNodeSourceList(sources []*service.NodeSource) error

func (*Service) AddNodeTask

func (s *Service) AddNodeTask(list []*service.NodeTask) error

func (*Service) GetNodeTaskByBlockHash

func (s *Service) GetNodeTaskByBlockHash(hash string, taskType int, blockChain int) (*service.NodeTask, error)

func (*Service) GetNodeTaskByBlockNumber

func (s *Service) GetNodeTaskByBlockNumber(number string, taskType int, blockChain int) (*service.NodeTask, error)

func (*Service) GetNodeTaskWithTx

func (s *Service) GetNodeTaskWithTx(txHash string, taskType int, blockChain int, taskStatus int) (*service.NodeTask, error)

func (*Service) GetNodeTaskWithTxs

func (s *Service) GetNodeTaskWithTxs(txHash []string, taskType int, blockChain int, taskStatus int) ([]int64, error)

func (*Service) GetTaskWithBlock

func (s *Service) GetTaskWithBlock(blockChain int, nodeId string) ([]*service.NodeTask, error)

func (*Service) GetTaskWithReceipt

func (s *Service) GetTaskWithReceipt(blockChain int, nodeId string) ([]*service.NodeTask, error)

func (*Service) GetTaskWithTx

func (s *Service) GetTaskWithTx(blockChain int, nodeId string) ([]*service.NodeTask, error)

func (*Service) UpdateNodeTaskListStatusWithTx

func (s *Service) UpdateNodeTaskListStatusWithTx(txHashList []string, taskType int, blockChain int, taskStatus int) error

func (*Service) UpdateNodeTaskStatus

func (s *Service) UpdateNodeTaskStatus(id int64, status int) error

func (*Service) UpdateNodeTaskStatusWithBatch

func (s *Service) UpdateNodeTaskStatusWithBatch(ids []int64, status int) error

func (*Service) UpdateNodeTaskStatusWithBlockByHash

func (s *Service) UpdateNodeTaskStatusWithBlockByHash(hash string, taskType int, blockChain int, taskStatus int) error

func (*Service) UpdateNodeTaskStatusWithBlockByNumber

func (s *Service) UpdateNodeTaskStatusWithBlockByNumber(number string, taskType int, blockChain int, taskStatus int) error

func (*Service) UpdateNodeTaskStatusWithTx

func (s *Service) UpdateNodeTaskStatusWithTx(txHash string, taskType int, blockChain int, taskStatus int) error