udschannel

Documentation

Index

• Constants
• type Channel
  • func NewChannel(producerSocket, consumerSocket int) *Channel
  • func (c *Channel) Close() error
  • func (c *Channel) Read(buf []byte) (int, error)
  • func (c *Channel) Write(bytes []byte) (int, error)
• type UdsChannel
  • func NewController(filePath string, args []string, channelNum int) (*UdsChannel, error)
  • func (w *UdsChannel) GetChannel(index int) (*Channel, error)
  • func (w *UdsChannel) Signal(signal os.Signal) error
  • func (w *UdsChannel) StopChild() error
  • func (w *UdsChannel) WatchChild() chan error

Constants

const (
	CustomerPipeStart = 3
)

Types

type Channel

type Channel struct {
	ProducerSocket int
	ConsumerSocket int
	// contains filtered or unexported fields
}

func NewChannel

func NewChannel(producerSocket, consumerSocket int) *Channel

func (*Channel) Close

func (c *Channel) Close() error

func (*Channel) Read

func (c *Channel) Read(buf []byte) (int, error)

func (*Channel) Write

func (c *Channel) Write(bytes []byte) (int, error)

type UdsChannel

type UdsChannel struct {
	Child       *os.Process
	ChildStdOut *os.File
	ChildStdErr *os.File

	Closed bool

	Channels []*Channel

	// watch the child process status
	ChildExit chan error
}

func NewController

func NewController(filePath string, args []string, channelNum int) (*UdsChannel, error)

NOTICE :the stdioMapping param is a analogy of nodejs spawn stdio map , like stdio:["ignore", "inherit", "pipe"]

func (*UdsChannel) GetChannel

func (w *UdsChannel) GetChannel(index int) (*Channel, error)

func (*UdsChannel) Signal

func (w *UdsChannel) Signal(signal os.Signal) error

func (*UdsChannel) StopChild

func (w *UdsChannel) StopChild() error

func (*UdsChannel) WatchChild

func (w *UdsChannel) WatchChild() chan error