Versions in this module Expand all Collapse all v0 v0.1.14 Apr 23, 2024 v0.1.13 Mar 5, 2024 Changes in this version + const MaxContactSize + func GetClientCert(req *http.Request, frontendConfig *cpb.FrontendConfig) (*x509.Certificate, error) + type Communicator struct + func NewCommunicator(p Params) (*Communicator, error) + func (c *Communicator) Setup(fs comms.Context) error + func (c *Communicator) Start() error + func (c *Communicator) Stop() + type Params struct + Cert []byte + FrontendConfig *cpb.FrontendConfig + Key []byte + Listener net.Listener + MaxPerClientBatchProcessors uint32 + Streaming bool + StreamingCloseTime time.Duration + StreamingJitter time.Duration + StreamingLifespan time.Duration