ipc

Aug 4, 2025

Changes in this version

+ func Hijackify(conn net.Conn, timeout time.Duration) (net.Conn, error)

+ func NewClientIPC(logger logging.Logger, sockConn io.ReadWriteCloser, handler http.Handler, ...) (io.Closer, *http.Client, error)

+ func NewHijackAcceptor(logger logging.Logger, cb func(context.Context, io.ReadWriteCloser)) (string, http.Handler)

+ func NewServerIPC(logger logging.Logger, sockConn io.ReadWriteCloser, handler http.Handler, ...) (io.Closer, *http.Client, error)

+ type CloseWriter interface

+ CloseWrite func() error

Jul 16, 2025

Changes in this version

+ func FromCustomCfg(cfg Custom) (io.ReadWriteCloser, error)

+ type Custom struct

+ Fd int

+ R uint64

+ W uint64

+ func FakeTestCustom(fd int) Custom

+ type FdWrapper struct

+ func NewConnectionPair(cmd *exec.Cmd) (io.ReadWriteCloser, *FdWrapper, error)

+ func NewConnectionPair(cmd *exec.Cmd) (net.Conn, *FdWrapper, error)

+ func (p *FdWrapper) Close() error

+ func (p *FdWrapper) ToCustomCfg() Custom

+ type PipeConn struct — windows/amd64

+ R *os.File

+ W *os.File

+ func (p *PipeConn) Close() error

+ func (p *PipeConn) Read(b []byte) (int, error)

+ func (p *PipeConn) Write(b []byte) (int, error)

Jul 11, 2025

Changes in this version

+ func NewPluginIPC(sockConn net.Conn, handler http.Handler, onServerClosed func(error), ...) (io.Closer, *http.Client, error)

+ func NewRuntimeIPC(sockConn net.Conn, handler http.Handler, onServerClosed func(error), ...) (io.Closer, *http.Client, error)

+ type Option func(*cfg) *cfg

+ func WithShutdownTimeout(d time.Duration) Option

+ type PluginConfigFromEngine struct

+ Fd int

+ Name string

+ RegistrationTimeout time.Duration

+ func NewPluginConfigFromEngineEnv(in string) (*PluginConfigFromEngine, error)

+ func (c *PluginConfigFromEngine) ToString() (string, error)