provider

package
v0.0.0-...-190da1e Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2026 License: MIT Imports: 24 Imported by: 0

Documentation

Overview

Package provider defines trusted system-provider library contracts and registration. Package provider 定义受信任系统供应商库合同和注册机制。

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrAuthenticationRejected reports that an upstream authentication service rejected provider-issued credential material.
	// ErrAuthenticationRejected 表示上游认证服务拒绝了供应商签发的凭据材料。
	ErrAuthenticationRejected = errors.New("provider authentication was rejected")
	// ErrAuthenticationUnavailable reports that an upstream authentication service could not complete a request because it was unreachable or temporarily unavailable.
	// ErrAuthenticationUnavailable 表示上游认证服务因无法连接或暂时不可用而无法完成请求。
	ErrAuthenticationUnavailable = errors.New("provider authentication service is unavailable")
	// ErrAuthenticationResponseInvalid reports that an upstream authentication service returned an unusable response.
	// ErrAuthenticationResponseInvalid 表示上游认证服务返回了无法使用的响应。
	ErrAuthenticationResponseInvalid = errors.New("provider authentication response is invalid")
)
View Source 
var (
	// ErrExecutionDriverRequired reports an empty provider execution registration.
	// ErrExecutionDriverRequired 表示空的供应商执行 Driver 注册。
	ErrExecutionDriverRequired = errors.New("provider execution driver is required")
	// ErrExecutionDriverDuplicate reports duplicate ownership of one definition and protocol profile pair.
	// ErrExecutionDriverDuplicate 表示同一供应商定义和协议 Profile 对被重复拥有。
	ErrExecutionDriverDuplicate = errors.New("provider execution driver is already registered")
	// ErrExecutionDriverNotFound reports a target with no matching exact execution driver.
	// ErrExecutionDriverNotFound 表示 Target 没有匹配的精确执行 Driver。
	ErrExecutionDriverNotFound = errors.New("provider execution driver is not registered")
	// ErrCustomExecutionFactoryRequired reports a missing custom-provider execution factory registration.
	// ErrCustomExecutionFactoryRequired 表示缺少自定义供应商执行 Factory 注册。
	ErrCustomExecutionFactoryRequired = errors.New("custom provider execution driver factory is required")
	// ErrCustomExecutionFactoryDuplicate reports overlapping ownership of runtime custom-provider execution.
	// ErrCustomExecutionFactoryDuplicate 表示运行时自定义供应商执行归属发生重叠。
	ErrCustomExecutionFactoryDuplicate = errors.New("custom provider execution driver factory is already registered")
	// ErrExecutionBinding reports a definition, channel, target, or continuation mismatch.
	// ErrExecutionBinding 表示 Definition、Channel、Target 或 Continuation 不匹配。
	ErrExecutionBinding = errors.New("invalid provider execution binding")
	// ErrContinuationRejected reports explicit upstream rejection of the exact bound continuation handle.
	// ErrContinuationRejected 表示上游明确拒绝精确绑定的续接句柄。
	ErrContinuationRejected = errors.New("provider continuation rejected")
	// ErrActionExecutionDriverRequired reports an empty action execution registration.
	// ErrActionExecutionDriverRequired 表示空的动作执行 Driver 注册。
	ErrActionExecutionDriverRequired = errors.New("provider action execution driver is required")
	// ErrActionExecutionDriverDuplicate reports duplicate ownership of one definition and action binding pair.
	// ErrActionExecutionDriverDuplicate 表示同一供应商定义和动作绑定对被重复拥有。
	ErrActionExecutionDriverDuplicate = errors.New("provider action execution driver is already registered")
	// ErrTaskExecutionDriverRequired reports an empty asynchronous action driver registration.
	// ErrTaskExecutionDriverRequired 表示空的异步动作 Driver 注册。
	ErrTaskExecutionDriverRequired = errors.New("provider task execution driver is required")
	// ErrTaskExecutionDriverDuplicate reports duplicate asynchronous ownership of one definition and action.
	// ErrTaskExecutionDriverDuplicate 表示同一 Definition 与动作的异步所有权重复。
	ErrTaskExecutionDriverDuplicate = errors.New("provider task execution driver is already registered")
	// ErrExecutionEventSinkClosed reports an event emitted after the durable execution reached a terminal state.
	// ErrExecutionEventSinkClosed 表示持久执行进入终态后仍尝试发送事件。
	ErrExecutionEventSinkClosed = errors.New("provider execution event sink is closed")
	// ErrOutputBudgetExceeded reports a provider stream that crossed the caller's hard output byte ceiling.
	// ErrOutputBudgetExceeded 表示供应商流超过调用方的硬输出字节上限。
	ErrOutputBudgetExceeded = errors.New("provider output budget exceeded")
)
View Source 
var (
	// ErrMetadataAuthentication reports that an upstream provider rejected the stored credential.
	// ErrMetadataAuthentication 表示上游供应商拒绝了已存储凭据。
	ErrMetadataAuthentication = errors.New("provider metadata authentication failed")
	// ErrMetadataUnavailable reports that an upstream provider could not be reached or was temporarily unavailable.
	// ErrMetadataUnavailable 表示无法连接上游供应商或上游暂时不可用。
	ErrMetadataUnavailable = errors.New("provider metadata service unavailable")
	// ErrMetadataResponseInvalid reports that an upstream provider returned an unusable metadata response.
	// ErrMetadataResponseInvalid 表示上游供应商返回了无法使用的元数据响应。
	ErrMetadataResponseInvalid = errors.New("provider metadata response is invalid")
)

Functions

func AdditionalPayloadProjectionIsEmpty 

func AdditionalPayloadProjectionIsEmpty(projection catalog.AdditionalPayloadProjection) bool

AdditionalPayloadProjectionIsEmpty reports whether provider-wide runtime mutation rules are absent. AdditionalPayloadProjectionIsEmpty 报告是否不存在供应商级运行时变更规则。

func ApplyRequestProjection 

func ApplyRequestProjection(body []byte, projection catalog.RequestProjection, policy vcp.ReasoningPolicy) ([]byte, error)

ApplyRequestProjection applies one validated offering-specific projection to an already typed outbound JSON body. ApplyRequestProjection 将一个已校验的产品专属投影应用到已经类型化的出站 JSON Body。

func ApplyRequestProjections 

func ApplyRequestProjections(body []byte, providerProjection catalog.AdditionalPayloadProjection, modelProjection catalog.RequestProjection, policy vcp.ReasoningPolicy) ([]byte, error)

