embedderapi

Jun 19, 2026

Changes in this version

+ const Description

+ const Name

+ const Version

+ var MaxWorkers = define.Config

type Client

+ func (_c Client) Demo(ctx context.Context, method string, relativeURL string, body any) (res *http.Response, err error)

+ func (_c Client) DemoInit(ctx context.Context, relativeURL string, body any) (res *http.Response, err error)

+ func (_c Client) DemoStatus(ctx context.Context, relativeURL string) (res *http.Response, err error)

type MulticastClient

+ func (_c MulticastClient) Demo(ctx context.Context, method string, relativeURL string, body any) iter.Seq[*pub.Response]

+ func (_c MulticastClient) DemoInit(ctx context.Context, relativeURL string, body any) iter.Seq[*pub.Response]

+ func (_c MulticastClient) DemoStatus(ctx context.Context, relativeURL string) iter.Seq[*pub.Response]

Jun 18, 2026

Changes in this version

+ type Subflow struct

+ func NewSubflow(flow *workflow.Flow) Subflow

May 24, 2026

Changes in this version

type Executor

+ func (_c Executor) WithFlowOptions(flowOptions *workflow.FlowOptions) Executor

+ func (_c Executor) WithWorkflowRunner(runner WorkflowRunner) Executor

+ type WorkflowRunner interface

+ Run func(ctx context.Context, workflowName string, initialState any, ...) (outcome *workflow.FlowOutcome, err error)

May 15, 2026

Changes in this version

+ const Hostname

+ var Demo = Def

+ var DemoInit = Def

+ var DemoStatus = Def

+ var Embed = Def

+ var Similarity = Def

+ type Client struct

+ func NewClient(caller service.Publisher) Client

+ func (_c Client) Embed(ctx context.Context, text string) (vector []float64, err error)

+ func (_c Client) ForHost(host string) Client

+ func (_c Client) Similarity(ctx context.Context, a string, b string) (score float64, err error)

+ func (_c Client) WithOptions(opts ...pub.Option) Client

+ type Def struct

+ Method string

+ Route string

+ func (d Def) URL() string

+ type EmbedIn struct

+ Text string

+ type EmbedOut struct

+ Vector []float64

+ type EmbedResponse multicastResponse

+ func (_res *EmbedResponse) Get() (vector []float64, err error)

+ type Executor struct

+ func NewExecutor(caller service.Publisher) Executor

+ func (_c Executor) ForHost(host string) Executor

+ func (_c Executor) WithInputFlow(flow *workflow.Flow) Executor

+ func (_c Executor) WithOptions(opts ...pub.Option) Executor

+ func (_c Executor) WithOutputFlow(flow *workflow.Flow) Executor

+ type Hook struct

+ func NewHook(listener service.Subscriber) Hook

+ func (c Hook) ForHost(host string) Hook

+ func (c Hook) WithOptions(opts ...sub.Option) Hook

+ type MulticastClient struct

+ func NewMulticastClient(caller service.Publisher) MulticastClient

+ func (_c MulticastClient) Embed(ctx context.Context, text string) iter.Seq[*EmbedResponse]

+ func (_c MulticastClient) ForHost(host string) MulticastClient

+ func (_c MulticastClient) Similarity(ctx context.Context, a string, b string) iter.Seq[*SimilarityResponse]

+ func (_c MulticastClient) WithOptions(opts ...pub.Option) MulticastClient

+ type MulticastTrigger struct

+ func NewMulticastTrigger(caller service.Publisher) MulticastTrigger

+ func (_c MulticastTrigger) ForHost(host string) MulticastTrigger

+ func (_c MulticastTrigger) WithOptions(opts ...pub.Option) MulticastTrigger

+ type SimilarityIn struct

+ A string

+ B string

+ type SimilarityOut struct

+ Score float64

+ type SimilarityResponse multicastResponse

+ func (_res *SimilarityResponse) Get() (score float64, err error)