Documentation
¶
Index ¶
- Constants
- Variables
- func CreateErrorResponse(err error) (int32, string)
- func CreateSuccessResponse() (int32, string)
- func IsPluginError(err error) bool
- func IsSuccess(code int32) bool
- func MapErrorToPluginCode(err error) int32
- func RegisterProviderServiceServer(s grpc.ServiceRegistrar, srv ProviderServiceServer)
- type CheckEngineRequest
- type CheckEngineResponse
- func (*CheckEngineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckEngineResponse) GetCode() int32
- func (x *CheckEngineResponse) GetInstalled() bool
- func (x *CheckEngineResponse) GetMessage() string
- func (*CheckEngineResponse) ProtoMessage()
- func (x *CheckEngineResponse) ProtoReflect() protoreflect.Message
- func (x *CheckEngineResponse) Reset()
- func (x *CheckEngineResponse) String() string
- type DeleteModelRequest
- func (*DeleteModelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteModelRequest) GetRequestJson() []byte
- func (*DeleteModelRequest) ProtoMessage()
- func (x *DeleteModelRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteModelRequest) Reset()
- func (x *DeleteModelRequest) String() string
- type DeleteModelResponse
- func (*DeleteModelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteModelResponse) GetCode() int32
- func (x *DeleteModelResponse) GetMessage() string
- func (*DeleteModelResponse) ProtoMessage()
- func (x *DeleteModelResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteModelResponse) Reset()
- func (x *DeleteModelResponse) String() string
- type GetConfigRequest
- type GetConfigResponse
- func (*GetConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetConfigResponse) GetCode() int32
- func (x *GetConfigResponse) GetConfigJson() []byte
- func (x *GetConfigResponse) GetMessage() string
- func (*GetConfigResponse) ProtoMessage()
- func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetConfigResponse) Reset()
- func (x *GetConfigResponse) String() string
- type GetManifestRequest
- type GetManifestResponse
- func (*GetManifestResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetManifestResponse) GetCode() int32
- func (x *GetManifestResponse) GetManifestJson() []byte
- func (x *GetManifestResponse) GetMessage() string
- func (*GetManifestResponse) ProtoMessage()
- func (x *GetManifestResponse) ProtoReflect() protoreflect.Message
- func (x *GetManifestResponse) Reset()
- func (x *GetManifestResponse) String() string
- type GetOperateStatusRequest
- type GetOperateStatusResponse
- func (*GetOperateStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetOperateStatusResponse) GetStatus() int32
- func (*GetOperateStatusResponse) ProtoMessage()
- func (x *GetOperateStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetOperateStatusResponse) Reset()
- func (x *GetOperateStatusResponse) String() string
- type GetRunningModelsRequest
- type GetRunningModelsResponse
- func (*GetRunningModelsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetRunningModelsResponse) GetCode() int32
- func (x *GetRunningModelsResponse) GetMessage() string
- func (x *GetRunningModelsResponse) GetResponseJson() []byte
- func (*GetRunningModelsResponse) ProtoMessage()
- func (x *GetRunningModelsResponse) ProtoReflect() protoreflect.Message
- func (x *GetRunningModelsResponse) Reset()
- func (x *GetRunningModelsResponse) String() string
- type GetVersionRequest
- func (*GetVersionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetVersionRequest) GetRequestJson() []byte
- func (*GetVersionRequest) ProtoMessage()
- func (x *GetVersionRequest) ProtoReflect() protoreflect.Message
- func (x *GetVersionRequest) Reset()
- func (x *GetVersionRequest) String() string
- type GetVersionResponse
- func (*GetVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetVersionResponse) GetCode() int32
- func (x *GetVersionResponse) GetMessage() string
- func (x *GetVersionResponse) GetResponseJson() []byte
- func (*GetVersionResponse) ProtoMessage()
- func (x *GetVersionResponse) ProtoReflect() protoreflect.Message
- func (x *GetVersionResponse) Reset()
- func (x *GetVersionResponse) String() string
- type HealthCheckRequest
- type HealthCheckResponse
- func (*HealthCheckResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckResponse) GetCode() int32
- func (x *HealthCheckResponse) GetMessage() string
- func (*HealthCheckResponse) ProtoMessage()
- func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message
- func (x *HealthCheckResponse) Reset()
- func (x *HealthCheckResponse) String() string
- type InitEnvRequest
- type InitEnvResponse
- func (*InitEnvResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InitEnvResponse) GetCode() int32
- func (x *InitEnvResponse) GetMessage() string
- func (*InitEnvResponse) ProtoMessage()
- func (x *InitEnvResponse) ProtoReflect() protoreflect.Message
- func (x *InitEnvResponse) Reset()
- func (x *InitEnvResponse) String() string
- type InstallEngineRequest
- func (*InstallEngineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InstallEngineRequest) GetCover() bool
- func (*InstallEngineRequest) ProtoMessage()
- func (x *InstallEngineRequest) ProtoReflect() protoreflect.Message
- func (x *InstallEngineRequest) Reset()
- func (x *InstallEngineRequest) String() string
- type InstallEngineResponse
- func (*InstallEngineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InstallEngineResponse) GetCode() int32
- func (x *InstallEngineResponse) GetMessage() string
- func (*InstallEngineResponse) ProtoMessage()
- func (x *InstallEngineResponse) ProtoReflect() protoreflect.Message
- func (x *InstallEngineResponse) Reset()
- func (x *InstallEngineResponse) String() string
- type InvokeServiceBidiRequest
- func (*InvokeServiceBidiRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InvokeServiceBidiRequest) GetAuthInfo() string
- func (x *InvokeServiceBidiRequest) GetData() []byte
- func (x *InvokeServiceBidiRequest) GetIsFirst() bool
- func (x *InvokeServiceBidiRequest) GetMessageType() string
- func (x *InvokeServiceBidiRequest) GetMetadata() map[string]string
- func (x *InvokeServiceBidiRequest) GetServiceName() string
- func (*InvokeServiceBidiRequest) ProtoMessage()
- func (x *InvokeServiceBidiRequest) ProtoReflect() protoreflect.Message
- func (x *InvokeServiceBidiRequest) Reset()
- func (x *InvokeServiceBidiRequest) String() string
- type InvokeServiceBidiResponse
- func (*InvokeServiceBidiResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InvokeServiceBidiResponse) GetCode() int32
- func (x *InvokeServiceBidiResponse) GetData() []byte
- func (x *InvokeServiceBidiResponse) GetMessage() string
- func (x *InvokeServiceBidiResponse) GetMessageType() string
- func (x *InvokeServiceBidiResponse) GetMetadata() map[string]string
- func (*InvokeServiceBidiResponse) ProtoMessage()
- func (x *InvokeServiceBidiResponse) ProtoReflect() protoreflect.Message
- func (x *InvokeServiceBidiResponse) Reset()
- func (x *InvokeServiceBidiResponse) String() string
- type InvokeServiceRequest
- func (*InvokeServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InvokeServiceRequest) GetAuthInfo() string
- func (x *InvokeServiceRequest) GetRequestData() []byte
- func (x *InvokeServiceRequest) GetServiceName() string
- func (*InvokeServiceRequest) ProtoMessage()
- func (x *InvokeServiceRequest) ProtoReflect() protoreflect.Message
- func (x *InvokeServiceRequest) Reset()
- func (x *InvokeServiceRequest) String() string
- type InvokeServiceResponse
- func (*InvokeServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InvokeServiceResponse) GetCode() int32
- func (x *InvokeServiceResponse) GetMessage() string
- func (x *InvokeServiceResponse) GetResponseData() []byte
- func (*InvokeServiceResponse) ProtoMessage()
- func (x *InvokeServiceResponse) ProtoReflect() protoreflect.Message
- func (x *InvokeServiceResponse) Reset()
- func (x *InvokeServiceResponse) String() string
- type InvokeServiceStreamResponse
- func (*InvokeServiceStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InvokeServiceStreamResponse) GetChunkData() []byte
- func (x *InvokeServiceStreamResponse) GetCode() int32
- func (x *InvokeServiceStreamResponse) GetIsFinal() bool
- func (x *InvokeServiceStreamResponse) GetMessage() string
- func (x *InvokeServiceStreamResponse) GetMetadata() map[string]string
- func (*InvokeServiceStreamResponse) ProtoMessage()
- func (x *InvokeServiceStreamResponse) ProtoReflect() protoreflect.Message
- func (x *InvokeServiceStreamResponse) Reset()
- func (x *InvokeServiceStreamResponse) String() string
- type ListModelsRequest
- type ListModelsResponse
- func (*ListModelsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListModelsResponse) GetCode() int32
- func (x *ListModelsResponse) GetMessage() string
- func (x *ListModelsResponse) GetResponseJson() []byte
- func (*ListModelsResponse) ProtoMessage()
- func (x *ListModelsResponse) ProtoReflect() protoreflect.Message
- func (x *ListModelsResponse) Reset()
- func (x *ListModelsResponse) String() string
- type LoadModelRequest
- type LoadModelResponse
- func (*LoadModelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LoadModelResponse) GetCode() int32
- func (x *LoadModelResponse) GetMessage() string
- func (*LoadModelResponse) ProtoMessage()
- func (x *LoadModelResponse) ProtoReflect() protoreflect.Message
- func (x *LoadModelResponse) Reset()
- func (x *LoadModelResponse) String() string
- type PluginError
- type ProviderServiceClient
- type ProviderServiceServer
- type ProviderService_InvokeServiceBidiClient
- type ProviderService_InvokeServiceBidiServer
- type ProviderService_InvokeServiceStreamClient
- type ProviderService_InvokeServiceStreamServer
- type ProviderService_PullModelStreamClient
- type ProviderService_PullModelStreamServer
- type PullModelRequest
- type PullModelResponse
- func (*PullModelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PullModelResponse) GetCode() int32
- func (x *PullModelResponse) GetMessage() string
- func (x *PullModelResponse) GetResponseJson() []byte
- func (*PullModelResponse) ProtoMessage()
- func (x *PullModelResponse) ProtoReflect() protoreflect.Message
- func (x *PullModelResponse) Reset()
- func (x *PullModelResponse) String() string
- type PullModelStreamRequest
- func (*PullModelStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PullModelStreamRequest) GetRequestJson() []byte
- func (*PullModelStreamRequest) ProtoMessage()
- func (x *PullModelStreamRequest) ProtoReflect() protoreflect.Message
- func (x *PullModelStreamRequest) Reset()
- func (x *PullModelStreamRequest) String() string
- type PullModelStreamResponse
- func (*PullModelStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PullModelStreamResponse) GetCode() int32
- func (x *PullModelStreamResponse) GetData() []byte
- func (x *PullModelStreamResponse) GetMessage() string
- func (*PullModelStreamResponse) ProtoMessage()
- func (x *PullModelStreamResponse) ProtoReflect() protoreflect.Message
- func (x *PullModelStreamResponse) Reset()
- func (x *PullModelStreamResponse) String() string
- type RefreshAuthRequest
- type RefreshAuthResponse
- func (*RefreshAuthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshAuthResponse) GetCode() int32
- func (x *RefreshAuthResponse) GetMessage() string
- func (*RefreshAuthResponse) ProtoMessage()
- func (x *RefreshAuthResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshAuthResponse) Reset()
- func (x *RefreshAuthResponse) String() string
- type SetAuthRequest
- func (*SetAuthRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetAuthRequest) GetAuthType() string
- func (x *SetAuthRequest) GetCredentials() map[string]string
- func (*SetAuthRequest) ProtoMessage()
- func (x *SetAuthRequest) ProtoReflect() protoreflect.Message
- func (x *SetAuthRequest) Reset()
- func (x *SetAuthRequest) String() string
- type SetAuthResponse
- func (*SetAuthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SetAuthResponse) GetCode() int32
- func (x *SetAuthResponse) GetMessage() string
- func (*SetAuthResponse) ProtoMessage()
- func (x *SetAuthResponse) ProtoReflect() protoreflect.Message
- func (x *SetAuthResponse) Reset()
- func (x *SetAuthResponse) String() string
- type SetOperateStatusRequest
- func (*SetOperateStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetOperateStatusRequest) GetStatus() int32
- func (*SetOperateStatusRequest) ProtoMessage()
- func (x *SetOperateStatusRequest) ProtoReflect() protoreflect.Message
- func (x *SetOperateStatusRequest) Reset()
- func (x *SetOperateStatusRequest) String() string
- type SetOperateStatusResponse
- type StartEngineRequest
- func (*StartEngineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartEngineRequest) GetMode() string
- func (*StartEngineRequest) ProtoMessage()
- func (x *StartEngineRequest) ProtoReflect() protoreflect.Message
- func (x *StartEngineRequest) Reset()
- func (x *StartEngineRequest) String() string
- type StartEngineResponse
- func (*StartEngineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartEngineResponse) GetCode() int32
- func (x *StartEngineResponse) GetMessage() string
- func (*StartEngineResponse) ProtoMessage()
- func (x *StartEngineResponse) ProtoReflect() protoreflect.Message
- func (x *StartEngineResponse) Reset()
- func (x *StartEngineResponse) String() string
- type StopEngineRequest
- type StopEngineResponse
- func (*StopEngineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StopEngineResponse) GetCode() int32
- func (x *StopEngineResponse) GetMessage() string
- func (*StopEngineResponse) ProtoMessage()
- func (x *StopEngineResponse) ProtoReflect() protoreflect.Message
- func (x *StopEngineResponse) Reset()
- func (x *StopEngineResponse) String() string
- type UnimplementedProviderServiceServer
- func (UnimplementedProviderServiceServer) CheckEngine(context.Context, *CheckEngineRequest) (*CheckEngineResponse, error)
- func (UnimplementedProviderServiceServer) DeleteModel(context.Context, *DeleteModelRequest) (*DeleteModelResponse, error)
- func (UnimplementedProviderServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
- func (UnimplementedProviderServiceServer) GetManifest(context.Context, *GetManifestRequest) (*GetManifestResponse, error)
- func (UnimplementedProviderServiceServer) GetOperateStatus(context.Context, *GetOperateStatusRequest) (*GetOperateStatusResponse, error)
- func (UnimplementedProviderServiceServer) GetRunningModels(context.Context, *GetRunningModelsRequest) (*GetRunningModelsResponse, error)
- func (UnimplementedProviderServiceServer) GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)
- func (UnimplementedProviderServiceServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
- func (UnimplementedProviderServiceServer) InitEnv(context.Context, *InitEnvRequest) (*InitEnvResponse, error)
- func (UnimplementedProviderServiceServer) InstallEngine(context.Context, *InstallEngineRequest) (*InstallEngineResponse, error)
- func (UnimplementedProviderServiceServer) InvokeService(context.Context, *InvokeServiceRequest) (*InvokeServiceResponse, error)
- func (UnimplementedProviderServiceServer) InvokeServiceBidi(grpc.BidiStreamingServer[InvokeServiceBidiRequest, InvokeServiceBidiResponse]) error
- func (UnimplementedProviderServiceServer) InvokeServiceStream(*InvokeServiceRequest, grpc.ServerStreamingServer[InvokeServiceStreamResponse]) error
- func (UnimplementedProviderServiceServer) ListModels(context.Context, *ListModelsRequest) (*ListModelsResponse, error)
- func (UnimplementedProviderServiceServer) LoadModel(context.Context, *LoadModelRequest) (*LoadModelResponse, error)
- func (UnimplementedProviderServiceServer) PullModel(context.Context, *PullModelRequest) (*PullModelResponse, error)
- func (UnimplementedProviderServiceServer) PullModelStream(*PullModelStreamRequest, grpc.ServerStreamingServer[PullModelStreamResponse]) error
- func (UnimplementedProviderServiceServer) RefreshAuth(context.Context, *RefreshAuthRequest) (*RefreshAuthResponse, error)
- func (UnimplementedProviderServiceServer) SetAuth(context.Context, *SetAuthRequest) (*SetAuthResponse, error)
- func (UnimplementedProviderServiceServer) SetOperateStatus(context.Context, *SetOperateStatusRequest) (*SetOperateStatusResponse, error)
- func (UnimplementedProviderServiceServer) StartEngine(context.Context, *StartEngineRequest) (*StartEngineResponse, error)
- func (UnimplementedProviderServiceServer) StopEngine(context.Context, *StopEngineRequest) (*StopEngineResponse, error)
- func (UnimplementedProviderServiceServer) UnloadModel(context.Context, *UnloadModelRequest) (*UnloadModelResponse, error)
- func (UnimplementedProviderServiceServer) UpgradeEngine(context.Context, *UpgradeEngineRequest) (*UpgradeEngineResponse, error)
- func (UnimplementedProviderServiceServer) ValidateAuth(context.Context, *ValidateAuthRequest) (*ValidateAuthResponse, error)
- type UnloadModelRequest
- func (*UnloadModelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnloadModelRequest) GetRequestJson() []byte
- func (*UnloadModelRequest) ProtoMessage()
- func (x *UnloadModelRequest) ProtoReflect() protoreflect.Message
- func (x *UnloadModelRequest) Reset()
- func (x *UnloadModelRequest) String() string
- type UnloadModelResponse
- func (*UnloadModelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UnloadModelResponse) GetCode() int32
- func (x *UnloadModelResponse) GetMessage() string
- func (*UnloadModelResponse) ProtoMessage()
- func (x *UnloadModelResponse) ProtoReflect() protoreflect.Message
- func (x *UnloadModelResponse) Reset()
- func (x *UnloadModelResponse) String() string
- type UnsafeProviderServiceServer
- type UpgradeEngineRequest
- type UpgradeEngineResponse
- func (*UpgradeEngineResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpgradeEngineResponse) GetCode() int32
- func (x *UpgradeEngineResponse) GetMessage() string
- func (*UpgradeEngineResponse) ProtoMessage()
- func (x *UpgradeEngineResponse) ProtoReflect() protoreflect.Message
- func (x *UpgradeEngineResponse) Reset()
- func (x *UpgradeEngineResponse) String() string
- type ValidateAuthRequest
- type ValidateAuthResponse
- func (*ValidateAuthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateAuthResponse) GetCode() int32
- func (x *ValidateAuthResponse) GetMessage() string
- func (*ValidateAuthResponse) ProtoMessage()
- func (x *ValidateAuthResponse) ProtoReflect() protoreflect.Message
- func (x *ValidateAuthResponse) Reset()
- func (x *ValidateAuthResponse) String() string
Constants ¶
const ( // Success codes PluginCodeSuccess = 200 PluginCodeOK = 0 // Client errors 4xx PluginCodeBadRequest = 400 // Request parameter error 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 PluginCodeBadGateway = 502 // Bad gateway (upstream service error) )
Plugin error code constants
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 ¶
var File_provider_proto protoreflect.FileDescriptor
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 ¶
CreateErrorResponse is a helper function to create error response
func CreateSuccessResponse ¶
CreateSuccessResponse is a helper function to create success response
func IsPluginError ¶
IsPluginError checks if the error is of PluginError type
func MapErrorToPluginCode ¶
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 (x *InvokeServiceBidiResponse) ProtoReflect() protoreflect.Message
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 (x *InvokeServiceStreamResponse) ProtoReflect() protoreflect.Message
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 ¶
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
func NewProviderServiceClient ¶
func NewProviderServiceClient(cc grpc.ClientConnInterface) ProviderServiceClient
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) CheckEngine(context.Context, *CheckEngineRequest) (*CheckEngineResponse, error)
func (UnimplementedProviderServiceServer) DeleteModel ¶
func (UnimplementedProviderServiceServer) DeleteModel(context.Context, *DeleteModelRequest) (*DeleteModelResponse, error)
func (UnimplementedProviderServiceServer) GetConfig ¶
func (UnimplementedProviderServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
func (UnimplementedProviderServiceServer) GetManifest ¶
func (UnimplementedProviderServiceServer) GetManifest(context.Context, *GetManifestRequest) (*GetManifestResponse, error)
func (UnimplementedProviderServiceServer) GetOperateStatus ¶
func (UnimplementedProviderServiceServer) GetOperateStatus(context.Context, *GetOperateStatusRequest) (*GetOperateStatusResponse, error)
func (UnimplementedProviderServiceServer) GetRunningModels ¶
func (UnimplementedProviderServiceServer) GetRunningModels(context.Context, *GetRunningModelsRequest) (*GetRunningModelsResponse, error)
func (UnimplementedProviderServiceServer) GetVersion ¶
func (UnimplementedProviderServiceServer) GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)
func (UnimplementedProviderServiceServer) HealthCheck ¶
func (UnimplementedProviderServiceServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
func (UnimplementedProviderServiceServer) InitEnv ¶
func (UnimplementedProviderServiceServer) InitEnv(context.Context, *InitEnvRequest) (*InitEnvResponse, error)
func (UnimplementedProviderServiceServer) InstallEngine ¶
func (UnimplementedProviderServiceServer) InstallEngine(context.Context, *InstallEngineRequest) (*InstallEngineResponse, error)
func (UnimplementedProviderServiceServer) InvokeService ¶
func (UnimplementedProviderServiceServer) InvokeService(context.Context, *InvokeServiceRequest) (*InvokeServiceResponse, error)
func (UnimplementedProviderServiceServer) InvokeServiceBidi ¶
func (UnimplementedProviderServiceServer) InvokeServiceBidi(grpc.BidiStreamingServer[InvokeServiceBidiRequest, InvokeServiceBidiResponse]) error
func (UnimplementedProviderServiceServer) InvokeServiceStream ¶
func (UnimplementedProviderServiceServer) InvokeServiceStream(*InvokeServiceRequest, grpc.ServerStreamingServer[InvokeServiceStreamResponse]) error
func (UnimplementedProviderServiceServer) ListModels ¶
func (UnimplementedProviderServiceServer) ListModels(context.Context, *ListModelsRequest) (*ListModelsResponse, error)
func (UnimplementedProviderServiceServer) LoadModel ¶
func (UnimplementedProviderServiceServer) LoadModel(context.Context, *LoadModelRequest) (*LoadModelResponse, error)
func (UnimplementedProviderServiceServer) PullModel ¶
func (UnimplementedProviderServiceServer) PullModel(context.Context, *PullModelRequest) (*PullModelResponse, error)
func (UnimplementedProviderServiceServer) PullModelStream ¶
func (UnimplementedProviderServiceServer) PullModelStream(*PullModelStreamRequest, grpc.ServerStreamingServer[PullModelStreamResponse]) error
func (UnimplementedProviderServiceServer) RefreshAuth ¶
func (UnimplementedProviderServiceServer) RefreshAuth(context.Context, *RefreshAuthRequest) (*RefreshAuthResponse, error)
func (UnimplementedProviderServiceServer) SetAuth ¶
func (UnimplementedProviderServiceServer) SetAuth(context.Context, *SetAuthRequest) (*SetAuthResponse, error)
func (UnimplementedProviderServiceServer) SetOperateStatus ¶
func (UnimplementedProviderServiceServer) SetOperateStatus(context.Context, *SetOperateStatusRequest) (*SetOperateStatusResponse, error)
func (UnimplementedProviderServiceServer) StartEngine ¶
func (UnimplementedProviderServiceServer) StartEngine(context.Context, *StartEngineRequest) (*StartEngineResponse, error)
func (UnimplementedProviderServiceServer) StopEngine ¶
func (UnimplementedProviderServiceServer) StopEngine(context.Context, *StopEngineRequest) (*StopEngineResponse, error)
func (UnimplementedProviderServiceServer) UnloadModel ¶
func (UnimplementedProviderServiceServer) UnloadModel(context.Context, *UnloadModelRequest) (*UnloadModelResponse, error)
func (UnimplementedProviderServiceServer) UpgradeEngine ¶
func (UnimplementedProviderServiceServer) UpgradeEngine(context.Context, *UpgradeEngineRequest) (*UpgradeEngineResponse, error)
func (UnimplementedProviderServiceServer) ValidateAuth ¶
func (UnimplementedProviderServiceServer) ValidateAuth(context.Context, *ValidateAuthRequest) (*ValidateAuthResponse, error)
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