tunnel

Documentation

Index

• type ClientPeerInitializer
• type Dialer
  • func NewDialer(initializer ClientPeerInitializer) *Dialer
  • func (d *Dialer) DialViaRoom(ctx context.Context, portal transport.Peer, target identity.Public) (transport.Peer, error)
• type ResponseStreamReadWriteCloserAdapter
  • func NewResponseStreamReadWriteCloserAdapter(stream rpc.ResponseStream, cancel context.CancelFunc) *ResponseStreamReadWriteCloserAdapter
  • func (s ResponseStreamReadWriteCloserAdapter) Close() error
  • func (s ResponseStreamReadWriteCloserAdapter) Read(p []byte) (int, error)
  • func (s ResponseStreamReadWriteCloserAdapter) Write(p []byte) (n int, err error)
• type StreamReadWriteCloserAdapter
  • func NewStreamReadWriteCloserAdapter(stream mux.Stream, cancel context.CancelFunc) *StreamReadWriteCloserAdapter
  • func (s StreamReadWriteCloserAdapter) Close() error
  • func (s StreamReadWriteCloserAdapter) Read(p []byte) (n int, err error)
  • func (s StreamReadWriteCloserAdapter) Write(p []byte) (n int, err error)

Types

type ClientPeerInitializer

type ClientPeerInitializer interface {
	// InitializeClientPeer initializes outgoing connections by performing a
	// handshake and establishing an RPC connection using the provided
	// ReadWriteCloser. Context is used as the RPC connection context.
	InitializeClientPeer(ctx context.Context, rwc io.ReadWriteCloser, remote identity.Public) (transport.Peer, error)
}

type Dialer

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

func NewDialer

func NewDialer(initializer ClientPeerInitializer) *Dialer

func (*Dialer) DialViaRoom

func (d *Dialer) DialViaRoom(ctx context.Context, portal transport.Peer, target identity.Public) (transport.Peer, error)

type ResponseStreamReadWriteCloserAdapter

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

func NewResponseStreamReadWriteCloserAdapter

func NewResponseStreamReadWriteCloserAdapter(stream rpc.ResponseStream, cancel context.CancelFunc) *ResponseStreamReadWriteCloserAdapter

func (ResponseStreamReadWriteCloserAdapter) Close

func (s ResponseStreamReadWriteCloserAdapter) Close() error

func (ResponseStreamReadWriteCloserAdapter) Read

func (s ResponseStreamReadWriteCloserAdapter) Read(p []byte) (int, error)

func (ResponseStreamReadWriteCloserAdapter) Write

func (s ResponseStreamReadWriteCloserAdapter) Write(p []byte) (n int, err error)

type StreamReadWriteCloserAdapter

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

func NewStreamReadWriteCloserAdapter

func NewStreamReadWriteCloserAdapter(stream mux.Stream, cancel context.CancelFunc) *StreamReadWriteCloserAdapter

func (StreamReadWriteCloserAdapter) Close

func (s StreamReadWriteCloserAdapter) Close() error

func (StreamReadWriteCloserAdapter) Read

func (s StreamReadWriteCloserAdapter) Read(p []byte) (n int, err error)

func (StreamReadWriteCloserAdapter) Write

func (s StreamReadWriteCloserAdapter) Write(p []byte) (n int, err error)