server

Documentation

Index

• Constants
• func Reverse(b []byte) []byte
• type MineInfo
• type Miner
  • func (miner *Miner) SendMessageToMiner(msg string) error
  • func (miner *Miner) UpdateMineInfo(trxid string, diff uint32, send bool)
• type MinerRequest
• type PowPayload
• type XrpMintServer
  • func (xrp *XrpMintServer) AddMiner(miner *Miner)
  • func (xrp *XrpMintServer) ListenTcp()
  • func (xrp *XrpMintServer) NotifyMiner(trxid string, diff uint32, nonceReport chan uint64, rebuildTrx chan bool)

Constants

const (
	NotCalcNonce  = 0
	CalcNonceDone = 1
	CalcNonceEnd  = 2
)

Functions

func Reverse

func Reverse(b []byte) []byte

Types

type MineInfo

type MineInfo struct {
	TrxId     string
	Difficult uint32
}

type Miner

type Miner struct {
	sync.Mutex
	IP   string
	Port string
	// contains filtered or unexported fields
}

func (*Miner) SendMessageToMiner

func (miner *Miner) SendMessageToMiner(msg string) error

func (*Miner) UpdateMineInfo

func (miner *Miner) UpdateMineInfo(trxid string, diff uint32, send bool)

type MinerRequest

type MinerRequest struct {
	Method string        `json:"method"`
	Params []interface{} `json:"params"`
}

type PowPayload

type PowPayload struct {
	Version  uint32
	TxHash   string
	Reserved [44]byte
	NBits    uint32
	Nonce    uint64
}

type XrpMintServer

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

func (*XrpMintServer) AddMiner

func (xrp *XrpMintServer) AddMiner(miner *Miner)

func (*XrpMintServer) ListenTcp

func (xrp *XrpMintServer) ListenTcp()

func (*XrpMintServer) NotifyMiner

func (xrp *XrpMintServer) NotifyMiner(trxid string, diff uint32, nonceReport chan uint64, rebuildTrx chan bool)