Documentation
¶
Index ¶
- Variables
- func Start(opt Opt) error
- type AuthRequest
- func (*AuthRequest) Descriptor() ([]byte, []int)
- func (m *AuthRequest) GetAuthorizedKey() []byte
- func (m *AuthRequest) GetClientVersion() string
- func (m *AuthRequest) GetRemoteAddr() string
- func (*AuthRequest) ProtoMessage()
- func (m *AuthRequest) Reset()
- func (m *AuthRequest) String() string
- func (m *AuthRequest) XXX_DiscardUnknown()
- func (m *AuthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AuthRequest) XXX_Merge(src proto.Message)
- func (m *AuthRequest) XXX_Size() int
- func (m *AuthRequest) XXX_Unmarshal(b []byte) error
- type CreateSessionRequest
- func (*CreateSessionRequest) Descriptor() ([]byte, []int)
- func (m *CreateSessionRequest) GetClientAuthorizedKeys() [][]byte
- func (m *CreateSessionRequest) GetHostPublicKeys() [][]byte
- func (m *CreateSessionRequest) GetHostUser() string
- func (*CreateSessionRequest) ProtoMessage()
- func (m *CreateSessionRequest) Reset()
- func (m *CreateSessionRequest) String() string
- func (m *CreateSessionRequest) XXX_DiscardUnknown()
- func (m *CreateSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateSessionRequest) XXX_Merge(src proto.Message)
- func (m *CreateSessionRequest) XXX_Size() int
- func (m *CreateSessionRequest) XXX_Unmarshal(b []byte) error
- type CreateSessionResponse
- func (*CreateSessionResponse) Descriptor() ([]byte, []int)
- func (m *CreateSessionResponse) GetNodeAddr() string
- func (m *CreateSessionResponse) GetSessionID() string
- func (*CreateSessionResponse) ProtoMessage()
- func (m *CreateSessionResponse) Reset()
- func (m *CreateSessionResponse) String() string
- func (m *CreateSessionResponse) XXX_DiscardUnknown()
- func (m *CreateSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateSessionResponse) XXX_Merge(src proto.Message)
- func (m *CreateSessionResponse) XXX_Size() int
- func (m *CreateSessionResponse) XXX_Unmarshal(b []byte) error
- type FindUpstreamFunc
- type MemoryProvider
- type NetworkOptions
- type NetworkProvider
- type Opt
- type SSHDDialListener
- type SSHRouting
- type Server
- type ServerInfo
- type SessionDialListener
- type UnixProvider
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrListnerClosed = errors.New("routing: listener closed")
)
Functions ¶
Types ¶
type AuthRequest ¶
type AuthRequest struct {
ClientVersion string `protobuf:"bytes,1,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`
RemoteAddr string `protobuf:"bytes,2,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
AuthorizedKey []byte `protobuf:"bytes,3,opt,name=authorized_key,json=authorizedKey,proto3" json:"authorized_key,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*AuthRequest) Descriptor ¶
func (*AuthRequest) Descriptor() ([]byte, []int)
func (*AuthRequest) GetAuthorizedKey ¶
func (m *AuthRequest) GetAuthorizedKey() []byte
func (*AuthRequest) GetClientVersion ¶
func (m *AuthRequest) GetClientVersion() string
func (*AuthRequest) GetRemoteAddr ¶
func (m *AuthRequest) GetRemoteAddr() string
func (*AuthRequest) ProtoMessage ¶
func (*AuthRequest) ProtoMessage()
func (*AuthRequest) Reset ¶
func (m *AuthRequest) Reset()
func (*AuthRequest) String ¶
func (m *AuthRequest) String() string
func (*AuthRequest) XXX_DiscardUnknown ¶
func (m *AuthRequest) XXX_DiscardUnknown()
func (*AuthRequest) XXX_Marshal ¶
func (m *AuthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AuthRequest) XXX_Merge ¶
func (m *AuthRequest) XXX_Merge(src proto.Message)
func (*AuthRequest) XXX_Size ¶
func (m *AuthRequest) XXX_Size() int
func (*AuthRequest) XXX_Unmarshal ¶
func (m *AuthRequest) XXX_Unmarshal(b []byte) error
type CreateSessionRequest ¶
type CreateSessionRequest struct {
HostUser string `protobuf:"bytes,1,opt,name=hostUser,proto3" json:"hostUser,omitempty"`
HostPublicKeys [][]byte `protobuf:"bytes,2,rep,name=hostPublicKeys,proto3" json:"hostPublicKeys,omitempty"`
ClientAuthorizedKeys [][]byte `protobuf:"bytes,3,rep,name=clientAuthorizedKeys,proto3" json:"clientAuthorizedKeys,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CreateSessionRequest) Descriptor ¶
func (*CreateSessionRequest) Descriptor() ([]byte, []int)
func (*CreateSessionRequest) GetClientAuthorizedKeys ¶
func (m *CreateSessionRequest) GetClientAuthorizedKeys() [][]byte
func (*CreateSessionRequest) GetHostPublicKeys ¶
func (m *CreateSessionRequest) GetHostPublicKeys() [][]byte
func (*CreateSessionRequest) GetHostUser ¶
func (m *CreateSessionRequest) GetHostUser() string
func (*CreateSessionRequest) ProtoMessage ¶
func (*CreateSessionRequest) ProtoMessage()
func (*CreateSessionRequest) Reset ¶
func (m *CreateSessionRequest) Reset()
func (*CreateSessionRequest) String ¶
func (m *CreateSessionRequest) String() string
func (*CreateSessionRequest) XXX_DiscardUnknown ¶
func (m *CreateSessionRequest) XXX_DiscardUnknown()
func (*CreateSessionRequest) XXX_Marshal ¶
func (m *CreateSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateSessionRequest) XXX_Merge ¶
func (m *CreateSessionRequest) XXX_Merge(src proto.Message)
func (*CreateSessionRequest) XXX_Size ¶
func (m *CreateSessionRequest) XXX_Size() int
func (*CreateSessionRequest) XXX_Unmarshal ¶
func (m *CreateSessionRequest) XXX_Unmarshal(b []byte) error
type CreateSessionResponse ¶
type CreateSessionResponse struct {
SessionID string `protobuf:"bytes,1,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
NodeAddr string `protobuf:"bytes,2,opt,name=nodeAddr,proto3" json:"nodeAddr,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CreateSessionResponse) Descriptor ¶
func (*CreateSessionResponse) Descriptor() ([]byte, []int)
func (*CreateSessionResponse) GetNodeAddr ¶
func (m *CreateSessionResponse) GetNodeAddr() string
func (*CreateSessionResponse) GetSessionID ¶
func (m *CreateSessionResponse) GetSessionID() string
func (*CreateSessionResponse) ProtoMessage ¶
func (*CreateSessionResponse) ProtoMessage()
func (*CreateSessionResponse) Reset ¶
func (m *CreateSessionResponse) Reset()
func (*CreateSessionResponse) String ¶
func (m *CreateSessionResponse) String() string
func (*CreateSessionResponse) XXX_DiscardUnknown ¶
func (m *CreateSessionResponse) XXX_DiscardUnknown()
func (*CreateSessionResponse) XXX_Marshal ¶
func (m *CreateSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateSessionResponse) XXX_Merge ¶
func (m *CreateSessionResponse) XXX_Merge(src proto.Message)
func (*CreateSessionResponse) XXX_Size ¶
func (m *CreateSessionResponse) XXX_Size() int
func (*CreateSessionResponse) XXX_Unmarshal ¶
func (m *CreateSessionResponse) XXX_Unmarshal(b []byte) error
type FindUpstreamFunc ¶
type FindUpstreamFunc func(conn ssh.ConnMetadata, challengeCtx ssh.AdditionalChallengeContext) (net.Conn, *ssh.AuthPipe, error)
type MemoryProvider ¶
type MemoryProvider struct {
SocketPath string
// contains filtered or unexported fields
}
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 NetworkProvider ¶
type NetworkProvider interface {
SetOpts(opts NetworkOptions) error
Session() SessionDialListener
SSHD() SSHDDialListener
Name() string
Opts() string
}
type SSHDDialListener ¶
type SSHRouting ¶
type SSHRouting struct {
HostSigners []ssh.Signer
FindUpstreamFunc FindUpstreamFunc
Logger log.FieldLogger
MetricsProvider provider.Provider
// contains filtered or unexported fields
}
func (*SSHRouting) Shutdown ¶
func (p *SSHRouting) Shutdown() error
type Server ¶
type Server struct {
NodeAddr string
HostSigners []ssh.Signer
NetworkProvider NetworkProvider
MetricsProvider provider.Provider
Logger log.FieldLogger
// contains filtered or unexported fields
}
func (*Server) ServeWithContext ¶
type ServerInfo ¶
type ServerInfo struct {
NodeAddr string
}
type SessionDialListener ¶
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
Click to show internal directories.
Click to hide internal directories.