dehub

May 15, 2024

Changes in this version

type Master

+ func (m *Master) ForwardGRPC(listenTo net.Listener) error

+ func (m *Master) ForwardHTTP(listenTo net.Listener) error

May 10, 2024

Changes in this version

type DB

+ DeleteLocation func(id string) error

May 10, 2024

Changes in this version

type Hub

+ func (h *Hub) MustStartRelay() func()

+ func (h *Hub) StartRelay(addr string) (func(), error)

May 7, 2024

Changes in this version

+ func FormatPubKey(key ssh.PublicKey) string

May 7, 2024

Changes in this version

+ func CheckPublicKeys(trustedPubKeys ...[]byte) func(ssh.PublicKey) bool

May 7, 2024

Changes in this version

type Servant

+ func (s *Servant) Serve(conn io.ReadWriteCloser) func()

May 6, 2024

Changes in this version

type Hub

+ DB DB

May 6, 2024

Changes in this version

+ const DefaultSignTimeout

+ const ExecResizeRequest

+ const FailedStartPTY

+ const PubKeyRawKey

+ const UnmarshalMetaFailed

+ func WebsocketDial(ctx context.Context, addr string) (net.Conn, error)

+ func WebsocketUpgrade(conn io.ReadWriter) error

+ type ClientType int

+ const ClientTypeMaster

+ const ClientTypeServant

+ type Command string

+ const CommandExec

+ const CommandForwardSocks5

+ const CommandShareDir

+ func (c Command) String() string

+ type DB interface

+ LoadLocation func(id ServantID) (netAddr string, err error)

+ StoreLocation func(id ServantID, netAddr string) error

+ type ExecMeta struct

+ Args []string

+ Cmd string

+ Size *pty.Winsize

+ type Hub struct

+ GetIP func() (string, error)

+ Logger *slog.Logger

+ func NewHub() *Hub

+ func (h *Hub) Handle(conn io.ReadWriteCloser)

+ type HubHeader struct

+ ID ServantID

+ Type ClientType

+ type Logger interface

+ Error func(string, ...slog.Attr)

+ Info func(string, ...slog.Attr)

+ Warn func(string, ...slog.Attr)

+ type Master struct

+ Logger *slog.Logger

+ func NewMaster(id ServantID, prvKey ssh.Signer, trustedPubKeys ...[]byte) *Master

+ func (m *Master) Connect(conn io.ReadWriteCloser) error

+ func (m *Master) Exec(in io.Reader, out io.Writer, cmd string, args ...string) error

+ func (m *Master) ForwardSocks5(listenTo net.Listener) error

+ func (m *Master) ServeNFS(remoteDir string, fsSrv net.Listener, cacheLimit int) error

+ type MountDirMeta struct

+ CacheLimit int

+ Path string

+ type PubKey struct

+ type PubKeys map[string]PubKey

+ type Servant struct

+ Logger *slog.Logger

+ SignTimeout time.Duration

+ func NewServant(id ServantID, prvKey ssh.Signer, pubKeys ...[]byte) *Servant

+ func (s *Servant) Handle(conn io.ReadWriteCloser) func()

+ type ServantID string

+ func (n ServantID) String() string

+ type TunnelHeader struct

+ Command Command

+ ExecMeta *ExecMeta

+ PubKeyHash [md5.Size]byte

+ ShareDirMeta *MountDirMeta

+ Sign *ssh.Signature

+ Timestamp []byte