ApplyRequestProjections applies provider defaults first and model-specific rules second to preserve explicit inheritance. ApplyRequestProjections 先应用供应商默认规则，再应用模型专属规则，以保留显式继承关系。

func EmitExecutionEvents 

func EmitExecutionEvents(ctx context.Context, sink ExecutionEventSink, events []vcp.Event) error

EmitExecutionEvents forwards one decoded event batch to the optional real-time sink in causal order. EmitExecutionEvents 按因果顺序将一批已解码事件转发到可选实时 Sink。

func NewUpstreamError 

func NewUpstreamError(evidence UpstreamErrorEvidence, cause error) error

NewUpstreamError creates one bounded provider error without retaining the complete response body. NewUpstreamError 创建一个受限供应商错误且不保留完整响应正文。

func RequestProjectionIsEmpty 

func RequestProjectionIsEmpty(projection catalog.RequestProjection) bool

RequestProjectionIsEmpty reports whether an offering carries no runtime mutation rules. RequestProjectionIsEmpty 报告一个产品是否未携带任何运行时变更规则。

func SanitizeUpstreamErrorText 

func SanitizeUpstreamErrorText(value string) string

SanitizeUpstreamErrorText bounds one provider-authored message and removes unsafe control characters. SanitizeUpstreamErrorText 限制一条供应商原始信息并移除不安全控制字符。

func UpstreamHTTPError 

func UpstreamHTTPError(statusError transport.StatusError, cause error) error

UpstreamHTTPError converts one bounded transport status observation into the provider-wide evidence contract. UpstreamHTTPError 将一个受限传输状态观测转换为供应商范围的统一证据合同。

func UpstreamHTTPResponseError 

func UpstreamHTTPResponseError(response *http.Response, body []byte, cause error) error

UpstreamHTTPResponseError converts one already-read bounded response body into provider-wide evidence without mutating the caller's response. UpstreamHTTPResponseError 将一个已读取的有界响应正文转换为供应商范围证据，且不修改调用方的响应。

func UpstreamStatusError 

func UpstreamStatusError(httpStatus int, code string, errorType string, message string, requestID string) error

UpstreamStatusError creates one business-envelope failure, including HTTP 200 failures. UpstreamStatusError 创建一个业务信封失败，包括 HTTP 200 失败。

func WrapClassifiedExecutionError 

func WrapClassifiedExecutionError(classification ClassifiedError, cause error) error

WrapClassifiedExecutionError binds one complete trusted classification to its safe transport cause. WrapClassifiedExecutionError 将一个完整受信任分类绑定到其安全传输原因。

Types

type ActionExecutionDriver 

type ActionExecutionDriver interface {
	// ProviderDefinitionID returns the sole provider definition owned by this Driver.
	// ProviderDefinitionID 返回该 Driver 唯一拥有的供应商 Definition。
	ProviderDefinitionID() string
	// ActionBindingID returns the sole provider action binding owned by this Driver.
	// ActionBindingID 返回该 Driver 唯一拥有的供应商动作绑定。
	ActionBindingID() string
	// Execute projects and sends one action without changing its target scope.
	// Execute 在不改变 Target 作用域的前提下投影并发送一个动作。
	Execute(context.Context, ExecutionRequest) (ExecutionResult, error)
}

ActionExecutionDriver executes one exact definition-owned action binding. ActionExecutionDriver 执行一个精确的 Definition 所有动作绑定。

type AllowanceReader 

type AllowanceReader interface {
	// ReadAllowances returns arbitrary consumable resource snapshots for one credential and its shared scopes.
	// ReadAllowances 返回一个凭据及其共享作用域的任意可消费资源快照。
	ReadAllowances(context.Context, providerconfig.ProviderInstance, providerconfig.Credential) ([]catalog.AllowanceSnapshot, error)
}

AllowanceReader is implemented by drivers that can query quotas, balances, or credits. AllowanceReader 由可以查询额度、余额或 Credit 的 Driver 实现。

type ClassifiedError 

type ClassifiedError struct {
	// Category is the stable Vulcan provider error category.
	// Category 是稳定的 Vulcan 供应商错误类别。
	Category string
	// Scope identifies the provider-owned resource affected by the failure.
	// Scope 标识失败影响的供应商拥有资源。
	Scope ErrorScope
	// Action is the recommended same-provider recovery behavior.
	// Action 是建议的同供应商恢复行为。
	Action RetryAction
	// RetryAt is the earliest known safe retry time.
	// RetryAt 是最早的已知安全重试时间。
	RetryAt *time.Time
	// RuleID identifies the trusted provider rule that produced the classification.
	// RuleID 标识产生分类的受信任供应商规则。
	RuleID string
	// ProviderRequestID preserves the upstream request identifier for diagnostics.
	// ProviderRequestID 为诊断保留上游请求标识。
	ProviderRequestID string
	// Upstream preserves bounded provider-authored error evidence for the authenticated caller.
	// Upstream 为已认证调用方保留受限的供应商原始错误证据。
	Upstream *UpstreamErrorEvidence
}

ClassifiedError contains stable provider semantics and retry boundaries. ClassifiedError 包含稳定供应商语义和重试边界。

type ClassifiedExecutionError 

type ClassifiedExecutionError struct {
	// Classification is the complete same-provider retry decision.
	// Classification 是完整的同供应商重试决策。
	Classification ClassifiedError
	// Cause is the safe underlying execution error.
	// Cause 是安全的底层执行错误。
	Cause error
}

ClassifiedExecutionError carries one provider-specific closed classification while preserving its safe transport cause. ClassifiedExecutionError 携带一个供应商专属封闭分类，同时保留其安全传输原因。

func (*ClassifiedExecutionError) Error 

func (e *ClassifiedExecutionError) Error() string

Error returns only the already-safe underlying error text. Error 仅返回已经安全的底层错误文本。

func (*ClassifiedExecutionError) Unwrap 

func (e *ClassifiedExecutionError) Unwrap() error

Unwrap exposes the safe transport cause for diagnostics and compatibility. Unwrap 暴露安全传输原因用于诊断与兼容。

type ContinuationBinding 

