server

package
v0.0.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 3, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrListnerClosed = errors.New("routing: listener closed")

Functions

This section is empty.

Types

type FindUpstreamFunc

type FindUpstreamFunc func(conn ssh.ConnMetadata, challengeCtx ssh.AdditionalChallengeContext) (net.Conn, *ssh.AuthPipe, error)

type MemoryProvider

type MemoryProvider struct {
	SocketPath string
}

func (*MemoryProvider) Name

func (p *MemoryProvider) Name() string

func (*MemoryProvider) Opts

func (p *MemoryProvider) Opts() string

func (*MemoryProvider) SSHD

func (p *MemoryProvider) SSHD() SSHDDialListener

func (*MemoryProvider) Session

func (p *MemoryProvider) Session() SessionDialListener

func (*MemoryProvider) SetOpts

func (p *MemoryProvider) SetOpts(opts NetworkOptions) error

type NetworkOptions

type NetworkOptions map[string]string

type NetworkProvider

type NetworkProvider interface {
	SetOpts(opts NetworkOptions) error
	Session() SessionDialListener
	SSHD() SSHDDialListener
	Name() string
	Opts() string
}

type NetworkProviders

type NetworkProviders []NetworkProvider
var Networks NetworkProviders

func (NetworkProviders) Get

type Proxy

type Proxy struct {
	HostSigners         []ssh.Signer
	SSHDDialListener    SSHDDialListener
	SessionDialListener SessionDialListener
	UpstreamNode        bool
	Logger              log.FieldLogger
	// contains filtered or unexported fields
}

func (*Proxy) Serve

func (r *Proxy) Serve(ln net.Listener) error

func (*Proxy) Shutdown

func (r *Proxy) Shutdown() error

type Routing

type Routing struct {
	HostSigners      []ssh.Signer
	FindUpstreamFunc FindUpstreamFunc
	Logger           log.FieldLogger
	// contains filtered or unexported fields
}

func (*Routing) Serve

func (p *Routing) Serve(ln net.Listener) error

func (*Routing) Shutdown

func (p *Routing) Shutdown() error

type SSHD

type SSHD struct {
	HostSigners         []gossh.Signer
	NodeAddr            string
	SessionDialListener SessionDialListener
	Logger              log.FieldLogger
	// contains filtered or unexported fields
}

func (*SSHD) Serve

func (s *SSHD) Serve(ln net.Listener) error

func (*SSHD) Shutdown

func (s *SSHD) Shutdown() error

type SSHDDialListener

type SSHDDialListener interface {
	Listen() (net.Listener, error)
	Dial() (net.Conn, error)
}

type Server

type Server struct {
	HostSigners     []ssh.Signer
	NodeAddr        string
	NetworkProvider NetworkProvider
	UpstreamNode    bool
	Logger          log.FieldLogger
	// contains filtered or unexported fields
}

func (*Server) Serve

func (s *Server) Serve(ln net.Listener) error

func (*Server) Shutdown

func (s *Server) Shutdown()

type ServerInfo

type ServerInfo struct {
	NodeAddr string
}

type SessionDialListener

type SessionDialListener interface {
	Listen(sesisonID string) (net.Listener, error)
	Dial(sessionID string) (net.Conn, error)
}

type UnixProvider

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

func (*UnixProvider) Name

func (p *UnixProvider) Name() string

func (*UnixProvider) Opts

func (p *UnixProvider) Opts() string

func (*UnixProvider) SSHD

func (p *UnixProvider) SSHD() SSHDDialListener

func (*UnixProvider) Session

func (p *UnixProvider) Session() SessionDialListener

func (*UnixProvider) SetOpts

func (p *UnixProvider) SetOpts(opts NetworkOptions) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL