Documentation
¶
Index ¶
- type Pipe
- func (v *Pipe) AtomicExecute(target func())
- func (v *Pipe) Close() error
- func (v *Pipe) ExecuteControlCommand(cmd message.Command) (message.Command, error)
- func (v *Pipe) Fail()
- func (v *Pipe) Failed() bool
- func (v *Pipe) ProcessControlCommand(expectedType message.CMD_TYPE, ...) error
- func (v *Pipe) Run(ctx context.Context, is_server bool) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pipe ¶
type Pipe struct {
Iface *water.Interface
File *os.File
Transport transport.Transport
FailFlag bool
Mutex *sync.Mutex
Routes []string
}
func (*Pipe) AtomicExecute ¶
func (v *Pipe) AtomicExecute(target func())
func (*Pipe) ExecuteControlCommand ¶
func (*Pipe) ProcessControlCommand ¶
Source Files
Click to show internal directories.
Click to hide internal directories.