peers

Documentation

Index

• Constants
• Variables
• 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()
• func GetPPStatusFromSP()
• 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 ScheduleReloadPPStatus(future time.Duration)
• func ScheduleReloadPPlist()
• 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 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)
• type OptimalSp
• type PPServer
  • func GetPPServer() *PPServer
  • func NewServer() *PPServer

Constants

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
)

Variables

var Peers types.PeerList

Peers is a list of the know PP node peers

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

GetPPList P node get ppList from sp

func GetPPStatusFromSP

func GetPPStatusFromSP()

GetMyNodeStatusFromSP P node get node status

func GetSPList

func GetSPList()

GetPPList P node get ppList

func InitPPList

func InitPPList()

InitPPList

func InitPeer

func InitPeer(registerFn func())

InitPeer

func ListenOffline

func ListenOffline()

func RegisterToSP

func RegisterToSP(toSP bool)

RegisterToSP

func ReportNodeStatus

func ReportNodeStatus()

ReportNodeStatus

func ReqTransferSendSP

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

ReqTransferSendSP

func ScheduleReloadPPStatus

func ScheduleReloadPPStatus(future time.Duration)

func ScheduleReloadPPlist

func ScheduleReloadPPlist()

* Long: pp not activated Medium: mining not yet started Short: by default (mining)

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 SetPPServer

func SetPPServer(pp *PPServer)

func StartListenServer

func StartListenServer(port string)

StartListenServer

func StartMining

func StartMining()

StartMining

func StartPP

func StartPP(registerFn func())

StartPP

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

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.