aigo

Jun 11, 2026

Changes in this version

type AgentTask

+ Quality string

type AgentTaskStructured

+ ImageQuality string

Jun 4, 2026

Changes in this version

+ const MetadataResponseHeaders

+ const MetadataResults

Jun 3, 2026

Changes in this version

type Client

+ func (c *Client) ApplyEnvURI() ([]string, error)

+ func (c *Client) ApplyURI(uris string) ([]string, error)

Jun 3, 2026

Changes in this version

+ var ErrSearcherNotConfigured = errors.New("aigo: material searcher not configured")

type AgentTask

+ Search *SearchOptions

type Client

+ func (c *Client) SearchMaterial(ctx context.Context, req material.Request) (material.Result, error)

+ func (c *Client) SearchMaterialFromTask(ctx context.Context, task AgentTask) (material.Result, error)

+ func (c *Client) SetSearcher(s material.Searcher)

type ClientOption

+ func WithSearcher(s material.Searcher) ClientOption

+ type SearchOptions struct

+ FieldQuery string

+ MaxResults int

+ MediaTypes []string

+ Mode string

+ NextToken string

+ Order string

+ Page int

+ SimpleQuery string

+ Sort string

+ Source string

+ Tags []string

Jun 1, 2026

Changes in this version

type AgentTask

+ AudioMix *AudioMixOptions

+ SFX *SFXOptions

+ type AudioMixOptions struct

+ AudioURLs []string

+ Delays []int

+ Duration int

+ Format string

+ Volumes []float64

+ type SFXOptions struct

+ Duration int

+ Format string

May 29, 2026

Changes in this version

type AgentTask

+ AudioURL string

May 26, 2026

Changes in this version

type ProgressEvent

+ Percent float64

+ PreviewURL string

May 1, 2026

Changes in this version

type AgentTaskStructured

+ ImageAspectRatio string

+ ImageCameraAngle string

+ ImageResolution string

type Client

+ func (c *Client) AllModelInfos() []engine.ModelInfo

+ func (c *Client) ExportModelCatalog() ([]byte, error)

+ func (c *Client) ModelInfo(model string) (engine.ModelInfo, bool)

+ func (c *Client) ModelInfosByCapability(cap string) []engine.ModelInfo

+ func (c *Client) ModelInfosByProvider(provider string) []engine.ModelInfo

+ func (c *Client) SearchModelInfos(query string) []engine.ModelInfo

type EngineInfo

+ DocURL string

+ Intro engine.DisplayName

+ Models []engine.ModelInfo

Apr 17, 2026

Changes in this version

+ var ErrEngineDisabled = errors.New("aigo: engine is disabled")

+ func InferMediaType(task AgentTask) string

type Client

+ func (c *Client) ApplyConfig(cfg FileConfig) ([]string, error)

+ func (c *Client) DisableEngine(name string) error

+ func (c *Client) EnableEngine(name string) error

+ func (c *Client) EngineInfos() []EngineInfo

+ func (c *Client) ExecuteTaskAutoWithFallback(ctx context.Context, selector Selector, task AgentTask) (RoutedResult, error)

+ func (c *Client) IsEnabled(name string) bool

+ func (c *Client) RegisterAll(engines map[string]engine.Engine) error

+ func (c *Client) RegisterAllIfKey(entries []EngineEntry) ([]string, error)

+ func (c *Client) RegisterEngineIfKey(name string, e engine.Engine, envVars ...string) (bool, error)

+ func (c *Client) RegisterProvider(p engine.Provider) ([]string, error)

+ func (c *Client) UnregisterEngine(name string) error

+ type EngineEntry struct

+ Engine engine.Engine

+ EnvVars []string

+ Name string

+ type EngineInfo struct

+ Capability engine.Capability

+ DisplayName engine.DisplayName

+ Name string

+ type FileConfig struct

+ Engines []engine.EngineConfig