type ContinuationBinding struct {
	// ContinuationID is the Router-owned opaque continuation identifier requested by the caller.
	// ContinuationID 是调用方请求的 Router 所有不透明续接标识。
	ContinuationID string
	// ProviderDefinitionID fixes the originating provider integration.
	// ProviderDefinitionID 固定来源供应商集成。
	ProviderDefinitionID string
	// ProviderInstanceID fixes the originating provider instance.
	// ProviderInstanceID 固定来源供应商实例。
	ProviderInstanceID string
	// ChannelID fixes the originating provider channel.
	// ChannelID 固定来源供应商通道。
	ChannelID string
	// EndpointID fixes the originating provider endpoint selected by resolution.
	// EndpointID 固定解析阶段选定的来源供应商 Endpoint。
	EndpointID string
	// CredentialID fixes the originating provider credential selected by resolution.
	// CredentialID 固定解析阶段选定的来源供应商 Credential。
	CredentialID string
	// ProviderModelID fixes the originating logical provider model.
	// ProviderModelID 固定来源逻辑供应商模型。
	ProviderModelID string
	// UpstreamModelID fixes the exact wire model identifier that accepted the originating response.
	// UpstreamModelID 固定接受来源响应的精确 wire 模型标识。
	UpstreamModelID string
	// ExecutionProfileID fixes the originating protocol profile shape.
	// ExecutionProfileID 固定来源协议 Profile 形态。
	ExecutionProfileID string
	// UpstreamResponseID is the sealed provider response identifier sent only at the outbound wire boundary.
	// UpstreamResponseID 是仅在出站 wire 边界发送的密封供应商响应标识。
	UpstreamResponseID string
}

ContinuationBinding contains a Router-resolved provider continuation that remains bound to one exact target scope. ContinuationBinding 包含 Router 解析的供应商续接状态，并始终绑定到一个精确 Target 作用域。

func (ContinuationBinding) Validate 

func (c ContinuationBinding) Validate(target resolve.Target) error

Validate verifies that a continuation cannot cross provider, channel, model, or profile boundaries. Validate 校验续接状态不能跨越供应商、通道、模型或 Profile 边界。

type ConversationActionDriver 

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

ConversationActionDriver adapts one proven conversation profile Driver to one immutable ActionBinding. ConversationActionDriver 将一个已验证会话 Profile Driver 适配到一个不可变 ActionBinding。

func NewConversationActionDriver 

func NewConversationActionDriver(actionBindingID string, profileDriver ExecutionDriver) (*ConversationActionDriver, error)

NewConversationActionDriver creates an action adapter without changing provider wire behavior. NewConversationActionDriver 创建一个不改变供应商 wire 行为的动作适配器。

func (*ConversationActionDriver) ActionBindingID 

func (d *ConversationActionDriver) ActionBindingID() string

ActionBindingID returns the sole conversation action binding. ActionBindingID 返回唯一会话动作绑定。

func (*ConversationActionDriver) Execute 

func (d *ConversationActionDriver) Execute(ctx context.Context, request ExecutionRequest) (ExecutionResult, error)

Execute converts the validated action envelope and delegates to the unchanged profile Driver. Execute 转换已校验动作信封并委派给未改变的 Profile Driver。

func (*ConversationActionDriver) PreflightUsage 

func (d *ConversationActionDriver) PreflightUsage(ctx context.Context, request ExecutionRequest) (UsagePreflightResult, error)

PreflightUsage converts the action envelope and delegates only when the proven profile owns a native counter. PreflightUsage 转换动作信封，并且仅在已验证 Profile 拥有原生计量器时委派。

func (*ConversationActionDriver) ProviderDefinitionID 

func (d *ConversationActionDriver) ProviderDefinitionID() string

ProviderDefinitionID returns the exact definition owned by the proven Driver. ProviderDefinitionID 返回已验证 Driver 拥有的精确 Definition。

type CredentialMetadataReader 

type CredentialMetadataReader interface {
	// ReadCredentialMetadata returns one internally consistent account observation for one credential.
	// ReadCredentialMetadata 为一个凭据返回一份内部一致的账号观测。
	ReadCredentialMetadata(context.Context, providerconfig.ProviderInstance, providerconfig.Credential) (CredentialMetadataResult, error)
}

CredentialMetadataReader is implemented when one provider call returns multiple account capability classes. CredentialMetadataReader 由一次供应商调用返回多类账号能力的 Driver 实现。

type CredentialMetadataResult 

type CredentialMetadataResult struct {
	// Plan is the optional commercial plan returned by the provider observation.
	// Plan 是供应商观测返回的可选商业套餐。
	Plan *catalog.PlanSnapshot
	// Entitlements contains account-specific model authorization observations.
	// Entitlements 包含账号特定模型授权观测。
	Entitlements []catalog.ModelEntitlement
	// ServiceEntitlements contains account-specific special-service authorization observations.
	// ServiceEntitlements 包含账号特定特殊服务授权观测。
	ServiceEntitlements []catalog.ServiceEntitlement
	// Allowances contains quota, balance, or credit observations from the same response.
	// Allowances 包含来自同一响应的额度、余额或积分观测。
	Allowances []catalog.AllowanceSnapshot
}

CredentialMetadataResult contains every account fact decoded from one provider observation. CredentialMetadataResult 包含从一次供应商观测解码出的全部账号事实。

type CustomExecutionDriverFactory 

type CustomExecutionDriverFactory interface {
	// BuildCustomDriver validates the closed custom shape and returns a Driver bound to that exact definition revision.
	// BuildCustomDriver 校验封闭的自定义形态，并返回绑定到该精确 Definition 修订的 Driver。
	BuildCustomDriver(providerconfig.ProviderDefinition) (ExecutionDriver, error)
}

CustomExecutionDriverFactory creates one request-scoped Driver from an immutable persisted custom definition snapshot. CustomExecutionDriverFactory 根据不可变的已持久化自定义 Definition 快照创建一个请求作用域 Driver。

type Driver 

type Driver interface {
	// Definition returns the immutable code-owned provider definition.
	// Definition 返回代码拥有的不可变供应商定义。
	Definition() providerconfig.ProviderDefinition
	// ClassifyError converts one protocol-neutral upstream observation into provider semantics.
	// ClassifyError 将一个协议无关上游观测转换为供应商语义。
	ClassifyError(ErrorObservation) (ClassifiedError, bool)
}

Driver is the minimum trusted library contract for one system provider. Driver 是一个系统供应商的最小受信任库合同。

type EntitlementReader 

type EntitlementReader interface {
	// ReadEntitlements returns model authorization snapshots for one credential.
	// ReadEntitlements 返回一个凭据的模型授权快照。
	ReadEntitlements(context.Context, providerconfig.ProviderInstance, providerconfig.Credential) ([]catalog.ModelEntitlement, error)
}

