test

Documentation

Index

• Constants
• Variables
• func StartServer(ctx context.Context) error
• type Channel
  • func (c *Channel) Close() error
  • func (c *Channel) CloseWrite() error
  • func (c *Channel) Read(data []byte) (int, error)
  • func (c *Channel) SendRequest(name string, wantReply bool, payload []byte) (bool, error)
  • func (c *Channel) Stderr() io.ReadWriter
  • func (c *Channel) Write(data []byte) (int, error)
• type Session
  • func (s *Session) KeepAlive(reason string)
  • func (s *Session) OpenStreamingChannel(ctx context.Context, id liveshare.ChannelID) (ssh.Channel, error)
  • func (s *Session) StartSharing(ctx context.Context, sessionName string, port int) (liveshare.ChannelID, error)

Constants

const (
	ServerPort = 50051
)

Variables

var (
	JupyterPort      = 1234
	JupyterServerUrl = "http://localhost:1234?token=1234"
	JupyterMessage   = ""
	JupyterResult    = true
)

Functions

func StartServer

func StartServer(ctx context.Context) error

Starts the mock gRPC server listening on port 50051

Types

type Channel

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

func (*Channel) Close

func (c *Channel) Close() error

func (*Channel) CloseWrite

func (c *Channel) CloseWrite() error

func (*Channel) Read

func (c *Channel) Read(data []byte) (int, error)

func (*Channel) SendRequest

func (c *Channel) SendRequest(name string, wantReply bool, payload []byte) (bool, error)

func (*Channel) Stderr

func (c *Channel) Stderr() io.ReadWriter

func (*Channel) Write

func (c *Channel) Write(data []byte) (int, error)

type Session

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

func (*Session) KeepAlive

func (s *Session) KeepAlive(reason string)

func (*Session) OpenStreamingChannel

func (s *Session) OpenStreamingChannel(ctx context.Context, id liveshare.ChannelID) (ssh.Channel, error)

Creates mock SSH channel connected to the mock gRPC server

func (*Session) StartSharing

func (s *Session) StartSharing(ctx context.Context, sessionName string, port int) (liveshare.ChannelID, error)