rt

Documentation

Index

• Constants
• Variables
• func AllNSes() map[string]*vm.Namespace
• func DefNSBare(name string) *vm.Namespace
• func DumpNamespaces(fileName string)
• func EDNEncodeArgs(args []vm.Value) (string, error)
• func FuzzyNamespacedSymbolLookup(currentNS *vm.Namespace, s vm.Symbol) []vm.Symbol
• func JSONDecodeValue(s string) (vm.Value, error)
• func JSONEncodeArgs(args []vm.Value) (string, error)
• func LookupNS(name string) *vm.Namespace
• func LookupOrRegisterNS(name string) *vm.Namespace
• func LookupOrRegisterNSNoLoad(name string) *vm.Namespace
• func MarkNSNeedsLoad(name string)
• func NS(name string) *vm.Namespace
• func RegisterNS(namespace *vm.Namespace) *vm.Namespace
• func SetEvalInNS(fn func(string, *vm.Namespace) (vm.Value, error))
• func SetNSLoader(loader NSLoader)
• func SetReadEDN(fn func(string) (vm.Value, error))
• func ShutdownAllPods()
• func TransitDecodeValue(s string) (vm.Value, error)
• func TransitEncodeArgs(args []vm.Value) (string, error)
• type FileStat
• type HTTPRequest
• type HTTPResponse
• type Handler
  • func (h *Handler) ServeHTTP(resp http.ResponseWriter, request *http.Request)
• type IOHandle
  • func NewIOHandle(f *os.File) *IOHandle
  • func (h *IOHandle) Close() error
  • func (h *IOHandle) Reader() *bufio.Reader
  • func (h *IOHandle) String() string
• type LGBuffer
  • func (b *LGBuffer) Read(p []byte) (int, error)
  • func (b *LGBuffer) String() string
  • func (b *LGBuffer) Write(p []byte) (int, error)
• type LGReader
  • func (r *LGReader) Buffered() *bufio.Reader
  • func (r *LGReader) Close() error
  • func (r *LGReader) Read(p []byte) (int, error)
  • func (r *LGReader) String() string
• type LGURL
• type LGWriter
  • func (w *LGWriter) Buffered() *bufio.Writer
  • func (w *LGWriter) Close() error
  • func (w *LGWriter) Flush() error
  • func (w *LGWriter) String() string
  • func (w *LGWriter) Write(p []byte) (int, error)
• type Mult
• type NSLoader
• type Pod
  • func (p *Pod) Invoke(varName string, args []vm.Value) (vm.Value, error)
  • func (p *Pod) InvokeAsync(varName string, args []vm.Value) (vm.Chan, error)
  • func (p *Pod) Shutdown()
• type Pub
• type ShellResult
• type TransitDecoder
  • func NewTransitDecoder() *TransitDecoder
  • func (d *TransitDecoder) Decode(s string) (vm.Value, error)
• type TransitEncoder
  • func NewTransitEncoder() *TransitEncoder
  • func (e *TransitEncoder) Encode(v vm.Value) (string, error)
  • func (e *TransitEncoder) EncodeList(vals []vm.Value) (string, error)

Constants

const NameCoreNS = "core"

Variables

var (
	ReadableProto *vm.Protocol // method: -make-reader [x] → reader
	WritableProto *vm.Protocol // method: -make-writer [x] → writer
)

IReadable and IWritable are the IO coercion protocols. Extending these allows user-defined types to participate in the IO system.

var AsyncSrc string

var CoreCompiledLGB []byte

var CoreNS *vm.Namespace

var CoreSrc string

var CurrentNS *vm.Var

var DataSrc string

var EdnSrc string

var IoSrc string

var PprintSrc string

var SetSrc string

var StringSrc string

var TestSrc string

var WalkSrc string

var ZipSrc string

Functions

func AllNSes

func AllNSes() map[string]*vm.Namespace

func DefNSBare

func DefNSBare(name string) *vm.Namespace

