server

Documentation

Index

• Constants
• Variables
• func ErrorText(err error) string
• func Flags(flags *flag.FlagSet)
• func LoadDeprecated(flags *flag.FlagSet)
• func RemoteIP(addr net.Addr) string
• type APIServer
  • func NewAPI(flags *flag.FlagSet) APIServer
  • func (s *APIServer) Health(w http.ResponseWriter, _ *http.Request)
  • func (s *APIServer) Listen(ctx context.Context) error
  • func (s *APIServer) Streams(w http.ResponseWriter, r *http.Request)
• type HealthResponse
• type Info
  • func NewInfo() Info
  • func (s *Info) GetStreams() []Stream
  • func (s *Info) NumActive() int
  • func (s *Info) StreamConnect(server, remoteIP string) (uint, error)
  • func (s *Info) StreamDisconnect(id uint)
• type MovieServer
  • func NewMovieServer(flags *flag.FlagSet, prefix string) MovieServer
• type SSHServer
  • func NewSSH(flags *flag.FlagSet) SSHServer
  • func (s *SSHServer) Handler(m *movie.Movie) bubbletea.Handler
  • func (s *SSHServer) Listen(ctx context.Context, m *movie.Movie) error
  • func (s *SSHServer) TrackStream(handler ssh.Handler) ssh.Handler
• type Server
  • func NewServer(flags *flag.FlagSet, prefix string) Server
• type Stream
• type StreamsResponse
• type TelnetServer
  • func NewTelnet(flags *flag.FlagSet) TelnetServer
  • func (s *TelnetServer) Handler(ctx context.Context, conn net.Conn, m *movie.Movie)
  • func (s *TelnetServer) Listen(ctx context.Context, m *movie.Movie) error

Constants

const (
	SSHFlagPrefix    = "ssh"
	TelnetFlagPrefix = "telnet"
	APIFlagPrefix    = "api"
	EnabledFlag      = "-enabled"
	AddressFlag      = "-address"

	SSHHostKeyPathFlag = SSHFlagPrefix + "-host-key"
	SSHHostKeyDataFlag = SSHFlagPrefix + "-host-key-data"

	ConcurrentStreamsFlag = "concurrent-streams"
	TimeoutFlag           = "timeout"
	IdleTimeoutFlag       = "idle-timeout"
	MaxTimeoutFlag        = "max-timeout"
)

Variables

var ErrRateLimited = errors.New("rate limited")

Functions

func ErrorText

func ErrorText(err error) string

func Flags

func Flags(flags *flag.FlagSet)

func LoadDeprecated

func LoadDeprecated(flags *flag.FlagSet)

func RemoteIP

func RemoteIP(addr net.Addr) string

Types

type APIServer

type APIServer struct {
	Server
	TelnetEnabled bool
	SSHEnabled    bool
}

func NewAPI

func NewAPI(flags *flag.FlagSet) APIServer

func (*APIServer) Health

func (s *APIServer) Health(w http.ResponseWriter, _ *http.Request)

func (*APIServer) Listen

func (s *APIServer) Listen(ctx context.Context) error

func (*APIServer) Streams

func (s *APIServer) Streams(w http.ResponseWriter, r *http.Request)

type HealthResponse

type HealthResponse struct {
	Healthy bool `json:"healthy"`
	SSH     bool `json:"ssh"`
	Telnet  bool `json:"telnet"`
}

type Info

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

func NewInfo

func NewInfo() Info

func (*Info) GetStreams

func (s *Info) GetStreams() []Stream

func (*Info) NumActive

func (s *Info) NumActive() int

func (*Info) StreamConnect

func (s *Info) StreamConnect(server, remoteIP string) (uint, error)

func (*Info) StreamDisconnect

func (s *Info) StreamDisconnect(id uint)

type MovieServer

type MovieServer struct {
	Server
	Movie *movie.Movie
}

func NewMovieServer

func NewMovieServer(flags *flag.FlagSet, prefix string) MovieServer

type SSHServer

type SSHServer struct {
	MovieServer
	HostKeyPath []string
	HostKeyPEM  []string
}

func NewSSH

func NewSSH(flags *flag.FlagSet) SSHServer

func (*SSHServer) Handler

func (s *SSHServer) Handler(m *movie.Movie) bubbletea.Handler

func (*SSHServer) Listen

func (s *SSHServer) Listen(ctx context.Context, m *movie.Movie) error

func (*SSHServer) TrackStream

func (s *SSHServer) TrackStream(handler ssh.Handler) ssh.Handler

type Server

type Server struct {
	Enabled bool
	Address string
	Log     *slog.Logger
}

func NewServer

func NewServer(flags *flag.FlagSet, prefix string) Server

type Stream

type Stream struct {
	Server    string    `json:"server"`
	RemoteIP  string    `json:"remote_ip"`
	Connected time.Time `json:"connected"`
}

type StreamsResponse

type StreamsResponse struct {
	Active  *int      `json:"active,omitempty"`
	Total   *uint32   `json:"total,omitempty"`
	Streams *[]Stream `json:"streams,omitempty"`
}

type TelnetServer

type TelnetServer struct {
	MovieServer
}

func NewTelnet

func NewTelnet(flags *flag.FlagSet) TelnetServer

func (*TelnetServer) Handler

func (s *TelnetServer) Handler(ctx context.Context, conn net.Conn, m *movie.Movie)

func (*TelnetServer) Listen

func (s *TelnetServer) Listen(ctx context.Context, m *movie.Movie) error