+ func LoadConfig(path string) (FileConfig, error)

+ type PrioritySelector struct

+ Filter *RuleFilter

+ Priority []string

+ func (s *PrioritySelector) SelectEngine(_ context.Context, task AgentTask, engines []string) (Selection, error)

+ func (s *PrioritySelector) SelectEngineFromCandidates(_ context.Context, task AgentTask, candidates []EngineInfo) (Selection, error)

+ type RichSelector interface

+ SelectEngineFromCandidates func(ctx context.Context, task AgentTask, candidates []EngineInfo) (Selection, error)

+ type RuleFilter struct

+ func (f *RuleFilter) Filter(task AgentTask, candidates []EngineInfo) []EngineInfo

Apr 16, 2026

Changes in this version

+ const TaskStatusCompleted

+ const TaskStatusFailed

+ const TaskStatusPending

+ var ErrResumeNotSupported = errors.New("aigo: engine does not support resume")

+ var ErrStoreNotConfigured = errors.New("aigo: task store not configured")

+ var ErrTaskNotFound = errors.New("aigo: task not found")

type Client

+ func (c *Client) RecoverPending() ([]TaskRecord, error)

+ func (c *Client) Resume(ctx context.Context, taskID string) (Result, error)

+ func (c *Client) Submit(ctx context.Context, engineName string, graph workflow.Graph, ...) (string, error)

+ type ClientOption func(*Client)

+ func WithDefaultStore() (ClientOption, error)

+ func WithStore(s TaskStore) ClientOption

+ type FileTaskStore struct

+ func DefaultFileTaskStore() (*FileTaskStore, error)

+ func NewFileTaskStore(path string) (*FileTaskStore, error)

+ func (s *FileTaskStore) All() ([]TaskRecord, error)

+ func (s *FileTaskStore) Delete(id string) error

+ func (s *FileTaskStore) Load(id string) (TaskRecord, error)

+ func (s *FileTaskStore) Purge(maxAge time.Duration) error

+ func (s *FileTaskStore) Save(record TaskRecord) error

+ type TaskRecord struct

+ CreatedAt time.Time

+ EngineName string

+ ErrMsg string

+ ID string

+ RemoteID string

+ ResultKind OutputKind

+ ResultVal string

+ Status string

+ UpdatedAt time.Time

+ type TaskStore interface

+ All func() ([]TaskRecord, error)

+ Delete func(id string) error

+ Load func(id string) (TaskRecord, error)

+ Save func(record TaskRecord) error

Apr 15, 2026

Changes in this version

type AgentTask

+ Music *MusicOptions

+ type MusicOptions struct

+ Bitrate int

+ Format string

+ IsInstrumental *bool

+ Lyrics string

+ LyricsOptimizer *bool

+ OutputFormat string

+ SampleRate int

Apr 6, 2026

Changes in this version

type AgentTaskStructured

+ VideoAspectRatio string

+ VideoAudio *bool

+ VideoResolution string

Apr 6, 2026

Changes in this version

+ const OutputDataURI

+ const OutputJSON

+ const OutputPlainText

+ const OutputURL

+ const OutputUnknown

+ var ErrEngineExists = errors.New("aigo: engine already registered")

+ var ErrEngineNameEmpty = errors.New("aigo: engine name is empty")

+ var ErrEngineNil = errors.New("aigo: engine is nil")

+ var ErrEngineNotFound = errors.New("aigo: engine not found")

+ func BuildGraph(task AgentTask) workflow.Graph

+ type AgentTask struct

+ Duration int

+ Height int

+ NegativePrompt string

+ Prompt string

+ References []ReferenceAsset

+ Size string

+ Structured *AgentTaskStructured

+ TTS *TTSOptions

+ VoiceDesign *VoiceDesignOptions

+ Watermark *bool

+ Width int

+ type AgentTaskStructured struct

+ ImageSize string

+ ImageWatermark *bool

