protocol

package
v0.0.0-...-b58e781 Latest Latest
Warning

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

Go to latest
Published: Apr 14, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// Success codes
	PluginCodeSuccess = 200
	PluginCodeOK      = 0

	// Client errors 4xx
	PluginCodeBadRequest     = 400 // Request parameter error
	PluginCodeUnauthorized   = 401 // Authentication failed
	PluginCodeNotFound       = 404 // Resource not found (e.g., model not found)
	PluginCodeTimeout        = 408 // Request timeout
	PluginCodePrecondFailed  = 412 // Precondition failed (e.g., engine not installed)
	PluginCodeNotImplemented = 501 // Method not implemented

	// Server errors 5xx
	PluginCodeInternalError  = 500 // Internal error
	PluginCodeServiceUnavail = 503 // Service unavailable (e.g., engine not started)
	PluginCodeBadGateway     = 502 // Bad gateway (upstream service error)
)

Plugin error code constants

View Source
const (
	ProviderService_GetManifest_FullMethodName         = "/protocol.ProviderService/GetManifest"
	ProviderService_InvokeService_FullMethodName       = "/protocol.ProviderService/InvokeService"
	ProviderService_InvokeServiceStream_FullMethodName = "/protocol.ProviderService/InvokeServiceStream"
	ProviderService_InvokeServiceBidi_FullMethodName   = "/protocol.ProviderService/InvokeServiceBidi"
	ProviderService_HealthCheck_FullMethodName         = "/protocol.ProviderService/HealthCheck"
	ProviderService_GetOperateStatus_FullMethodName    = "/protocol.ProviderService/GetOperateStatus"
	ProviderService_SetOperateStatus_FullMethodName    = "/protocol.ProviderService/SetOperateStatus"
	ProviderService_SetAuth_FullMethodName             = "/protocol.ProviderService/SetAuth"
	ProviderService_ValidateAuth_FullMethodName        = "/protocol.ProviderService/ValidateAuth"
	ProviderService_RefreshAuth_FullMethodName         = "/protocol.ProviderService/RefreshAuth"
	ProviderService_StartEngine_FullMethodName         = "/protocol.ProviderService/StartEngine"
	ProviderService_StopEngine_FullMethodName          = "/protocol.ProviderService/StopEngine"
	ProviderService_GetConfig_FullMethodName           = "/protocol.ProviderService/GetConfig"
	ProviderService_CheckEngine_FullMethodName         = "/protocol.ProviderService/CheckEngine"
	ProviderService_InstallEngine_FullMethodName       = "/protocol.ProviderService/InstallEngine"
	ProviderService_InitEnv_FullMethodName             = "/protocol.ProviderService/InitEnv"
	ProviderService_UpgradeEngine_FullMethodName       = "/protocol.ProviderService/UpgradeEngine"
	ProviderService_PullModel_FullMethodName           = "/protocol.ProviderService/PullModel"
	ProviderService_PullModelStream_FullMethodName     = "/protocol.ProviderService/PullModelStream"
	ProviderService_DeleteModel_FullMethodName         = "/protocol.ProviderService/DeleteModel"
	ProviderService_ListModels_FullMethodName          = "/protocol.ProviderService/ListModels"
	ProviderService_LoadModel_FullMethodName           = "/protocol.ProviderService/LoadModel"
	ProviderService_UnloadModel_FullMethodName         = "/protocol.ProviderService/UnloadModel"
	ProviderService_GetRunningModels_FullMethodName    = "/protocol.ProviderService/GetRunningModels"
	ProviderService_GetVersion_FullMethodName          = "/protocol.ProviderService/GetVersion"
)

Variables

View Source
var File_provider_proto protoreflect.FileDescriptor
View Source
var ProviderService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protocol.ProviderService",
	HandlerType: (*ProviderServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _ProviderService_GetManifest_Handler,
		},
		{
			MethodName: "InvokeService",
			Handler:    _ProviderService_InvokeService_Handler,
		},
		{
			MethodName: "HealthCheck",
			Handler:    _ProviderService_HealthCheck_Handler,
		},
		{
			MethodName: "GetOperateStatus",
			Handler:    _ProviderService_GetOperateStatus_Handler,
		},
		{
			MethodName: "SetOperateStatus",
			Handler:    _ProviderService_SetOperateStatus_Handler,
		},
		{
			MethodName: "SetAuth",
			Handler:    _ProviderService_SetAuth_Handler,
		},
		{
			MethodName: "ValidateAuth",
			Handler:    _ProviderService_ValidateAuth_Handler,
		},
		{
			MethodName: "RefreshAuth",
			Handler:    _ProviderService_RefreshAuth_Handler,
		},
		{
			MethodName: "StartEngine",
			Handler:    _ProviderService_StartEngine_Handler,
		},
		{
			MethodName: "StopEngine",
			Handler:    _ProviderService_StopEngine_Handler,
		},
		{
			MethodName: "GetConfig",
			Handler:    _ProviderService_GetConfig_Handler,
		},
		{
			MethodName: "CheckEngine",
			Handler:    _ProviderService_CheckEngine_Handler,
		},
		{
			MethodName: "InstallEngine",
			Handler:    _ProviderService_InstallEngine_Handler,
		},
		{
			MethodName: "InitEnv",
			Handler:    _ProviderService_InitEnv_Handler,
		},
		{
			MethodName: "UpgradeEngine",
			Handler:    _ProviderService_UpgradeEngine_Handler,
		},
		{
			MethodName: "PullModel",
			Handler:    _ProviderService_PullModel_Handler,
		},
		{
			MethodName: "DeleteModel",
			Handler:    _ProviderService_DeleteModel_Handler,
		},
		{
			MethodName: "ListModels",
			Handler:    _ProviderService_ListModels_Handler,
		},
		{
			MethodName: "LoadModel",
			Handler:    _ProviderService_LoadModel_Handler,
		},
		{
			MethodName: "UnloadModel",
			Handler:    _ProviderService_UnloadModel_Handler,
		},
		{
			MethodName: "GetRunningModels",
			Handler:    _ProviderService_GetRunningModels_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _ProviderService_GetVersion_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InvokeServiceStream",
			Handler:       _ProviderService_InvokeServiceStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "InvokeServiceBidi",
			Handler:       _ProviderService_InvokeServiceBidi_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "PullModelStream",
			Handler:       _ProviderService_PullModelStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "provider.proto",
}

ProviderService_ServiceDesc is the grpc.ServiceDesc for ProviderService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func CreateErrorResponse

func CreateErrorResponse(err error) (int32, string)

CreateErrorResponse is a helper function to create error response

func CreateSuccessResponse

func CreateSuccessResponse() (int32, string)

CreateSuccessResponse is a helper function to create success response

func IsPluginError

func IsPluginError(err error) bool

IsPluginError checks if the error is of PluginError type

func IsSuccess

func IsSuccess(code int32) bool

IsSuccess checks if the error code indicates success

func MapErrorToPluginCode

func MapErrorToPluginCode(err error) int32

MapErrorToPluginCode maps a Go error to a plugin error code

func RegisterProviderServiceServer

func RegisterProviderServiceServer(s grpc.ServiceRegistrar, srv ProviderServiceServer)

Types

type CheckEngineRequest

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

func (*CheckEngineRequest) Descriptor deprecated