EntitlementReader is implemented by drivers that can query account-specific model authorization. EntitlementReader 由可以查询账号特定模型授权的 Driver 实现。

type ErrorObservation 

type ErrorObservation struct {
	// HTTPStatus is the upstream HTTP status when available.
	// HTTPStatus 是可用时的上游 HTTP 状态。
	HTTPStatus int
	// Code is the structured provider error code when available.
	// Code 是可用时的结构化供应商错误码。
	Code string
	// Type is the structured provider error type when available.
	// Type 是可用时的结构化供应商错误类型。
	Type string
	// Message is a redacted provider error message used by trusted rules only.
	// Message 是仅供受信任规则使用的脱敏供应商错误消息。
	Message string
	// RetryAfter is the parsed provider retry delay when available.
	// RetryAfter 是可用时解析出的供应商重试延迟。
	RetryAfter *time.Duration
	// ProviderRequestID is the upstream request identifier when available.
	// ProviderRequestID 是可用时的上游请求标识。
	ProviderRequestID string
}

ErrorObservation contains protocol-neutral upstream failure evidence. ErrorObservation 包含协议无关的上游失败证据。

type ErrorScope 

type ErrorScope string

ErrorScope identifies which provider-owned resource is affected by a failure. ErrorScope 标识失败影响的供应商拥有资源。 

const (
	// ErrorScopeRequest affects only the current logical request.
	// ErrorScopeRequest 只影响当前逻辑请求。
	ErrorScopeRequest ErrorScope = "request"
	// ErrorScopeCredential affects one account or API key.
	// ErrorScopeCredential 影响一个账号或 API Key。
	ErrorScopeCredential ErrorScope = "credential"
	// ErrorScopeSubscription affects credentials sharing one subscription.
	// ErrorScopeSubscription 影响共享一个订阅的凭据。
	ErrorScopeSubscription ErrorScope = "subscription"
	// ErrorScopeBillingAccount affects credentials sharing one billing account.
	// ErrorScopeBillingAccount 影响共享一个计费账号的凭据。
	ErrorScopeBillingAccount ErrorScope = "billing_account"
	// ErrorScopeEndpoint affects one upstream endpoint.
	// ErrorScopeEndpoint 影响一个上游端点。
	ErrorScopeEndpoint ErrorScope = "endpoint"
	// ErrorScopeModel affects one provider model.
	// ErrorScopeModel 影响一个供应商模型。
	ErrorScopeModel ErrorScope = "model"
	// ErrorScopeProvider affects the complete selected provider instance.
	// ErrorScopeProvider 影响完整的所选供应商实例。
	ErrorScopeProvider ErrorScope = "provider"
)

type ExecutionDriver 

type ExecutionDriver interface {
	// ProviderDefinitionID returns the sole provider definition owned by this Driver.
	// ProviderDefinitionID 返回该 Driver 唯一拥有的供应商 Definition。
	ProviderDefinitionID() string
	// ProtocolProfileID returns the sole upstream protocol profile implemented by this Driver.
	// ProtocolProfileID 返回该 Driver 实现的唯一上游协议 Profile。
	ProtocolProfileID() string
	// Execute projects and sends one request without changing its target scope.
	// Execute 在不改变 Target 作用域的前提下投影并发送一条请求。
	Execute(context.Context, ExecutionRequest) (ExecutionResult, error)
}

ExecutionDriver executes one protocol profile for exactly one provider definition. ExecutionDriver 为一个精确供应商 Definition 执行一种协议 Profile。

type ExecutionEventSink 

type ExecutionEventSink interface {
	// Emit validates and durably publishes one provider semantic event before returning to the upstream reader.
	// Emit 在返回上游读取器前校验并持久发布一个供应商语义事件。
	Emit(context.Context, vcp.Event) error
}

ExecutionEventSink durably accepts validated provider semantic events while an upstream stream is still active. ExecutionEventSink 在上游流仍活跃时持久接收经过校验的供应商语义事件。

type ExecutionRegistry 

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

ExecutionRegistry dispatches to a Driver selected only by target definition and definition-owned channel profile. ExecutionRegistry 仅按 Target Definition 和 Definition 拥有的 Channel Profile 分派 Driver。

func NewExecutionRegistry 

func NewExecutionRegistry() *ExecutionRegistry

NewExecutionRegistry creates an empty provider-scoped execution registry. NewExecutionRegistry 创建一个空的供应商作用域执行注册表。

func (*ExecutionRegistry) CancelTask 

func (r *ExecutionRegistry) CancelTask(ctx context.Context, request ExecutionRequest, providerTaskID string) (TaskResult, error)

CancelTask requests cancellation of one exact asynchronous provider task. CancelTask 请求取消一个精确异步供应商任务。

func (*ExecutionRegistry) ClassifyExecutionError 

func (r *ExecutionRegistry) ClassifyExecutionError(request ExecutionRequest, executionError error) (ClassifiedError, bool)

ClassifyExecutionError converts safe transport failures into closed same-provider retry semantics. ClassifyExecutionError 将安全传输失败转换为封闭的同供应商重试语义。

func (*ExecutionRegistry) Execute 

func (r *ExecutionRegistry) Execute(ctx context.Context, request ExecutionRequest) (ExecutionResult, error)

Execute validates the exact binding and dispatches without candidate lists or cross-provider fallback. Execute 校验精确绑定并进行分派，不使用候选列表或跨供应商回退。

func (*ExecutionRegistry) PollTask 

func (r *ExecutionRegistry) PollTask(ctx context.Context, request ExecutionRequest, providerTaskID string) (TaskResult, error)

PollTask observes one exact asynchronous provider task without changing affinity. PollTask 在不改变亲和性的情况下观察一个精确异步供应商任务。

func (*ExecutionRegistry) PreflightUsage 

func (r *ExecutionRegistry) PreflightUsage(ctx context.Context, request ExecutionRequest) (UsagePreflightResult, error)

PreflightUsage dispatches only to an explicitly registered provider-native counter. PreflightUsage 仅分派到显式注册的供应商原生计量器。

func (*ExecutionRegistry) ProviderIDs 

func (r *ExecutionRegistry) ProviderIDs() []string

ProviderIDs returns stable unique definition identifiers that own at least one registered execution driver. ProviderIDs 返回至少拥有一个已注册执行 Driver 的稳定唯一 Definition 标识。

func (*ExecutionRegistry) Register 

