swarm

package
v0.60.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 12, 2026 License: MIT Imports: 28 Imported by: 0

README

Swarm

A lightweight multi-agent orchestration.

Swarm Magentic-One

Documentation

Index

Constants

View Source 
const (
	// read from clipboard
	ClipinRedirect = "{"

	// read from clipboard and wait, allowing multiple copy
	// until Ctrl-D is entered
	ClipinRedirect2 = "{{"

	// write to clipboard, overwriting its content
	ClipoutRedirect = "}"

	// append to clipboard
	ClipoutRedirect2 = "}}"
)

clipboard redirection

View Source 
const StdinRedirect = "-"

stdin

Variables

This section is empty.

Functions

func ActionNameFromFile added in v0.1.1 

func ActionNameFromFile(file string) string

Return agent/kit name:

  • agent: pack[/sub]
  • tool: kit:name

if the path matches the following pattern: agents/pack/agent.yaml agents/pack/pack.yaml agents/pack/sub.yaml

tools/kit/name.yaml

func Cat added in v0.1.1 

func Cat(a, b, sep string) string

func ClearAllEnv added in v0.1.1 

func ClearAllEnv(keeps []string)

ClearAllEnv clears all environment variables execep for the keeps

func GetInput added in v0.1.1 

func GetInput(ctx context.Context, argv []string) (*api.InputConfig, error)

func GetUserInput added in v0.1.1 

func GetUserInput(ctx context.Context, cfg *api.InputConfig) (*api.UserInput, error)

GetUserInput collects user input for the agent. It prefers a direct message from the command line flag (--message), otherwise, it determines the input source (stdin, clipboard, editor) and collects input accordingly. It also attaches any provided files or template file if provided.

func NewAgentScriptRunner added in v0.1.1 

func NewAgentScriptRunner(sw *Swarm, agent *api.Agent) api.ActionRunner

func NewAgentToolRunner added in v0.1.1 

func NewAgentToolRunner(sw *Swarm, user string, agent *api.Agent) api.ActionRunner

func NewTemplate added in v0.11.1 

func NewTemplate(sw *Swarm, agent *api.Agent) *template.Template

https://pkg.go.dev/text/template https://masterminds.github.io/sprig/

func NewToolSystem added in v0.1.1 

func NewToolSystem(rte *api.ActionRTEnv) (api.ToolSystem, error)

func NilSafe added in v0.11.1 

func NilSafe[T any](ptr *T) T

func ParseSpecialChars added in v0.1.1 

func ParseSpecialChars(args []string) *api.InputConfig

parse special char sequence for stdin/clipboard they can: + be at the end of the args + be in any order + be multiple instances

func RunCoreUtil added in v0.1.1 

func RunCoreUtil(sw *Swarm, cmd string, a []string) string

Types

type AIKit added in v0.1.1 

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

func NewAIKit added in v0.1.1 

func NewAIKit(sw *Swarm, agent *api.Agent) *AIKit

func (*AIKit) BuildContext added in v0.1.1 

func (r *AIKit) BuildContext(ctx context.Context, vars *api.Vars, tf string, args api.ArgMap) (any, error)

func (*AIKit) BuildPrompt added in v0.1.1 

func (r *AIKit) BuildPrompt(ctx context.Context, vars *api.Vars, tf string, args api.ArgMap) (string, error)

func (*AIKit) BuildQuery added in v0.1.1 

func (r *AIKit) BuildQuery(ctx context.Context, vars *api.Vars, tf string, args api.ArgMap) (string, error)

func (*AIKit) Call added in v0.1.1 

func (r *AIKit) Call(ctx context.Context, vars *api.Vars, tf *api.ToolFunc, args map[string]any) (any, error)

func (*AIKit) CallLlm added in v0.1.1 

func (r *AIKit) CallLlm(ctx context.Context, vars *api.Vars, tf string, args map[string]any) (*api.Result, error)

