transptest

Documentation

Index

• func GenCertsForIPIfMIssing(t *testing.T, ip net.IP, name string) error
• type MockServer
  • func NewMockServerTCP(t *testing.T, to time.Duration, cert string, proxy *transport.ProxyConfig) *MockServer
  • func NewMockServerTLS(t *testing.T, to time.Duration, cert string, proxy *transport.ProxyConfig) *MockServer
  • func (m *MockServer) Accept() net.Conn
  • func (m *MockServer) Addr() string
  • func (m *MockServer) Await() chan net.Conn
  • func (m *MockServer) ClientDeadline(client net.Conn, to time.Duration)
  • func (m *MockServer) ConnectPair() (net.Conn, *transport.Client, error)
• type MockServerFactory
• type TransportFactory

Functions

func GenCertsForIPIfMIssing

func GenCertsForIPIfMIssing(
	t *testing.T,
	ip net.IP,
	name string,
) error

genCertsIfMIssing generates a testing certificate for ip 127.0.0.1 for testing if certificate or key is missing. Generated is used for CA, client-auth and server-auth. Use only for testing.

Types

type MockServer

type MockServer struct {
	net.Listener
	Timeout   time.Duration
	Err       error
	Handshake func(net.Conn)
	Transp    func() (*transport.Client, error)
}

func NewMockServerTCP

func NewMockServerTCP(t *testing.T, to time.Duration, cert string, proxy *transport.ProxyConfig) *MockServer

func NewMockServerTLS

func NewMockServerTLS(t *testing.T, to time.Duration, cert string, proxy *transport.ProxyConfig) *MockServer

func (*MockServer) Accept

func (m *MockServer) Accept() net.Conn

func (*MockServer) Addr

func (m *MockServer) Addr() string

func (*MockServer) Await

func (m *MockServer) Await() chan net.Conn

func (*MockServer) ClientDeadline

func (m *MockServer) ClientDeadline(client net.Conn, to time.Duration)

func (*MockServer) ConnectPair

func (m *MockServer) ConnectPair() (net.Conn, *transport.Client, error)

type MockServerFactory

type MockServerFactory func(*testing.T, time.Duration, string, *transport.ProxyConfig) *MockServer

type TransportFactory

type TransportFactory func(addr string, proxy *transport.ProxyConfig) (*transport.Client, error)