peers

Documentation

Index

• Constants
• func ClearBufferedSpConns()
• func ConfirmOptSP(spNetworkAddr string)
• func ConnectToGatewayPP(pplist []*types.PeerInfo) bool
• func ConnectToSP() (newConnection bool, err error)
• func GetBufferedSpConns() []*cf.ClientConn
• func GetNetworkAddress()
• func GetOptSPAndClear() (string, error)
• func GetPPList() (list []*types.PeerInfo, total int64)
• func GetPPListFromSP()
• func GetPPStatusFromSP()
• func GetPPStatusInitPPList()
• func GetSPList()
• func InitPPList()
• func InitPeer(registerFn func())
• func ListenOffline()
• func RegisterToSP(toSP bool)
• func ReportNodeStatus()
• func ReqTransferSendSP(ctx context.Context, conn core.WriteCloser)
• func SavePPList(target *protos.RspGetPPList) error
• func ScheduleReloadPPStatus(future time.Duration)
• func ScheduleReloadSPlist(future time.Duration)
• func SendLatencyCheckMessageToSPList()
• func SendMessage(conn core.WriteCloser, pb proto.Message, cmd string) error
• func SendMessageDirectToSPOrViaPP(pb proto.Message, cmd string)
• func SendMessageToSPServer(pb proto.Message, cmd string)
• func SendResponseMessageWithReqId(conn core.WriteCloser, pb proto.Message, cmd string, reqId int64) error
• func SetPPServer(pp *PPServer)
• func StartListenServer(port string)
• func StartMining()
• func StartPP(registerFn func())
• func StartStatusReportToSP()
• func TransferSendMessageToClient(p2pAddress string, msgBuf *msg.RelayMsgBuf)
• func TransferSendMessageToPPServ(addr string, msgBuf *msg.RelayMsgBuf)
• func TransferSendMessageToPPServByP2pAddress(p2pAddress string, msgBuf *msg.RelayMsgBuf)
• func TransferSendMessageToSPServer(msg *msg.RelayMsgBuf)
• func UpdatePP(pp *types.PeerInfo)
• type OptimalSp
• type PPServer
  • func GetPPServer() *PPServer
  • func NewServer() *PPServer

Constants

const (
	PP_LOG_ALL      = false
	PP_LOG_READ     = true
	PP_LOG_WRITE    = true
	PP_LOG_INBOUND  = true
	PP_LOG_OUTBOUND = true
)

todo: pp server should be move out of peers package

const (
	RELOAD_PP_LIST_INTERVAL_SHORT  = 5 * time.Second
	RELOAD_PP_LIST_INTERVAL_MEDIUM = 15 * time.Second
	RELOAD_PP_LIST_INTERVAL_LONG   = 30 * time.Second
)

Functions

func ClearBufferedSpConns

func ClearBufferedSpConns()

func ConfirmOptSP

func ConfirmOptSP(spNetworkAddr string)

ConnectToOptSP connect if there is a detected optimal SP node.

func ConnectToGatewayPP

func ConnectToGatewayPP(pplist []*types.PeerInfo) bool

func ConnectToSP

func ConnectToSP() (newConnection bool, err error)

ConnectToSP Checks if there is a connection to an SP node. If it doesn't, it attempts to create one with a random SP node.

func GetBufferedSpConns

func GetBufferedSpConns() []*cf.ClientConn

func GetNetworkAddress

func GetNetworkAddress()

GetNetworkAddress

func GetOptSPAndClear

func GetOptSPAndClear() (string, error)

func GetPPList

func GetPPList() (list []*types.PeerInfo, total int64)

GetPPList will just get the list from

func GetPPListFromSP

func GetPPListFromSP()

GetPPListFromSP node get ppList from sp

func GetPPStatusFromSP

func GetPPStatusFromSP()

GetMyNodeStatusFromSP P node get node status

func GetPPStatusInitPPList

func GetPPStatusInitPPList()

GetMyNodeStatusFromSP P node get node status

func GetSPList

func GetSPList()

GetSPList node get spList

func InitPPList

func InitPPList()

InitPPList

func InitPeer

func InitPeer(registerFn func())

func ListenOffline

func ListenOffline()

func RegisterToSP

func RegisterToSP(toSP bool)

func ReportNodeStatus

func ReportNodeStatus()

ReportNodeStatus

func ReqTransferSendSP

func ReqTransferSendSP(ctx context.Context, conn core.WriteCloser)

ReqTransferSendSP

func SavePPList

func SavePPList(target *protos.RspGetPPList) error

SavePPList will save the target list to local list

func ScheduleReloadPPStatus

func ScheduleReloadPPStatus(future time.Duration)

func ScheduleReloadSPlist

func ScheduleReloadSPlist(future time.Duration)

func SendLatencyCheckMessageToSPList

func SendLatencyCheckMessageToSPList()

func SendMessage

func SendMessage(conn core.WriteCloser, pb proto.Message, cmd string) error

SendMessage

func SendMessageDirectToSPOrViaPP

func SendMessageDirectToSPOrViaPP(pb proto.Message, cmd string)

func SendMessageToSPServer

func SendMessageToSPServer(pb proto.Message, cmd string)

SendMessageToSPServer SendMessageToSPServer

func SendResponseMessageWithReqId

func SendResponseMessageWithReqId(conn core.WriteCloser, pb proto.Message, cmd string, reqId int64) error

func SetPPServer

func SetPPServer(pp *PPServer)

func StartListenServer

func StartListenServer(port string)

StartListenServer

func StartMining

func StartMining()

func StartPP

func StartPP(registerFn func())

func StartStatusReportToSP

func StartStatusReportToSP()

func TransferSendMessageToClient

func TransferSendMessageToClient(p2pAddress string, msgBuf *msg.RelayMsgBuf)

transferSendMessageToClient

func TransferSendMessageToPPServ

func TransferSendMessageToPPServ(addr string, msgBuf *msg.RelayMsgBuf)

TransferSendMessageToPPServ

func TransferSendMessageToPPServByP2pAddress

func TransferSendMessageToPPServByP2pAddress(p2pAddress string, msgBuf *msg.RelayMsgBuf)

func TransferSendMessageToSPServer

func TransferSendMessageToSPServer(msg *msg.RelayMsgBuf)

transferSendMessageToSPServer

func UpdatePP

func UpdatePP(pp *types.PeerInfo)

UpdatePP will update one pp info to local list

Types

type OptimalSp

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

type PPServer

type PPServer struct {
	*core.Server
}

PPServer

func GetPPServer

func GetPPServer() *PPServer

GetPPServer

func NewServer

func NewServer() *PPServer

NewServer returns a server.