tcp

Documentation

Index

• type Proxy
  • func NewTCPProxy(tp tokenaccessor.TokenAccessor, c collector.EventCollector, ...) *Proxy
  • func (p *Proxy) CompleteEndPointAuthorization(downIP net.IP, downPort int, upConn, downConn net.Conn) (bool, error)
  • func (p *Proxy) RunNetworkServer(ctx context.Context, listener net.Listener, encrypted bool) error
  • func (p *Proxy) ShutDown() error
  • func (p *Proxy) StartClientAuthStateMachine(downIP net.IP, downPort int, downConn net.Conn) (bool, error)
  • func (p *Proxy) StartServerAuthStateMachine(ip fmt.Stringer, backendport int, upConn net.Conn) (bool, error)
  • func (p *Proxy) UpdatePortCache(portCache map[int]string)
  • func (p *Proxy) UpdateSecrets(cert *tls.Certificate, caPool *x509.CertPool, s secrets.Secrets, ...)

Types

type Proxy

type Proxy struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Proxy maintains state for proxies connections from listen to backend.

func NewTCPProxy

func NewTCPProxy(
	tp tokenaccessor.TokenAccessor,
	c collector.EventCollector,
	puFromID cache.DataStore,
	puContext string,
	certificate *tls.Certificate,
	caPool *x509.CertPool,
) *Proxy

NewTCPProxy creates a new instance of proxy reate a new instance of Proxy

func (*Proxy) CompleteEndPointAuthorization

func (p *Proxy) CompleteEndPointAuthorization(downIP net.IP, downPort int, upConn, downConn net.Conn) (bool, error)

CompleteEndPointAuthorization -- Aporeto Handshake on top of a completed connection We will define states here equivalent to SYN_SENT AND SYN_RECEIVED

func (*Proxy) RunNetworkServer

func (p *Proxy) RunNetworkServer(ctx context.Context, listener net.Listener, encrypted bool) error

RunNetworkServer implements enforcer.Enforcer interface

func (*Proxy) ShutDown

func (p *Proxy) ShutDown() error

ShutDown shuts down the server.

func (*Proxy) StartClientAuthStateMachine

func (p *Proxy) StartClientAuthStateMachine(downIP net.IP, downPort int, downConn net.Conn) (bool, error)

StartClientAuthStateMachine -- Starts the aporeto handshake for client application

func (*Proxy) StartServerAuthStateMachine

func (p *Proxy) StartServerAuthStateMachine(ip fmt.Stringer, backendport int, upConn net.Conn) (bool, error)

StartServerAuthStateMachine -- Start the aporeto handshake for a server application

func (*Proxy) UpdatePortCache

func (p *Proxy) UpdatePortCache(portCache map[int]string)

UpdatePortCache updates the port cache

func (*Proxy) UpdateSecrets

func (p *Proxy) UpdateSecrets(cert *tls.Certificate, caPool *x509.CertPool, s secrets.Secrets, certPEM, keyPEM string)

UpdateSecrets updates the secrets of the connections.