sshproxy

type GetUpstreamCallback ¶

type GetUpstreamCallback func(ctx context.Context, id string) (Upstream, error)

GetUpstreamCallback should return ErrUpstreamNotFound if upstream not found and any error value in case of other errors. The implementation should set reasonable timeouts for long-running operations, the caller side don't apply any timeout when calling the function.

type Host ¶

type Host struct {
	// contains filtered or unexported fields
}

func NewHost(address string, user string, privateKey ssh.Signer) Host

type HostKey ¶

type HostKey = ssh.Signer

func LoadHostKeysFromBlob(blob []byte) ([]HostKey, error)

func LoadHostKeysFromFile(path string) ([]HostKey, error)

type Server ¶

type Server struct {
	// contains filtered or unexported fields
}

func NewServer(
	ctx context.Context, address string, port int,
	hostKeys []HostKey, getUpstream GetUpstreamCallback,
) *Server

func (s *Server) Close(ctx context.Context) error

func (s *Server) ListenAndServe(ctx context.Context) error

type Upstream ¶

type Upstream struct {
	// contains filtered or unexported fields
}

func NewUpstream(hosts []Host, authorizedKeys []ssh.PublicKey) Upstream

func (u *Upstream) IsAuthorized(publicKey ssh.PublicKey) bool