onet

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

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

type Conn interface {
	io.ReadWriteCloser

	LocalAddr() *Addr

	RemoteAddr() *Addr

	SetDeadline(t time.Time) error

	SetReadDeadline(t time.Time) error

	SetWriteDeadline(t time.Time) error

	ONet() *OverlayNetwork
}

type Listener interface {
	Accept() (Conn, error)

	Close() error

	// Addr returns the listener's network address.
	Addr() *Addr
}

type MuxTransport interface {
	Transport
	Listen(onet *OverlayNetwork, chainOffset int) (Listener, error)
	Dial(ctx context.Context, onet *OverlayNetwork, chainOffset int) (Conn, error)
	OverlayTransport
}

type NativeTransport interface {
	Transport
	Listen(onet *OverlayNetwork) (Listener, error)
	Dial(ctx context.Context, onet *OverlayNetwork) (Conn, error)
}

type Option func(*Config) error

type OverlayNetwork struct {
	slf4go.Logger
	Addr              *Addr
	NavtiveAddr       *Addr
	NativeTransport   NativeTransport
	MuxAddrs          []*Addr
	MuxTransports     []MuxTransport
	OverlayAddrs      []*Addr
	OverlayTransports []OverlayTransport
	Config            *Config
}

type OverlayTransport interface {
	Transport
	Client(onet *OverlayNetwork, conn Conn, chainOffset int) (Conn, error)
	Server(onet *OverlayNetwork, conn Conn, chainOffset int) (Conn, error)
}

type Protocol struct {
	Name       string
	HasValue   bool
	CheckValue func(value string) error
}

type SubAddr interface {
	Protocol() string
	Value() string
}

type Transport interface {
	fmt.Stringer
	Protocol() string
}