Versions in this module Expand all Collapse all v3 v3.4.4 Mar 18, 2020 Changes in this version + type Server interface + BlackholeRx func() + BlackholeTx func() + Close func() error + DelayAccept func(latency, rv time.Duration) + DelayRx func(latency, rv time.Duration) + DelayTx func(latency, rv time.Duration) + Done func() <-chan struct{} + Error func() <-chan error + From func() string + LatencyAccept func() time.Duration + LatencyRx func() time.Duration + LatencyTx func() time.Duration + ModifyRx func(f func(data []byte) []byte) + ModifyTx func(f func(data []byte) []byte) + PauseAccept func() + PauseRx func() + PauseTx func() + Ready func() <-chan struct{} + ResetListener func() error + To func() string + UnblackholeRx func() + UnblackholeTx func() + UndelayAccept func() + UndelayRx func() + UndelayTx func() + UnmodifyRx func() + UnmodifyTx func() + UnpauseAccept func() + UnpauseRx func() + UnpauseTx func() + func NewServer(cfg ServerConfig) Server + type ServerConfig struct + BufferSize int + DialTimeout time.Duration + From url.URL + Logger *zap.Logger + RetryInterval time.Duration + TLSInfo transport.TLSInfo + To url.URL