serial

Documentation

Index

• type Node
  • func New(peer dndm.Peer) (*Node, error)
  • func (f *Node) Dial(ctx context.Context, peer dndm.Peer, o ...network.DialOpt) (io.ReadWriteCloser, error)
  • func (f *Node) Scheme() string
  • func (f *Node) Serve(ctx context.Context, ...) error

Types

type Node

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

func New

func New(peer dndm.Peer) (*Node, error)

func (*Node) Dial

func (f *Node) Dial(ctx context.Context, peer dndm.Peer, o ...network.DialOpt) (io.ReadWriteCloser, error)

func (*Node) Scheme

func (f *Node) Scheme() string

func (*Node) Serve

func (f *Node) Serve(ctx context.Context, onConnect func(peer dndm.Peer, r io.ReadWriteCloser) error, o ...network.SrvOpt) error