transport

Documentation

Index

• type RuvchainDial
• type RuvchainListener
  • func (t *RuvchainListener) Accept() (net.Conn, error)
  • func (t *RuvchainListener) Addr() net.Addr
  • func (t *RuvchainListener) Close() error
• type RuvchainSession
• type RuvchainTransport
  • func NewRuvchainTransport(log *log.Logger, sk ed25519.PrivateKey, pk ed25519.PublicKey, peers []string, ...) (*RuvchainTransport, error)
  • func (t *RuvchainTransport) Dial(host string) (net.Conn, error)
  • func (t *RuvchainTransport) Listener() net.Listener
• type Transport

Types

type RuvchainDial

type RuvchainDial struct {
	context.Context
	context.CancelFunc
}

type RuvchainListener

type RuvchainListener struct {
	*RuvchainTransport
}

func (*RuvchainListener) Accept

func (t *RuvchainListener) Accept() (net.Conn, error)

func (*RuvchainListener) Addr

func (t *RuvchainListener) Addr() net.Addr

func (*RuvchainListener) Close

func (t *RuvchainListener) Close() error

type RuvchainSession

type RuvchainSession struct {
	quic.Connection
	quic.Stream
}

type RuvchainTransport

type RuvchainTransport struct {
	Ruvchain net.PacketConn
	// contains filtered or unexported fields
}

func NewRuvchainTransport

func NewRuvchainTransport(log *log.Logger, sk ed25519.PrivateKey, pk ed25519.PublicKey, peers []string, mcast bool) (*RuvchainTransport, error)

func (*RuvchainTransport) Dial

func (t *RuvchainTransport) Dial(host string) (net.Conn, error)

func (*RuvchainTransport) Listener

func (t *RuvchainTransport) Listener() net.Listener

type Transport

type Transport interface {
	Dial(host string) (net.Conn, error)
	Listener() net.Listener
}