proto

type AccountProto struct {
	Id              int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name            string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Platform        string `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	Type            string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	CredentialsJson []byte `protobuf:"bytes,5,opt,name=credentials_json,json=credentialsJson,proto3" json:"credentials_json,omitempty"`
	ProxyUrl        string `protobuf:"bytes,6,opt,name=proxy_url,json=proxyUrl,proto3" json:"proxy_url,omitempty"`
	// contains filtered or unexported fields
}

type AccountTypeProto struct {
	Key         string                  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Label       string                  `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Description string                  `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Fields      []*CredentialFieldProto `protobuf:"bytes,4,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

type BackgroundTaskProto struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IntervalMs int64  `protobuf:"varint,2,opt,name=interval_ms,json=intervalMs,proto3" json:"interval_ms,omitempty"`
	// contains filtered or unexported fields
}

type BackgroundTasksResponse struct {
	Tasks []*BackgroundTaskProto `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

type ConfigFieldProto struct {
	Key          string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Label        string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Type         string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Required     bool   `protobuf:"varint,4,opt,name=required,proto3" json:"required,omitempty"`
	DefaultValue string `protobuf:"bytes,5,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	Description  string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	Placeholder  string `protobuf:"bytes,7,opt,name=placeholder,proto3" json:"placeholder,omitempty"`
	// contains filtered or unexported fields
}

type CredentialFieldProto struct {
	Key          string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Label        string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Type         string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Required     bool   `protobuf:"varint,4,opt,name=required,proto3" json:"required,omitempty"`
	Placeholder  string `protobuf:"bytes,5,opt,name=placeholder,proto3" json:"placeholder,omitempty"`
	EditDisabled bool   `protobuf:"varint,6,opt,name=edit_disabled,json=editDisabled,proto3" json:"edit_disabled,omitempty"` // 编辑模式下隐藏该字段
	// contains filtered or unexported fields
}