func (r *ExecutionRegistry) Register(driver ExecutionDriver) error

Register adds one Driver and rejects overlapping ownership of a definition/profile pair. Register 添加一个 Driver 并拒绝重叠拥有同一 Definition/Profile 对。

func (*ExecutionRegistry) RegisterAction 

func (r *ExecutionRegistry) RegisterAction(driver ActionExecutionDriver) error

RegisterAction adds one Driver and rejects overlapping ownership of a definition/action pair. RegisterAction 添加一个 Driver 并拒绝重叠拥有同一 Definition/Action 对。

func (*ExecutionRegistry) RegisterCustomFactory 

func (r *ExecutionRegistry) RegisterCustomFactory(factory CustomExecutionDriverFactory) error

RegisterCustomFactory installs the sole runtime factory for persisted custom definitions. RegisterCustomFactory 安装已持久化自定义 Definition 的唯一运行时 Factory。

func (*ExecutionRegistry) RegisterTaskAction 

func (r *ExecutionRegistry) RegisterTaskAction(driver TaskExecutionDriver) error

RegisterTaskAction adds one asynchronous Driver and rejects overlapping ownership. RegisterTaskAction 添加一个异步 Driver 并拒绝重叠所有权。

func (*ExecutionRegistry) StartTask 

func (r *ExecutionRegistry) StartTask(ctx context.Context, request ExecutionRequest) (TaskResult, error)

StartTask validates exact ownership and starts one asynchronous provider task. StartTask 校验精确所有权并创建一个异步供应商任务。

type ExecutionRequest 

type ExecutionRequest struct {
	// Binding contains the immutable target and exact endpoint and credential snapshots.
	// Binding 包含不可变 Target 与精确 Endpoint、Credential 快照。
	Binding transport.Binding
	// Definition is the immutable provider definition that owns the selected channel.
	// Definition 是拥有选定 Channel 的不可变供应商 Definition。
	Definition providerconfig.ProviderDefinition
	// Request is the validated VCP request to project and execute.
	// Request 是待投影和执行的已校验 VCP 请求。
	Request vcp.VulcanRequest
	// Execution is the closed multi-operation VCP request used by action-bound drivers.
	// Execution 是动作绑定 Driver 使用的封闭多操作 VCP 请求。
	Execution *vcp.ExecutionRequest
	// MaterializedInputs contains the exact representations frozen by an accepted input plan.
	// MaterializedInputs 包含已接受输入方案冻结的精确表示。
	MaterializedInputs []resource.MaterializedInput
	// ValidatedParameters contains the closed provider-specific parameter tree accepted at the resolution boundary.
	// ValidatedParameters 包含在解析边界接受的封闭供应商专属参数树。
	ValidatedParameters *catalog.ValidatedParameterSet
	// LineageID identifies the Router-owned execution lineage for projection and reports.
	// LineageID 标识供投影和报告使用的 Router 所有执行谱系。
	LineageID string
	// Now fixes deterministic projection timestamps.
	// Now 固定确定性的投影时间戳。
	Now time.Time
	// Continuation supplies a target-bound provider response only after Router resolution.
	// Continuation 仅在 Router 解析后提供一个 Target 绑定的供应商响应。
	Continuation *ContinuationBinding
	// PreparedWorkflow contains one Router-resolved provider handle only for an explicit multi-step operation.
	// PreparedWorkflow 仅为显式多步骤操作包含一个由 Router 解析的供应商句柄。
	PreparedWorkflow *PreparedWorkflowBinding
	// EventSink receives validated semantic events immediately for explicitly streaming requests.
	// EventSink 为显式流式请求立即接收经过校验的语义事件。
	EventSink ExecutionEventSink
	// ResourceSink receives native generated-resource byte progress for explicitly streaming requests.
	// ResourceSink 为显式流式请求接收原生生成资源字节进度。
	ResourceSink ExecutionResourceSink
}

ExecutionRequest joins canonical input, exact configuration snapshots, and optional resolved continuation state. ExecutionRequest 组合规范输入、精确配置快照与可选的已解析续接状态。

func (*ExecutionRequest) ValidateForAction 

func (r *ExecutionRequest) ValidateForAction(actionBindingID string, supportedAuthTypes ...providerconfig.AuthMethodType) (providerconfig.ProviderActionBinding, error)

ValidateForAction verifies one exact definition-owned action before its Driver can emit network traffic. ValidateForAction 在动作 Driver 发起网络流量前校验一个精确的 Definition 所有动作。

func (ExecutionRequest) ValidateForProfile 

func (r ExecutionRequest) ValidateForProfile(profileID string, supportedAuthTypes ...providerconfig.AuthMethodType) (string, error)

ValidateForProfile verifies all invariant facts before a Profile or Driver can emit network traffic; supportedAuthTypes restricts the Driver's closed wire authentication capability when supplied. ValidateForProfile 在 Profile 或 Driver 发起网络流量前校验全部不变量事实；提供 supportedAuthTypes 时，它会限制 Driver 的封闭 wire 认证能力。

type ExecutionResourceSink 

type ExecutionResourceSink interface {
	// EmitResourceProgress publishes one strictly increasing cumulative byte observation.
	// EmitResourceProgress 发布一个严格递增的累计字节观测。
	EmitResourceProgress(context.Context, ResourceProgress) error
}

ExecutionResourceSink durably accepts real provider resource progress while an upstream stream is active. ExecutionResourceSink 在上游流活跃时持久接收真实供应商资源进度。

type ExecutionResult 