func (*AIKit) GetAgentInfo added in v0.1.1 

func (r *AIKit) GetAgentInfo(ctx context.Context, vars *api.Vars, _ string, args map[string]any) (string, error)

func (*AIKit) GetToolInfo added in v0.1.1 

func (r *AIKit) GetToolInfo(ctx context.Context, vars *api.Vars, tf string, args map[string]any) (string, error)

func (*AIKit) ListAgents added in v0.1.1 

func (r *AIKit) ListAgents(ctx context.Context, vars *api.Vars, tf string, args map[string]any) (string, error)

func (*AIKit) ListMessages added in v0.1.1 

func (r *AIKit) ListMessages(ctx context.Context, vars *api.Vars, tf string, args map[string]any) (string, error)

func (*AIKit) ListModels added in v0.1.1 

func (r *AIKit) ListModels(ctx context.Context, vars *api.Vars, tf string, args map[string]any) (string, error)

func (*AIKit) ListTools added in v0.1.1 

func (r *AIKit) ListTools(ctx context.Context, vars *api.Vars, tf string, args map[string]any) (string, error)

func (*AIKit) NewAgent added in v0.1.1 

func (r *AIKit) NewAgent(ctx context.Context, vars *api.Vars, tf string, args map[string]any) (*api.Result, error)

func (*AIKit) ReadAgentConfig added in v0.1.1 

func (r *AIKit) ReadAgentConfig(ctx context.Context, vars *api.Vars, _ string, args api.ArgMap) (*api.AppConfig, error)

func (*AIKit) ReadToolConfig added in v0.1.1 

func (r *AIKit) ReadToolConfig(ctx context.Context, vars *api.Vars, tf string, args map[string]any) (any, error)

func (*AIKit) ReloadAgent added in v0.12.1 

func (r *AIKit) ReloadAgent(ctx context.Context, _ *api.Vars, _ string, args map[string]any) (*api.Result, error)

func (*AIKit) SaveMessages added in v0.1.1 

func (r *AIKit) SaveMessages(_ context.Context, _ *api.Vars, _ string, args api.ArgMap) (*api.Result, error)

func (*AIKit) SpawnAgent added in v0.1.1 

func (r *AIKit) SpawnAgent(ctx context.Context, vars *api.Vars, _ string, args api.ArgMap) (*api.Result, error)

agent can be invoked directly by name with kit name "agent:" /agent:pack/sub and agent__pack__sub as tool id by LLM this tool serves as a simple interface for LLM tool calls. agent is required. actions defatult to the following if not set: entrypoint: "ai:new_agent", "ai:build_query", "ai:build_prompt", "ai:build_context", "ai:call_llm"

func (*AIKit) TransferAgent added in v0.1.1 

func (r *AIKit) TransferAgent(_ context.Context, _ *api.Vars, _ string, args map[string]any) (*api.Result, error)

type AgentCacheKey added in v0.1.1 

type AgentCacheKey struct {
	// user email
	User string
	// agent
	Pack string
	Sub  string
}

type AgentScriptRunner added in v0.1.1 

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

func (*AgentScriptRunner) Run added in v0.1.1 

func (r *AgentScriptRunner) Run(ctx context.Context, script string, args map[string]any) (any, error)

Run command or script. If script is empty, read command or script from args.

type AgentToolRunner added in v0.1.1 

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

func (*AgentToolRunner) Run added in v0.1.1 

func (r *AgentToolRunner) Run(ctx context.Context, tid string, args map[string]any) (any, error)

Lookup aciton for tid or kit:name in the args if tid is not provided

type ConfigLoader added in v0.1.1 

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

func NewConfigLoader added in v0.1.1 

func NewConfigLoader(rte *api.ActionRTEnv) *ConfigLoader

func (*ConfigLoader) Create added in v0.1.1 

func (r *ConfigLoader) Create(ctx context.Context, packname api.Packname) (*api.Agent, error)

