fan

Nov 26, 2021

Changes in this version

+ type ActiveChannelPool struct

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

Nov 26, 2021

Changes in this version

+ func RedirectFanIn(Context context.Context, Config *RedirectionConfig, FanInReceiver Receiver, ...) error

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

+ type RedirectionConfig struct

+ BufferSize int64

+ Timeout time.Duration

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

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