llmrunnerpb

package
v0.0.0-...-92056dc Latest Latest
Warning

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

Go to latest
Published: Jul 1, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
var File_llmrunner_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Embedding.ProtoReflect.Descriptor instead.

func (*Embedding) GetValues

func (x *Embedding) GetValues() []float32

func (*Embedding) ProtoMessage

func (*Embedding) ProtoMessage()

func (*Embedding) ProtoReflect

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

func (*Embedding) Reset

func (x *Embedding) Reset()

func (*Embedding) String

func (x *Embedding) String() string

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use GpuInfo.ProtoReflect.Descriptor instead.

func (*GpuInfo) GetMemoryTotalMb

func (x *GpuInfo) GetMemoryTotalMb() uint64

func (*GpuInfo) GetMemoryUsedMb

func (x *GpuInfo) GetMemoryUsedMb() uint64

func (*GpuInfo) GetName

func (x *GpuInfo) GetName() string

func (*GpuInfo) GetTemperatureC

func (x *GpuInfo) GetTemperatureC() int32

func (*GpuInfo) GetUtilizationPercent

func (x *GpuInfo) GetUtilizationPercent() uint32

func (*GpuInfo) ProtoMessage

func (*GpuInfo) ProtoMessage()

func (*GpuInfo) ProtoReflect

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

func (*GpuInfo) Reset

func (x *GpuInfo) Reset()

func (*GpuInfo) String

func (x *GpuInfo) String() string

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.

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) EmbedBatch

func (UnimplementedLLMRunnerServiceServer) GetGpuInfo

func (UnimplementedLLMRunnerServiceServer) GetLoadedModel

func (UnimplementedLLMRunnerServiceServer) GetModels

func (UnimplementedLLMRunnerServiceServer) GetServerInfo

func (UnimplementedLLMRunnerServiceServer) LoadModel

func (UnimplementedLLMRunnerServiceServer) ResetMemory

func (UnimplementedLLMRunnerServiceServer) RunnerProbe

func (UnimplementedLLMRunnerServiceServer) SendMessage

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.

Jump to

Keyboard shortcuts

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