type ExecutionResult struct {
	// Response is the deterministic VCP reduction of returned events.
	// Response 是返回事件的确定性 VCP 归并结果。
	Response vcp.Response
	// Events contains the replayable VCP event sequence.
	// Events 包含可回放的 VCP 事件序列。
	Events []vcp.Event
	// Report contains only client-safe execution and conversion facts.
	// Report 仅包含客户端安全的执行与转换事实。
	Report vcp.ExecutionReport
	// UpstreamResponseID is a provider response identifier for Router-owned continuation persistence.
	// UpstreamResponseID 是供 Router 所有续接持久化使用的供应商响应标识。
	UpstreamResponseID string
	// ContinuationUpstreamResponseID is present only when this exact driver can consume the identifier on a later bound request.
	// ContinuationUpstreamResponseID 仅在此精确 Driver 可于后续绑定请求中消费该标识时存在。
	ContinuationUpstreamResponseID string
	// Embeddings contains ordered typed vector results for embedding actions.
	// Embeddings 包含 Embedding 动作的有序类型化向量结果。
	Embeddings []vcp.EmbeddingItem
	// Rerank contains ordered typed ranking results for rerank actions.
	// Rerank 包含重排动作的有序类型化排序结果。
	Rerank []vcp.RerankResult
	// Search contains one unified typed web-search result.
	// Search 包含一个统一类型化网页搜索结果。
	Search *vcp.WebSearchResponse
	// Extract contains one unified typed web-content extraction result.
	// Extract 包含一个统一类型化网页内容提取结果。
	Extract *vcp.WebExtractResponse
	// Transcript contains one complete typed non-realtime recognition result.
	// Transcript 包含一个完整的类型化非实时识别结果。
	Transcript *vcp.Transcript
	// Transcriptions contains ordered resource-owned results for batch recognition.
	// Transcriptions 包含批量识别的有序且归属资源的结果。
	Transcriptions []vcp.TranscriptionResult
	// MusicCoverPreparation contains one private provider handle and safe editable cover facts.
	// MusicCoverPreparation 包含一个私有供应商句柄及安全可编辑的翻唱事实。
	MusicCoverPreparation *MusicCoverPreparationResult
	// GeneratedResources contains private provider bytes or temporary URLs that the execution layer must import before publication.
	// GeneratedResources 包含执行层必须在公开前导入的私有供应商字节或临时 URL。
	GeneratedResources []GeneratedResource
}

ExecutionResult contains canonical output and optional state that a Router may persist as a new continuation. ExecutionResult 包含规范输出及 Router 可持久化为新续接状态的可选状态。

type GeneratedResource 

type GeneratedResource struct {
	// OutputID is stable within the provider result and never reused for another output.
	// OutputID 在供应商结果内保持稳定且不会被其他输出复用。
	OutputID string
	// Kind identifies the generated media family.
	// Kind 标识生成媒体类别。
	Kind vcp.MediaKind
	// MIMEType is the provider-declared media type verified by Router content probing.
	// MIMEType 是由 Router 内容探测校验的供应商声明媒体类型。
	MIMEType string
	// Data contains complete generated bytes when the provider returned inline or authenticated content.
	// Data 在供应商返回内联或需认证内容时包含完整生成字节。
	Data []byte
	// DownloadURL contains one temporary public provider URL when no authenticated fetch is required.
	// DownloadURL 在无需认证获取时包含一个临时公网供应商 URL。
	DownloadURL string
}

GeneratedResource contains one exact provider output acquisition source. GeneratedResource 包含一个精确的供应商输出获取来源。

type MusicCoverPreparationResult 

type MusicCoverPreparationResult struct {
	// ProviderHandle is the upstream cover feature identifier and must never enter public JSON.
	// ProviderHandle 是上游翻唱特征标识且绝不能进入公开 JSON。
	ProviderHandle string
	// FormattedLyrics contains editable provider-extracted lyrics.
	// FormattedLyrics 包含可编辑的供应商提取歌词。
	FormattedLyrics string
	// Structure contains parsed provider-confirmed song sections.
	// Structure 包含已解析且由供应商确认的歌曲段落。
	Structure []vcp.MusicStructureSegment
	// AudioDurationSeconds is the provider-confirmed source duration.
	// AudioDurationSeconds 是供应商确认的来源时长。
	AudioDurationSeconds float64
	// ExpiresAt is the provider-confirmed handle expiry.
	// ExpiresAt 是供应商确认的句柄过期时间。
	ExpiresAt time.Time
}

MusicCoverPreparationResult contains provider-private state and typed safe preprocessing output. MusicCoverPreparationResult 包含供应商私有状态及类型化安全预处理输出。

type PlanReader 

type PlanReader interface {
	// ReadPlan returns the current commercial plan snapshot for one credential.
	// ReadPlan 返回一个凭据的当前商业套餐快照。
	ReadPlan(context.Context, providerconfig.ProviderInstance, providerconfig.Credential) (catalog.PlanSnapshot, error)
}

PlanReader is implemented by drivers that can query commercial plan metadata. PlanReader 由可以查询商业套餐元数据的 Driver 实现。

type PreparedWorkflowBinding 

type PreparedWorkflowBinding struct {
	// PreparationID is the public Router-owned preparation identifier.
	// PreparationID 是公开的 Router 所有准备标识。
	PreparationID string
	// ProviderHandle is the protected provider value consumed on the wire.
	// ProviderHandle 是在 Wire 上消费的受保护供应商值。
	ProviderHandle string
	// ExpiresAt is the provider-confirmed handle expiry.
	// ExpiresAt 是供应商确认的句柄过期时间。
	ExpiresAt time.Time
}

PreparedWorkflowBinding contains one private target-bound provider preparation handle. PreparedWorkflowBinding 包含一个私有且绑定 Target 的供应商准备句柄。

type ProviderFileDiagnostic 

type ProviderFileDiagnostic struct {
	// FileID is the provider file identifier visible only through the protected management plane.
	// FileID 是仅通过受保护管理面可见的供应商文件标识。
	FileID string `json:"file_id"`
	// Filename is the provider-recorded basename.
	// Filename 是供应商记录的文件基本名。
	Filename string `json:"filename"`
	// Purpose is the provider-recorded file purpose.
	// Purpose 是供应商记录的文件用途。
	Purpose string `json:"purpose"`
	// SizeBytes is the provider-reported object size.
	// SizeBytes 是供应商报告的对象大小。
	SizeBytes int64 `json:"size_bytes"`
	// CreatedAt is the provider-reported creation time.
	// CreatedAt 是供应商报告的创建时间。
	CreatedAt time.Time `json:"created_at"`
	// DownloadAvailable reports whether the provider returned a temporary download URL without exposing it.
	// DownloadAvailable 表示供应商是否返回临时下载地址，但不暴露该地址。
	DownloadAvailable bool `json:"download_available"`
}

ProviderFileDiagnostic is management-safe metadata for one provider-owned file. ProviderFileDiagnostic 是一个供应商拥有文件的管理安全元数据。

type ProviderFileDiagnosticsReader 

type ProviderFileDiagnosticsReader interface {
	// ListProviderFiles returns current provider file metadata without downloading content.
	// ListProviderFiles 返回当前供应商文件元数据且不下载正文。
	ListProviderFiles(context.Context, string, string, string) ([]ProviderFileDiagnostic, error)
	// GetProviderFile returns current metadata for one exact provider file without exposing its temporary download URL.
	// GetProviderFile 返回一个精确供应商文件的当前元数据，但不暴露其临时下载地址。
	GetProviderFile(context.Context, string, string, string, string) (ProviderFileDiagnostic, error)
}

