v200

Documentation

Index

• Variables
• type V200Handshaker
  • func NewV200VersionedHS(is p2pcommon.InternalService, log *log.Logger, vm p2pcommon.VersionedManager, ...) *V200Handshaker
  • func (h *V200Handshaker) DoForInbound(ctx context.Context) (*p2pcommon.HandshakeResult, error)
  • func (h *V200Handshaker) DoForOutbound(ctx context.Context) (*p2pcommon.HandshakeResult, error)
  • func (h *V200Handshaker) GetMsgRW() p2pcommon.MsgReadWriter

Variables

var (
	ErrInvalidAgentStatus = errors.New("invalid agent status")
	ErrInvalidCertIssue   = errors.New("invalid issue request")
)

Types

type V200Handshaker

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

V200Handshaker exchange status data over protocol version 1.0.0

func NewV200VersionedHS

func NewV200VersionedHS(is p2pcommon.InternalService, log *log.Logger, vm p2pcommon.VersionedManager, cm p2pcommon.CertificateManager, peerID types.PeerID, rwc io.ReadWriteCloser, genesis []byte) *V200Handshaker

func (*V200Handshaker) DoForInbound

func (h *V200Handshaker) DoForInbound(ctx context.Context) (*p2pcommon.HandshakeResult, error)

DoForInbound is handle handshake from inbound peer

func (*V200Handshaker) DoForOutbound

func (h *V200Handshaker) DoForOutbound(ctx context.Context) (*p2pcommon.HandshakeResult, error)

handshakeOutboundPeer start handshake with outbound peer

func (*V200Handshaker) GetMsgRW

func (h *V200Handshaker) GetMsgRW() p2pcommon.MsgReadWriter