server

Documentation

Index

• type HandshakeFailureHandler
• type SipcChild
  • func (child *SipcChild) AttachProcess(process *os.Process) error
  • func (child *SipcChild) AttachProcessWithPid(pid int) error
  • func (child *SipcChild) Close() error
  • func (child *SipcChild) GetEncodedConnectInfo() string
  • func (child *SipcChild) IsClosed() bool
  • func (child *SipcChild) Read(p []byte) (int, error)
  • func (child *SipcChild) Start() error
  • func (child *SipcChild) Write(p []byte) (n int, err error)
• type SipcChildConfig
• type SipcServer
  • func NewSipcServer(config SipcServerConfig) (*SipcServer, error)
  • func (server *SipcServer) CreateProcess(cmd *exec.Cmd, config *SipcChildConfig) (*SipcChild, error)
  • func (server *SipcServer) PrepareProcess(config *SipcChildConfig) (*SipcChild, error)
  • func (server *SipcServer) Shutdown()
• type SipcServerConfig
• type State

Types

type HandshakeFailureHandler

type HandshakeFailureHandler func(child *SipcChild, cause error)

type SipcChild

type SipcChild struct {
	io.ReadWriteCloser
	// contains filtered or unexported fields
}

func (*SipcChild) AttachProcess

func (child *SipcChild) AttachProcess(process *os.Process) error

func (*SipcChild) AttachProcessWithPid

func (child *SipcChild) AttachProcessWithPid(pid int) error

func (*SipcChild) Close

func (child *SipcChild) Close() error

func (*SipcChild) GetEncodedConnectInfo

func (child *SipcChild) GetEncodedConnectInfo() string

func (*SipcChild) IsClosed

func (child *SipcChild) IsClosed() bool

func (*SipcChild) Read

func (child *SipcChild) Read(p []byte) (int, error)

func (*SipcChild) Start

func (child *SipcChild) Start() error

func (*SipcChild) Write

func (child *SipcChild) Write(p []byte) (n int, err error)

type SipcChildConfig

type SipcChildConfig struct {
	HandshakeFailureHandler HandshakeFailureHandler
}

type SipcServer

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

func NewSipcServer

func NewSipcServer(config SipcServerConfig) (*SipcServer, error)

func (*SipcServer) CreateProcess

func (server *SipcServer) CreateProcess(cmd *exec.Cmd, config *SipcChildConfig) (*SipcChild, error)

func (*SipcServer) PrepareProcess

func (server *SipcServer) PrepareProcess(config *SipcChildConfig) (*SipcChild, error)

func (*SipcServer) Shutdown

func (server *SipcServer) Shutdown()

type SipcServerConfig

type SipcServerConfig struct {
	Path             string
	LocalPrivateKey  []byte
	HandshakeTimeout time.Duration
	Transport        transport.Transport
	AllowReconnect   bool
}

type State

type State int