taskcommon

package

v1.0.4-preview.5 Latest Latest Go to latest Published: Jul 15, 2026 License: AGPL-3.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/MAX-API-Next/MAX-API

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ApplyTaskParamOverride(requestBody io.Reader, info *relaycommon.RelayInfo) (io.Reader, error)
func ApplyTaskParamOverrideBytes(requestBody io.Reader, info *relaycommon.RelayInfo) ([]byte, error)
func BuildConfiguredTaskPassThroughBody(c *gin.Context, info *relaycommon.RelayInfo) (io.Reader, bool, error)
func BuildConfiguredTaskURL(baseURL string, path string, values map[string]string) string
func BuildProxyURL(taskID string) string
func BuildTaskQueryURL(baseURL string, body map[string]any, fallback string) string
func BuildTaskSubmitURL(info *relaycommon.RelayInfo, fallback string) string
func ConfiguredTaskErrorWrapper(err error, code string, statusCode int) *dto.TaskError
func ConvertConfiguredTaskToOpenAIVideo(originTask *model.Task) ([]byte, bool, error)
func DecodeLocalTaskID(id string) (string, error)
func DefaultInt(val, fallback int) int
func DefaultString(val, fallback string) string
func EffectiveTaskProtocolConfig(settings dto.ChannelOtherSettings) dto.TaskProtocolConfig
func EncodeLocalTaskID(name string) string
func EstimateGenericTaskBilling(c *gin.Context, info *relaycommon.RelayInfo, platform string) (*types.TaskBillingResult, error)
func ExtractConfiguredResultURL(data []byte, paths []string) string
func HasTaskProtocolConfig(settings dto.ChannelOtherSettings) bool
func IsTaskParamOverrideError(err error) bool
func IsVideoTaskChannelType(channelType int) bool
func MapConfiguredTaskStatus(status string, cfg dto.TaskProtocolConfig) string
func MissingConfiguredTaskIDError() *dto.TaskError
func NormalizeConfiguredProgress(progress string, status string) string
func NormalizeInternalTaskStatus(status string) string
func NormalizeTaskProtocolConfig(input *dto.TaskProtocolConfig) dto.TaskProtocolConfig
func ParseConfiguredTaskResult(respBody []byte, settings dto.ChannelOtherSettings) (*relaycommon.TaskInfo, bool, error)
func StringFromGJSONPath(data []byte, path string) string
func StripTaskProtocolConfig(body map[string]any) map[string]any
func SyncTaskRequestContext(c *gin.Context, data []byte) error
func TaskProtocolConfigFromTask(task *model.Task) (dto.TaskProtocolConfig, bool)
func TimestampFromGJSONPath(data []byte, path string) int64
func TryHandleConfiguredSubmitResponse(c *gin.Context, responseBody []byte, info *relaycommon.RelayInfo) (string, bool, *dto.TaskError)
func UnmarshalMetadata(metadata map[string]any, target any) error
func UseConfiguredTaskProtocol(settings dto.ChannelOtherSettings) bool
func ValidateTaskProtocolSettings(otherSettings string) error
func WithTaskProtocolConfig(body map[string]any, settings dto.ChannelOtherSettings) map[string]any
type BaseBilling
- func (BaseBilling) AdjustBillingOnComplete(_ *model.Task, _ *relaycommon.TaskInfo) int
- func (BaseBilling) AdjustBillingOnSubmit(_ *relaycommon.RelayInfo, _ []byte) map[string]float64
- func (BaseBilling) EstimateBilling(_ *gin.Context, _ *relaycommon.RelayInfo) map[string]float64

Constants ¶

View Source

const (
	ProgressSubmitted  = "10%"
	ProgressQueued     = "20%"
	ProgressInProgress = "30%"
	ProgressComplete   = "100%"
)

Status-to-progress mapping constants for polling updates.

View Source

const (
	TaskProtocolGenericVideo = "generic_video_task"
)

Variables ¶

View Source

var ErrTaskParamOverride = errors.New("task param override failed")

Functions ¶

func ApplyTaskParamOverride ¶

func ApplyTaskParamOverride(requestBody io.Reader, info *relaycommon.RelayInfo) (io.Reader, error)

func ApplyTaskParamOverrideBytes ¶

func ApplyTaskParamOverrideBytes(requestBody io.Reader, info *relaycommon.RelayInfo) ([]byte, error)

func BuildConfiguredTaskPassThroughBody ¶

func BuildConfiguredTaskPassThroughBody(c *gin.Context, info *relaycommon.RelayInfo) (io.Reader, bool, error)

func BuildConfiguredTaskURL ¶

func BuildConfiguredTaskURL(baseURL string, path string, values map[string]string) string

func BuildProxyURL ¶

func BuildProxyURL(taskID string) string

BuildProxyURL constructs the video proxy URL using the public task ID. e.g., "https://your-server.com/v1/videos/task_xxxx/content"

func BuildTaskQueryURL ¶

func BuildTaskQueryURL(baseURL string, body map[string]any, fallback string) string

func BuildTaskSubmitURL ¶

func BuildTaskSubmitURL(info *relaycommon.RelayInfo, fallback string) string

