ipc

package

v0.0.5 Latest Latest Go to latest Published: Jul 16, 2025 License: MIT Imports: 17 Imported by: 0

Details

Rendered for

This section is empty.

This section is empty.

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

FromCustomCfg is the counter part of ToCustomCfg(). Turns a win pipe handler pair back into an io.ReadWriteCloser

func NewPluginIPC(sockConn io.ReadWriteCloser, handler http.Handler, onServerClosed func(error), option ...Option) (io.Closer, *http.Client, error)

func NewRuntimeIPC(sockConn io.ReadWriteCloser, handler http.Handler, onServerClosed func(error), option ...Option) (io.Closer, *http.Client, error)

type Custom struct {
	R uint64 `json:"r"`
	W uint64 `json:"w"`
}

func FakeTestCustom(fd int) Custom

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

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

func (p *FdWrapper) Close() error

func (p *FdWrapper) ToCustomCfg() Custom

type Option func(*cfg) *cfg

func WithShutdownTimeout(d time.Duration) Option

type PipeConn struct {
	R *os.File
	W *os.File
}

PipeConn turns a pair of uni directional pipe handlers into a bidirectional io.ReadWriteCloser

func (p *PipeConn) Close() error

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

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

type PluginConfigFromEngine struct {
	Name                string        `json:"name"`
	RegistrationTimeout time.Duration `json:"timeout"`
	Custom
}

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

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