compute

Other4 providers

togo compute capability — submit batch/stream jobs to a pluggable engine (local/beam/spark/flink/databricks)

togo-framework

bash

togo install togo-framework/compute

Install

bash

togo install togo-framework/compute

togo's compute capability — submit batch/stream jobs to a pluggable engine. Distinct from worker (supervised background goroutine workers) and queue (app job dispatch): compute is for data/compute engines.

Main plugin: defines Compute + ships the built-in local backend. Engine backends register into the same slot:

Backend	Repo
local (default)	built in
Apache Beam	togo-framework/compute-beam
Apache Spark	togo-framework/compute-spark
Apache Flink	togo-framework/compute-flink
Databricks	togo-framework/compute-databricks

Rows per page

1–5 of 5

Page 1 of 1

bash

togo install togo-framework/compute-spark
togo provider:use compute spark

c := compute.FromKernel(k)
run, _ := c.Submit(ctx, compute.Job{Name: "nightly-etl", Cmd: []string{"python", "etl.py"}})

<div align="center"> <h3>💎 Premium sponsors</h3> <p> <a href="https://id8media.com"><img src=".github/assets/id8media.svg" height="44" alt="ID8 Media" /></a>      <a href="https://one-studio.co"><img src=".github/assets/one-studio.jpeg" height="44" alt="One Studio" /></a> </p> <p><sub>Support togo — <a href="https://github.com/sponsors/fadymondy">become a sponsor</a>.</sub></p> </div>