create agent (class) from config

func (*ConfigLoader) CreateTool added in v0.1.1 

func (r *ConfigLoader) CreateTool(tid string) (*api.ToolFunc, error)

func (*ConfigLoader) LoadAgentConfig added in v0.1.1 

func (r *ConfigLoader) LoadAgentConfig(packname api.Packname) (*api.AppConfig, error)

func (*ConfigLoader) LoadConfig added in v0.1.1 

func (r *ConfigLoader) LoadConfig(s string) (*api.AppConfig, error)

load config for agent/tool

func (*ConfigLoader) LoadContent added in v0.1.1 

func (r *ConfigLoader) LoadContent(s string) error

func (*ConfigLoader) LoadToolConfig added in v0.1.1 

func (r *ConfigLoader) LoadToolConfig(kn api.Kitname) (*api.AppConfig, error)

func (*ConfigLoader) NewAgent added in v0.1.1 

func (r *ConfigLoader) NewAgent(c *api.AgentConfig, pn api.Packname) (*api.Agent, error)

type KitKey added in v0.1.1 

type KitKey struct {
	Type api.ToolType
	Kit  string
}

func NewKitKey added in v0.1.1 

func NewKitKey(fnType api.ToolType, kit string) KitKey

type ListCacheKey added in v0.1.1 

type ListCacheKey struct {
	Type string
	User string
}

type Swarm 

type Swarm struct {
	// session id
	ID string

	User *api.User

	Secrets api.SecretStore

	Assets api.AssetManager

	Tools api.ToolSystem

	Adapters api.AdapterRegistry

	Blobs api.BlobStore

	OS        vos.System
	Workspace vfs.Workspace
	History   api.MemStore
	Log       api.CallLogger

	//
	Vars *api.Vars
}

func (*Swarm) CreateAgent added in v0.11.1 

func (sw *Swarm) CreateAgent(ctx context.Context, parent *api.Agent, packname api.Packname, config []byte) (*api.Agent, error)

func (*Swarm) Exec added in v0.1.1 

func (sw *Swarm) Exec(ctx context.Context, input any) (*api.Result, error)

func (*Swarm) Format added in v0.1.1 

func (sw *Swarm) Format(ctx context.Context, argm map[string]any) (*api.Result, error)

func (*Swarm) Init added in v0.11.1 

func (sw *Swarm) Init(rte *api.ActionRTEnv) error

func (*Swarm) LoadScript added in v0.12.1 

func (sw *Swarm) LoadScript(v string) (string, error)

func (*Swarm) Parse added in v0.1.1 

func (sw *Swarm) Parse(ctx context.Context, input any) (api.ArgMap, error)

Source Files

View all Source files

Directories

Path Synopsis
atm
conf
https://pkg.go.dev/modernc.org/sqlite https://sqlite.org/docs.html
 https://pkg.go.dev/modernc.org/sqlite https://sqlite.org/docs.html
Package flag implements command-line flag parsing.
 Package flag implements command-line flag parsing.
llm
adapter
anthropic
gemini
openai
standard/agents/web command
tool
lang
memory
sequentialthinking command
util
web
web/bing
web/brave
web/ddg
https://github.com/tmc/langchaingo/blob/main/tools/duckduckgo/internal/client.go https://github.com/tmc/langchaingo?tab=MIT-1-ov-file#readme
 https://github.com/tmc/langchaingo/blob/main/tools/duckduckgo/internal/client.go https://github.com/tmc/langchaingo?tab=MIT-1-ov-file#readme
web/google
web/scrape
https://github.com/tmc/langchaingo/blob/main/tools/scraper/scraper.go https://github.com/tmc/langchaingo?tab=MIT-1-ov-file#readme
 https://github.com/tmc/langchaingo/blob/main/tools/scraper/scraper.go https://github.com/tmc/langchaingo?tab=MIT-1-ov-file#readme
web/util
calllog
conf
history

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.