Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterLLMRunnerServiceServer(s grpc.ServiceRegistrar, srv LLMRunnerServiceServer)
- type ChatMessage
- func (*ChatMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ChatMessage) GetAttachmentContent() []byte
- func (x *ChatMessage) GetAttachmentMime() string
- func (x *ChatMessage) GetAttachmentName() string
- func (x *ChatMessage) GetContent() string
- func (x *ChatMessage) GetCreatedAt() int64
- func (x *ChatMessage) GetId() int64
- func (x *ChatMessage) GetRole() string
- func (*ChatMessage) ProtoMessage()
- func (x *ChatMessage) ProtoReflect() protoreflect.Message
- func (x *ChatMessage) Reset()
- func (x *ChatMessage) String() string
- type ChatResponse
- func (*ChatResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChatResponse) GetCompletionTokens() int32
- func (x *ChatResponse) GetContent() string
- func (x *ChatResponse) GetCreatedAt() int64
- func (x *ChatResponse) GetDone() bool
- func (x *ChatResponse) GetId() int64
- func (x *ChatResponse) GetPromptTokens() int32
- func (x *ChatResponse) GetReasoningContent() string
- func (x *ChatResponse) GetRole() string
- func (x *ChatResponse) GetTotalTokens() int32
- func (*ChatResponse) ProtoMessage()
- func (x *ChatResponse) ProtoReflect() protoreflect.Message
- func (x *ChatResponse) Reset()
- func (x *ChatResponse) String() string
- type EmbedBatchRequest
- type EmbedBatchResponse
- func (*EmbedBatchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EmbedBatchResponse) GetEmbeddings() []*Embedding
- func (*EmbedBatchResponse) ProtoMessage()
- func (x *EmbedBatchResponse) ProtoReflect() protoreflect.Message
- func (x *EmbedBatchResponse) Reset()
- func (x *EmbedBatchResponse) String() string
- type EmbedRequest
- type EmbedResponse
- type Embedding
- type Empty
- type GenerationParams
- func (*GenerationParams) Descriptor() ([]byte, []int)deprecated
- func (x *GenerationParams) GetEnableThinking() bool
- func (x *GenerationParams) GetMaxTokens() int32
- func (x *GenerationParams) GetResponseFormat() *ResponseFormat
- func (x *GenerationParams) GetTemperature() float32
- func (x *GenerationParams) GetTopK() int32
- func (x *GenerationParams) GetTopP() float32
- func (*GenerationParams) ProtoMessage()
- func (x *GenerationParams) ProtoReflect() protoreflect.Message
- func (x *GenerationParams) Reset()
- func (x *GenerationParams) String() string
- type GetGpuInfoResponse
- func (*GetGpuInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetGpuInfoResponse) GetGpus() []*GpuInfo
- func (*GetGpuInfoResponse) ProtoMessage()
- func (x *GetGpuInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetGpuInfoResponse) Reset()
- func (x *GetGpuInfoResponse) String() string
- type GetLoadedModelResponse
- func (*GetLoadedModelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetLoadedModelResponse) GetDisplayName() string
- func (x *GetLoadedModelResponse) GetGgufBasename() string
- func (x *GetLoadedModelResponse) GetLoaded() bool
- func (*GetLoadedModelResponse) ProtoMessage()
- func (x *GetLoadedModelResponse) ProtoReflect() protoreflect.Message
- func (x *GetLoadedModelResponse) Reset()
- func (x *GetLoadedModelResponse) String() string
- type GetModelsResponse
- type GpuInfo
- func (*GpuInfo) Descriptor() ([]byte, []int)deprecated
- func (x *GpuInfo) GetMemoryTotalMb() uint64
- func (x *GpuInfo) GetMemoryUsedMb() uint64
- func (x *GpuInfo) GetName() string
- func (x *GpuInfo) GetTemperatureC() int32
- func (x *GpuInfo) GetUtilizationPercent() uint32
- func (*GpuInfo) ProtoMessage()
- func (x *GpuInfo) ProtoReflect() protoreflect.Message
- func (x *GpuInfo) Reset()
- func (x *GpuInfo) String() string
- type LLMRunnerServiceClient
- type LLMRunnerServiceServer
- type LLMRunnerService_SendMessageClient
- type LLMRunnerService_SendMessageServer
- type LoadModelRequest
- type ResponseFormat
- func (*ResponseFormat) Descriptor() ([]byte, []int)deprecated
- func (x *ResponseFormat) GetSchema() string
- func (x *ResponseFormat) GetType() string
- func (*ResponseFormat) ProtoMessage()
- func (x *ResponseFormat) ProtoReflect() protoreflect.Message
- func (x *ResponseFormat) Reset()
- func (x *ResponseFormat) String() string
- type RunnerProbeResponse
- func (*RunnerProbeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RunnerProbeResponse) GetBackendConnected() bool
- func (x *RunnerProbeResponse) GetGpus() []*GpuInfo
- func (x *RunnerProbeResponse) GetLoadedModel() *GetLoadedModelResponse
- func (x *RunnerProbeResponse) GetServer() *ServerInfo
- func (*RunnerProbeResponse) ProtoMessage()
- func (x *RunnerProbeResponse) ProtoReflect() protoreflect.Message
- func (x *RunnerProbeResponse) Reset()
- func (x *RunnerProbeResponse) String() string
- type SendMessageRequest
- func (*SendMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessageRequest) GetGenerationParams() *GenerationParams
- func (x *SendMessageRequest) GetMessages() []*ChatMessage
- func (x *SendMessageRequest) GetRenderedPrompt() string
- func (x *SendMessageRequest) GetStopSequences() []string
- func (x *SendMessageRequest) GetTimeoutSeconds() int32
- func (*SendMessageRequest) ProtoMessage()
- func (x *SendMessageRequest) ProtoReflect() protoreflect.Message
- func (x *SendMessageRequest) Reset()
- func (x *SendMessageRequest) String() string
- type ServerInfo
- func (*ServerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ServerInfo) GetArch() string
- func (x *ServerInfo) GetCpuCores() int32
- func (x *ServerInfo) GetHostname() string
- func (x *ServerInfo) GetMemoryTotalMb() uint64
- func (x *ServerInfo) GetOs() string
- func (*ServerInfo) ProtoMessage()
- func (x *ServerInfo) ProtoReflect() protoreflect.Message
- func (x *ServerInfo) Reset()
- func (x *ServerInfo) String() string
- type UnimplementedLLMRunnerServiceServer
- func (UnimplementedLLMRunnerServiceServer) Embed(context.Context, *EmbedRequest) (*EmbedResponse, error)
- func (UnimplementedLLMRunnerServiceServer) EmbedBatch(context.Context, *EmbedBatchRequest) (*EmbedBatchResponse, error)
- func (UnimplementedLLMRunnerServiceServer) GetGpuInfo(context.Context, *Empty) (*GetGpuInfoResponse, error)
- func (UnimplementedLLMRunnerServiceServer) GetLoadedModel(context.Context, *Empty) (*GetLoadedModelResponse, error)
- func (UnimplementedLLMRunnerServiceServer) GetModels(context.Context, *Empty) (*GetModelsResponse, error)
- func (UnimplementedLLMRunnerServiceServer) GetServerInfo(context.Context, *Empty) (*ServerInfo, error)
- func (UnimplementedLLMRunnerServiceServer) LoadModel(context.Context, *LoadModelRequest) (*Empty, error)
- func (UnimplementedLLMRunnerServiceServer) ResetMemory(context.Context, *Empty) (*Empty, error)
- func (UnimplementedLLMRunnerServiceServer) RunnerProbe(context.Context, *Empty) (*RunnerProbeResponse, error)
- func (UnimplementedLLMRunnerServiceServer) SendMessage(*SendMessageRequest, grpc.ServerStreamingServer[ChatResponse]) error
- func (UnimplementedLLMRunnerServiceServer) UnloadModel(context.Context, *Empty) (*Empty, error)
- type UnsafeLLMRunnerServiceServer
Constants ¶
const ( LLMRunnerService_GetModels_FullMethodName = "/llmrunner.LLMRunnerService/GetModels" LLMRunnerService_GetServerInfo_FullMethodName = "/llmrunner.LLMRunnerService/GetServerInfo" LLMRunnerService_GetGpuInfo_FullMethodName = "/llmrunner.LLMRunnerService/GetGpuInfo" LLMRunnerService_RunnerProbe_FullMethodName = "/llmrunner.LLMRunnerService/RunnerProbe" LLMRunnerService_LoadModel_FullMethodName = "/llmrunner.LLMRunnerService/LoadModel" LLMRunnerService_GetLoadedModel_FullMethodName = "/llmrunner.LLMRunnerService/GetLoadedModel" LLMRunnerService_UnloadModel_FullMethodName = "/llmrunner.LLMRunnerService/UnloadModel" LLMRunnerService_ResetMemory_FullMethodName = "/llmrunner.LLMRunnerService/ResetMemory" LLMRunnerService_SendMessage_FullMethodName = "/llmrunner.LLMRunnerService/SendMessage" LLMRunnerService_Embed_FullMethodName = "/llmrunner.LLMRunnerService/Embed" LLMRunnerService_EmbedBatch_FullMethodName = "/llmrunner.LLMRunnerService/EmbedBatch" )
Variables ¶
var File_llmrunner_proto protoreflect.FileDescriptor
var LLMRunnerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "llmrunner.LLMRunnerService", HandlerType: (*LLMRunnerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetModels", Handler: _LLMRunnerService_GetModels_Handler, }, { MethodName: "GetServerInfo", Handler: _LLMRunnerService_GetServerInfo_Handler, }, { MethodName: "GetGpuInfo", Handler: _LLMRunnerService_GetGpuInfo_Handler, }, { MethodName: "RunnerProbe", Handler: _LLMRunnerService_RunnerProbe_Handler, }, { MethodName: "LoadModel", Handler: _LLMRunnerService_LoadModel_Handler, }, { MethodName: "GetLoadedModel", Handler: _LLMRunnerService_GetLoadedModel_Handler, }, { MethodName: "UnloadModel", Handler: _LLMRunnerService_UnloadModel_Handler, }, { MethodName: "ResetMemory", Handler: _LLMRunnerService_ResetMemory_Handler, }, { MethodName: "Embed", Handler: _LLMRunnerService_Embed_Handler, }, { MethodName: "EmbedBatch", Handler: _LLMRunnerService_EmbedBatch_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SendMessage", Handler: _LLMRunnerService_SendMessage_Handler, ServerStreams: true, }, }, Metadata: "llmrunner.proto", }
LLMRunnerService_ServiceDesc is the grpc.ServiceDesc for LLMRunnerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLLMRunnerServiceServer ¶
func RegisterLLMRunnerServiceServer(s grpc.ServiceRegistrar, srv LLMRunnerServiceServer)
Types ¶
type ChatMessage ¶
type ChatMessage struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
Role string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
CreatedAt int64 `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
AttachmentName *string `protobuf:"bytes,5,opt,name=attachment_name,json=attachmentName,proto3,oneof" json:"attachment_name,omitempty"`
AttachmentContent []byte `protobuf:"bytes,6,opt,name=attachment_content,json=attachmentContent,proto3,oneof" json:"attachment_content,omitempty"`
AttachmentMime *string `protobuf:"bytes,7,opt,name=attachment_mime,json=attachmentMime,proto3,oneof" json:"attachment_mime,omitempty"`
// contains filtered or unexported fields
}
func (*ChatMessage) Descriptor
deprecated
func (*ChatMessage) Descriptor() ([]byte, []int)
Deprecated: Use ChatMessage.ProtoReflect.Descriptor instead.
func (*ChatMessage) GetAttachmentContent ¶
func (x *ChatMessage) GetAttachmentContent() []byte
func (*ChatMessage) GetAttachmentMime ¶
func (x *ChatMessage) GetAttachmentMime() string
func (*ChatMessage) GetAttachmentName ¶
func (x *ChatMessage) GetAttachmentName() string
func (*ChatMessage) GetContent ¶
func (x *ChatMessage) GetContent() string
func (*ChatMessage) GetCreatedAt ¶
func (x *ChatMessage) GetCreatedAt() int64
func (*ChatMessage) GetId ¶
func (x *ChatMessage) GetId() int64
func (*ChatMessage) GetRole ¶
func (x *ChatMessage) GetRole() string
func (*ChatMessage) ProtoMessage ¶
func (*ChatMessage) ProtoMessage()
func (*ChatMessage) ProtoReflect ¶
func (x *ChatMessage) ProtoReflect() protoreflect.Message
func (*ChatMessage) Reset ¶
func (x *ChatMessage) Reset()
func (*ChatMessage) String ¶
func (x *ChatMessage) String() string
type ChatResponse ¶
type ChatResponse struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
Role string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
CreatedAt int64 `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
Done bool `protobuf:"varint,5,opt,name=done,proto3" json:"done,omitempty"`
ReasoningContent *string `protobuf:"bytes,6,opt,name=reasoning_content,json=reasoningContent,proto3,oneof" json:"reasoning_content,omitempty"`
PromptTokens *int32 `protobuf:"varint,7,opt,name=prompt_tokens,json=promptTokens,proto3,oneof" json:"prompt_tokens,omitempty"`
CompletionTokens *int32 `protobuf:"varint,8,opt,name=completion_tokens,json=completionTokens,proto3,oneof" json:"completion_tokens,omitempty"`
TotalTokens *int32 `protobuf:"varint,9,opt,name=total_tokens,json=totalTokens,proto3,oneof" json:"total_tokens,omitempty"`
// contains filtered or unexported fields
}
func (*ChatResponse) Descriptor
deprecated
func (*ChatResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChatResponse.ProtoReflect.Descriptor instead.
func (*ChatResponse) GetCompletionTokens ¶
func (x *ChatResponse) GetCompletionTokens() int32
func (*ChatResponse) GetContent ¶
func (x *ChatResponse) GetContent() string
func (*ChatResponse) GetCreatedAt ¶
func (x *ChatResponse) GetCreatedAt() int64
func (*ChatResponse) GetDone ¶
func (x *ChatResponse) GetDone() bool
func (*ChatResponse) GetId ¶
func (x *ChatResponse) GetId() int64
func (*ChatResponse) GetPromptTokens ¶
func (x *ChatResponse) GetPromptTokens() int32
func (*ChatResponse) GetReasoningContent ¶
func (x *ChatResponse) GetReasoningContent() string
func (*ChatResponse) GetRole ¶
func (x *ChatResponse) GetRole() string
func (*ChatResponse) GetTotalTokens ¶
func (x *ChatResponse) GetTotalTokens() int32
func (*ChatResponse) ProtoMessage ¶
func (*ChatResponse) ProtoMessage()
func (*ChatResponse) ProtoReflect ¶
func (x *ChatResponse) ProtoReflect() protoreflect.Message
func (*ChatResponse) Reset ¶
func (x *ChatResponse) Reset()
func (*ChatResponse) String ¶
func (x *ChatResponse) String() string
type EmbedBatchRequest ¶
type EmbedBatchRequest struct {
Texts []string `protobuf:"bytes,1,rep,name=texts,proto3" json:"texts,omitempty"`
// contains filtered or unexported fields
}
func (*EmbedBatchRequest) Descriptor
deprecated
func (*EmbedBatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use EmbedBatchRequest.ProtoReflect.Descriptor instead.
func (*EmbedBatchRequest) GetTexts ¶
func (x *EmbedBatchRequest) GetTexts() []string
func (*EmbedBatchRequest) ProtoMessage ¶
func (*EmbedBatchRequest) ProtoMessage()
func (*EmbedBatchRequest) ProtoReflect ¶
func (x *EmbedBatchRequest) ProtoReflect() protoreflect.Message
func (*EmbedBatchRequest) Reset ¶
func (x *EmbedBatchRequest) Reset()
func (*EmbedBatchRequest) String ¶
func (x *EmbedBatchRequest) String() string
type EmbedBatchResponse ¶
type EmbedBatchResponse struct {
Embeddings []*Embedding `protobuf:"bytes,1,rep,name=embeddings,proto3" json:"embeddings,omitempty"`
// contains filtered or unexported fields
}
func (*EmbedBatchResponse) Descriptor
deprecated
func (*EmbedBatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmbedBatchResponse.ProtoReflect.Descriptor instead.
func (*EmbedBatchResponse) GetEmbeddings ¶
func (x *EmbedBatchResponse) GetEmbeddings() []*Embedding
func (*EmbedBatchResponse) ProtoMessage ¶
func (*EmbedBatchResponse) ProtoMessage()
func (*EmbedBatchResponse) ProtoReflect ¶
func (x *EmbedBatchResponse) ProtoReflect() protoreflect.Message
func (*EmbedBatchResponse) Reset ¶
func (x *EmbedBatchResponse) Reset()
func (*EmbedBatchResponse) String ¶
func (x *EmbedBatchResponse) String() string
type EmbedRequest ¶
type EmbedRequest struct {
Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
// contains filtered or unexported fields
}
func (*EmbedRequest) Descriptor
deprecated
func (*EmbedRequest) Descriptor() ([]byte, []int)
Deprecated: Use EmbedRequest.ProtoReflect.Descriptor instead.
func (*EmbedRequest) GetText ¶
func (x *EmbedRequest) GetText() string
func (*EmbedRequest) ProtoMessage ¶
func (*EmbedRequest) ProtoMessage()
func (*EmbedRequest) ProtoReflect ¶
func (x *EmbedRequest) ProtoReflect() protoreflect.Message
func (*EmbedRequest) Reset ¶
func (x *EmbedRequest) Reset()
func (*EmbedRequest) String ¶
func (x *EmbedRequest) String() string
type EmbedResponse ¶
type EmbedResponse struct {
Values []float32 `protobuf:"fixed32,1,rep,packed,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
func (*EmbedResponse) Descriptor
deprecated
func (*EmbedResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmbedResponse.ProtoReflect.Descriptor instead.
func (*EmbedResponse) GetValues ¶
func (x *EmbedResponse) GetValues() []float32
func (*EmbedResponse) ProtoMessage ¶
func (*EmbedResponse) ProtoMessage()
func (*EmbedResponse) ProtoReflect ¶
func (x *EmbedResponse) ProtoReflect() protoreflect.Message
func (*EmbedResponse) Reset ¶
func (x *EmbedResponse) Reset()
func (*EmbedResponse) String ¶
func (x *EmbedResponse) String() string
type Embedding ¶
type Embedding struct {
Values []float32 `protobuf:"fixed32,1,rep,packed,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
func (*Embedding) Descriptor
deprecated
func (*Embedding) ProtoMessage ¶
func (*Embedding) ProtoMessage()
func (*Embedding) ProtoReflect ¶
func (x *Embedding) ProtoReflect() protoreflect.Message
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type GenerationParams ¶
type GenerationParams struct {
Temperature *float32 `protobuf:"fixed32,1,opt,name=temperature,proto3,oneof" json:"temperature,omitempty"`
MaxTokens *int32 `protobuf:"varint,2,opt,name=max_tokens,json=maxTokens,proto3,oneof" json:"max_tokens,omitempty"`
TopK *int32 `protobuf:"varint,3,opt,name=top_k,json=topK,proto3,oneof" json:"top_k,omitempty"`
TopP *float32 `protobuf:"fixed32,4,opt,name=top_p,json=topP,proto3,oneof" json:"top_p,omitempty"`
ResponseFormat *ResponseFormat `protobuf:"bytes,5,opt,name=response_format,json=responseFormat,proto3" json:"response_format,omitempty"`
EnableThinking *bool `protobuf:"varint,6,opt,name=enable_thinking,json=enableThinking,proto3,oneof" json:"enable_thinking,omitempty"`
// contains filtered or unexported fields
}
func (*GenerationParams) Descriptor
deprecated
func (*GenerationParams) Descriptor() ([]byte, []int)
Deprecated: Use GenerationParams.ProtoReflect.Descriptor instead.
func (*GenerationParams) GetEnableThinking ¶
func (x *GenerationParams) GetEnableThinking() bool
func (*GenerationParams) GetMaxTokens ¶
func (x *GenerationParams) GetMaxTokens() int32
func (*GenerationParams) GetResponseFormat ¶
func (x *GenerationParams) GetResponseFormat() *ResponseFormat
func (*GenerationParams) GetTemperature ¶
func (x *GenerationParams) GetTemperature() float32
func (*GenerationParams) GetTopK ¶
func (x *GenerationParams) GetTopK() int32
func (*GenerationParams) GetTopP ¶
func (x *GenerationParams) GetTopP() float32
func (*GenerationParams) ProtoMessage ¶
func (*GenerationParams) ProtoMessage()
func (*GenerationParams) ProtoReflect ¶
func (x *GenerationParams) ProtoReflect() protoreflect.Message
func (*GenerationParams) Reset ¶
func (x *GenerationParams) Reset()
func (*GenerationParams) String ¶
func (x *GenerationParams) String() string
type GetGpuInfoResponse ¶
type GetGpuInfoResponse struct {
Gpus []*GpuInfo `protobuf:"bytes,1,rep,name=gpus,proto3" json:"gpus,omitempty"`
// contains filtered or unexported fields
}
func (*GetGpuInfoResponse) Descriptor
deprecated
func (*GetGpuInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetGpuInfoResponse.ProtoReflect.Descriptor instead.
func (*GetGpuInfoResponse) GetGpus ¶
func (x *GetGpuInfoResponse) GetGpus() []*GpuInfo
func (*GetGpuInfoResponse) ProtoMessage ¶
func (*GetGpuInfoResponse) ProtoMessage()
func (*GetGpuInfoResponse) ProtoReflect ¶
func (x *GetGpuInfoResponse) ProtoReflect() protoreflect.Message
func (*GetGpuInfoResponse) Reset ¶
func (x *GetGpuInfoResponse) Reset()
func (*GetGpuInfoResponse) String ¶
func (x *GetGpuInfoResponse) String() string
type GetLoadedModelResponse ¶
type GetLoadedModelResponse struct {
Loaded bool `protobuf:"varint,1,opt,name=loaded,proto3" json:"loaded,omitempty"`
GgufBasename string `protobuf:"bytes,2,opt,name=gguf_basename,json=ggufBasename,proto3" json:"gguf_basename,omitempty"`
DisplayName string `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
// contains filtered or unexported fields
}
func (*GetLoadedModelResponse) Descriptor
deprecated
func (*GetLoadedModelResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetLoadedModelResponse.ProtoReflect.Descriptor instead.
func (*GetLoadedModelResponse) GetDisplayName ¶
func (x *GetLoadedModelResponse) GetDisplayName() string
func (*GetLoadedModelResponse) GetGgufBasename ¶
func (x *GetLoadedModelResponse) GetGgufBasename() string
func (*GetLoadedModelResponse) GetLoaded ¶
func (x *GetLoadedModelResponse) GetLoaded() bool
func (*GetLoadedModelResponse) ProtoMessage ¶
func (*GetLoadedModelResponse) ProtoMessage()
func (*GetLoadedModelResponse) ProtoReflect ¶
func (x *GetLoadedModelResponse) ProtoReflect() protoreflect.Message
func (*GetLoadedModelResponse) Reset ¶
func (x *GetLoadedModelResponse) Reset()
func (*GetLoadedModelResponse) String ¶
func (x *GetLoadedModelResponse) String() string
type GetModelsResponse ¶
type GetModelsResponse struct {
Models []string `protobuf:"bytes,1,rep,name=models,proto3" json:"models,omitempty"`
// contains filtered or unexported fields
}
func (*GetModelsResponse) Descriptor
deprecated
func (*GetModelsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetModelsResponse.ProtoReflect.Descriptor instead.
func (*GetModelsResponse) GetModels ¶
func (x *GetModelsResponse) GetModels() []string
func (*GetModelsResponse) ProtoMessage ¶
func (*GetModelsResponse) ProtoMessage()
func (*GetModelsResponse) ProtoReflect ¶
func (x *GetModelsResponse) ProtoReflect() protoreflect.Message
func (*GetModelsResponse) Reset ¶
func (x *GetModelsResponse) Reset()
func (*GetModelsResponse) String ¶
func (x *GetModelsResponse) String() string
type GpuInfo ¶
type GpuInfo struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
TemperatureC int32 `protobuf:"varint,2,opt,name=temperature_c,json=temperatureC,proto3" json:"temperature_c,omitempty"`
MemoryTotalMb uint64 `protobuf:"varint,3,opt,name=memory_total_mb,json=memoryTotalMb,proto3" json:"memory_total_mb,omitempty"`
MemoryUsedMb uint64 `protobuf:"varint,4,opt,name=memory_used_mb,json=memoryUsedMb,proto3" json:"memory_used_mb,omitempty"`
UtilizationPercent uint32 `protobuf:"varint,5,opt,name=utilization_percent,json=utilizationPercent,proto3" json:"utilization_percent,omitempty"`
// contains filtered or unexported fields
}
func (*GpuInfo) Descriptor
deprecated
func (*GpuInfo) GetMemoryTotalMb ¶
func (*GpuInfo) GetMemoryUsedMb ¶
func (*GpuInfo) GetTemperatureC ¶
func (*GpuInfo) GetUtilizationPercent ¶
func (*GpuInfo) ProtoMessage ¶
func (*GpuInfo) ProtoMessage()
func (*GpuInfo) ProtoReflect ¶
func (x *GpuInfo) ProtoReflect() protoreflect.Message
type LLMRunnerServiceClient ¶
type LLMRunnerServiceClient interface {
// GetModels - имена моделей в model_path
GetModels(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetModelsResponse, error)
// GetServerInfo - hostname, платформа, число ядер, объём RAM
GetServerInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ServerInfo, error)
// GetGpuInfo - по каждой GPU: название, температура, VRAM, загрузка (%)
GetGpuInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetGpuInfoResponse, error)
// RunnerProbe - агрегат для балансировщика: backend, хост, GPU, загруженная модель
RunnerProbe(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RunnerProbeResponse, error)
// LoadModel - загрузить веса в RAM/VRAM; вызывать до SendMessage
LoadModel(ctx context.Context, in *LoadModelRequest, opts ...grpc.CallOption) (*Empty, error)
// GetLoadedModel - признак загрузки и идентификаторы
GetLoadedModel(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetLoadedModelResponse, error)
// UnloadModel - выгрузить текущую модель и освободить память
UnloadModel(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
// ResetMemory - выгрузка модели (эквивалент UnloadModel)
ResetMemory(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
// SendMessage - server-stream чата; модель берётся из LoadModel
SendMessage(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ChatResponse], error)
// Embed - вектор одного текста
Embed(ctx context.Context, in *EmbedRequest, opts ...grpc.CallOption) (*EmbedResponse, error)
// EmbedBatch - векторы для списка текстов
EmbedBatch(ctx context.Context, in *EmbedBatchRequest, opts ...grpc.CallOption) (*EmbedBatchResponse, error)
}
LLMRunnerServiceClient is the client API for LLMRunnerService 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.
func NewLLMRunnerServiceClient ¶
func NewLLMRunnerServiceClient(cc grpc.ClientConnInterface) LLMRunnerServiceClient
type LLMRunnerServiceServer ¶
type LLMRunnerServiceServer interface {
// GetModels - имена моделей в model_path
GetModels(context.Context, *Empty) (*GetModelsResponse, error)
// GetServerInfo - hostname, платформа, число ядер, объём RAM
GetServerInfo(context.Context, *Empty) (*ServerInfo, error)
// GetGpuInfo - по каждой GPU: название, температура, VRAM, загрузка (%)
GetGpuInfo(context.Context, *Empty) (*GetGpuInfoResponse, error)
// RunnerProbe - агрегат для балансировщика: backend, хост, GPU, загруженная модель
RunnerProbe(context.Context, *Empty) (*RunnerProbeResponse, error)
// LoadModel - загрузить веса в RAM/VRAM; вызывать до SendMessage
LoadModel(context.Context, *LoadModelRequest) (*Empty, error)
// GetLoadedModel - признак загрузки и идентификаторы
GetLoadedModel(context.Context, *Empty) (*GetLoadedModelResponse, error)
// UnloadModel - выгрузить текущую модель и освободить память
UnloadModel(context.Context, *Empty) (*Empty, error)
// ResetMemory - выгрузка модели (эквивалент UnloadModel)
ResetMemory(context.Context, *Empty) (*Empty, error)
// SendMessage - server-stream чата; модель берётся из LoadModel
SendMessage(*SendMessageRequest, grpc.ServerStreamingServer[ChatResponse]) error
// Embed - вектор одного текста
Embed(context.Context, *EmbedRequest) (*EmbedResponse, error)
// EmbedBatch - векторы для списка текстов
EmbedBatch(context.Context, *EmbedBatchRequest) (*EmbedBatchResponse, error)
// contains filtered or unexported methods
}
LLMRunnerServiceServer is the server API for LLMRunnerService service. All implementations must embed UnimplementedLLMRunnerServiceServer for forward compatibility.
type LLMRunnerService_SendMessageClient ¶
type LLMRunnerService_SendMessageClient = grpc.ServerStreamingClient[ChatResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type LLMRunnerService_SendMessageServer ¶
type LLMRunnerService_SendMessageServer = grpc.ServerStreamingServer[ChatResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type LoadModelRequest ¶
type LoadModelRequest struct {
Model string `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
// contains filtered or unexported fields
}
func (*LoadModelRequest) Descriptor
deprecated
func (*LoadModelRequest) Descriptor() ([]byte, []int)
Deprecated: Use LoadModelRequest.ProtoReflect.Descriptor instead.
func (*LoadModelRequest) GetModel ¶
func (x *LoadModelRequest) GetModel() string
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 ResponseFormat ¶
type ResponseFormat struct {
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Schema *string `protobuf:"bytes,2,opt,name=schema,proto3,oneof" json:"schema,omitempty"`
// contains filtered or unexported fields
}
func (*ResponseFormat) Descriptor
deprecated
func (*ResponseFormat) Descriptor() ([]byte, []int)
Deprecated: Use ResponseFormat.ProtoReflect.Descriptor instead.
func (*ResponseFormat) GetSchema ¶
func (x *ResponseFormat) GetSchema() string
func (*ResponseFormat) GetType ¶
func (x *ResponseFormat) GetType() string
func (*ResponseFormat) ProtoMessage ¶
func (*ResponseFormat) ProtoMessage()
func (*ResponseFormat) ProtoReflect ¶
func (x *ResponseFormat) ProtoReflect() protoreflect.Message
func (*ResponseFormat) Reset ¶
func (x *ResponseFormat) Reset()
func (*ResponseFormat) String ¶
func (x *ResponseFormat) String() string
type RunnerProbeResponse ¶
type RunnerProbeResponse struct {
BackendConnected bool `protobuf:"varint,1,opt,name=backend_connected,json=backendConnected,proto3" json:"backend_connected,omitempty"`
Server *ServerInfo `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"`
Gpus []*GpuInfo `protobuf:"bytes,3,rep,name=gpus,proto3" json:"gpus,omitempty"`
LoadedModel *GetLoadedModelResponse `protobuf:"bytes,4,opt,name=loaded_model,json=loadedModel,proto3" json:"loaded_model,omitempty"`
// contains filtered or unexported fields
}
func (*RunnerProbeResponse) Descriptor
deprecated
func (*RunnerProbeResponse) Descriptor() ([]byte, []int)
Deprecated: Use RunnerProbeResponse.ProtoReflect.Descriptor instead.
func (*RunnerProbeResponse) GetBackendConnected ¶
func (x *RunnerProbeResponse) GetBackendConnected() bool
func (*RunnerProbeResponse) GetGpus ¶
func (x *RunnerProbeResponse) GetGpus() []*GpuInfo
func (*RunnerProbeResponse) GetLoadedModel ¶
func (x *RunnerProbeResponse) GetLoadedModel() *GetLoadedModelResponse
func (*RunnerProbeResponse) GetServer ¶
func (x *RunnerProbeResponse) GetServer() *ServerInfo
func (*RunnerProbeResponse) ProtoMessage ¶
func (*RunnerProbeResponse) ProtoMessage()
func (*RunnerProbeResponse) ProtoReflect ¶
func (x *RunnerProbeResponse) ProtoReflect() protoreflect.Message
func (*RunnerProbeResponse) Reset ¶
func (x *RunnerProbeResponse) Reset()
func (*RunnerProbeResponse) String ¶
func (x *RunnerProbeResponse) String() string
type SendMessageRequest ¶
type SendMessageRequest struct {
Messages []*ChatMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
StopSequences []string `protobuf:"bytes,2,rep,name=stop_sequences,json=stopSequences,proto3" json:"stop_sequences,omitempty"`
TimeoutSeconds *int32 `protobuf:"varint,3,opt,name=timeout_seconds,json=timeoutSeconds,proto3,oneof" json:"timeout_seconds,omitempty"`
GenerationParams *GenerationParams `protobuf:"bytes,4,opt,name=generation_params,json=generationParams,proto3" json:"generation_params,omitempty"`
RenderedPrompt *string `protobuf:"bytes,5,opt,name=rendered_prompt,json=renderedPrompt,proto3,oneof" json:"rendered_prompt,omitempty"`
// contains filtered or unexported fields
}
func (*SendMessageRequest) Descriptor
deprecated
func (*SendMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendMessageRequest.ProtoReflect.Descriptor instead.
func (*SendMessageRequest) GetGenerationParams ¶
func (x *SendMessageRequest) GetGenerationParams() *GenerationParams
func (*SendMessageRequest) GetMessages ¶
func (x *SendMessageRequest) GetMessages() []*ChatMessage
func (*SendMessageRequest) GetRenderedPrompt ¶
func (x *SendMessageRequest) GetRenderedPrompt() string
func (*SendMessageRequest) GetStopSequences ¶
func (x *SendMessageRequest) GetStopSequences() []string
func (*SendMessageRequest) GetTimeoutSeconds ¶
func (x *SendMessageRequest) GetTimeoutSeconds() int32
func (*SendMessageRequest) ProtoMessage ¶
func (*SendMessageRequest) ProtoMessage()
func (*SendMessageRequest) ProtoReflect ¶
func (x *SendMessageRequest) ProtoReflect() protoreflect.Message
func (*SendMessageRequest) Reset ¶
func (x *SendMessageRequest) Reset()
func (*SendMessageRequest) String ¶
func (x *SendMessageRequest) String() string
type ServerInfo ¶
type ServerInfo struct {
Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
Os string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
Arch string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"`
CpuCores int32 `protobuf:"varint,4,opt,name=cpu_cores,json=cpuCores,proto3" json:"cpu_cores,omitempty"`
MemoryTotalMb uint64 `protobuf:"varint,5,opt,name=memory_total_mb,json=memoryTotalMb,proto3" json:"memory_total_mb,omitempty"`
// contains filtered or unexported fields
}
func (*ServerInfo) Descriptor
deprecated
func (*ServerInfo) Descriptor() ([]byte, []int)
Deprecated: Use ServerInfo.ProtoReflect.Descriptor instead.
func (*ServerInfo) GetArch ¶
func (x *ServerInfo) GetArch() string
func (*ServerInfo) GetCpuCores ¶
func (x *ServerInfo) GetCpuCores() int32
func (*ServerInfo) GetHostname ¶
func (x *ServerInfo) GetHostname() string
func (*ServerInfo) GetMemoryTotalMb ¶
func (x *ServerInfo) GetMemoryTotalMb() uint64
func (*ServerInfo) GetOs ¶
func (x *ServerInfo) GetOs() string
func (*ServerInfo) ProtoMessage ¶
func (*ServerInfo) ProtoMessage()
func (*ServerInfo) ProtoReflect ¶
func (x *ServerInfo) ProtoReflect() protoreflect.Message
func (*ServerInfo) Reset ¶
func (x *ServerInfo) Reset()
func (*ServerInfo) String ¶
func (x *ServerInfo) String() string
type UnimplementedLLMRunnerServiceServer ¶
type UnimplementedLLMRunnerServiceServer struct{}
UnimplementedLLMRunnerServiceServer 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 (UnimplementedLLMRunnerServiceServer) Embed ¶
func (UnimplementedLLMRunnerServiceServer) Embed(context.Context, *EmbedRequest) (*EmbedResponse, error)
func (UnimplementedLLMRunnerServiceServer) EmbedBatch ¶
func (UnimplementedLLMRunnerServiceServer) EmbedBatch(context.Context, *EmbedBatchRequest) (*EmbedBatchResponse, error)
func (UnimplementedLLMRunnerServiceServer) GetGpuInfo ¶
func (UnimplementedLLMRunnerServiceServer) GetGpuInfo(context.Context, *Empty) (*GetGpuInfoResponse, error)
func (UnimplementedLLMRunnerServiceServer) GetLoadedModel ¶
func (UnimplementedLLMRunnerServiceServer) GetLoadedModel(context.Context, *Empty) (*GetLoadedModelResponse, error)
func (UnimplementedLLMRunnerServiceServer) GetModels ¶
func (UnimplementedLLMRunnerServiceServer) GetModels(context.Context, *Empty) (*GetModelsResponse, error)
func (UnimplementedLLMRunnerServiceServer) GetServerInfo ¶
func (UnimplementedLLMRunnerServiceServer) GetServerInfo(context.Context, *Empty) (*ServerInfo, error)
func (UnimplementedLLMRunnerServiceServer) LoadModel ¶
func (UnimplementedLLMRunnerServiceServer) LoadModel(context.Context, *LoadModelRequest) (*Empty, error)
func (UnimplementedLLMRunnerServiceServer) ResetMemory ¶
func (UnimplementedLLMRunnerServiceServer) RunnerProbe ¶
func (UnimplementedLLMRunnerServiceServer) RunnerProbe(context.Context, *Empty) (*RunnerProbeResponse, error)
func (UnimplementedLLMRunnerServiceServer) SendMessage ¶
func (UnimplementedLLMRunnerServiceServer) SendMessage(*SendMessageRequest, grpc.ServerStreamingServer[ChatResponse]) error
func (UnimplementedLLMRunnerServiceServer) UnloadModel ¶
type UnsafeLLMRunnerServiceServer ¶
type UnsafeLLMRunnerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLLMRunnerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LLMRunnerServiceServer will result in compilation errors.