func (*CheckEngineRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckEngineRequest.ProtoReflect.Descriptor instead.

func (*CheckEngineRequest) ProtoMessage

func (*CheckEngineRequest) ProtoMessage()

func (*CheckEngineRequest) ProtoReflect

func (x *CheckEngineRequest) ProtoReflect() protoreflect.Message

func (*CheckEngineRequest) Reset

func (x *CheckEngineRequest) Reset()

func (*CheckEngineRequest) String

func (x *CheckEngineRequest) String() string

type CheckEngineResponse

type CheckEngineResponse struct {
	Code      int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`           // Error code: 0 or 200 = success, other = failure
	Message   string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`      // Error message or success message
	Installed bool   `protobuf:"varint,3,opt,name=installed,proto3" json:"installed,omitempty"` // Whether installed
	// contains filtered or unexported fields
}

func (*CheckEngineResponse) Descriptor deprecated

func (*CheckEngineResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckEngineResponse.ProtoReflect.Descriptor instead.

func (*CheckEngineResponse) GetCode

func (x *CheckEngineResponse) GetCode() int32

func (*CheckEngineResponse) GetInstalled

func (x *CheckEngineResponse) GetInstalled() bool

func (*CheckEngineResponse) GetMessage

func (x *CheckEngineResponse) GetMessage() string

func (*CheckEngineResponse) ProtoMessage

func (*CheckEngineResponse) ProtoMessage()

func (*CheckEngineResponse) ProtoReflect

func (x *CheckEngineResponse) ProtoReflect() protoreflect.Message

func (*CheckEngineResponse) Reset

func (x *CheckEngineResponse) Reset()

func (*CheckEngineResponse) String

func (x *CheckEngineResponse) String() string

type DeleteModelRequest

type DeleteModelRequest struct {
	RequestJson []byte `protobuf:"bytes,1,opt,name=request_json,json=requestJson,proto3" json:"request_json,omitempty"` // JSON serialized DeleteRequest
	// contains filtered or unexported fields
}

func (*DeleteModelRequest) Descriptor deprecated

func (*DeleteModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteModelRequest.ProtoReflect.Descriptor instead.

func (*DeleteModelRequest) GetRequestJson

func (x *DeleteModelRequest) GetRequestJson() []byte

func (*DeleteModelRequest) ProtoMessage

func (*DeleteModelRequest) ProtoMessage()

func (*DeleteModelRequest) ProtoReflect

func (x *DeleteModelRequest) ProtoReflect() protoreflect.Message

func (*DeleteModelRequest) Reset

func (x *DeleteModelRequest) Reset()

func (*DeleteModelRequest) String

func (x *DeleteModelRequest) String() string

type DeleteModelResponse

type DeleteModelResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*DeleteModelResponse) Descriptor deprecated

func (*DeleteModelResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteModelResponse.ProtoReflect.Descriptor instead.

func (*DeleteModelResponse) GetCode

func (x *DeleteModelResponse) GetCode() int32

func (*DeleteModelResponse) GetMessage

func (x *DeleteModelResponse) GetMessage() string

func (*DeleteModelResponse) ProtoMessage

func (*DeleteModelResponse) ProtoMessage()

func (*DeleteModelResponse) ProtoReflect

func (x *DeleteModelResponse) ProtoReflect() protoreflect.Message

func (*DeleteModelResponse) Reset

func (x *DeleteModelResponse) Reset()

func (*DeleteModelResponse) String

func (x *DeleteModelResponse) String() string

type GetConfigRequest

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

func (*GetConfigRequest) Descriptor deprecated

func (*GetConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.

func (*GetConfigRequest) ProtoMessage

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) ProtoReflect

func (x *GetConfigRequest) ProtoReflect() protoreflect.Message

func (*GetConfigRequest) Reset

func (x *GetConfigRequest) Reset()

func (*GetConfigRequest) String

func (x *GetConfigRequest) String() string

type GetConfigResponse

type GetConfigResponse struct {
	Code       int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`                              // Error code: 0 or 200 = success, other = failure
	Message    string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                         // Error message or success message
	ConfigJson []byte `protobuf:"bytes,3,opt,name=config_json,json=configJson,proto3" json:"config_json,omitempty"` // JSON serialized EngineConfig
	// contains filtered or unexported fields
}

func (*GetConfigResponse) Descriptor deprecated

func (*GetConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.

func (*GetConfigResponse) GetCode

func (x *GetConfigResponse) GetCode() int32

func (*GetConfigResponse) GetConfigJson

func (x *GetConfigResponse) GetConfigJson() []byte

func (*GetConfigResponse) GetMessage

func (x *GetConfigResponse) GetMessage() string

func (*GetConfigResponse) ProtoMessage

func (*GetConfigResponse) ProtoMessage()

func (*GetConfigResponse) ProtoReflect

func (x *GetConfigResponse) ProtoReflect() protoreflect.Message

func (*GetConfigResponse) Reset

func (x *GetConfigResponse) Reset()

func (*GetConfigResponse) String

func (x *GetConfigResponse) String() string

type GetManifestRequest

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

func (*GetManifestRequest) Descriptor deprecated

func (*GetManifestRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetManifestRequest.ProtoReflect.Descriptor instead.

func (*GetManifestRequest) ProtoMessage

func (*GetManifestRequest) ProtoMessage()

func (*GetManifestRequest) ProtoReflect

func (x *GetManifestRequest) ProtoReflect() protoreflect.Message

func (*GetManifestRequest) Reset

func (x *GetManifestRequest) Reset()

func (*GetManifestRequest) String

func (x *GetManifestRequest) String() string

type GetManifestResponse

type GetManifestResponse struct {
	Code         int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`                                    // Error code: 0 or 200 = success, other = failure
	Message      string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                               // Error message or success message
	ManifestJson []byte `protobuf:"bytes,3,opt,name=manifest_json,json=manifestJson,proto3" json:"manifest_json,omitempty"` // JSON serialized PluginManifest
	// contains filtered or unexported fields
}

func (*GetManifestResponse) Descriptor deprecated

func (*GetManifestResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetManifestResponse.ProtoReflect.Descriptor instead.

func (*GetManifestResponse) GetCode

func (x *GetManifestResponse) GetCode() int32

func (*GetManifestResponse) GetManifestJson

func (x *GetManifestResponse) GetManifestJson() []byte

func (*GetManifestResponse) GetMessage

func (x *GetManifestResponse) GetMessage() string

func (*GetManifestResponse) ProtoMessage

func (*GetManifestResponse) ProtoMessage()

func (*GetManifestResponse) ProtoReflect

func (x *GetManifestResponse) ProtoReflect() protoreflect.Message

func (*GetManifestResponse) Reset

func (x *GetManifestResponse) Reset()

func (*GetManifestResponse) String

func (x *GetManifestResponse) String() string

type GetOperateStatusRequest

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

func (*GetOperateStatusRequest) Descriptor deprecated

func (*GetOperateStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetOperateStatusRequest.ProtoReflect.Descriptor instead.

func (*GetOperateStatusRequest) ProtoMessage

func (*GetOperateStatusRequest) ProtoMessage()

func (*GetOperateStatusRequest) ProtoReflect

func (x *GetOperateStatusRequest) ProtoReflect() protoreflect.Message

func (*GetOperateStatusRequest) Reset

func (x *GetOperateStatusRequest) Reset()

func (*GetOperateStatusRequest) String

func (x *GetOperateStatusRequest) String() string

type GetOperateStatusResponse

type GetOperateStatusResponse struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperateStatusResponse) Descriptor deprecated

func (*GetOperateStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetOperateStatusResponse.ProtoReflect.Descriptor instead.

func (*GetOperateStatusResponse) GetStatus

func (x *GetOperateStatusResponse) GetStatus() int32

func (*GetOperateStatusResponse) ProtoMessage

func (*GetOperateStatusResponse) ProtoMessage()

func (*GetOperateStatusResponse) ProtoReflect

func (x *GetOperateStatusResponse) ProtoReflect() protoreflect.Message

func (*GetOperateStatusResponse) Reset

func (x *GetOperateStatusResponse) Reset()

func (*GetOperateStatusResponse) String

func (x *GetOperateStatusResponse) String() string

type GetRunningModelsRequest

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

func (*GetRunningModelsRequest) Descriptor deprecated

func (*GetRunningModelsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRunningModelsRequest.ProtoReflect.Descriptor instead.

func (*GetRunningModelsRequest) ProtoMessage

func (*GetRunningModelsRequest) ProtoMessage()

func (*GetRunningModelsRequest) ProtoReflect

func (x *GetRunningModelsRequest) ProtoReflect() protoreflect.Message

func (*GetRunningModelsRequest) Reset

func (x *GetRunningModelsRequest) Reset()

func (*GetRunningModelsRequest) String

func (x *GetRunningModelsRequest) String() string

type GetRunningModelsResponse

type GetRunningModelsResponse struct {
	Code         int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`                                    // Error code: 0 or 200 = success, other = failure
	Message      string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                               // Error message or success message
	ResponseJson []byte `protobuf:"bytes,3,opt,name=response_json,json=responseJson,proto3" json:"response_json,omitempty"` // JSON serialized ListModelsResponse
	// contains filtered or unexported fields
}

func (*GetRunningModelsResponse) Descriptor deprecated

func (*GetRunningModelsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRunningModelsResponse.ProtoReflect.Descriptor instead.

func (*GetRunningModelsResponse) GetCode

func (x *GetRunningModelsResponse) GetCode() int32

func (*GetRunningModelsResponse) GetMessage

func (x *GetRunningModelsResponse) GetMessage() string

func (*GetRunningModelsResponse) GetResponseJson

func (x *GetRunningModelsResponse) GetResponseJson() []byte

func (*GetRunningModelsResponse) ProtoMessage

func (*GetRunningModelsResponse) ProtoMessage()

func (*GetRunningModelsResponse) ProtoReflect

func (x *GetRunningModelsResponse) ProtoReflect() protoreflect.Message

func (*GetRunningModelsResponse) Reset

func (x *GetRunningModelsResponse) Reset()

func (*GetRunningModelsResponse) String

func (x *GetRunningModelsResponse) String() string

type GetVersionRequest

type GetVersionRequest struct {
	RequestJson []byte `protobuf:"bytes,1,opt,name=request_json,json=requestJson,proto3" json:"request_json,omitempty"` // JSON serialized EngineVersionResponse (as template)
	// contains filtered or unexported fields
}

func (*GetVersionRequest) Descriptor deprecated

func (*GetVersionRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetVersionRequest.ProtoReflect.Descriptor instead.

func (*GetVersionRequest) GetRequestJson

func (x *GetVersionRequest) GetRequestJson() []byte

func (*GetVersionRequest) ProtoMessage

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) ProtoReflect

func (x *GetVersionRequest) ProtoReflect() protoreflect.Message

func (*GetVersionRequest) Reset

func (x *GetVersionRequest) Reset()

func (*GetVersionRequest) String

func (x *GetVersionRequest) String() string

type GetVersionResponse

type GetVersionResponse struct {
	Code         int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`                                    // Error code: 0 or 200 = success, other = failure
	Message      string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                               // Error message or success message
	ResponseJson []byte `protobuf:"bytes,3,opt,name=response_json,json=responseJson,proto3" json:"response_json,omitempty"` // JSON serialized EngineVersionResponse
	// contains filtered or unexported fields
}

func (*GetVersionResponse) Descriptor deprecated

func (*GetVersionResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetVersionResponse.ProtoReflect.Descriptor instead.

func (*GetVersionResponse) GetCode

func (x *GetVersionResponse) GetCode() int32

func (*GetVersionResponse) GetMessage

func (x *GetVersionResponse) GetMessage() string

func (*GetVersionResponse) GetResponseJson

func (x *GetVersionResponse) GetResponseJson() []byte

func (*GetVersionResponse) ProtoMessage

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) ProtoReflect

func (x *GetVersionResponse) ProtoReflect() protoreflect.Message

func (*GetVersionResponse) Reset

func (x *GetVersionResponse) Reset()

func (*GetVersionResponse) String

func (x *GetVersionResponse) String() string

type HealthCheckRequest

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

func (*HealthCheckRequest) Descriptor deprecated

func (*HealthCheckRequest) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) ProtoMessage

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect

func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message

func (*HealthCheckRequest) Reset

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String

func (x *HealthCheckRequest) String() string

type HealthCheckResponse

type HealthCheckResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated

func (*HealthCheckResponse) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetCode

func (x *HealthCheckResponse) GetCode() int32

func (*HealthCheckResponse) GetMessage

func (x *HealthCheckResponse) GetMessage() string

func (*HealthCheckResponse) ProtoMessage

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect

func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message

func (*HealthCheckResponse) Reset

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String

func (x *HealthCheckResponse) String() string

type InitEnvRequest

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

func (*InitEnvRequest) Descriptor deprecated

func (*InitEnvRequest) Descriptor() ([]byte, []int)

Deprecated: Use InitEnvRequest.ProtoReflect.Descriptor instead.

func (*InitEnvRequest) ProtoMessage

func (*InitEnvRequest) ProtoMessage()

func (*InitEnvRequest) ProtoReflect

func (x *InitEnvRequest) ProtoReflect() protoreflect.Message

func (*InitEnvRequest) Reset

func (x *InitEnvRequest) Reset()

func (*InitEnvRequest) String

func (x *InitEnvRequest) String() string

type InitEnvResponse

type InitEnvResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*InitEnvResponse) Descriptor deprecated

func (*InitEnvResponse) Descriptor() ([]byte, []int)

Deprecated: Use InitEnvResponse.ProtoReflect.Descriptor instead.

func (*InitEnvResponse) GetCode

func (x *InitEnvResponse) GetCode() int32

func (*InitEnvResponse) GetMessage

func (x *InitEnvResponse) GetMessage() string

func (*InitEnvResponse) ProtoMessage

func (*InitEnvResponse) ProtoMessage()

func (*InitEnvResponse) ProtoReflect

func (x *InitEnvResponse) ProtoReflect() protoreflect.Message

func (*InitEnvResponse) Reset

func (x *InitEnvResponse) Reset()

func (*InitEnvResponse) String

func (x *InitEnvResponse) String() string

type InstallEngineRequest

type InstallEngineRequest struct {
	Cover bool `protobuf:"varint,1,opt,name=cover,proto3" json:"cover,omitempty"`
	// contains filtered or unexported fields
}

func (*InstallEngineRequest) Descriptor deprecated

func (*InstallEngineRequest) Descriptor() ([]byte, []int)

Deprecated: Use InstallEngineRequest.ProtoReflect.Descriptor instead.

func (*InstallEngineRequest) GetCover

func (x *InstallEngineRequest) GetCover() bool

func (*InstallEngineRequest) ProtoMessage

func (*InstallEngineRequest) ProtoMessage()

func (*InstallEngineRequest) ProtoReflect

func (x *InstallEngineRequest) ProtoReflect() protoreflect.Message

func (*InstallEngineRequest) Reset

func (x *InstallEngineRequest) Reset()

func (*InstallEngineRequest) String

func (x *InstallEngineRequest) String() string

type InstallEngineResponse

type InstallEngineResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*InstallEngineResponse) Descriptor deprecated

func (*InstallEngineResponse) Descriptor() ([]byte, []int)

Deprecated: Use InstallEngineResponse.ProtoReflect.Descriptor instead.

func (*InstallEngineResponse) GetCode

func (x *InstallEngineResponse) GetCode() int32

func (*InstallEngineResponse) GetMessage

func (x *InstallEngineResponse) GetMessage() string

func (*InstallEngineResponse) ProtoMessage

func (*InstallEngineResponse) ProtoMessage()

func (*InstallEngineResponse) ProtoReflect

func (x *InstallEngineResponse) ProtoReflect() protoreflect.Message

func (*InstallEngineResponse) Reset

func (x *InstallEngineResponse) Reset()

func (*InstallEngineResponse) String

func (x *InstallEngineResponse) String() string

type InvokeServiceBidiRequest

type InvokeServiceBidiRequest struct {
	ServiceName string            `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // Service name (only in first message)
	Data        []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`                                  // Data chunk
	MessageType string            `protobuf:"bytes,3,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"` // Message type: "text", "binary", "ping", "pong", "close"
	Metadata    map[string]string ``                                                                                               // Metadata
	/* 143-byte string literal not displayed */
	IsFirst  bool   `protobuf:"varint,5,opt,name=is_first,json=isFirst,proto3" json:"is_first,omitempty"`   // Whether this is the first message
	AuthInfo string `protobuf:"bytes,6,opt,name=auth_info,json=authInfo,proto3" json:"auth_info,omitempty"` // remote auth (only in first message)
	// contains filtered or unexported fields
}

InvokeServiceBidiRequest bidirectional streaming request Used for bidirectional communication scenarios like WebSocket

func (*InvokeServiceBidiRequest) Descriptor deprecated

func (*InvokeServiceBidiRequest) Descriptor() ([]byte, []int)

Deprecated: Use InvokeServiceBidiRequest.ProtoReflect.Descriptor instead.

func (*InvokeServiceBidiRequest) GetAuthInfo

func (x *InvokeServiceBidiRequest) GetAuthInfo() string

func (*InvokeServiceBidiRequest) GetData

func (x *InvokeServiceBidiRequest) GetData() []byte

func (*InvokeServiceBidiRequest) GetIsFirst

func (x *InvokeServiceBidiRequest) GetIsFirst() bool

func (*InvokeServiceBidiRequest) GetMessageType

func (x *InvokeServiceBidiRequest) GetMessageType() string

func (*InvokeServiceBidiRequest) GetMetadata

func (x *InvokeServiceBidiRequest) GetMetadata() map[string]string

func (*InvokeServiceBidiRequest) GetServiceName

func (x *InvokeServiceBidiRequest) GetServiceName() string

func (*InvokeServiceBidiRequest) ProtoMessage

func (*InvokeServiceBidiRequest) ProtoMessage()

func (*InvokeServiceBidiRequest) ProtoReflect

func (x *InvokeServiceBidiRequest) ProtoReflect() protoreflect.Message

func (*InvokeServiceBidiRequest) Reset

func (x *InvokeServiceBidiRequest) Reset()

func (*InvokeServiceBidiRequest) String

func (x *InvokeServiceBidiRequest) String() string

type InvokeServiceBidiResponse

type InvokeServiceBidiResponse struct {
	Code        int32             `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`                                 // Error code: 0 or 200 = success, other = failure
	Message     string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                            // Error message or success message
	Data        []byte            `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`                                  // Response data chunk
	MessageType string            `protobuf:"bytes,4,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"` // Message type: "text", "binary", "ping", "pong", "close"
	Metadata    map[string]string ``                                                                                               // Metadata
	/* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

InvokeServiceBidiResponse bidirectional streaming response Used for bidirectional communication scenarios like WebSocket

func (*InvokeServiceBidiResponse) Descriptor deprecated

func (*InvokeServiceBidiResponse) Descriptor() ([]byte, []int)

Deprecated: Use InvokeServiceBidiResponse.ProtoReflect.Descriptor instead.

func (*InvokeServiceBidiResponse) GetCode

func (x *InvokeServiceBidiResponse) GetCode() int32

func (*InvokeServiceBidiResponse) GetData

func (x *InvokeServiceBidiResponse) GetData() []byte

func (*InvokeServiceBidiResponse) GetMessage

func (x *InvokeServiceBidiResponse) GetMessage() string

func (*InvokeServiceBidiResponse) GetMessageType

func (x *InvokeServiceBidiResponse) GetMessageType() string

func (*InvokeServiceBidiResponse) GetMetadata

func (x *InvokeServiceBidiResponse) GetMetadata() map[string]string

func (*InvokeServiceBidiResponse) ProtoMessage

func (*InvokeServiceBidiResponse) ProtoMessage()

func (*InvokeServiceBidiResponse) ProtoReflect

func (*InvokeServiceBidiResponse) Reset

func (x *InvokeServiceBidiResponse) Reset()

func (*InvokeServiceBidiResponse) String

func (x *InvokeServiceBidiResponse) String() string

type InvokeServiceRequest

type InvokeServiceRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // 服务名称: "chat", "embed", "text-to-image" 等
	RequestData []byte `protobuf:"bytes,2,opt,name=request_data,json=requestData,proto3" json:"request_data,omitempty"` // JSON 格式的请求数据
	AuthInfo    string `protobuf:"bytes,3,opt,name=auth_info,json=authInfo,proto3" json:"auth_info,omitempty"`          // 认证信息
	// contains filtered or unexported fields
}

func (*InvokeServiceRequest) Descriptor deprecated

func (*InvokeServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use InvokeServiceRequest.ProtoReflect.Descriptor instead.

func (*InvokeServiceRequest) GetAuthInfo

func (x *InvokeServiceRequest) GetAuthInfo() string

func (*InvokeServiceRequest) GetRequestData

func (x *InvokeServiceRequest) GetRequestData() []byte

func (*InvokeServiceRequest) GetServiceName

func (x *InvokeServiceRequest) GetServiceName() string

func (*InvokeServiceRequest) ProtoMessage

func (*InvokeServiceRequest) ProtoMessage()

func (*InvokeServiceRequest) ProtoReflect

func (x *InvokeServiceRequest) ProtoReflect() protoreflect.Message

func (*InvokeServiceRequest) Reset

func (x *InvokeServiceRequest) Reset()

func (*InvokeServiceRequest) String

func (x *InvokeServiceRequest) String() string

type InvokeServiceResponse

type InvokeServiceResponse struct {
	Code         int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`                                    // Error code: 0 or 200 = success, other = failure
	Message      string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                               // Error message or success message
	ResponseData []byte `protobuf:"bytes,3,opt,name=response_data,json=responseData,proto3" json:"response_data,omitempty"` // JSON format response data
	// contains filtered or unexported fields
}

func (*InvokeServiceResponse) Descriptor deprecated

func (*InvokeServiceResponse) Descriptor() ([]byte, []int)

Deprecated: Use InvokeServiceResponse.ProtoReflect.Descriptor instead.

func (*InvokeServiceResponse) GetCode

func (x *InvokeServiceResponse) GetCode() int32

func (*InvokeServiceResponse) GetMessage

func (x *InvokeServiceResponse) GetMessage() string

func (*InvokeServiceResponse) GetResponseData

func (x *InvokeServiceResponse) GetResponseData() []byte

func (*InvokeServiceResponse) ProtoMessage

func (*InvokeServiceResponse) ProtoMessage()

func (*InvokeServiceResponse) ProtoReflect

func (x *InvokeServiceResponse) ProtoReflect() protoreflect.Message

func (*InvokeServiceResponse) Reset

func (x *InvokeServiceResponse) Reset()

func (*InvokeServiceResponse) String

func (x *InvokeServiceResponse) String() string

type InvokeServiceStreamResponse

type InvokeServiceStreamResponse struct {
	Code      int32             `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`                           // Error code: 0 or 200 = success, other = failure
	Message   string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                      // Error message or success message
	ChunkData []byte            `protobuf:"bytes,3,opt,name=chunk_data,json=chunkData,proto3" json:"chunk_data,omitempty"` // Streaming data chunk
	IsFinal   bool              `protobuf:"varint,4,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"`      // Whether this is the final chunk
	Metadata  map[string]string ``                                                                                         // Metadata (e.g., content-type)
	/* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

InvokeServiceStreamResponse server-side streaming response Used for transferring streaming data from plugin to AOG

func (*InvokeServiceStreamResponse) Descriptor deprecated

func (*InvokeServiceStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use InvokeServiceStreamResponse.ProtoReflect.Descriptor instead.

func (*InvokeServiceStreamResponse) GetChunkData

func (x *InvokeServiceStreamResponse) GetChunkData() []byte

func (*InvokeServiceStreamResponse) GetCode

func (x *InvokeServiceStreamResponse) GetCode() int32

func (*InvokeServiceStreamResponse) GetIsFinal

func (x *InvokeServiceStreamResponse) GetIsFinal() bool

func (*InvokeServiceStreamResponse) GetMessage

func (x *InvokeServiceStreamResponse) GetMessage() string

func (*InvokeServiceStreamResponse) GetMetadata

func (x *InvokeServiceStreamResponse) GetMetadata() map[string]string

func (*InvokeServiceStreamResponse) ProtoMessage

func (*InvokeServiceStreamResponse) ProtoMessage()

func (*InvokeServiceStreamResponse) ProtoReflect

func (*InvokeServiceStreamResponse) Reset

func (x *InvokeServiceStreamResponse) Reset()

func (*InvokeServiceStreamResponse) String

func (x *InvokeServiceStreamResponse) String() string

type ListModelsRequest

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

func (*ListModelsRequest) Descriptor deprecated

func (*ListModelsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListModelsRequest.ProtoReflect.Descriptor instead.

func (*ListModelsRequest) ProtoMessage

func (*ListModelsRequest) ProtoMessage()

func (*ListModelsRequest) ProtoReflect

func (x *ListModelsRequest) ProtoReflect() protoreflect.Message

func (*ListModelsRequest) Reset

func (x *ListModelsRequest) Reset()

func (*ListModelsRequest) String

func (x *ListModelsRequest) String() string

type ListModelsResponse

type ListModelsResponse struct {
	Code         int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`                                    // Error code: 0 or 200 = success, other = failure
	Message      string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                               // Error message or success message
	ResponseJson []byte `protobuf:"bytes,3,opt,name=response_json,json=responseJson,proto3" json:"response_json,omitempty"` // JSON serialized ListModelsResponse
	// contains filtered or unexported fields
}

func (*ListModelsResponse) Descriptor deprecated

func (*ListModelsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListModelsResponse.ProtoReflect.Descriptor instead.

func (*ListModelsResponse) GetCode

func (x *ListModelsResponse) GetCode() int32

func (*ListModelsResponse) GetMessage

func (x *ListModelsResponse) GetMessage() string

func (*ListModelsResponse) GetResponseJson

func (x *ListModelsResponse) GetResponseJson() []byte

func (*ListModelsResponse) ProtoMessage

func (*ListModelsResponse) ProtoMessage()

func (*ListModelsResponse) ProtoReflect

func (x *ListModelsResponse) ProtoReflect() protoreflect.Message

func (*ListModelsResponse) Reset

func (x *ListModelsResponse) Reset()

func (*ListModelsResponse) String

func (x *ListModelsResponse) String() string

type LoadModelRequest

type LoadModelRequest struct {
	RequestJson []byte `protobuf:"bytes,1,opt,name=request_json,json=requestJson,proto3" json:"request_json,omitempty"` // JSON serialized LoadModelRequest
	// contains filtered or unexported fields
}

func (*LoadModelRequest) Descriptor deprecated

func (*LoadModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadModelRequest.ProtoReflect.Descriptor instead.

func (*LoadModelRequest) GetRequestJson

func (x *LoadModelRequest) GetRequestJson() []byte

func (*LoadModelRequest) ProtoMessage

func (*LoadModelRequest) ProtoMessage()

func (*LoadModelRequest) ProtoReflect

func (x *LoadModelRequest) ProtoReflect() protoreflect.Message

func (*LoadModelRequest) Reset

func (x *LoadModelRequest) Reset()

func (*LoadModelRequest) String

func (x *LoadModelRequest) String() string

type LoadModelResponse

type LoadModelResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*LoadModelResponse) Descriptor deprecated

func (*LoadModelResponse) Descriptor() ([]byte, []int)

Deprecated: Use LoadModelResponse.ProtoReflect.Descriptor instead.

func (*LoadModelResponse) GetCode

func (x *LoadModelResponse) GetCode() int32

func (*LoadModelResponse) GetMessage

func (x *LoadModelResponse) GetMessage() string

func (*LoadModelResponse) ProtoMessage

func (*LoadModelResponse) ProtoMessage()

func (*LoadModelResponse) ProtoReflect

func (x *LoadModelResponse) ProtoReflect() protoreflect.Message

func (*LoadModelResponse) Reset

func (x *LoadModelResponse) Reset()

func (*LoadModelResponse) String

func (x *LoadModelResponse) String() string

type PluginError

type PluginError struct {
	Code    int32
	Message string
	Plugin  string
}

PluginError represents a plugin gRPC error

func AsPluginError

func AsPluginError(err error) (*PluginError, bool)

AsPluginError attempts to convert the error to PluginError

func NewPluginError

func NewPluginError(code int32, message string) *PluginError

NewPluginError creates a plugin error

func WrapPluginError

func WrapPluginError(err error, pluginName, operation string) *PluginError

WrapPluginError wraps an error with plugin context information

func (*PluginError) Error

func (e *PluginError) Error() string

type ProviderServiceClient

type ProviderServiceClient interface {
	// GetManifest returns plugin metadata
	GetManifest(ctx context.Context, in *GetManifestRequest, opts ...grpc.CallOption) (*GetManifestResponse, error)
	// InvokeService invokes plugin service (core method - unary call)
	InvokeService(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*InvokeServiceResponse, error)
	// InvokeServiceStream server-side streaming call (for HTTP streaming: SSE/NDJSON)
	// Only called when service declares capabilities.support_streaming = true
	InvokeServiceStream(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[InvokeServiceStreamResponse], error)
	// InvokeServiceBidi bidirectional streaming call (for WebSocket)
	// Only called when service declares protocol = "WEBSOCKET" or capabilities.support_bidirectional = true
	InvokeServiceBidi(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[InvokeServiceBidiRequest, InvokeServiceBidiResponse], error)
	// HealthCheck performs health check
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// GetOperateStatus returns operational status
	GetOperateStatus(ctx context.Context, in *GetOperateStatusRequest, opts ...grpc.CallOption) (*GetOperateStatusResponse, error)
	// SetOperateStatus sets operational status
	SetOperateStatus(ctx context.Context, in *SetOperateStatusRequest, opts ...grpc.CallOption) (*SetOperateStatusResponse, error)
	// Remote plugin methods (cloud API plugins)
	SetAuth(ctx context.Context, in *SetAuthRequest, opts ...grpc.CallOption) (*SetAuthResponse, error)
	ValidateAuth(ctx context.Context, in *ValidateAuthRequest, opts ...grpc.CallOption) (*ValidateAuthResponse, error)
	RefreshAuth(ctx context.Context, in *RefreshAuthRequest, opts ...grpc.CallOption) (*RefreshAuthResponse, error)
	// Engine lifecycle management
	StartEngine(ctx context.Context, in *StartEngineRequest, opts ...grpc.CallOption) (*StartEngineResponse, error)
	StopEngine(ctx context.Context, in *StopEngineRequest, opts ...grpc.CallOption) (*StopEngineResponse, error)
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
	// Engine installation and environment management
	CheckEngine(ctx context.Context, in *CheckEngineRequest, opts ...grpc.CallOption) (*CheckEngineResponse, error)
	InstallEngine(ctx context.Context, in *InstallEngineRequest, opts ...grpc.CallOption) (*InstallEngineResponse, error)
	InitEnv(ctx context.Context, in *InitEnvRequest, opts ...grpc.CallOption) (*InitEnvResponse, error)
	UpgradeEngine(ctx context.Context, in *UpgradeEngineRequest, opts ...grpc.CallOption) (*UpgradeEngineResponse, error)
	// Model management
	PullModel(ctx context.Context, in *PullModelRequest, opts ...grpc.CallOption) (*PullModelResponse, error)
	PullModelStream(ctx context.Context, in *PullModelStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[PullModelStreamResponse], error)
	DeleteModel(ctx context.Context, in *DeleteModelRequest, opts ...grpc.CallOption) (*DeleteModelResponse, error)
	ListModels(ctx context.Context, in *ListModelsRequest, opts ...grpc.CallOption) (*ListModelsResponse, error)
	LoadModel(ctx context.Context, in *LoadModelRequest, opts ...grpc.CallOption) (*LoadModelResponse, error)
	UnloadModel(ctx context.Context, in *UnloadModelRequest, opts ...grpc.CallOption) (*UnloadModelResponse, error)
	GetRunningModels(ctx context.Context, in *GetRunningModelsRequest, opts ...grpc.CallOption) (*GetRunningModelsResponse, error)
	// Version information
	GetVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*GetVersionResponse, error)
}

ProviderServiceClient is the client API for ProviderService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

ProviderService defines the gRPC service for plugin Provider

Note:

  • Remote plugins only need to implement partial methods (common methods + Auth methods)
  • Local plugins need to implement full lifecycle and model management methods
  • Unimplemented methods will return "not supported" error

type ProviderServiceServer

type ProviderServiceServer interface {
	// GetManifest returns plugin metadata
	GetManifest(context.Context, *GetManifestRequest) (*GetManifestResponse, error)
	// InvokeService invokes plugin service (core method - unary call)
	InvokeService(context.Context, *InvokeServiceRequest) (*InvokeServiceResponse, error)
	// InvokeServiceStream server-side streaming call (for HTTP streaming: SSE/NDJSON)
	// Only called when service declares capabilities.support_streaming = true
	InvokeServiceStream(*InvokeServiceRequest, grpc.ServerStreamingServer[InvokeServiceStreamResponse]) error
	// InvokeServiceBidi bidirectional streaming call (for WebSocket)
	// Only called when service declares protocol = "WEBSOCKET" or capabilities.support_bidirectional = true
	InvokeServiceBidi(grpc.BidiStreamingServer[InvokeServiceBidiRequest, InvokeServiceBidiResponse]) error
	// HealthCheck performs health check
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// GetOperateStatus returns operational status
	GetOperateStatus(context.Context, *GetOperateStatusRequest) (*GetOperateStatusResponse, error)
	// SetOperateStatus sets operational status
	SetOperateStatus(context.Context, *SetOperateStatusRequest) (*SetOperateStatusResponse, error)
	// Remote plugin methods (cloud API plugins)
	SetAuth(context.Context, *SetAuthRequest) (*SetAuthResponse, error)
	ValidateAuth(context.Context, *ValidateAuthRequest) (*ValidateAuthResponse, error)
	RefreshAuth(context.Context, *RefreshAuthRequest) (*RefreshAuthResponse, error)
	// Engine lifecycle management
	StartEngine(context.Context, *StartEngineRequest) (*StartEngineResponse, error)
	StopEngine(context.Context, *StopEngineRequest) (*StopEngineResponse, error)
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	// Engine installation and environment management
	CheckEngine(context.Context, *CheckEngineRequest) (*CheckEngineResponse, error)
	InstallEngine(context.Context, *InstallEngineRequest) (*InstallEngineResponse, error)
	InitEnv(context.Context, *InitEnvRequest) (*InitEnvResponse, error)
	UpgradeEngine(context.Context, *UpgradeEngineRequest) (*UpgradeEngineResponse, error)
	// Model management
	PullModel(context.Context, *PullModelRequest) (*PullModelResponse, error)
	PullModelStream(*PullModelStreamRequest, grpc.ServerStreamingServer[PullModelStreamResponse]) error
	DeleteModel(context.Context, *DeleteModelRequest) (*DeleteModelResponse, error)
	ListModels(context.Context, *ListModelsRequest) (*ListModelsResponse, error)
	LoadModel(context.Context, *LoadModelRequest) (*LoadModelResponse, error)
	UnloadModel(context.Context, *UnloadModelRequest) (*UnloadModelResponse, error)
	GetRunningModels(context.Context, *GetRunningModelsRequest) (*GetRunningModelsResponse, error)
	// Version information
	GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)
	// contains filtered or unexported methods
}

ProviderServiceServer is the server API for ProviderService service. All implementations must embed UnimplementedProviderServiceServer for forward compatibility.

ProviderService defines the gRPC service for plugin Provider

Note:

  • Remote plugins only need to implement partial methods (common methods + Auth methods)
  • Local plugins need to implement full lifecycle and model management methods
  • Unimplemented methods will return "not supported" error

type ProviderService_InvokeServiceBidiClient

type ProviderService_InvokeServiceBidiClient = grpc.BidiStreamingClient[InvokeServiceBidiRequest, InvokeServiceBidiResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ProviderService_InvokeServiceBidiServer

type ProviderService_InvokeServiceBidiServer = grpc.BidiStreamingServer[InvokeServiceBidiRequest, InvokeServiceBidiResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ProviderService_InvokeServiceStreamClient

type ProviderService_InvokeServiceStreamClient = grpc.ServerStreamingClient[InvokeServiceStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ProviderService_InvokeServiceStreamServer

type ProviderService_InvokeServiceStreamServer = grpc.ServerStreamingServer[InvokeServiceStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ProviderService_PullModelStreamClient

type ProviderService_PullModelStreamClient = grpc.ServerStreamingClient[PullModelStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ProviderService_PullModelStreamServer

type ProviderService_PullModelStreamServer = grpc.ServerStreamingServer[PullModelStreamResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type PullModelRequest

type PullModelRequest struct {
	RequestJson []byte `protobuf:"bytes,1,opt,name=request_json,json=requestJson,proto3" json:"request_json,omitempty"` // JSON serialized PullModelRequest
	// contains filtered or unexported fields
}

func (*PullModelRequest) Descriptor deprecated

func (*PullModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use PullModelRequest.ProtoReflect.Descriptor instead.

func (*PullModelRequest) GetRequestJson

func (x *PullModelRequest) GetRequestJson() []byte

func (*PullModelRequest) ProtoMessage

func (*PullModelRequest) ProtoMessage()

func (*PullModelRequest) ProtoReflect

func (x *PullModelRequest) ProtoReflect() protoreflect.Message

func (*PullModelRequest) Reset

func (x *PullModelRequest) Reset()

func (*PullModelRequest) String

func (x *PullModelRequest) String() string

type PullModelResponse

type PullModelResponse struct {
	Code         int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`                                    // Error code: 0 or 200 = success, other = failure
	Message      string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                               // Error message or success message
	ResponseJson []byte `protobuf:"bytes,3,opt,name=response_json,json=responseJson,proto3" json:"response_json,omitempty"` // JSON serialized ProgressResponse
	// contains filtered or unexported fields
}

func (*PullModelResponse) Descriptor deprecated

func (*PullModelResponse) Descriptor() ([]byte, []int)

Deprecated: Use PullModelResponse.ProtoReflect.Descriptor instead.

func (*PullModelResponse) GetCode

func (x *PullModelResponse) GetCode() int32

func (*PullModelResponse) GetMessage

func (x *PullModelResponse) GetMessage() string

func (*PullModelResponse) GetResponseJson

func (x *PullModelResponse) GetResponseJson() []byte

func (*PullModelResponse) ProtoMessage

func (*PullModelResponse) ProtoMessage()

func (*PullModelResponse) ProtoReflect

func (x *PullModelResponse) ProtoReflect() protoreflect.Message

func (*PullModelResponse) Reset

func (x *PullModelResponse) Reset()

func (*PullModelResponse) String

func (x *PullModelResponse) String() string

type PullModelStreamRequest

type PullModelStreamRequest struct {
	RequestJson []byte `protobuf:"bytes,1,opt,name=request_json,json=requestJson,proto3" json:"request_json,omitempty"`
	// contains filtered or unexported fields
}

func (*PullModelStreamRequest) Descriptor deprecated

func (*PullModelStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use PullModelStreamRequest.ProtoReflect.Descriptor instead.

func (*PullModelStreamRequest) GetRequestJson

func (x *PullModelStreamRequest) GetRequestJson() []byte

func (*PullModelStreamRequest) ProtoMessage

func (*PullModelStreamRequest) ProtoMessage()

func (*PullModelStreamRequest) ProtoReflect

func (x *PullModelStreamRequest) ProtoReflect() protoreflect.Message

func (*PullModelStreamRequest) Reset

func (x *PullModelStreamRequest) Reset()

func (*PullModelStreamRequest) String

func (x *PullModelStreamRequest) String() string

type PullModelStreamResponse

type PullModelStreamResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	Data    []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`       // Stream data
	// contains filtered or unexported fields
}

func (*PullModelStreamResponse) Descriptor deprecated

func (*PullModelStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use PullModelStreamResponse.ProtoReflect.Descriptor instead.

func (*PullModelStreamResponse) GetCode

func (x *PullModelStreamResponse) GetCode() int32

func (*PullModelStreamResponse) GetData

func (x *PullModelStreamResponse) GetData() []byte

func (*PullModelStreamResponse) GetMessage

func (x *PullModelStreamResponse) GetMessage() string

func (*PullModelStreamResponse) ProtoMessage

func (*PullModelStreamResponse) ProtoMessage()

func (*PullModelStreamResponse) ProtoReflect

func (x *PullModelStreamResponse) ProtoReflect() protoreflect.Message

func (*PullModelStreamResponse) Reset

func (x *PullModelStreamResponse) Reset()

func (*PullModelStreamResponse) String

func (x *PullModelStreamResponse) String() string

type RefreshAuthRequest

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

func (*RefreshAuthRequest) Descriptor deprecated

func (*RefreshAuthRequest) Descriptor() ([]byte, []int)

Deprecated: Use RefreshAuthRequest.ProtoReflect.Descriptor instead.

func (*RefreshAuthRequest) ProtoMessage

func (*RefreshAuthRequest) ProtoMessage()

func (*RefreshAuthRequest) ProtoReflect

func (x *RefreshAuthRequest) ProtoReflect() protoreflect.Message

func (*RefreshAuthRequest) Reset

func (x *RefreshAuthRequest) Reset()

func (*RefreshAuthRequest) String

func (x *RefreshAuthRequest) String() string

type RefreshAuthResponse

type RefreshAuthResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*RefreshAuthResponse) Descriptor deprecated

func (*RefreshAuthResponse) Descriptor() ([]byte, []int)

Deprecated: Use RefreshAuthResponse.ProtoReflect.Descriptor instead.

func (*RefreshAuthResponse) GetCode

func (x *RefreshAuthResponse) GetCode() int32

func (*RefreshAuthResponse) GetMessage

func (x *RefreshAuthResponse) GetMessage() string

func (*RefreshAuthResponse) ProtoMessage

func (*RefreshAuthResponse) ProtoMessage()

func (*RefreshAuthResponse) ProtoReflect

func (x *RefreshAuthResponse) ProtoReflect() protoreflect.Message

func (*RefreshAuthResponse) Reset

func (x *RefreshAuthResponse) Reset()

func (*RefreshAuthResponse) String

func (x *RefreshAuthResponse) String() string

type SetAuthRequest

type SetAuthRequest struct {
	AuthType    string            `protobuf:"bytes,1,opt,name=auth_type,json=authType,proto3" json:"auth_type,omitempty"` // Auth type: "apikey", "token", "sign", "oauth"
	Credentials map[string]string ``                                                                                      // Authentication credentials
	/* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetAuthRequest) Descriptor deprecated

func (*SetAuthRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetAuthRequest.ProtoReflect.Descriptor instead.

func (*SetAuthRequest) GetAuthType

func (x *SetAuthRequest) GetAuthType() string

func (*SetAuthRequest) GetCredentials

func (x *SetAuthRequest) GetCredentials() map[string]string

func (*SetAuthRequest) ProtoMessage

func (*SetAuthRequest) ProtoMessage()

func (*SetAuthRequest) ProtoReflect

func (x *SetAuthRequest) ProtoReflect() protoreflect.Message

func (*SetAuthRequest) Reset

func (x *SetAuthRequest) Reset()

func (*SetAuthRequest) String

func (x *SetAuthRequest) String() string

type SetAuthResponse

type SetAuthResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*SetAuthResponse) Descriptor deprecated

func (*SetAuthResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetAuthResponse.ProtoReflect.Descriptor instead.

func (*SetAuthResponse) GetCode

func (x *SetAuthResponse) GetCode() int32

func (*SetAuthResponse) GetMessage

func (x *SetAuthResponse) GetMessage() string

func (*SetAuthResponse) ProtoMessage

func (*SetAuthResponse) ProtoMessage()

func (*SetAuthResponse) ProtoReflect

func (x *SetAuthResponse) ProtoReflect() protoreflect.Message

func (*SetAuthResponse) Reset

func (x *SetAuthResponse) Reset()

func (*SetAuthResponse) String

func (x *SetAuthResponse) String() string

type SetOperateStatusRequest

type SetOperateStatusRequest struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SetOperateStatusRequest) Descriptor deprecated

func (*SetOperateStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetOperateStatusRequest.ProtoReflect.Descriptor instead.

func (*SetOperateStatusRequest) GetStatus

func (x *SetOperateStatusRequest) GetStatus() int32

func (*SetOperateStatusRequest) ProtoMessage

func (*SetOperateStatusRequest) ProtoMessage()

func (*SetOperateStatusRequest) ProtoReflect

func (x *SetOperateStatusRequest) ProtoReflect() protoreflect.Message

func (*SetOperateStatusRequest) Reset

func (x *SetOperateStatusRequest) Reset()

func (*SetOperateStatusRequest) String

func (x *SetOperateStatusRequest) String() string

type SetOperateStatusResponse

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

func (*SetOperateStatusResponse) Descriptor deprecated

func (*SetOperateStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetOperateStatusResponse.ProtoReflect.Descriptor instead.

func (*SetOperateStatusResponse) ProtoMessage

func (*SetOperateStatusResponse) ProtoMessage()

func (*SetOperateStatusResponse) ProtoReflect

func (x *SetOperateStatusResponse) ProtoReflect() protoreflect.Message

func (*SetOperateStatusResponse) Reset

func (x *SetOperateStatusResponse) Reset()

func (*SetOperateStatusResponse) String

func (x *SetOperateStatusResponse) String() string

type StartEngineRequest

type StartEngineRequest struct {
	Mode string `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"` // "cpu", "gpu", "auto"
	// contains filtered or unexported fields
}

func (*StartEngineRequest) Descriptor deprecated

func (*StartEngineRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartEngineRequest.ProtoReflect.Descriptor instead.

func (*StartEngineRequest) GetMode

func (x *StartEngineRequest) GetMode() string

func (*StartEngineRequest) ProtoMessage

func (*StartEngineRequest) ProtoMessage()

func (*StartEngineRequest) ProtoReflect

func (x *StartEngineRequest) ProtoReflect() protoreflect.Message

func (*StartEngineRequest) Reset

func (x *StartEngineRequest) Reset()

func (*StartEngineRequest) String

func (x *StartEngineRequest) String() string

type StartEngineResponse

type StartEngineResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*StartEngineResponse) Descriptor deprecated

func (*StartEngineResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartEngineResponse.ProtoReflect.Descriptor instead.

func (*StartEngineResponse) GetCode

func (x *StartEngineResponse) GetCode() int32

func (*StartEngineResponse) GetMessage

func (x *StartEngineResponse) GetMessage() string

func (*StartEngineResponse) ProtoMessage

func (*StartEngineResponse) ProtoMessage()

func (*StartEngineResponse) ProtoReflect

func (x *StartEngineResponse) ProtoReflect() protoreflect.Message

func (*StartEngineResponse) Reset

func (x *StartEngineResponse) Reset()

func (*StartEngineResponse) String

func (x *StartEngineResponse) String() string

type StopEngineRequest

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

func (*StopEngineRequest) Descriptor deprecated

func (*StopEngineRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopEngineRequest.ProtoReflect.Descriptor instead.

func (*StopEngineRequest) ProtoMessage

func (*StopEngineRequest) ProtoMessage()

func (*StopEngineRequest) ProtoReflect

func (x *StopEngineRequest) ProtoReflect() protoreflect.Message

func (*StopEngineRequest) Reset

func (x *StopEngineRequest) Reset()

func (*StopEngineRequest) String

func (x *StopEngineRequest) String() string

type StopEngineResponse

type StopEngineResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*StopEngineResponse) Descriptor deprecated

func (*StopEngineResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopEngineResponse.ProtoReflect.Descriptor instead.

func (*StopEngineResponse) GetCode

func (x *StopEngineResponse) GetCode() int32

func (*StopEngineResponse) GetMessage

func (x *StopEngineResponse) GetMessage() string

func (*StopEngineResponse) ProtoMessage

func (*StopEngineResponse) ProtoMessage()

func (*StopEngineResponse) ProtoReflect

func (x *StopEngineResponse) ProtoReflect() protoreflect.Message

func (*StopEngineResponse) Reset

func (x *StopEngineResponse) Reset()

func (*StopEngineResponse) String

func (x *StopEngineResponse) String() string

type UnimplementedProviderServiceServer

type UnimplementedProviderServiceServer struct{}

UnimplementedProviderServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedProviderServiceServer) CheckEngine

func (UnimplementedProviderServiceServer) DeleteModel

func (UnimplementedProviderServiceServer) GetConfig

func (UnimplementedProviderServiceServer) GetManifest

func (UnimplementedProviderServiceServer) GetOperateStatus

func (UnimplementedProviderServiceServer) GetRunningModels

func (UnimplementedProviderServiceServer) GetVersion

func (UnimplementedProviderServiceServer) HealthCheck

func (UnimplementedProviderServiceServer) InitEnv

func (UnimplementedProviderServiceServer) InstallEngine

func (UnimplementedProviderServiceServer) InvokeService

func (UnimplementedProviderServiceServer) ListModels

func (UnimplementedProviderServiceServer) LoadModel

func (UnimplementedProviderServiceServer) PullModel

func (UnimplementedProviderServiceServer) RefreshAuth

func (UnimplementedProviderServiceServer) SetAuth

func (UnimplementedProviderServiceServer) SetOperateStatus

func (UnimplementedProviderServiceServer) StartEngine

func (UnimplementedProviderServiceServer) StopEngine

func (UnimplementedProviderServiceServer) UnloadModel

func (UnimplementedProviderServiceServer) UpgradeEngine

func (UnimplementedProviderServiceServer) ValidateAuth

type UnloadModelRequest

type UnloadModelRequest struct {
	RequestJson []byte `protobuf:"bytes,1,opt,name=request_json,json=requestJson,proto3" json:"request_json,omitempty"` // JSON serialized UnloadModelRequest
	// contains filtered or unexported fields
}

func (*UnloadModelRequest) Descriptor deprecated

func (*UnloadModelRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnloadModelRequest.ProtoReflect.Descriptor instead.

func (*UnloadModelRequest) GetRequestJson

func (x *UnloadModelRequest) GetRequestJson() []byte

func (*UnloadModelRequest) ProtoMessage

func (*UnloadModelRequest) ProtoMessage()

func (*UnloadModelRequest) ProtoReflect

func (x *UnloadModelRequest) ProtoReflect() protoreflect.Message

func (*UnloadModelRequest) Reset

func (x *UnloadModelRequest) Reset()

func (*UnloadModelRequest) String

func (x *UnloadModelRequest) String() string

type UnloadModelResponse

type UnloadModelResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*UnloadModelResponse) Descriptor deprecated

func (*UnloadModelResponse) Descriptor() ([]byte, []int)

Deprecated: Use UnloadModelResponse.ProtoReflect.Descriptor instead.

func (*UnloadModelResponse) GetCode

func (x *UnloadModelResponse) GetCode() int32

func (*UnloadModelResponse) GetMessage

func (x *UnloadModelResponse) GetMessage() string

func (*UnloadModelResponse) ProtoMessage

func (*UnloadModelResponse) ProtoMessage()

func (*UnloadModelResponse) ProtoReflect

func (x *UnloadModelResponse) ProtoReflect() protoreflect.Message

func (*UnloadModelResponse) Reset

func (x *UnloadModelResponse) Reset()

func (*UnloadModelResponse) String

func (x *UnloadModelResponse) String() string

type UnsafeProviderServiceServer

type UnsafeProviderServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeProviderServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProviderServiceServer will result in compilation errors.

type UpgradeEngineRequest

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

func (*UpgradeEngineRequest) Descriptor deprecated

func (*UpgradeEngineRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpgradeEngineRequest.ProtoReflect.Descriptor instead.

func (*UpgradeEngineRequest) ProtoMessage

func (*UpgradeEngineRequest) ProtoMessage()

func (*UpgradeEngineRequest) ProtoReflect

func (x *UpgradeEngineRequest) ProtoReflect() protoreflect.Message

func (*UpgradeEngineRequest) Reset

func (x *UpgradeEngineRequest) Reset()

func (*UpgradeEngineRequest) String

func (x *UpgradeEngineRequest) String() string

type UpgradeEngineResponse

type UpgradeEngineResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*UpgradeEngineResponse) Descriptor deprecated

func (*UpgradeEngineResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpgradeEngineResponse.ProtoReflect.Descriptor instead.

func (*UpgradeEngineResponse) GetCode

func (x *UpgradeEngineResponse) GetCode() int32

func (*UpgradeEngineResponse) GetMessage

func (x *UpgradeEngineResponse) GetMessage() string

func (*UpgradeEngineResponse) ProtoMessage

func (*UpgradeEngineResponse) ProtoMessage()

func (*UpgradeEngineResponse) ProtoReflect

func (x *UpgradeEngineResponse) ProtoReflect() protoreflect.Message

func (*UpgradeEngineResponse) Reset

func (x *UpgradeEngineResponse) Reset()

func (*UpgradeEngineResponse) String

func (x *UpgradeEngineResponse) String() string

type ValidateAuthRequest

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

func (*ValidateAuthRequest) Descriptor deprecated

func (*ValidateAuthRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateAuthRequest.ProtoReflect.Descriptor instead.

func (*ValidateAuthRequest) ProtoMessage

func (*ValidateAuthRequest) ProtoMessage()

func (*ValidateAuthRequest) ProtoReflect

func (x *ValidateAuthRequest) ProtoReflect() protoreflect.Message

func (*ValidateAuthRequest) Reset

func (x *ValidateAuthRequest) Reset()

func (*ValidateAuthRequest) String

func (x *ValidateAuthRequest) String() string

type ValidateAuthResponse

type ValidateAuthResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`      // Error code: 0 or 200 = success, other = failure
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Error message or success message
	// contains filtered or unexported fields
}

func (*ValidateAuthResponse) Descriptor deprecated

func (*ValidateAuthResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValidateAuthResponse.ProtoReflect.Descriptor instead.

func (*ValidateAuthResponse) GetCode

func (x *ValidateAuthResponse) GetCode() int32

func (*ValidateAuthResponse) GetMessage

func (x *ValidateAuthResponse) GetMessage() string

func (*ValidateAuthResponse) ProtoMessage

func (*ValidateAuthResponse) ProtoMessage()

func (*ValidateAuthResponse) ProtoReflect

func (x *ValidateAuthResponse) ProtoReflect() protoreflect.Message

func (*ValidateAuthResponse) Reset

func (x *ValidateAuthResponse) Reset()

func (*ValidateAuthResponse) String

func (x *ValidateAuthResponse) String() string

Jump to

Keyboard shortcuts

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