func ConfiguredTaskErrorWrapper ¶

func ConfiguredTaskErrorWrapper(err error, code string, statusCode int) *dto.TaskError

func ConvertConfiguredTaskToOpenAIVideo ¶

func ConvertConfiguredTaskToOpenAIVideo(originTask *model.Task) ([]byte, bool, error)

func DecodeLocalTaskID ¶

func DecodeLocalTaskID(id string) (string, error)

DecodeLocalTaskID decodes a base64-encoded upstream operation name.

func DefaultInt ¶

func DefaultInt(val, fallback int) int

DefaultInt returns val if non-zero, otherwise fallback.

func DefaultString ¶

func DefaultString(val, fallback string) string

DefaultString returns val if non-empty, otherwise fallback.

func EffectiveTaskProtocolConfig ¶

func EffectiveTaskProtocolConfig(settings dto.ChannelOtherSettings) dto.TaskProtocolConfig

func EncodeLocalTaskID ¶

func EncodeLocalTaskID(name string) string

EncodeLocalTaskID encodes an upstream operation name to a URL-safe base64 string. Used by Gemini/Vertex to store upstream names as task IDs.

func EstimateGenericTaskBilling ¶

func EstimateGenericTaskBilling(c *gin.Context, info *relaycommon.RelayInfo, platform string) (*types.TaskBillingResult, error)

func ExtractConfiguredResultURL ¶

func ExtractConfiguredResultURL(data []byte, paths []string) string

func HasTaskProtocolConfig ¶

func HasTaskProtocolConfig(settings dto.ChannelOtherSettings) bool

func IsTaskParamOverrideError ¶

func IsTaskParamOverrideError(err error) bool

func IsVideoTaskChannelType ¶

func IsVideoTaskChannelType(channelType int) bool

func MapConfiguredTaskStatus ¶

func MapConfiguredTaskStatus(status string, cfg dto.TaskProtocolConfig) string

func MissingConfiguredTaskIDError ¶

func MissingConfiguredTaskIDError() *dto.TaskError

func NormalizeConfiguredProgress ¶

func NormalizeConfiguredProgress(progress string, status string) string

func NormalizeInternalTaskStatus ¶

func NormalizeInternalTaskStatus(status string) string

func NormalizeTaskProtocolConfig ¶

func NormalizeTaskProtocolConfig(input *dto.TaskProtocolConfig) dto.TaskProtocolConfig

func ParseConfiguredTaskResult ¶

func ParseConfiguredTaskResult(respBody []byte, settings dto.ChannelOtherSettings) (*relaycommon.TaskInfo, bool, error)

func StringFromGJSONPath ¶

func StringFromGJSONPath(data []byte, path string) string

func StripTaskProtocolConfig ¶

func StripTaskProtocolConfig(body map[string]any) map[string]any

func SyncTaskRequestContext ¶

func SyncTaskRequestContext(c *gin.Context, data []byte) error

func TaskProtocolConfigFromTask ¶

func TaskProtocolConfigFromTask(task *model.Task) (dto.TaskProtocolConfig, bool)

func TimestampFromGJSONPath ¶

func TimestampFromGJSONPath(data []byte, path string) int64

func TryHandleConfiguredSubmitResponse ¶

func TryHandleConfiguredSubmitResponse(c *gin.Context, responseBody []byte, info *relaycommon.RelayInfo) (string, bool, *dto.TaskError)

func UnmarshalMetadata ¶

func UnmarshalMetadata(metadata map[string]any, target any) error

UnmarshalMetadata converts a map[string]any metadata to a typed struct via JSON round-trip. This replaces the repeated pattern: json.Marshal(metadata) → json.Unmarshal(bytes, &target).

func UseConfiguredTaskProtocol ¶

func UseConfiguredTaskProtocol(settings dto.ChannelOtherSettings) bool

func ValidateTaskProtocolSettings ¶

func ValidateTaskProtocolSettings(otherSettings string) error

ValidateTaskProtocolSettings 校验渠道 settings JSON 中的任务协议配置。仅在配置存在时校验，不解析失败的 JSON 交由渠道其他校验处理。

func WithTaskProtocolConfig ¶

func WithTaskProtocolConfig(body map[string]any, settings dto.ChannelOtherSettings) map[string]any

Types ¶

type BaseBilling ¶

type BaseBilling struct{}

func (BaseBilling) AdjustBillingOnComplete ¶

func (BaseBilling) AdjustBillingOnComplete(_ *model.Task, _ *relaycommon.TaskInfo) int

AdjustBillingOnComplete returns 0 (keep pre-charged amount).

func (BaseBilling) AdjustBillingOnSubmit ¶

func (BaseBilling) AdjustBillingOnSubmit(_ *relaycommon.RelayInfo, _ []byte) map[string]float64

AdjustBillingOnSubmit returns nil (no submit-time adjustment).

func (BaseBilling) EstimateBilling ¶

func (BaseBilling) EstimateBilling(_ *gin.Context, _ *relaycommon.RelayInfo) map[string]float64

EstimateBilling returns nil (no extra ratios; use base model price).

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL