server

package
v0.4.4 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2020 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func Start added in v0.1.1 

func Start(opt Opt) error

Types

type AuthRequest added in v0.3.0 

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 added in v0.3.0 

func (*AuthRequest) Descriptor() ([]byte, []int)

func (*AuthRequest) GetAuthorizedKey added in v0.3.0 

func (m *AuthRequest) GetAuthorizedKey() []byte

func (*AuthRequest) GetClientVersion added in v0.3.0 

func (m *AuthRequest) GetClientVersion() string

func (*AuthRequest) GetRemoteAddr added in v0.3.0 

func (m *AuthRequest) GetRemoteAddr() string

func (*AuthRequest) ProtoMessage added in v0.3.0 

func (*AuthRequest) ProtoMessage()

func (*AuthRequest) Reset added in v0.3.0 

func (m *AuthRequest) Reset()

func (*AuthRequest) String added in v0.3.0 

func (m *AuthRequest) String() string

func (*AuthRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *AuthRequest) XXX_DiscardUnknown()

func (*AuthRequest) XXX_Marshal added in v0.3.0 

func (m *AuthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AuthRequest) XXX_Merge added in v0.3.0 

func (m *AuthRequest) XXX_Merge(src proto.Message)

func (*AuthRequest) XXX_Size added in v0.3.0 

func (m *AuthRequest) XXX_Size() int

func (*AuthRequest) XXX_Unmarshal added in v0.3.0 

func (m *AuthRequest) XXX_Unmarshal(b []byte) error

type CreateSessionRequest added in v0.2.0 

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 added in v0.2.0 

func (*CreateSessionRequest) Descriptor() ([]byte, []int)

func (*CreateSessionRequest) GetClientAuthorizedKeys added in v0.2.0 

func (m *CreateSessionRequest) GetClientAuthorizedKeys() [][]byte

func (*CreateSessionRequest) GetHostPublicKeys added in v0.2.0 

func (m *CreateSessionRequest) GetHostPublicKeys() [][]byte

func (*CreateSessionRequest) GetHostUser added in v0.2.0 

func (m *CreateSessionRequest) GetHostUser() string

func (*CreateSessionRequest) ProtoMessage added in v0.2.0 

func (*CreateSessionRequest) ProtoMessage()

func (*CreateSessionRequest) Reset added in v0.2.0 

func (m *CreateSessionRequest) Reset()

func (*CreateSessionRequest) String added in v0.2.0 

func (m *CreateSessionRequest) String() string

func (*CreateSessionRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *CreateSessionRequest) XXX_DiscardUnknown()

func (*CreateSessionRequest) XXX_Marshal added in v0.2.0 

func (m *CreateSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSessionRequest) XXX_Merge added in v0.2.0 

func (m *CreateSessionRequest) XXX_Merge(src proto.Message)

func (*CreateSessionRequest) XXX_Size added in v0.2.0 

func (m *CreateSessionRequest) XXX_Size() int

func (*CreateSessionRequest) XXX_Unmarshal added in v0.2.0 

func (m *CreateSessionRequest) XXX_Unmarshal(b []byte) error

type CreateSessionResponse added in v0.2.0 

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 added in v0.2.0 

func (*CreateSessionResponse) Descriptor() ([]byte, []int)

func (*CreateSessionResponse) GetNodeAddr added in v0.2.0 

func (m *CreateSessionResponse) GetNodeAddr() string

func (*CreateSessionResponse) GetSessionID added in v0.2.0 

func (m *CreateSessionResponse) GetSessionID() string

func (*CreateSessionResponse) ProtoMessage added in v0.2.0 

func (*CreateSessionResponse) ProtoMessage()

func (*CreateSessionResponse) Reset added in v0.2.0 

func (m *CreateSessionResponse) Reset()

func (*CreateSessionResponse) String added in v0.2.0 

func (m *CreateSessionResponse) String() string

func (*CreateSessionResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *CreateSessionResponse) XXX_DiscardUnknown()

func (*CreateSessionResponse) XXX_Marshal added in v0.2.0 

func (m *CreateSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSessionResponse) XXX_Merge added in v0.2.0 

func (m *CreateSessionResponse) XXX_Merge(src proto.Message)

func (*CreateSessionResponse) XXX_Size added in v0.2.0 

func (m *CreateSessionResponse) XXX_Size() int

func (*CreateSessionResponse) XXX_Unmarshal added in v0.2.0 

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 NetworkOptions map[string]string

type NetworkProvider 

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

type Opt added in v0.1.1 

type Opt struct {
	SSHAddr    string
	WSAddr     string
	NodeAddr   string
	KeyFiles   []string
	Network    string
	NetworkOpt []string
	MetricAddr string
}

type SSHDDialListener 

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

type SSHRouting added in v0.1.1 

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

func (*SSHRouting) Serve added in v0.1.1 

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

func (*SSHRouting) Shutdown added in v0.1.1 

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 added in v0.1.1 

func (s *Server) ServeWithContext(ctx context.Context, sshln net.Listener, wsln 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.