pluginv1

type AsyncResolveRequest struct {
	TaskId uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

type AsyncResolveResponse struct {
	TaskId uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Done   bool   `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	Result []byte `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` // protobuf-encoded response (HttpRequestResponse, RedisGetResponse, etc.)
	Error  string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type AsyncSubmitRequest struct {
	OpType string `protobuf:"bytes,1,opt,name=op_type,json=opType,proto3" json:"op_type,omitempty"` // "http_get", "http_post", "db_query", "redis_get", "redis_set"
	Params []byte `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`               // protobuf-encoded request (HttpRequestRequest, RedisGetRequest, etc.)
	// contains filtered or unexported fields
}

type AsyncSubmitResponse struct {
	TaskId uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

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

type AsyncWaitAnyResponse struct {
	TaskId uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` // the task that completed
	// contains filtered or unexported fields
}

type BoolResult struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ConfigGetRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type ConfigGetResponse struct {
	Value  string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Exists bool   `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

type DbQueryRequest struct {
	Model      string                 `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`           // "user" | "order" | "subscribe" | ...
	Operation  string                 `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`   // "find" | "list" | "create" | "update" | "delete"
	Conditions *structpb.Struct       `protobuf:"bytes,3,opt,name=conditions,proto3" json:"conditions,omitempty"` // 动态条件
	Fields     *fieldmaskpb.FieldMask `protobuf:"bytes,4,opt,name=fields,proto3" json:"fields,omitempty"`         // 指定返回字段
	Limit      int32                  `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset     int32                  `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type DbQueryResponse struct {
	Rows  []*structpb.Struct `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Total int64              `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Error string             `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type EmitEventRequest struct {
	Event   string           `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Payload *structpb.Struct `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

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

type EnqueueTaskRequest struct {
	TaskName string           `protobuf:"bytes,1,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"` // asynq task type name
	Payload  *structpb.Struct `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`                   // task payload
	// contains filtered or unexported fields
}

type HandleRequest 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   map[string]*StringList `` /* 137-byte string literal not displayed */
	Headers map[string]*StringList `` /* 141-byte string literal not displayed */
	Body    []byte                 `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	Context *RequestContext        `protobuf:"bytes,6,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

type HandleResponse struct {
	Status  int32             `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Body    []byte            `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	Headers map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

type HostConfig struct {
	SiteName       string `protobuf:"bytes,1,opt,name=site_name,json=siteName,proto3" json:"site_name,omitempty"`
	SiteHost       string `protobuf:"bytes,2,opt,name=site_host,json=siteHost,proto3" json:"site_host,omitempty"`
	CurrencyUnit   string `protobuf:"bytes,3,opt,name=currency_unit,json=currencyUnit,proto3" json:"currency_unit,omitempty"`
	CurrencySymbol string `protobuf:"bytes,4,opt,name=currency_symbol,json=currencySymbol,proto3" json:"currency_symbol,omitempty"`
	Debug          bool   `protobuf:"varint,5,opt,name=debug,proto3" json:"debug,omitempty"`
	// contains filtered or unexported fields
}

type HttpRequestRequest struct {
	Method  string            `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Url     string            `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Headers map[string]string `` /* 141-byte string literal not displayed */
	Body    []byte            `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type HttpRequestResponse struct {
	Status  int32             `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Body    []byte            `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	Headers map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

type InitRequest struct {
	PluginName string           `protobuf:"bytes,1,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"`
	Config     *structpb.Struct `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` // 插件专属配置
	HostConfig *HostConfig      `protobuf:"bytes,3,opt,name=host_config,json=hostConfig,proto3" json:"host_config,omitempty"`
	// contains filtered or unexported fields
}

type LogRequest struct {
	Level   string            `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"` // "info" | "warn" | "error"
	Message string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Fields  map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type MiddlewareResponse struct {
	Action  string            `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`  // "next" | "abort" | "modify"
	Status  int32             `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"` // for abort
	Body    []byte            `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`      // for abort
	Headers map[string]string ``                                                                   // headers to add (for next/modify) or return (for abort)
	/* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RedisGetRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type RedisGetResponse struct {
	Value  string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Exists bool   `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

type RedisSetRequest struct {
	Key        string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value      string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	TtlSeconds int64  `protobuf:"varint,3,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"`
	// contains filtered or unexported fields
}

type RegisterMiddlewareRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`       // 中间件名，供路由引用
	Handler string `protobuf:"bytes,2,opt,name=handler,proto3" json:"handler,omitempty"` // WASM 导出函数名
	// contains filtered or unexported fields
}

type RegisterRouteRequest struct {
	Method     string   `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`         // "GET" | "POST" | "PUT" | "DELETE"
	Path       string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`             // "/stats" (自动加前缀 /v1/plugin/{name})
	Handler    string   `protobuf:"bytes,3,opt,name=handler,proto3" json:"handler,omitempty"`       // WASM 导出函数名
	Middleware []string `protobuf:"bytes,4,rep,name=middleware,proto3" json:"middleware,omitempty"` // "auth" | "device" | 自定义中间件名
	// contains filtered or unexported fields
}

type RequestContext struct {
	UserId   int64  `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	IsAdmin  bool   `protobuf:"varint,2,opt,name=is_admin,json=isAdmin,proto3" json:"is_admin,omitempty"`
	ClientIp string `protobuf:"bytes,3,opt,name=client_ip,json=clientIp,proto3" json:"client_ip,omitempty"`
	// contains filtered or unexported fields
}

type ScheduleTaskRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Cron    string `protobuf:"bytes,2,opt,name=cron,proto3" json:"cron,omitempty"`       // "0 */6 * * *"
	Handler string `protobuf:"bytes,3,opt,name=handler,proto3" json:"handler,omitempty"` // WASM 导出函数名
	// contains filtered or unexported fields
}

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

type SubscribeEventRequest struct {
	Event   string `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`     // event name, "*" means all events
	Handler string `protobuf:"bytes,2,opt,name=handler,proto3" json:"handler,omitempty"` // WASM export name, default: on_<event>
	// contains filtered or unexported fields
}