protoadaptor

Documentation

Index

• func GetFnode(station router.Station) string
• type ProtoAdaptor
  • func NewProtoAdaptor(config *p2p.Config) *ProtoAdaptor
  • func (adaptor *ProtoAdaptor) Protocols() []p2p.Protocol
  • func (adaptor *ProtoAdaptor) SendOut(e *router.Event) error
  • func (adaptor *ProtoAdaptor) Start() error
  • func (adaptor *ProtoAdaptor) Stop()

Functions

func GetFnode

func GetFnode(station router.Station) string

Types

type ProtoAdaptor

type ProtoAdaptor struct {
	p2p.Server
	// contains filtered or unexported fields
}

ProtoAdaptor is subprotocol on p2p

func NewProtoAdaptor

func NewProtoAdaptor(config *p2p.Config) *ProtoAdaptor

NewProtoAdaptor return new ProtoAdaptor

func (*ProtoAdaptor) Protocols

func (adaptor *ProtoAdaptor) Protocols() []p2p.Protocol

Protocols .

func (*ProtoAdaptor) SendOut

func (adaptor *ProtoAdaptor) SendOut(e *router.Event) error

SendOut .

func (*ProtoAdaptor) Start

func (adaptor *ProtoAdaptor) Start() error

Start start p2p protocol adaptor

func (*ProtoAdaptor) Stop

func (adaptor *ProtoAdaptor) Stop()

Stop .