Documentation
¶
Index ¶
- func FromCustomCfg(cfg Custom) (io.ReadWriteCloser, error)
- 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
- type Custom
- type FdWrapper
- type Option
- type PluginConfigFromEngine
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 Hijackify ¶
Hijackify to be used in conjunction with HijackAcceptor. Tells the server to perform hijack operation on the connection which means the server will retrieve the underlying tcp connection and hand it over / no longer serves requests to it. -> we can use it as a long-running server-client connection and re-purpose it to run our IPC/yamux stack on top.
func NewClientIPC ¶
func NewHijackAcceptor ¶
Types ¶
type CloseWriter ¶
type CloseWriter interface {
CloseWrite() error
}
type FdWrapper ¶
type FdWrapper struct {
// contains filtered or unexported fields
}
func (*FdWrapper) ToCustomCfg ¶
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)
Source Files
Click to show internal directories.
Click to hide internal directories.