type CredentialsRequest struct {
	Credentials map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

type ExtensionServiceClient interface {
	Migrate(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	GetBackgroundTasks(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BackgroundTasksResponse, error)
	// 由 Core 调度器按 Interval 周期触发；插件进程内查表执行 Handler
	RunBackgroundTask(ctx context.Context, in *RunBackgroundTaskRequest, opts ...grpc.CallOption) (*Empty, error)
	// HTTP 请求由核心代理到插件
	HandleRequest(ctx context.Context, in *HttpRequest, opts ...grpc.CallOption) (*HttpResponse, error)
	HandleStreamRequest(ctx context.Context, in *HttpRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[HttpResponseChunk], error)
}

type ExtensionServiceServer interface {
	Migrate(context.Context, *Empty) (*Empty, error)
	GetBackgroundTasks(context.Context, *Empty) (*BackgroundTasksResponse, error)
	// 由 Core 调度器按 Interval 周期触发；插件进程内查表执行 Handler
	RunBackgroundTask(context.Context, *RunBackgroundTaskRequest) (*Empty, error)
	// HTTP 请求由核心代理到插件
	HandleRequest(context.Context, *HttpRequest) (*HttpResponse, error)
	HandleStreamRequest(*HttpRequest, grpc.ServerStreamingServer[HttpResponseChunk]) error
	// contains filtered or unexported methods
}

type ExtensionService_HandleStreamRequestClient = grpc.ServerStreamingClient[HttpResponseChunk]

type ExtensionService_HandleStreamRequestServer = grpc.ServerStreamingServer[HttpResponseChunk]

type ForwardChunk struct {
	Data         []byte                   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Done         bool                     `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	FinalOutcome *ForwardOutcome          `protobuf:"bytes,3,opt,name=final_outcome,json=finalOutcome,proto3" json:"final_outcome,omitempty"`
	StatusCode   int32                    `protobuf:"varint,4,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Headers      map[string]*HeaderValues `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ForwardOutcome struct {
	Kind               OutcomeKind       `protobuf:"varint,1,opt,name=kind,proto3,enum=airgate.plugin.v1.OutcomeKind" json:"kind,omitempty"`
	Upstream           *UpstreamResponse `protobuf:"bytes,2,opt,name=upstream,proto3" json:"upstream,omitempty"`
	Usage              *Usage            `protobuf:"bytes,3,opt,name=usage,proto3" json:"usage,omitempty"`
	DurationMs         int64             `protobuf:"varint,4,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	RetryAfterMs       int64             `protobuf:"varint,5,opt,name=retry_after_ms,json=retryAfterMs,proto3" json:"retry_after_ms,omitempty"`
	Reason             string            `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	UpdatedCredentials map[string]string `` /* 189-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ForwardRequest struct {
	Body    []byte                   `protobuf:"bytes,7,opt,name=body,proto3" json:"body,omitempty"`
	Headers map[string]*HeaderValues `` /* 141-byte string literal not displayed */
	Model   string                   `protobuf:"bytes,9,opt,name=model,proto3" json:"model,omitempty"`
	Stream  bool                     `protobuf:"varint,10,opt,name=stream,proto3" json:"stream,omitempty"`
	Account *AccountProto            `protobuf:"bytes,11,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

type FrontendPageProto struct {
	Path        string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Title       string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Icon        string `protobuf:"bytes,3,opt,name=icon,proto3" json:"icon,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Audience    string `protobuf:"bytes,5,opt,name=audience,proto3" json:"audience,omitempty"` // "admin" | "user" | "all"，空 = "admin"
	// contains filtered or unexported fields
}

type FrontendWidgetProto struct {
	Slot      string `protobuf:"bytes,1,opt,name=slot,proto3" json:"slot,omitempty"`
	EntryFile string `protobuf:"bytes,2,opt,name=entry_file,json=entryFile,proto3" json:"entry_file,omitempty"`
	Title     string `protobuf:"bytes,3,opt,name=title,proto3" json:"title,omitempty"`
	// contains filtered or unexported fields
}

type GatewayServiceClient interface {
	GetPlatform(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StringResponse, error)
	GetModels(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ModelsResponse, error)
	GetRoutes(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RoutesResponse, error)
	Forward(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*ForwardOutcome, error)
	ForwardStream(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ForwardChunk], error)
	ValidateAccount(ctx context.Context, in *CredentialsRequest, opts ...grpc.CallOption) (*Empty, error)
	QueryQuota(ctx context.Context, in *CredentialsRequest, opts ...grpc.CallOption) (*QuotaInfoResponse, error)
	// WebSocket 双向流
	HandleWebSocket(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[WebSocketFrame, WebSocketFrame], error)
}

type GatewayServiceServer interface {
	GetPlatform(context.Context, *Empty) (*StringResponse, error)
	GetModels(context.Context, *Empty) (*ModelsResponse, error)
	GetRoutes(context.Context, *Empty) (*RoutesResponse, error)
	Forward(context.Context, *ForwardRequest) (*ForwardOutcome, error)
	ForwardStream(*ForwardRequest, grpc.ServerStreamingServer[ForwardChunk]) error
	ValidateAccount(context.Context, *CredentialsRequest) (*Empty, error)
	QueryQuota(context.Context, *CredentialsRequest) (*QuotaInfoResponse, error)
	// WebSocket 双向流
	HandleWebSocket(grpc.BidiStreamingServer[WebSocketFrame, WebSocketFrame]) error
	// contains filtered or unexported methods
}

type GatewayService_ForwardStreamClient = grpc.ServerStreamingClient[ForwardChunk]

type GatewayService_ForwardStreamServer = grpc.ServerStreamingServer[ForwardChunk]

type GatewayService_HandleWebSocketClient = grpc.BidiStreamingClient[WebSocketFrame, WebSocketFrame]

type GatewayService_HandleWebSocketServer = grpc.BidiStreamingServer[WebSocketFrame, WebSocketFrame]

type HeaderValues struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type HostForwardChunk struct {
	Data       []byte                   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Done       bool                     `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	StatusCode int32                    `protobuf:"varint,3,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` // 仅首块
	Headers    map[string]*HeaderValues ``                                                                                             // 仅首块
	/* 141-byte string literal not displayed */
	Usage *HostForwardUsage `protobuf:"bytes,5,opt,name=usage,proto3" json:"usage,omitempty"` // 仅末块
	// contains filtered or unexported fields
}

type HostForwardRequest struct {
	UserId  int64                    `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`    // 计费主体（扣余额的用户）
	GroupId int64                    `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"` // 调度分组
	Model   string                   `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`                     // 可空：空时 Core 取该 platform 的第一个 model
	Method  string                   `protobuf:"bytes,4,opt,name=method,proto3" json:"method,omitempty"`                   // HTTP method（POST / GET / ...）
	Path    string                   `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`                       // 请求路径（如 /v1/chat/completions）
	Headers map[string]*HeaderValues ``                                                                                    /* 141-byte string literal not displayed */
	Body    []byte                   `protobuf:"bytes,7,opt,name=body,proto3" json:"body,omitempty"`
	Stream  bool                     `protobuf:"varint,8,opt,name=stream,proto3" json:"stream,omitempty"` // 是否流式
	// contains filtered or unexported fields
}

type HostForwardResponse struct {
	StatusCode int32                    `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Headers    map[string]*HeaderValues `` /* 141-byte string literal not displayed */
	Body       []byte                   `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Usage      *HostForwardUsage        `protobuf:"bytes,4,opt,name=usage,proto3" json:"usage,omitempty"`
	// contains filtered or unexported fields
}

type HostForwardUsage struct {
	InputTokens  int64   `protobuf:"varint,1,opt,name=input_tokens,json=inputTokens,proto3" json:"input_tokens,omitempty"`
	OutputTokens int64   `protobuf:"varint,2,opt,name=output_tokens,json=outputTokens,proto3" json:"output_tokens,omitempty"`
	Cost         float64 `protobuf:"fixed64,3,opt,name=cost,proto3" json:"cost,omitempty"` // 总费用（已计入倍率）
	Model        string  `protobuf:"bytes,4,opt,name=model,proto3" json:"model,omitempty"` // 实际使用的 model（可能被 Core 改写）
	// contains filtered or unexported fields
}

type HostGetAssetBytesRequest struct {
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"object_key,omitempty"`
	// contains filtered or unexported fields
}

type HostGetAssetBytesResponse struct {
	Data        []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	ContentType string `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

type HostGetAssetURLRequest struct {
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"object_key,omitempty"`
	// contains filtered or unexported fields
}

type HostGetAssetURLResponse struct {
	PublicUrl string `protobuf:"bytes,1,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"`
	// contains filtered or unexported fields
}

type HostGetUserInfoRequest struct {
	UserId int64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

type HostGetUserInfoResponse struct {
	UserId   int64   `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Username string  `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Email    string  `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	Role     string  `protobuf:"bytes,4,opt,name=role,proto3" json:"role,omitempty"` // "admin" / "user"
	Balance  float64 `protobuf:"fixed64,5,opt,name=balance,proto3" json:"balance,omitempty"`
	Status   string  `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"` // "active" / "disabled"
	// contains filtered or unexported fields
}

type HostGroup struct {
	Id             int64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name           string  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Platform       string  `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	IsExclusive    bool    `protobuf:"varint,4,opt,name=is_exclusive,json=isExclusive,proto3" json:"is_exclusive,omitempty"`
	RateMultiplier float64 `protobuf:"fixed64,5,opt,name=rate_multiplier,json=rateMultiplier,proto3" json:"rate_multiplier,omitempty"`
	// contains filtered or unexported fields
}

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

type HostListGroupsResponse struct {
	Groups []*HostGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

type HostListModelsRequest struct {
	Platform string `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform,omitempty"` // 必填：平台标识
	// contains filtered or unexported fields
}

type HostListModelsResponse struct {
	Models []*ModelInfoProto `protobuf:"bytes,1,rep,name=models,proto3" json:"models,omitempty"` // 复用已有 ModelInfoProto，避免平行数据结构漂移
	// contains filtered or unexported fields
}

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

type HostListPlatformsResponse struct {
	Platforms []*HostPlatform `protobuf:"bytes,1,rep,name=platforms,proto3" json:"platforms,omitempty"`
	// contains filtered or unexported fields
}

type HostPlatform struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                  // 平台标识（如 "openai"）
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"` // 展示名称（如 "OpenAI 网关"）
	// contains filtered or unexported fields
}

type HostProbeForwardRequest struct {
	GroupId int64  `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Model   string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"` // 可空：自动取 platform 第一个 model
	// contains filtered or unexported fields
}

type HostProbeForwardResponse struct {
	Success    bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	AccountId  int64  `protobuf:"varint,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"` // 本次实际命中的账号 ID（用于运维诊断）
	Platform   string `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	Model      string `protobuf:"bytes,4,opt,name=model,proto3" json:"model,omitempty"` // 实际探测用的 model
	StatusCode int64  `protobuf:"varint,5,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	LatencyMs  int64  `protobuf:"varint,6,opt,name=latency_ms,json=latencyMs,proto3" json:"latency_ms,omitempty"`
	ErrorKind  string `protobuf:"bytes,7,opt,name=error_kind,json=errorKind,proto3" json:"error_kind,omitempty"` // "" / "no_account" / "scheduler" / "upstream_5xx" / "timeout" / ...
	ErrorMsg   string `protobuf:"bytes,8,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

type HostReportAccountResultRequest struct {
	AccountId int64  `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	Success   bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMsg  string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"` // 失败时上报，便于调试
	// contains filtered or unexported fields
}

type HostSelectAccountRequest struct {
	GroupId           int64   `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Model             string  `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`                          // 可空：空时 Core 用 platform 的第一个 model
	SessionId         string  `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // 可空
	ExcludeAccountIds []int64 `protobuf:"varint,4,rep,packed,name=exclude_account_ids,json=excludeAccountIds,proto3" json:"exclude_account_ids,omitempty"`
	// contains filtered or unexported fields
}

type HostSelectAccountResponse struct {
	AccountId   int64  `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	AccountName string `protobuf:"bytes,2,opt,name=account_name,json=accountName,proto3" json:"account_name,omitempty"`
	Platform    string `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	// contains filtered or unexported fields
}

type HostServiceClient interface {
	// 选号：根据 (group_id, model) 走和真实用户请求完全相同的调度路径。
	SelectAccount(ctx context.Context, in *HostSelectAccountRequest, opts ...grpc.CallOption) (*HostSelectAccountResponse, error)
	// 把账号调用结果反馈给 scheduler 的失败计数器/状态机。
	ReportAccountResult(ctx context.Context, in *HostReportAccountResultRequest, opts ...grpc.CallOption) (*Empty, error)
	// 黑盒探测：内部组装一次最小的 chat completion 请求并直接执行。
	// 跳过 usage_log 写入、跳过用户余额扣款，仍然 ReportResult 反哺账号状态机。
	ProbeForward(ctx context.Context, in *HostProbeForwardRequest, opts ...grpc.CallOption) (*HostProbeForwardResponse, error)
	// 非流式业务转发：走完整管线（调度 → 网关插件 → 计费 → usage_log）。
	// 调用方需提供 user_id + group_id 以确定计费主体和调度路径。
	Forward(ctx context.Context, in *HostForwardRequest, opts ...grpc.CallOption) (*HostForwardResponse, error)
	// 流式业务转发：与 Forward 相同管线，结果通过 server stream 逐块返回。
	// 最后一块 done=true 携带 usage 信息（计费已在 Core 侧完成）。
	ForwardStream(ctx context.Context, in *HostForwardRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[HostForwardChunk], error)
	// 列出所有分组。
	ListGroups(ctx context.Context, in *HostListGroupsRequest, opts ...grpc.CallOption) (*HostListGroupsResponse, error)
	// 列出已加载的网关平台（每个 gateway 插件对应一个 platform）。
	ListPlatforms(ctx context.Context, in *HostListPlatformsRequest, opts ...grpc.CallOption) (*HostListPlatformsResponse, error)
	// 列出指定平台的模型列表。
	ListModels(ctx context.Context, in *HostListModelsRequest, opts ...grpc.CallOption) (*HostListModelsResponse, error)
	// 获取用户基本信息（余额、角色、状态）。
	GetUserInfo(ctx context.Context, in *HostGetUserInfoRequest, opts ...grpc.CallOption) (*HostGetUserInfoResponse, error)
	// 资产存储：由 Core 根据全局 storage 设置选择 MinIO/S3 或本地磁盘。
	StoreAsset(ctx context.Context, in *HostStoreAssetRequest, opts ...grpc.CallOption) (*HostStoreAssetResponse, error)
	GetAssetURL(ctx context.Context, in *HostGetAssetURLRequest, opts ...grpc.CallOption) (*HostGetAssetURLResponse, error)
	GetAssetBytes(ctx context.Context, in *HostGetAssetBytesRequest, opts ...grpc.CallOption) (*HostGetAssetBytesResponse, error)
}

type HostServiceServer interface {
	// 选号：根据 (group_id, model) 走和真实用户请求完全相同的调度路径。
	SelectAccount(context.Context, *HostSelectAccountRequest) (*HostSelectAccountResponse, error)
	// 把账号调用结果反馈给 scheduler 的失败计数器/状态机。
	ReportAccountResult(context.Context, *HostReportAccountResultRequest) (*Empty, error)
	// 黑盒探测：内部组装一次最小的 chat completion 请求并直接执行。
	// 跳过 usage_log 写入、跳过用户余额扣款，仍然 ReportResult 反哺账号状态机。
	ProbeForward(context.Context, *HostProbeForwardRequest) (*HostProbeForwardResponse, error)
	// 非流式业务转发：走完整管线（调度 → 网关插件 → 计费 → usage_log）。
	// 调用方需提供 user_id + group_id 以确定计费主体和调度路径。
	Forward(context.Context, *HostForwardRequest) (*HostForwardResponse, error)
	// 流式业务转发：与 Forward 相同管线，结果通过 server stream 逐块返回。
	// 最后一块 done=true 携带 usage 信息（计费已在 Core 侧完成）。
	ForwardStream(*HostForwardRequest, grpc.ServerStreamingServer[HostForwardChunk]) error
	// 列出所有分组。
	ListGroups(context.Context, *HostListGroupsRequest) (*HostListGroupsResponse, error)
	// 列出已加载的网关平台（每个 gateway 插件对应一个 platform）。
	ListPlatforms(context.Context, *HostListPlatformsRequest) (*HostListPlatformsResponse, error)
	// 列出指定平台的模型列表。
	ListModels(context.Context, *HostListModelsRequest) (*HostListModelsResponse, error)
	// 获取用户基本信息（余额、角色、状态）。
	GetUserInfo(context.Context, *HostGetUserInfoRequest) (*HostGetUserInfoResponse, error)
	// 资产存储：由 Core 根据全局 storage 设置选择 MinIO/S3 或本地磁盘。
	StoreAsset(context.Context, *HostStoreAssetRequest) (*HostStoreAssetResponse, error)
	GetAssetURL(context.Context, *HostGetAssetURLRequest) (*HostGetAssetURLResponse, error)
	GetAssetBytes(context.Context, *HostGetAssetBytesRequest) (*HostGetAssetBytesResponse, error)
	// contains filtered or unexported methods
}

type HostService_ForwardStreamClient = grpc.ServerStreamingClient[HostForwardChunk]

type HostService_ForwardStreamServer = grpc.ServerStreamingServer[HostForwardChunk]

type HostStoreAssetRequest struct {
	UserId        int64  `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Scope         string `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	ContentType   string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Data          []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	FileExtension string `protobuf:"bytes,5,opt,name=file_extension,json=fileExtension,proto3" json:"file_extension,omitempty"`
	// contains filtered or unexported fields
}

type HostStoreAssetResponse struct {
	AssetId     string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	ObjectKey   string `protobuf:"bytes,2,opt,name=object_key,json=objectKey,proto3" json:"object_key,omitempty"`
	PublicUrl   string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"`
	SizeBytes   int64  `protobuf:"varint,4,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	ContentType string `protobuf:"bytes,5,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

type HttpRequest struct {
	Method     string                   `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Path       string                   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Query      string                   `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	Headers    map[string]*HeaderValues `` /* 141-byte string literal not displayed */
	Body       []byte                   `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	RemoteAddr string                   `protobuf:"bytes,6,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
	// contains filtered or unexported fields
}

type HttpResponse struct {
	StatusCode int32                    `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Headers    map[string]*HeaderValues `` /* 141-byte string literal not displayed */
	Body       []byte                   `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type HttpResponseChunk struct {
	Data       []byte                   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Done       bool                     `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	StatusCode int32                    `protobuf:"varint,3,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Headers    map[string]*HeaderValues `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

type InitRequest struct {
	Config   map[string]string `` /* 139-byte string literal not displayed */
	LogLevel string            `protobuf:"bytes,2,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	// host_broker_id 是 Core 通过 hashicorp/go-plugin GRPCBroker 启动的
	// HostService stream 的 ID。插件 Init 时拿到 ID 后，可以通过 broker.Dial(id)
	// 拿到 HostService 的 grpc client，回调 Core 提供的能力（SelectAccount /
	// ProbeForward / ListGroups 等）。0 表示 Core 没启用 HostService。
	HostBrokerId uint32 `protobuf:"varint,3,opt,name=host_broker_id,json=hostBrokerId,proto3" json:"host_broker_id,omitempty"`
	// contains filtered or unexported fields
}

type MiddlewareDecision struct {
	Action MiddlewareDecision_Action `protobuf:"varint,1,opt,name=action,proto3,enum=airgate.plugin.v1.MiddlewareDecision_Action" json:"action,omitempty"`
	// action=DENY 时的错误码 / 文案（对用户可见）
	DenyStatusCode int32  `protobuf:"varint,10,opt,name=deny_status_code,json=denyStatusCode,proto3" json:"deny_status_code,omitempty"` // 默认 403 if Action=DENY and 未指定
	DenyMessage    string `protobuf:"bytes,11,opt,name=deny_message,json=denyMessage,proto3" json:"deny_message,omitempty"`
	// action=MUTATE 时要追加/覆盖的请求头
	SetHeaders map[string]*HeaderValues `` /* 166-byte string literal not displayed */
	// 贯穿式 metadata：无论 allow/deny/mutate，都能往 bag 里写东西供后续 middleware / End 使用
	Metadata map[string]string `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

type MiddlewareDecision_Action int32

type MiddlewareEvent struct {

	// === 核心元数据（与 MiddlewareRequest 对齐）===
	RequestId      string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	UserId         int64  `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	GroupId        int64  `protobuf:"varint,3,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	AccountId      int64  `protobuf:"varint,4,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	Platform       string `protobuf:"bytes,5,opt,name=platform,proto3" json:"platform,omitempty"`
	Model          string `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Stream         bool   `protobuf:"varint,7,opt,name=stream,proto3" json:"stream,omitempty"`
	InputTokensEst int64  `protobuf:"varint,8,opt,name=input_tokens_est,json=inputTokensEst,proto3" json:"input_tokens_est,omitempty"` // 与 MiddlewareRequest 字段对齐：core 侧粗略估算，
	// === 响应结果 ===
	StatusCode        int64  `protobuf:"varint,20,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	DurationMs        int64  `protobuf:"varint,21,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	InputTokens       int64  `protobuf:"varint,22,opt,name=input_tokens,json=inputTokens,proto3" json:"input_tokens,omitempty"`
	OutputTokens      int64  `protobuf:"varint,23,opt,name=output_tokens,json=outputTokens,proto3" json:"output_tokens,omitempty"`
	CachedInputTokens int64  `protobuf:"varint,24,opt,name=cached_input_tokens,json=cachedInputTokens,proto3" json:"cached_input_tokens,omitempty"`
	FirstTokenMs      int64  `protobuf:"varint,25,opt,name=first_token_ms,json=firstTokenMs,proto3" json:"first_token_ms,omitempty"`
	ErrorKind         string `protobuf:"bytes,26,opt,name=error_kind,json=errorKind,proto3" json:"error_kind,omitempty"` // "" / "upstream_5xx" / "timeout" / "no_account" / ...
	ErrorMsg          string `protobuf:"bytes,27,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`    // 限长 512，见 core 实现
	// 费用快照（core 已计算好）
	InputCost       float64 `protobuf:"fixed64,30,opt,name=input_cost,json=inputCost,proto3" json:"input_cost,omitempty"`
	OutputCost      float64 `protobuf:"fixed64,31,opt,name=output_cost,json=outputCost,proto3" json:"output_cost,omitempty"`
	CachedInputCost float64 `protobuf:"fixed64,32,opt,name=cached_input_cost,json=cachedInputCost,proto3" json:"cached_input_cost,omitempty"`
	// metadata 延续自 OnForwardBegin 的 bag
	Metadata map[string]string `` /* 144-byte string literal not displayed */
	// === 按需字段（声明了 middleware.read_body capability 的插件才会收到）===
	// 流式响应时 response_body 只给摘要（首次非空 chunk 拼装），完整流式内容
	// 留给未来的 OnStreamChunk（ADR-0002）。
	ResponseBody    []byte                   `protobuf:"bytes,100,opt,name=response_body,json=responseBody,proto3" json:"response_body,omitempty"`
	ResponseHeaders map[string]*HeaderValues `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

type MiddlewareRequest struct {

	// === 核心元数据（默认总是填充）===
	RequestId      string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // core 为本次请求分配的唯一 ID（便于跨 Begin/End 关联）
	UserId         int64  `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	GroupId        int64  `protobuf:"varint,3,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	AccountId      int64  `protobuf:"varint,4,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"` // 已由 scheduler 选出
	Platform       string `protobuf:"bytes,5,opt,name=platform,proto3" json:"platform,omitempty"`
	Model          string `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Stream         bool   `protobuf:"varint,7,opt,name=stream,proto3" json:"stream,omitempty"`
	InputTokensEst int64  `protobuf:"varint,8,opt,name=input_tokens_est,json=inputTokensEst,proto3" json:"input_tokens_est,omitempty"` // core 侧粗略估算，仅用于早期决策
	// metadata KV bag：供多个 middleware 之间传递上下文（Open Question Q-open-3）。
	// 命名空间规则暂不强制，未来可能收紧。
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// === 按需字段（声明了 middleware.read_body capability 的插件才会收到）===
	RequestBody    []byte                   `protobuf:"bytes,100,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"`
	RequestHeaders map[string]*HeaderValues `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}