protocol

Jan 25, 2025

Changes in this version

type MasterSession

+ func (this *MasterSession) GetEnvironment(ctx context.Context, connectionId connection.Id) (sys.EnvVars, error)

type Method

+ const MethodGetEnvironment

Nov 26, 2024

Changes in this version

+ const DefaultExitCodeByConnectionIdPath — darwin/amd64, linux/amd64, windows/amd64

+ const DefaultExitCodeByConnectionIdPathUnix

+ const DefaultExitCodeByConnectionIdPathWindows

type Imp

+ ExitCodeByConnectionIdPath string

type MasterSession

+ func (this *MasterSession) GetConnectionExitCode(ctx context.Context, connectionId connection.Id) (int, error)

type Method

+ const MethodGetConnectionExitCode

type Ref

+ Dial func(context.Context) (gonet.Conn, error)

Oct 23, 2024

Changes in this version

+ const DefaultPort

+ const HeaderMagic

+ var ErrIllegalMethod = errors.System.Newf("Illegal protocol method")

+ var ErrNoSuchProcess = errors.System.Newf("no such process")

+ type Header struct

+ ConnectionId connection.Id

+ Method Method

+ func (this *Header) DecodeMsgPack(dec codec.MsgPackDecoder) (err error)

+ func (this *Header) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (this Header) EncodeMsgPack(enc codec.MsgPackEncoder) error

+ func (this Header) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Imp struct

+ Addr string

+ Logger log.Logger

+ MasterPublicKey crypto.PublicKey

+ SessionId session.Id

+ func (this *Imp) Serve(ctx context.Context) error

+ type Master struct

+ PrivateKey crypto.PrivateKey

+ func NewMaster(_ context.Context, masterPrivateKey crypto.PrivateKey) (*Master, error)

+ func (this *Master) DialContext(ctx context.Context, ref Ref) (gonet.Conn, error)

+ func (this *Master) DialContextWithMsgPack(ctx context.Context, ref Ref) (codec.MsgPackConn, error)

+ func (this *Master) Open(_ context.Context, ref Ref) (*MasterSession, error)

+ type MasterSession struct

+ 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 uint8

+ const MethodKill

+ const MethodNamedPipe

+ const MethodPing

+ const MethodTcpForward

+ 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 interface

+ EndpointAddr func() net.HostPort

+ PublicKey func() crypto.PublicKey

+ SessionId func() session.Id