ipc

Documentation

Index

• func FromCustomCfg(cfg Custom) (io.ReadWriteCloser, error)
• func NewPluginIPC(sockConn io.ReadWriteCloser, handler http.Handler, onServerClosed func(error), ...) (io.Closer, *http.Client, error)
• func NewRuntimeIPC(sockConn io.ReadWriteCloser, handler http.Handler, onServerClosed func(error), ...) (io.Closer, *http.Client, error)
• type Custom
  • func FakeTestCustom(fd int) Custom
• type FdWrapper
  • func NewConnectionPair(cmd *exec.Cmd) (net.Conn, *FdWrapper, error)
  • func (p *FdWrapper) Close() error
  • func (p *FdWrapper) ToCustomCfg() Custom
• type Option
  • func WithShutdownTimeout(d time.Duration) Option
• type PluginConfigFromEngine
  • func NewPluginConfigFromEngineEnv(in string) (*PluginConfigFromEngine, error)
  • func (c *PluginConfigFromEngine) ToString() (string, error)

Functions

func FromCustomCfg

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

FromCustomCfg is the counter part of ToCustomCfg(). Turns an file descriptor back into a connection object.

func NewPluginIPC

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

func NewRuntimeIPC

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

Types

type Custom

type Custom struct {
	Fd int `json:"fd"`
}

func FakeTestCustom

func FakeTestCustom(fd int) Custom

type FdWrapper

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

func NewConnectionPair

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

func (*FdWrapper) Close

func (p *FdWrapper) Close() error

func (*FdWrapper) ToCustomCfg

func (p *FdWrapper) ToCustomCfg() Custom

type Option

type Option func(*cfg) *cfg

func WithShutdownTimeout

func WithShutdownTimeout(d time.Duration) Option

type PluginConfigFromEngine

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

func NewPluginConfigFromEngineEnv

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

func (*PluginConfigFromEngine) ToString

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