p2p

type ID struct {
	// public_key of the peer (we no longer use the public key as the peer ID, but use it to verify messages)
	PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// id is the computed hash of the public key
	Id                   []byte   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

type P2PInterface interface {
	GetIP() net.IP
	GetID() []byte
	SetPort(port string)
	GetPort() string
	Listen() error
	Join(bootstrapIp []string) (num int, err error)
	DisConnectTo(id []byte) error
	Leave()
	Request(ctx context.Context, id []byte, m proto.Message) (msg P2PMessage, err error)
	Reply(ctx context.Context, id []byte, nonce uint64, m proto.Message) (err error)
	SubscribeEvent() (subID int, outch chan discover.P2PEvent, err error)
	UnSubscribeEvent(int)
	SubscribeMsg(chanBuffer int, messages ...interface{}) (outch chan P2PMessage, err error)
	UnSubscribeMsg(messages ...interface{})
	NumOfMembers() int
	MembersID() [][]byte
	RandomPeerIP() []string
	// contains filtered or unexported methods
}

type P2PMessage struct {
	Msg          ptypes.DynamicAny
	Sender       []byte
	RequestNonce uint64
}

type Package struct {
	Anything  *any.Any `protobuf:"bytes,1,opt,name=anything,proto3" json:"anything,omitempty"`
	Signature []byte   `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// Sender's address and public key.
	Sender []byte `protobuf:"bytes,3,opt,name=sender,proto3" json:"sender,omitempty"`
	// request_nonce is the request/response ID. Null if ID associated to a message is not a request/response.
	RequestNonce uint64 `protobuf:"varint,4,opt,name=request_nonce,json=requestNonce,proto3" json:"request_nonce,omitempty"`
	// reply_flag indicates this is a reply to a request
	ReplyFlag            bool     `protobuf:"varint,5,opt,name=reply_flag,json=replyFlag,proto3" json:"reply_flag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Ping struct {
	Count                uint64   `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Pong struct {
	Count                uint64   `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}