Documentation ¶
Index ¶
- Variables
- func NewFileTaskCreateService(config *config.Config, xg *xlog.XLog) task.StoreTaskInterface
- type TaskCreateFile
- func (t *TaskCreateFile) GetAndDelNodeId(blockChainCode int64) ([]string, error)
- func (t *TaskCreateFile) GetNodeId(blockChainCode int64) ([]string, error)
- func (t *TaskCreateFile) GetRecentNumber(blockCode int64) (int64, int64, error)
- func (t *TaskCreateFile) ToKafkaMessage(list []*task.NodeTask) ([]*kafka.Message, error)
- func (t *TaskCreateFile) UpdateLastNumber(blockChainCode int64, latestNumber int64) error
- func (t *TaskCreateFile) UpdateRecentNumber(blockChainCode int64, recentNumber int64) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( NodeKey = "nodeKey_%v" BlockChain = "blockChain" NodeTaskTopic = "task_%v" )
Functions ¶
Types ¶
type TaskCreateFile ¶
type TaskCreateFile struct {
// contains filtered or unexported fields
}
func (*TaskCreateFile) GetAndDelNodeId ¶
func (t *TaskCreateFile) GetAndDelNodeId(blockChainCode int64) ([]string, error)
func (*TaskCreateFile) GetNodeId ¶
func (t *TaskCreateFile) GetNodeId(blockChainCode int64) ([]string, error)
func (*TaskCreateFile) GetRecentNumber ¶
func (t *TaskCreateFile) GetRecentNumber(blockCode int64) (int64, int64, error)
func (*TaskCreateFile) ToKafkaMessage ¶ added in v0.5.1
func (t *TaskCreateFile) ToKafkaMessage(list []*task.NodeTask) ([]*kafka.Message, error)
func (*TaskCreateFile) UpdateLastNumber ¶
func (t *TaskCreateFile) UpdateLastNumber(blockChainCode int64, latestNumber int64) error
func (*TaskCreateFile) UpdateRecentNumber ¶
func (t *TaskCreateFile) UpdateRecentNumber(blockChainCode int64, recentNumber int64) error
Click to show internal directories.
Click to hide internal directories.