db

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 10, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	NodeKey    = "nodeKey_%v"
	BlockChain = "blockChain"
)

Functions

func NewFileTaskCreateService 

func NewFileTaskCreateService(config *config.Config, xg *xlog.XLog) task.StoreTaskInterface

Types

type TaskCreateFile 

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

func (*TaskCreateFile) AddNodeTask 

func (t *TaskCreateFile) AddNodeTask(list []*task.NodeTask) ([]*kafka.Message, error)

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) UpdateLastNumber 

func (t *TaskCreateFile) UpdateLastNumber(blockChainCode int64, latestNumber int64) error

func (*TaskCreateFile) UpdateRecentNumber 

func (t *TaskCreateFile) UpdateRecentNumber(blockChainCode int64, recentNumber int64) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.