Class: Nonnative::SocketPairFactory

Inherits:

Object

• Object
• Nonnative::SocketPairFactory

Defined in:

lib/nonnative/socket_pair_factory.rb

Overview

Factory for creating socket-pair implementations used by FaultInjectionProxy.

A socket-pair is responsible for wiring a local accepted socket to a remote upstream socket, optionally injecting failures (close connections, add delays, corrupt data, etc).

Proxy states are mapped as follows:

• :none (or any unknown value) -> SocketPair (pass-through)
• :close_all -> CloseAllSocketPair
• :reset_peer -> ResetPeerSocketPair
• :delay -> DelaySocketPair
• :timeout -> TimeoutSocketPair
• :invalid_data -> InvalidDataSocketPair
• :bandwidth -> BandwidthSocketPair
• :limit_data -> LimitDataSocketPair

See Also:

• FaultInjectionProxy
• SocketPair
• CloseAllSocketPair
• ResetPeerSocketPair
• DelaySocketPair
• TimeoutSocketPair
• InvalidDataSocketPair
• BandwidthSocketPair
• LimitDataSocketPair

Class Method Summary

• .create(kind, proxy) ⇒ Nonnative::SocketPair

  Creates a socket-pair instance for the given proxy state.

Class Method Details

.create(kind, proxy) ⇒ Nonnative::SocketPair

Creates a socket-pair instance for the given proxy state.

Parameters:

• kind (Symbol) —

  proxy state (e.g. :none, :close_all, :reset_peer, :delay, :timeout, :invalid_data, :bandwidth, :limit_data)

• proxy (Nonnative::ConfigurationProxy) —

  proxy configuration (host/port/options)

Returns:

• (Nonnative::SocketPair) —

  a socket-pair implementation instance

# File 'lib/nonnative/socket_pair_factory.rb', line 47

def create(kind, proxy)
  pair = PAIR_BY_STATE.fetch(kind, SocketPair)

  pair.new(proxy)
end