+ VideoDuration int

+ VideoSize string

+ VideoWatermark *bool

+ type AsyncResult struct

+ Err error

+ Result Result

+ type Client struct

+ func NewClient() *Client

+ func (c *Client) AvailableFor(mediaType string) []string

+ func (c *Client) DryRun(engineName string, task AgentTask) (engine.DryRunResult, error)

+ func (c *Client) EngineCapabilities(name string) (engine.Capability, error)

+ func (c *Client) EngineNames() []string

+ func (c *Client) Execute(ctx context.Context, engineName string, graph workflow.Graph, ...) (Result, error)

+ func (c *Client) ExecuteAsync(ctx context.Context, engineName string, graph workflow.Graph) <-chan AsyncResult

+ func (c *Client) ExecutePipeline(ctx context.Context, p *Pipeline) ([]Result, error)

+ func (c *Client) ExecutePrompt(ctx context.Context, engineName string, prompt string) (Result, error)

+ func (c *Client) ExecutePromptAuto(ctx context.Context, selector Selector, prompt string) (RoutedResult, error)

+ func (c *Client) ExecuteTask(ctx context.Context, engineName string, task AgentTask) (Result, error)

+ func (c *Client) ExecuteTaskAuto(ctx context.Context, selector Selector, task AgentTask) (RoutedResult, error)

+ func (c *Client) ExecuteTaskWithFallback(ctx context.Context, engines []string, task AgentTask) (FallbackResult, error)

+ func (c *Client) ExecuteWithFallback(ctx context.Context, engines []string, graph workflow.Graph) (FallbackResult, error)

+ func (c *Client) ExecuteWithHint(ctx context.Context, engineName string, graph workflow.Graph) (OutputHint, error)

+ func (c *Client) RegisterEngine(name string, e engine.Engine) error

+ func (c *Client) Use(mw ...Middleware)

+ type ExecuteOption func(*executeConfig)

+ func WithProgress(fn func(ProgressEvent)) ExecuteOption

+ type FallbackError struct

+ Engine string

+ Err error

+ func (e FallbackError) Error() string

+ func (e FallbackError) Unwrap() error

+ type FallbackResult struct

+ Engine string

+ Output Result

+ Skipped []FallbackError

+ type Middleware func(name string, next engine.Engine) engine.Engine

+ func WithLogging(w io.Writer) Middleware

+ func WithRetry(maxRetries int) Middleware

+ type OutputHint struct

+ Kind OutputKind

+ Raw string

+ type OutputKind = engine.OutputKind

+ func InterpretOutputKind(s string) OutputKind

+ type Pipeline struct

+ func NewPipeline(engineName string, task AgentTask) *Pipeline

+ func (p *Pipeline) Then(fn PipelineStep) *Pipeline

+ type PipelineStep func(prev Result) (AgentTask, string)

+ type ProgressEvent struct

+ Attempt int

+ Elapsed time.Duration

+ Phase string

+ type ReferenceAsset struct

+ Type ReferenceType

+ URL string

+ type ReferenceType string

+ const ReferenceTypeImage

+ const ReferenceTypeVideo

+ type Result struct

+ Elapsed time.Duration

+ Engine string

+ Kind OutputKind

+ Metadata map[string]any

+ Value string

+ func (r Result) String() string

+ type RoutedResult struct

+ Engine string

+ Output Result

+ Reason string

+ type Selection struct

+ Engine string

+ Reason string

+ type Selector interface

+ SelectEngine func(ctx context.Context, task AgentTask, engines []string) (Selection, error)

+ type TTSOptions struct

+ Instructions string

+ LanguageType string

+ OptimizeInstructions *bool

+ Voice string

+ type VoiceDesignOptions struct

+ Language string

+ OmitPreview bool

+ PreferredName string

+ PreviewText string

+ ResponseFormat string

+ SampleRate int

+ TargetModel string

+ VoicePrompt string