DefNSBare creates and registers a minimal namespace (with CoreNS refer) without triggering the loader. Used during bytecode decoding to create var homes for not-yet-loaded namespaces.

func DumpNamespaces

func DumpNamespaces(fileName string)

func EDNEncodeArgs

func EDNEncodeArgs(args []vm.Value) (string, error)

EDNEncodeArgs encodes args as an EDN vector string.

func FuzzyNamespacedSymbolLookup

func FuzzyNamespacedSymbolLookup(currentNS *vm.Namespace, s vm.Symbol) []vm.Symbol

func JSONDecodeValue

func JSONDecodeValue(s string) (vm.Value, error)

JSONDecodeValue decodes a JSON string into a vm.Value.

func JSONEncodeArgs

func JSONEncodeArgs(args []vm.Value) (string, error)

JSONEncodeArgs encodes args as a plain JSON array string.

func LookupNS

func LookupNS(name string) *vm.Namespace

LookupNS returns a namespace if it exists, nil otherwise. Does not create.

func LookupOrRegisterNS

func LookupOrRegisterNS(name string) *vm.Namespace

func LookupOrRegisterNSNoLoad

func LookupOrRegisterNSNoLoad(name string) *vm.Namespace

func MarkNSNeedsLoad

func MarkNSNeedsLoad(name string)

MarkNSNeedsLoad flags a namespace as needing on-demand loading even though it already exists in the registry (created during bytecode decoding).

func NS

func NS(name string) *vm.Namespace

func RegisterNS

func RegisterNS(namespace *vm.Namespace) *vm.Namespace

func SetEvalInNS

func SetEvalInNS(fn func(string, *vm.Namespace) (vm.Value, error))

SetEvalInNS sets the namespace-aware eval function.

func SetNSLoader

func SetNSLoader(loader NSLoader)

func SetReadEDN

func SetReadEDN(fn func(string) (vm.Value, error))

SetReadEDN sets the EDN reader function (called by compiler package).

func ShutdownAllPods

func ShutdownAllPods()

ShutdownAllPods gracefully shuts down all loaded pods.

func TransitDecodeValue

func TransitDecodeValue(s string) (vm.Value, error)

TransitDecodeValue decodes a transit+json payload string.

func TransitEncodeArgs

func TransitEncodeArgs(args []vm.Value) (string, error)

TransitEncodeArgs encodes a list of args for pod invocation.

Types

type FileStat

type FileStat struct {
	Name    string `letgo:"name"`
	Size    int64  `letgo:"size"`
	IsDir   bool   `letgo:"dir?"`
	ModTime string `letgo:"mod-time"`
}

FileStat is the struct behind os/stat return values.

type HTTPRequest

type HTTPRequest struct {
	RequestMethod string   `letgo:"request-method"`
	Scheme        string   `letgo:"scheme"`
	URI           string   `letgo:"uri"`
	Path          string   `letgo:"path"`
	QueryString   string   `letgo:"query-string"`
	Body          string   `letgo:"body"`
	RemoteAddr    string   `letgo:"remote-addr"`
	ServerAddr    string   `letgo:"server-addr"`
	ServerPort    string   `letgo:"server-port"`
	ContentType   string   `letgo:"content-type"`
	Headers       vm.Value `letgo:"headers"`
}

HTTPRequest is the struct behind ring-style HTTP request maps.

type HTTPResponse

type HTTPResponse struct {
	Status  int      `letgo:"status"`
	Body    vm.Value `letgo:"body"`
	Headers vm.Value `letgo:"headers"`
}

HTTPResponse is the struct behind HTTP client response maps.

type Handler

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

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(resp http.ResponseWriter, request *http.Request)

type IOHandle

type IOHandle struct {
	File *os.File
	// contains filtered or unexported fields
}

IOHandle wraps an *os.File with optional buffered reader for line-based reads.

func NewIOHandle

func NewIOHandle(f *os.File) *IOHandle

