service

Documentation

Index

• Constants
• func NewTaskHandler(cfg *config.Config, log *xlog.XLog) taskapi.TaskApiInterface
• type Server
  • func NewServer(cfg *config.Config, blockChain []int64, log *xlog.XLog) *Server
  • func (s *Server) Error(c *gin.Context, path string, err string)
  • func (s *Server) ExistNodeId(blockChainCode int64, nodeId string) bool
  • func (s *Server) PushBlockTask(c *gin.Context)
  • func (s *Server) PushReceiptTask(c *gin.Context)
  • func (s *Server) PushReceiptsTask(c *gin.Context)
  • func (s *Server) PushTxTask(c *gin.Context)
  • func (s *Server) PushTxsTask(c *gin.Context)
  • func (s *Server) Success(c *gin.Context, resp interface{}, path string)
• type TaskHandler
  • func (m *TaskHandler) SendNodeTask(task *taskapi.NodeTask) error

Constants

const (
	SUCCESS = 0
	FAIL    = 1
)

const (
	NodeKey = "nodeKey_%v"
)

Functions

func NewTaskHandler

func NewTaskHandler(cfg *config.Config, log *xlog.XLog) taskapi.TaskApiInterface

Types

type Server

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

func NewServer

func NewServer(cfg *config.Config, blockChain []int64, log *xlog.XLog) *Server

func (*Server) Error

func (s *Server) Error(c *gin.Context, path string, err string)

func (*Server) ExistNodeId

func (s *Server) ExistNodeId(blockChainCode int64, nodeId string) bool

func (*Server) PushBlockTask

func (s *Server) PushBlockTask(c *gin.Context)

func (*Server) PushReceiptTask

func (s *Server) PushReceiptTask(c *gin.Context)

func (*Server) PushReceiptsTask

func (s *Server) PushReceiptsTask(c *gin.Context)

func (*Server) PushTxTask

func (s *Server) PushTxTask(c *gin.Context)

func (*Server) PushTxsTask

func (s *Server) PushTxsTask(c *gin.Context)

func (*Server) Success

func (s *Server) Success(c *gin.Context, resp interface{}, path string)

type TaskHandler

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

func (*TaskHandler) SendNodeTask

func (m *TaskHandler) SendNodeTask(task *taskapi.NodeTask) error