ProviderFileDiagnosticsReader lists provider files for one exact protected account target. ProviderFileDiagnosticsReader 为一个精确且受保护的账号 Target 列出供应商文件。

type Registry 

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

Registry stores trusted system-provider libraries by immutable definition identifier. Registry 按不可变定义标识存储受信任系统供应商库。

func NewRegistry 

func NewRegistry(definitions *providerconfig.SystemRegistry) (*Registry, error)

NewRegistry creates an empty trusted provider library registry. NewRegistry 创建一个空的受信任供应商库注册表。

func (*Registry) DefinitionIDs 

func (r *Registry) DefinitionIDs() []string

DefinitionIDs returns a stable sorted trusted driver identifier snapshot. DefinitionIDs 返回稳定排序的受信任 Driver 标识快照。

func (*Registry) Lookup 

func (r *Registry) Lookup(definitionID string) (Driver, bool)

Lookup returns the exact trusted driver for one system provider definition. Lookup 返回一个系统供应商定义的精确受信任 Driver。

func (*Registry) Register 

func (r *Registry) Register(driver Driver) error

Register validates a driver capability contract and registers its immutable definition. Register 校验 Driver 能力合同并注册其不可变定义。

type ResourceProgress 

type ResourceProgress struct {
	// OutputID is stable within the provider result and matches GeneratedResource.OutputID.
	// OutputID 在供应商结果内保持稳定，并与 GeneratedResource.OutputID 一致。
	OutputID string
	// Kind identifies the generated media family.
	// Kind 标识生成媒体类别。
	Kind vcp.MediaKind
	// MIMEType identifies the exact output encoding selected before streaming starts.
	// MIMEType 标识流式开始前选定的精确输出编码。
	MIMEType string
	// PartialBytes is the cumulative count of provider bytes received so far.
	// PartialBytes 是当前已接收供应商字节的累计数量。
	PartialBytes int64
}

ResourceProgress contains one provider-confirmed cumulative output byte observation. ResourceProgress 包含一个由供应商确认的累计输出字节观测。

type RetryAction 

type RetryAction string

RetryAction identifies one explicit same-provider recovery recommendation. RetryAction 标识一个显式同供应商恢复建议。 

const (
	// RetryStop recommends returning the failure without internal retry.
	// RetryStop 建议不进行内部重试并返回失败。
	RetryStop RetryAction = "stop"
	// RetrySameTarget recommends retrying the same credential and endpoint.
	// RetrySameTarget 建议重试相同凭据和端点。
	RetrySameTarget RetryAction = "retry_same_target"
	// RetryOtherEndpoint recommends another endpoint in the same provider instance.
	// RetryOtherEndpoint 建议使用同一供应商实例中的其他端点。
	RetryOtherEndpoint RetryAction = "retry_other_endpoint"
	// RetryAfterReset recommends waiting until a known provider recovery time.
	// RetryAfterReset 建议等待已知供应商恢复时间。
	RetryAfterReset RetryAction = "retry_after_reset"
)

type TaskExecutionDriver 

type TaskExecutionDriver interface {
	// ProviderDefinitionID returns the sole owning provider definition.
	// ProviderDefinitionID 返回唯一拥有供应商 Definition。
	ProviderDefinitionID() string
	// ActionBindingID returns the sole owning action binding.
	// ActionBindingID 返回唯一拥有动作绑定。
	ActionBindingID() string
	// Start creates at most one provider task for one exact idempotently admitted execution.
	// Start 为一个精确幂等接收执行最多创建一个供应商任务。
	Start(context.Context, ExecutionRequest) (TaskResult, error)
	// Poll observes the same provider task without changing target affinity.
	// Poll 在不改变 Target 亲和性的情况下观察同一供应商任务。
	Poll(context.Context, ExecutionRequest, string) (TaskResult, error)
	// Cancel requests cancellation of the same provider task and returns its confirmed state.
	// Cancel 请求取消同一供应商任务并返回其确认状态。
	Cancel(context.Context, ExecutionRequest, string) (TaskResult, error)
}

TaskExecutionDriver owns asynchronous start, poll, and cancel for one exact action binding. TaskExecutionDriver 为一个精确动作绑定拥有异步创建、轮询与取消。

type TaskResult 

type TaskResult struct {
	// ProviderTaskID is the exact upstream identifier and must never enter public JSON or logs.
	// ProviderTaskID 是精确上游标识且绝不能进入公开 JSON 或日志。
	ProviderTaskID string
	// State is the provider-confirmed lifecycle state.
	// State 是供应商确认的生命周期状态。
	State TaskState
	// PollAfter is the earliest safe next polling time for non-terminal states.
	// PollAfter 是非终态最早安全下次轮询时间。
	PollAfter time.Time
	// Result contains typed output only for success states.
	// Result 仅在成功状态包含类型化输出。
	Result *ExecutionResult
	// ErrorCode is a client-safe provider classification only for failure.
	// ErrorCode 仅在失败时包含客户端安全供应商分类。
	ErrorCode string
	// Retryable reports a provider-evidenced retry classification.
	// Retryable 表示供应商有证据支持的重试分类。
	Retryable bool
}

TaskResult contains one provider-confirmed asynchronous task observation. TaskResult 包含一个供应商确认的异步任务观测。

func (TaskResult) Validate 

func (r TaskResult) Validate() error

Validate verifies one closed provider task observation without accepting invented progress. Validate 校验一个封闭供应商任务观测且不接受虚构进度。

type TaskState 

type TaskState string

TaskState identifies one provider-confirmed asynchronous task state. TaskState 标识一种供应商确认的异步任务状态。 

const (
	// TaskQueued is accepted by the provider but not running.
	// TaskQueued 已由供应商接收但尚未运行。
	TaskQueued TaskState = "queued"
	// TaskRunning is actively executing.
	// TaskRunning 正在执行。
	TaskRunning TaskState = "running"
	// TaskSucceeded completed successfully.
	// TaskSucceeded 已成功完成。
	TaskSucceeded TaskState = "succeeded"
	// TaskPartiallySucceeded completed with provider-confirmed partial output.
	// TaskPartiallySucceeded 已完成且具有供应商确认的部分输出。
	TaskPartiallySucceeded TaskState = "partially_succeeded"
	// TaskFailed terminated with a safe provider error code.
	// TaskFailed 已因安全供应商错误码终止。
	TaskFailed TaskState = "failed"
	// TaskCancelled is confirmed cancelled by the provider.
	// TaskCancelled 已由供应商确认取消。
	TaskCancelled TaskState = "cancelled"
)

