runtime

Documentation

Index

• Constants
• type Client
  • func NewOllamaClient(k8sClient client.Client, namespace string, rconfig config.RuntimeConfig, ...) Client
• type Manager
  • func NewManager(k8sClient client.Client, rtClient Client) *Manager
  • func (m *Manager) GetLLMAddress(modelID string) (string, error)
  • func (m *Manager) Initialize(ctx context.Context, apiReader client.Reader, namespace string) error
  • func (m *Manager) ListInProgressModels() []string
  • func (m *Manager) ListSyncedModelIDs(ctx context.Context) []string
  • func (m *Manager) PullModel(ctx context.Context, modelID string) error
  • func (m *Manager) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (m *Manager) SetupWithManager(mgr ctrl.Manager) error

Constants

const RuntimeNameOllama = "ollama"

RuntimeNameOllama is the name of the Ollama runtime.

Types

type Client

type Client interface {
	GetAddress(name string) string
	DeployRuntime(ctx context.Context, modelID string) error
}

Client is the interface for managing runtimes.

func NewOllamaClient

func NewOllamaClient(
	k8sClient client.Client,
	namespace string,
	rconfig config.RuntimeConfig,
	oconfig config.OllamaConfig,
) Client

NewOllamaClient creates a new Ollama runtime client.

type Manager

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

Manager manages runtimes.

func NewManager

func NewManager(k8sClient client.Client, rtClient Client) *Manager

NewManager creates a new runtime manager.

func (*Manager) GetLLMAddress

func (m *Manager) GetLLMAddress(modelID string) (string, error)

GetLLMAddress returns the address of the LLM.

func (*Manager) Initialize

func (m *Manager) Initialize(ctx context.Context, apiReader client.Reader, namespace string) error

Initialize initializes ready and pending runtimes. This function is not thread-safe.

func (*Manager) ListInProgressModels

func (m *Manager) ListInProgressModels() []string

ListInProgressModels returns the list of models that are in progress.

func (*Manager) ListSyncedModelIDs

func (m *Manager) ListSyncedModelIDs(ctx context.Context) []string

ListSyncedModelIDs returns the list of models that are synced.

func (*Manager) PullModel

func (m *Manager) PullModel(ctx context.Context, modelID string) error

PullModel pulls the model from the model manager.

func (*Manager) Reconcile

func (m *Manager) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile reconciles the runtime.

func (*Manager) SetupWithManager

func (m *Manager) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the runtime manager with the given controller manager.