func (*IOHandle) Close

func (h *IOHandle) Close() error

func (*IOHandle) Reader

func (h *IOHandle) Reader() *bufio.Reader

func (*IOHandle) String

func (h *IOHandle) String() string

type LGBuffer

type LGBuffer struct {
	Buf *bytes.Buffer
}

LGBuffer wraps bytes.Buffer as a readable/writable value.

func (*LGBuffer) Read

func (b *LGBuffer) Read(p []byte) (int, error)

func (*LGBuffer) String

func (b *LGBuffer) String() string

func (*LGBuffer) Write

func (b *LGBuffer) Write(p []byte) (int, error)

type LGReader

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

LGReader wraps any io.Reader with optional buffering and close.

func (*LGReader) Buffered

func (r *LGReader) Buffered() *bufio.Reader

func (*LGReader) Close

func (r *LGReader) Close() error

func (*LGReader) Read

func (r *LGReader) Read(p []byte) (int, error)

func (*LGReader) String

func (r *LGReader) String() string

type LGURL

type LGURL struct {
	Scheme   string `letgo:"scheme"`
	Host     string `letgo:"host"`
	Port     string `letgo:"port"`
	Path     string `letgo:"path"`
	Query    string `letgo:"query"`
	Fragment string `letgo:"fragment"`
	UserInfo string `letgo:"user-info"`
	Raw      string `letgo:"raw"`
}

LGURL represents a parsed URL as a record.

type LGWriter

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

LGWriter wraps any io.Writer with optional buffering and close.

func (*LGWriter) Buffered

func (w *LGWriter) Buffered() *bufio.Writer

func (*LGWriter) Close

func (w *LGWriter) Close() error

func (*LGWriter) Flush

func (w *LGWriter) Flush() error

func (*LGWriter) String

func (w *LGWriter) String() string

func (*LGWriter) Write

func (w *LGWriter) Write(p []byte) (int, error)

type Mult

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

Mult broadcasts values from a source channel to multiple tap channels.

type NSLoader

type NSLoader interface {
	Load(string) *vm.Namespace
}

type Pod

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

Pod represents a running babashka pod subprocess.

func (*Pod) Invoke

func (p *Pod) Invoke(varName string, args []vm.Value) (vm.Value, error)

Invoke calls a pod var and returns the result (synchronous).

func (*Pod) InvokeAsync

func (p *Pod) InvokeAsync(varName string, args []vm.Value) (vm.Chan, error)

InvokeAsync calls a pod var and sends results to a channel. The channel stays open for streaming - the pod sends multiple values with the same id.

func (*Pod) Shutdown

func (p *Pod) Shutdown()

Shutdown sends shutdown op if supported and waits for process to exit.

type Pub

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

Pub routes values from a source channel to subscribers by topic.

type ShellResult

type ShellResult struct {
	Exit int    `letgo:"exit"`
	Out  string `letgo:"out"`
	Err  string `letgo:"err"`
}

ShellResult is the struct behind os/sh return values.

type TransitDecoder

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

TransitDecoder decodes transit+json into vm.Values.

func NewTransitDecoder

func NewTransitDecoder() *TransitDecoder

NewTransitDecoder creates a new decoder with a fresh cache.

func (*TransitDecoder) Decode

func (d *TransitDecoder) Decode(s string) (vm.Value, error)

Decode parses a transit+json string into a vm.Value.

type TransitEncoder

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

TransitEncoder encodes vm.Values to transit+json.

func NewTransitEncoder

func NewTransitEncoder() *TransitEncoder

NewTransitEncoder creates a new encoder with a fresh cache.

func (*TransitEncoder) Encode

func (e *TransitEncoder) Encode(v vm.Value) (string, error)

Encode encodes a vm.Value to a transit+json string.

func (*TransitEncoder) EncodeList

func (e *TransitEncoder) EncodeList(vals []vm.Value) (string, error)

EncodeList encodes a slice of values as a transit list (used for pod args).