fan

Documentation

Index

• func RedirectFanIn(Context context.Context, ChannelPool *ActiveChannelPool, ...) error
• type ActiveChannelPool
  • func NewChannelPool(Context context.Context, Config *RedirectionConfig) *ActiveChannelPool
• type Receiver
• type RedirectionConfig
• type Sender
• type TunnelInitialier

Functions

func RedirectFanIn

func RedirectFanIn(Context context.Context, ChannelPool *ActiveChannelPool, FanInReceiver Receiver, FanInSender Sender, TunnelInitialier TunnelInitialier) error

RedirectFanIn will keep calling `FanInReceiver` to get a packet including data and a sender ID. Bridge the connection initialized with `TunnelInitialier` and returns its response back through `FanInSender`.

Types

type ActiveChannelPool

type ActiveChannelPool struct {
	// contains filtered or unexported fields
}

ActiveChannelPool keeps tracks of active UDP connections.

func NewChannelPool

func NewChannelPool(Context context.Context, Config *RedirectionConfig) *ActiveChannelPool

NewChannelPool creates a shared pool to store active connections safely.

type Receiver

type Receiver func([]byte) (int, string, error)

Receiver takes an empty buffer as input, returns how many bytes writen, the identifier of the sender, or an error.

type RedirectionConfig

type RedirectionConfig struct {
	// The timeout of a connection in idle state.
	Timeout time.Duration
	// FanIn function will allocate buffer in `BufferSize` while listening. A too large size might cause OOMing.
	BufferSize int64
}

RedirectionConfig specifies the configuration of stateless fan-in forwarding.

type Sender

type Sender func(string, []byte) (int, error)

Sender takes a sender ID and bytes to be sent as input parameters, returns the number of bytes writen or an error.

type TunnelInitialier

type TunnelInitialier func(string) (io.ReadWriteCloser, error)

TunnelInitialier takes a sender ID as an input parameter, returns the bridged connection or an error.