tcp

Documentation

Index

• type Proxy
  • func NewTCPProxy(c collector.EventCollector, puID string, certificate *tls.Certificate, ...) *Proxy
  • func (p *Proxy) InitiatePing(ctx context.Context, sctx *serviceregistry.ServiceContext, ...) error
  • func (p *Proxy) RunNetworkServer(ctx context.Context, listener net.Listener) error
  • func (p *Proxy) ShutDown() error
  • 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(
	c collector.EventCollector,
	puID string,
	certificate *tls.Certificate,
	caPool *x509.CertPool,
	agentVersion semver.Version,
	mark int,
) *Proxy

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

func (*Proxy) InitiatePing

func (p *Proxy) InitiatePing(ctx context.Context, sctx *serviceregistry.ServiceContext, sdata *serviceregistry.DependentServiceData, pingConfig *policy.PingConfig) error

InitiatePing initiates the ping request

func (*Proxy) RunNetworkServer

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

RunNetworkServer implements enforcer.Enforcer interface

func (*Proxy) ShutDown

func (p *Proxy) ShutDown() error

ShutDown shuts down the server.

func (*Proxy) UpdateSecrets

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

UpdateSecrets updates the secrets of the connections.