p2p

Documentation

Index

• Constants
• type Peer
  • func NewPeerEndpoint(endpoint string) (*Peer, error)
• type PeerPool
  • func NewPeerPoolWithEndpoints(endpoints []string) (*PeerPool, error)
  • func (pool *PeerPool) PushMsg(msg *SyncMsg)
  • func (pool *PeerPool) Start()
• type SyncMsg
• type SyncMsgType

Constants

const (
	SyncMsgRegType = iota
	SyncMsgRenewType
	SyncMsgCancelType
)

const DefaultEndpoint = "127.0.0.1:8005"

Types

type Peer

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

peer

func NewPeerEndpoint

func NewPeerEndpoint(endpoint string) (*Peer, error)

new a peer with endpoint

type PeerPool

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

peer pool

func NewPeerPoolWithEndpoints

func NewPeerPoolWithEndpoints(endpoints []string) (*PeerPool, error)

new a peer pool with endpoints

func (*PeerPool) PushMsg

func (pool *PeerPool) PushMsg(msg *SyncMsg)

push a sync message

func (*PeerPool) Start

func (pool *PeerPool) Start()

start the peer pool

type SyncMsg

type SyncMsg struct {
	Type    SyncMsgType
	Content interface{}
}

sync message

type SyncMsgType

type SyncMsgType int32