Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kernel

package

Go to main page

Versions in this module

v0

v0.10.1

Apr 14, 2024

Changes in this version

type Kernel

+ func (k *Kernel) CallInterruptSubscribers()

v0.10.0

Apr 7, 2024

Changes in this version

+ var CaptureSignals = []os.Signal

+ type InterruptFn func(id SubscriptionId)

type Kernel

+ func (k *Kernel) SubscribeInterrupt(fn InterruptFn) SubscriptionId

+ func (k *Kernel) UnsubscribeInterrupt(id SubscriptionId)

+ type SubscriptionId *list.Element

v0.9.6

Feb 18, 2024

v0.9.5

Jan 10, 2024

v0.9.4

Dec 13, 2023

v0.9.3

Oct 9, 2023

v0.9.2

Oct 7, 2023

v0.9.1

Oct 4, 2023

v0.9.0

Oct 4, 2023

Changes in this version

+ const JupyterDataDirEnv

+ const StatusBusy

+ const StatusIdle

+ const StatusStarting

+ const StreamStderr

+ const StreamStdout

+ var ProtocolVersion = "5.4"

+ func Install(extraArgs []string, forceDeps, forceCopy bool) error

+ func JupyterCursorPosToBytePos(cellContent string, cursorPosUTF16 int) int

+ func JupyterToLinesAndCursor(cellContent string, cursorPosUTF16 int) (lines []string, cursorLine, cursorCol int)

+ func LogDisplayData(data MIMEMap)

+ func NewJupyterStreamWriter(msg Message, stream string) io.Writer

+ func PublishData(msg Message, data Data) error

+ func PublishDisplayData(msg Message, data Data) error

+ func PublishExecuteInput(msg Message, code string) error

+ func PublishExecuteResult(msg Message, data Data) error

+ func PublishExecutionError(msg Message, err string, trace []string, name string) error

+ func PublishHtml(msg Message, html string) error

+ func PublishJavascript(msg Message, js string) error

+ func PublishKernelStatus(msg Message, status string) error

+ func PublishMarkdown(msg Message, markdown string) error

+ func PublishUpdateDisplayData(msg Message, data Data) error

+ func PublishWriteStream(msg Message, stream string, data string) error

+ func SendKernelInfo(msg Message, version string) error

+ type CommClose struct

+ CommId string

+ Data map[string]any

+ type CommInfoReply struct

+ Comms map[string]map[string]string

+ Status string

+ type CommMsg struct

+ CommId string

+ Data map[string]any

+ type CommOpen struct

+ CommId string

+ Data map[string]any

+ TargetName string

+ type CompleteReply struct

+ CursorEnd int

+ CursorStart int

+ Matches []string

+ Metadata MIMEMap

+ Status string

+ type ComposedMsg struct

+ Content any

+ Header zmqMsgHeader

+ Metadata map[string]any

+ ParentHeader zmqMsgHeader

+ func NewComposed(msgType string, parent ComposedMsg) (*ComposedMsg, error)

+ type Data = struct

+ Data MIMEMap

+ Metadata MIMEMap

+ Transient MIMEMap

+ type HelpLink struct

+ Text string

+ URL string

+ type InspectReply struct

+ Data MIMEMap

+ Found bool

+ Metadata MIMEMap

+ Status string

+ type InvalidSignatureError struct

+ func (e *InvalidSignatureError) Error() string

+ type Kernel struct

+ ExecCounter int

+ Interrupted atomic.Bool

+ JupyterKernelId string

+ KnownBlockIds common.Set[string]

+ func New(connectionFile string) (*Kernel, error)

+ func (k *Kernel) Control() <-chan Message

+ func (k *Kernel) ExitWait()

+ func (k *Kernel) FromWireMsg(zmqMsg zmq4.Msg) Message

+ func (k *Kernel) HandleInterrupt()

+ func (k *Kernel) IsStopped() bool

+ func (k *Kernel) Shell() <-chan Message

+ func (k *Kernel) Stdin() <-chan Message

+ func (k *Kernel) Stop()

+ func (k *Kernel) StoppedChan() <-chan struct{}

+ func (k *Kernel) ToWireMsg(c *ComposedMsg) ([][]byte, error)

+ type KernelInfo struct

+ Banner string

+ HelpLinks []HelpLink

+ Implementation string

+ ImplementationVersion string

+ LanguageInfo KernelLanguageInfo

+ ProtocolVersion string

+ type KernelLanguageInfo struct

+ CodeMirrorMode string

+ FileExtension string

+ MIMEType string

+ NBConvertExporter string

+ Name string

+ PygmentsLexer string

+ Version string

+ type MIMEMap = map[string]any

+ func EnsureMIMEMap(bundle MIMEMap) MIMEMap

+ type Message interface

+ CancelInput func() error

+ ComposedMsg func() ComposedMsg

+ DeliverInput func() error

+ Error func() error

+ Kernel func() *Kernel

+ Ok func() bool

+ PromptInput func(prompt string, password bool, onInput OnInputFn) error

+ Publish func(msgType string, content interface{}) error

+ Reply func(msgType string, content interface{}) error

+ type MessageImpl struct

+ Composed ComposedMsg

+ Identities [][]byte

+ func (m *MessageImpl) CancelInput() error

+ func (m *MessageImpl) ComposedMsg() ComposedMsg

+ func (m *MessageImpl) DeliverInput() error

+ func (m *MessageImpl) Error() error

+ func (m *MessageImpl) Kernel() *Kernel

+ func (m *MessageImpl) Ok() bool

+ func (m *MessageImpl) PromptInput(prompt string, password bool, onInput OnInputFn) error

+ func (m *MessageImpl) Publish(msgType string, content interface{}) error

+ func (m *MessageImpl) Reply(msgType string, content interface{}) error

+ type MsgOrError struct

+ Err error

+ Msg zmq4.Msg

+ type OnInputFn func(original, input *MessageImpl) error

+ type SocketGroup struct

+ ControlSocket SyncSocket

+ HBSocket SyncSocket

+ IOPubSocket SyncSocket

+ Key []byte

+ ShellSocket SyncSocket

+ StdinSocket SyncSocket

+ type SyncSocket struct

+ Lock sync.Mutex

+ Socket zmq4.Socket

+ func (s *SyncSocket) RunLocked(fn func(socket zmq4.Socket) error) error