type UpstreamError 

type UpstreamError struct {
	// Evidence is the sanitized provider failure evidence.
	// Evidence 是经过清理的供应商失败证据。
	Evidence UpstreamErrorEvidence
	// Cause is the safe local transport or decoding cause.
	// Cause 是安全的本地传输或解码原因。
	Cause error
}

UpstreamError wraps exact provider evidence as an execution or management error. UpstreamError 将精确供应商证据包装为执行或管理错误。

func (*UpstreamError) Error 

func (e *UpstreamError) Error() string

Error returns a bounded safe explanation without serializing a complete provider response. Error 返回受限的安全说明且不序列化完整供应商响应。

func (*UpstreamError) Unwrap 

func (e *UpstreamError) Unwrap() error

Unwrap exposes the safe local cause. Unwrap 暴露安全的本地原因。

type UpstreamErrorEvidence 

type UpstreamErrorEvidence struct {
	// HTTPStatus is the upstream transport status when known.
	// HTTPStatus 是已知时的上游传输状态。
	HTTPStatus *int
	// Code is the exact bounded provider error or business status code.
	// Code 是精确且受限的供应商错误码或业务状态码。
	Code string
	// Type is the exact bounded provider error type.
	// Type 是精确且受限的供应商错误类型。
	Type string
	// Message is the bounded provider-authored message.
	// Message 是受限的供应商原始信息。
	Message string
	// RequestID is the bounded provider support identifier.
	// RequestID 是受限的供应商支持标识。
	RequestID string
	// RetryAfter is the provider-declared safe delay when available.
	// RetryAfter 是可用时由供应商声明的安全等待时间。
	RetryAfter *time.Duration
	// UnclassifiedDetail contains bounded upstream text with no declared field mapping.
	// UnclassifiedDetail 包含没有已声明字段映射的受限上游文本。
	UnclassifiedDetail string
}

UpstreamErrorEvidence carries bounded error facts observed at one exact provider boundary. UpstreamErrorEvidence 携带在一个精确供应商边界观测到的受限错误事实。

type UsagePreflightDriver 

type UsagePreflightDriver interface {
	// PreflightUsage returns provider-native input accounting for the exact immutable target.
	// PreflightUsage 返回精确不可变 Target 的供应商原生输入计量。
	PreflightUsage(context.Context, ExecutionRequest) (UsagePreflightResult, error)
}

UsagePreflightDriver counts one request without creating model output or changing target scope. UsagePreflightDriver 在不创建模型输出或改变 Target 作用域的情况下计量请求。

type UsagePreflightResult 

type UsagePreflightResult struct {
	// Usage contains only values returned by the provider counting endpoint.
	// Usage 仅包含供应商计量接口返回的数值。
	Usage vcp.UsageObservation
	// Accuracy states whether the provider reported an exact value.
	// Accuracy 声明供应商是否报告了精确值。
	Accuracy vcp.PreflightAccuracy
}

UsagePreflightResult contains provider-owned side-effect-free input accounting. UsagePreflightResult 包含供应商拥有的无副作用输入计量。

type VoiceCatalogReader 

type VoiceCatalogReader interface {
	// ReadVoices returns one complete current voice catalog for the exact credential.
	// ReadVoices 为精确凭据返回一份完整的当前声音目录。
	ReadVoices(context.Context, providerconfig.ProviderInstance, providerconfig.Credential) ([]catalog.VoiceSnapshot, error)
}

VoiceCatalogReader is implemented by providers that expose credential-scoped preset voices. VoiceCatalogReader 由公开凭据作用域预设声音的供应商实现。

Source Files

View all Source files

Directories

Path Synopsis
Portions of this adapter are copied and adapted from bailian-cli packages/commands/src/commands/text/chat.ts at commit 678f60b.
 Portions of this adapter are copied and adapted from bailian-cli packages/commands/src/commands/text/chat.ts at commit 678f60b.
catalogdata
Package catalogdata owns versioned, credential-free Alibaba catalog facts.
 Package catalogdata owns versioned, credential-free Alibaba catalog facts.
Package anthropic contains Anthropic-specific execution drivers.
 Package anthropic contains Anthropic-specific execution drivers.
Package deepseek implements exact official DeepSeek provider adaptations.
 Package deepseek implements exact official DeepSeek provider adaptations.
Package google contains provider-scoped Google execution drivers.
 Package google contains provider-scoped Google execution drivers.
Portions of this adapter are copied and adapted from CLIProxyAPI internal/runtime/executor/kimi_executor.go at commit 9f4f53ca5a4d1474e3f7eb61d6ffc984995f1f66 and Kimi CLI 1.49.0.
 Portions of this adapter are copied and adapted from CLIProxyAPI internal/runtime/executor/kimi_executor.go at commit 9f4f53ca5a4d1474e3f7eb61d6ffc984995f1f66 and Kimi CLI 1.49.0.
Package metadata provides strict shared primitives for provider metadata readers.
 Package metadata provides strict shared primitives for provider metadata readers.
Package minimax contains MiniMax provider-specific execution behavior.
 Package minimax contains MiniMax provider-specific execution behavior.
Portions of this driver are adapted from CLIProxyAPI internal/runtime/executor/openai_compat_executor.go at commit 9f4f53ca5a4d1474e3f7eb61d6ffc984995f1f66.
 Portions of this driver are adapted from CLIProxyAPI internal/runtime/executor/openai_compat_executor.go at commit 9f4f53ca5a4d1474e3f7eb61d6ffc984995f1f66.
Package openrouter implements OpenRouter-native typed action drivers.
 Package openrouter implements OpenRouter-native typed action drivers.
Package tavily implements the exact Tavily Search API boundary.
 Package tavily implements the exact Tavily Search API boundary.
Package translatedresponses executes protocols translated from the typed OpenAI Responses projection.
 Package translatedresponses executes protocols translated from the typed OpenAI Responses projection.
Package transport provides provider-scoped HTTP and SSE transport primitives.
 Package transport provides provider-scoped HTTP and SSE transport primitives.
Package xai contains provider-scoped xAI execution drivers.
 Package xai contains provider-scoped xAI execution drivers.

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.