Documentation ¶
Index ¶
- Constants
- Variables
- type Header
- type Imp
- type Master
- type MasterSession
- func (this *MasterSession) Close() error
- func (this *MasterSession) InitiateNamedPipe(ctx context.Context, connectionId connection.Id, purpose net.Purpose) (net.NamedPipe, error)
- func (this *MasterSession) InitiateTcpForward(ctx context.Context, connectionId connection.Id, target net.HostPort) (gonet.Conn, error)
- func (this *MasterSession) Kill(ctx context.Context, connectionId connection.Id, pid int, signal sys.Signal) error
- func (this *MasterSession) Ping(ctx context.Context, connectionId connection.Id) error
- type Method
- func (this *Method) DecodeMsgPack(dec codec.MsgPackDecoder) error
- func (this *Method) DecodeMsgpack(dec *msgpack.Decoder) error
- func (this Method) EncodeMsgPack(enc codec.MsgPackEncoder) error
- func (this Method) EncodeMsgpack(enc *msgpack.Encoder) error
- func (this Method) MarshalText() ([]byte, error)
- func (this Method) String() string
- func (this Method) Validate() error
- type Ref
Constants ¶
View Source
const (
DefaultPort = 9687
)
View Source
const (
HeaderMagic = 183
)
Variables ¶
View Source
var (
ErrIllegalMethod = errors.System.Newf("Illegal protocol method")
)
View Source
var (
ErrNoSuchProcess = errors.System.Newf("no such process")
)
Functions ¶
This section is empty.
Types ¶
type Header ¶
type Header struct { Method Method ConnectionId connection.Id }
func (*Header) DecodeMsgPack ¶
func (this *Header) DecodeMsgPack(dec codec.MsgPackDecoder) (err error)
func (*Header) DecodeMsgpack ¶
func (Header) EncodeMsgPack ¶
func (this Header) EncodeMsgPack(enc codec.MsgPackEncoder) error
func (Header) EncodeMsgpack ¶
type Imp ¶
type Master ¶
type Master struct { PrivateKey crypto.PrivateKey // contains filtered or unexported fields }
func (*Master) DialContext ¶
func (*Master) DialContextWithMsgPack ¶
type MasterSession ¶
type MasterSession struct {
// contains filtered or unexported fields
}
func (*MasterSession) Close ¶
func (this *MasterSession) Close() error
func (*MasterSession) InitiateNamedPipe ¶
func (this *MasterSession) InitiateNamedPipe(ctx context.Context, connectionId connection.Id, purpose net.Purpose) (net.NamedPipe, error)
func (*MasterSession) InitiateTcpForward ¶
func (this *MasterSession) InitiateTcpForward(ctx context.Context, connectionId connection.Id, target net.HostPort) (gonet.Conn, error)
func (*MasterSession) Kill ¶
func (this *MasterSession) Kill(ctx context.Context, connectionId connection.Id, pid int, signal sys.Signal) error
func (*MasterSession) Ping ¶
func (this *MasterSession) Ping(ctx context.Context, connectionId connection.Id) error
type Method ¶
type Method uint8
func (*Method) DecodeMsgPack ¶
func (this *Method) DecodeMsgPack(dec codec.MsgPackDecoder) error
func (*Method) DecodeMsgpack ¶
func (Method) EncodeMsgPack ¶
func (this Method) EncodeMsgPack(enc codec.MsgPackEncoder) error
func (Method) EncodeMsgpack ¶
func (Method) MarshalText ¶
Click to show internal directories.
Click to hide internal directories.