internal

Documentation

Index

• type AdminServer
  • func (s *AdminServer) Serve(ctx context.Context, sock string) error
  • func (s *AdminServer) Shutdown(ctx context.Context) error
• type ClientRepo
  • func NewClientRepo() *ClientRepo
  • func (c *ClientRepo) Add(client *api.Client) error
  • func (c *ClientRepo) Clients() []*api.Client
  • func (c *ClientRepo) Delete(clientId string)
  • func (c *ClientRepo) Get(clientId string) *api.Client
• type PermissionDeniedError
  • func (e *PermissionDeniedError) Error() string
  • func (e *PermissionDeniedError) Unwrap() error
• type ReverseTunnel
  • func (c *ReverseTunnel) Close()
  • func (c *ReverseTunnel) Establish(ctx context.Context) (*server.CreateSessionResponse, error)
  • func (c *ReverseTunnel) Listener() net.Listener
• type Server
  • func (s *Server) ServeWithContext(ctx context.Context, l net.Listener) error

Types

type AdminServer

type AdminServer struct {
	Session    *api.GetSessionResponse
	ClientRepo *ClientRepo

	sync.Mutex
	// contains filtered or unexported fields
}

func (*AdminServer) Serve

func (s *AdminServer) Serve(ctx context.Context, sock string) error

func (*AdminServer) Shutdown

func (s *AdminServer) Shutdown(ctx context.Context) error

type ClientRepo

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

func NewClientRepo

func NewClientRepo() *ClientRepo

func (*ClientRepo) Add

func (c *ClientRepo) Add(client *api.Client) error

func (*ClientRepo) Clients

func (c *ClientRepo) Clients() []*api.Client

func (*ClientRepo) Delete

func (c *ClientRepo) Delete(clientId string)

func (*ClientRepo) Get

func (c *ClientRepo) Get(clientId string) *api.Client

type PermissionDeniedError

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

func (*PermissionDeniedError) Error

func (e *PermissionDeniedError) Error() string

func (*PermissionDeniedError) Unwrap

func (e *PermissionDeniedError) Unwrap() error

type ReverseTunnel

type ReverseTunnel struct {
	*ssh.Client

	Host              *url.URL
	Signers           []ssh.Signer
	AuthorizedKeys    []ssh.PublicKey
	KeepAliveDuration time.Duration
	HostKeyCallback   ssh.HostKeyCallback
	Logger            log.FieldLogger
	// contains filtered or unexported fields
}

func (*ReverseTunnel) Close

func (c *ReverseTunnel) Close()

func (*ReverseTunnel) Establish

func (c *ReverseTunnel) Establish(ctx context.Context) (*server.CreateSessionResponse, error)

func (*ReverseTunnel) Listener

func (c *ReverseTunnel) Listener() net.Listener

type Server

type Server struct {
	Command           []string
	CommandEnv        []string
	ForceCommand      []string
	Signers           []ssh.Signer
	AuthorizedKeys    []ssh.PublicKey
	EventEmitter      *emitter.Emitter
	KeepAliveDuration time.Duration
	Stdin             *os.File
	Stdout            *os.File
	Logger            log.FieldLogger
	ReadOnly          bool
}

func (*Server) ServeWithContext

func (s *Server) ServeWithContext(ctx context.Context, l net.Listener) error