stack

package

Go to main page

Versions in this module

v0

v0.15.0

Sep 13, 2026

v0.14.0

Sep 10, 2026

v0.13.0

Sep 8, 2026

v0.12.3

Mar 27, 2026

v0.12.2

Mar 26, 2026

v0.12.1

Mar 26, 2026

v0.12.0

Mar 26, 2026

v0.11.6

Mar 24, 2026

v0.11.5

Mar 16, 2026

v0.11.3

Mar 9, 2026

Changes in this version

+ func FilterFilesFromCheckpoint(files []string, checkpoint *IngestCheckpoint, resumeFrom string) ([]string, int, error)

+ func SaveCheckpoint(checkpoint *IngestCheckpoint, path string) error

+ type CollectionIngestConfig struct

+ BatchSize int

+ ChunkSize int

+ Embedding string

+ Flags []string

+ ImageStorage string

+ Images bool

+ MinioBucket string

+ RestartEvery int

+ SkipAllImages bool

+ Source string

+ Type string

+ Workers int

+ type IngestCheckpoint struct

+ Collection string

+ CompletedFiles []string

+ FailedFiles []FailedFile

+ LastUpdate time.Time

+ PendingFiles []string

+ StartTime time.Time

+ func InitCheckpoint(collection string, files []string, existingCheckpoint *IngestCheckpoint) *IngestCheckpoint

+ func LoadCheckpoint(path string) (*IngestCheckpoint, error)

+ func (c *IngestCheckpoint) GetFailedFile(file string) *FailedFile

+ func (c *IngestCheckpoint) MarkFileCompleted(file string)

+ func (c *IngestCheckpoint) MarkFileFailed(file string, attempts int, errorMsg string)

type IngestConfig

+ AutoRestart bool

+ CheckpointEvery int

+ CheckpointFile string

+ ClusterInfo *ClusterInfo

+ MaxRetries int

+ PortForwardCtx **PortForwardContext

+ RestartDelay int

+ RestartEvery int

+ ResumeFrom string

+ SkipFailed bool

type IngestionConfig

+ Collections map[string]CollectionIngestConfig

v0.11.2

Mar 7, 2026

v0.11.1

Mar 6, 2026

v0.11.0

Mar 6, 2026

v0.10.3

Feb 27, 2026

Changes in this version

+ func CheckDependencies(runtime string) error

+ func CommandExists(cmd string) bool

+ func CopyHelmTemplates(outputDir string) error

+ func EnhanceClusterError(err error, provider string) error

+ func EnhanceHelmError(err error, chartPath, releaseName string) error

+ func EnhancePodError(err error, podName, context string) error

+ func GeneratePM2Config(config *StackConfig, outputPath string) error

+ func GetPodLogs(selector, context string, follow bool, tail int) error

+ func HelmInstall(chartPath, releaseName, namespace string, timeout string, context string) error

+ func HelmUninstall(releaseName, namespace string, context string) error

+ func IngestToStack(cfg IngestConfig) error

+ func PM2List() (string, error)

+ func PM2Logs(appName string, lines int, follow bool) error

+ func PM2Monit() error

+ func PM2Restart(appName string) error

+ func PM2Start(appName, configPath string) error

+ func PM2Status(appName string) (string, error)

+ func PM2Stop(appName string) error

+ func WaitForPods(selector, context string, timeout time.Duration) error

type DashboardConfig

+ PM2 *PM2Config

+ Runtime string

+ type IngestConfig struct

+ BatchSize int

+ ChunkSize int

+ CollectionName string

+ DataPath string

+ EmbeddingModel string

+ MilvusLocalPort int

+ ParallelWorkers int

+ ProgressCallback func(string)

+ Type string

+ type PM2Config struct

+ AppName string

+ Autorestart bool

+ Cwd string

+ Env map[string]string

+ ErrorLog string

+ Instances int

+ KillTimeout int

+ LogDateFormat string

+ MaxMemoryRestart string

+ MaxRestarts int

+ MergeLogs bool

+ MinUptime string

+ OutLog string

+ Script string

+ Watch bool

+ type PodInfo struct

+ Age string

+ Component string

+ Name string

+ Ready string

+ Restarts string

+ Status string

+ func GetPods(selector, context string) ([]PodInfo, error)

+ type PortForwardContext struct

+ Cancel context.CancelFunc

+ Cmd *exec.Cmd

+ LocalPort int

+ func StartMilvusPortForward(clusterInfo *ClusterInfo) (*PortForwardContext, error)

+ func (p *PortForwardContext) Stop()

v0.9.31

Feb 23, 2026

Changes in this version

+ const DefaultStackFile

+ const DefaultStateDir

+ func DeleteCluster(info *ClusterInfo) error

+ func GenerateHelmChart(config *StackConfig, outputDir string) error

+ func GetClusterStatus(info *ClusterInfo) (string, error)

+ func GetRuntimeVersion(runtime ContainerRuntime) (string, error)

+ func SaveClusterInfo(info *ClusterInfo) error

+ func SaveHelmValues(values *HelmValues, outputPath string) error

+ func SaveStackConfig(config *StackConfig, path string) error

+ func StackExists() bool

+ func ValidateConfig(config *StackConfig) error

+ func ValidateRuntime(runtime ContainerRuntime) error

+ type APIRoute struct

+ Auth string

+ Collection string

+ Methods []string

+ Path string

+ Type string

+ type AutoScaling struct

+ MaxNodeCount int

+ MinNodeCount int

+ type BackupConfig struct

+ Enabled bool

+ RetentionDays int

+ Schedule string

+ type BuildConfig struct

+ Cache bool

+ Context string

+ Dockerfile string

+ Target string

+ type CheckpointConfig struct

+ Enabled bool

+ Path string

+ SaveInterval int

+ type ChunkingConfig struct

+ ChunkOverlap int

+ ChunkSize int

+ Strategy string

+ type CleanupConfig struct

+ CompressOldLogs bool

+ RemoveCheckpointsOnSuccess bool

+ RetainLogsDays int

+ type ClusterInfo struct

+ ContainerRuntime string

+ Context string

+ CreatedAt time.Time

+ Name string

+ Provider string

+ Status string

+ func CreateKindCluster(config *StackConfig) (*ClusterInfo, error)

+ func CreateMinikubeCluster(config *StackConfig) (*ClusterInfo, error)

+ func LoadClusterInfo() (*ClusterInfo, error)

+ type CollectionConfig struct

+ Chunking *ChunkingConfig

+ Description string

+ Embedding *EmbeddingConfig

+ Name string

+ Schema SchemaConfig

+ Sources []DataSource

+ Type string

+ type ContainerRuntime string

+ const RuntimeDocker

+ const RuntimeNone

+ const RuntimePodman

+ func DetectContainerRuntime() (ContainerRuntime, error)

+ func GetRuntimeCommand(preferredRuntime string) (ContainerRuntime, error)

+ type DashboardConfig struct

+ Enabled bool

+ Type string

+ Web *WebDashboard

+ type DashboardState struct

+ Port int

+ Status string

+ URL string

+ type DataSource struct

+ Mode string

+ Options map[string]interface{}

+ Pattern string

+ Type string

+ type DeploymentConfig struct

+ PVCSize string

+ Replicas int

+ StorageClass string

+ type DevConfig struct

+ Command string

+ HotReload bool

+ Port int

+ type EKSConfig struct

+ NodeGroups []EKSNodeGroup

+ Region string

+ type EKSNodeGroup struct

+ DesiredSize int

+ InstanceType string

+ MaxSize int

+ MinSize int

+ Name string

+ type EmbeddingConfig struct

+ Model string

+ Provider string

+ type FailedFile struct

+ Attempts int

+ Error string

+ File string

+ type GKEConfig struct

+ NodePools []GKENodePool

+ Zone string

+ type GKENodePool struct

+ AutoScaling *AutoScaling

+ MachineType string

+ Name string

+ NodeCount int

+ type HTTPGetAction struct

+ Path string

+ Port int

+ type HealthCheck struct

+ Liveness *Probe

+ Readiness *Probe

+ type HelmHealthCheck struct

+ Liveness HelmProbe

+ Readiness HelmProbe

+ type HelmImageStorage struct

+ Enabled bool

+ Replicas int

+ Resources HelmResources

+ Storage HelmStorage

+ Type string

+ type HelmProbe struct

+ FailureThreshold int

+ InitialDelaySeconds int

+ Path string

+ PeriodSeconds int

+ Port int

+ type HelmResourceLimits struct

+ CPU string

+ Memory string

+ type HelmResources struct

+ Limits HelmResourceLimits

+ Requests HelmResourceLimits

+ type HelmService struct

+ MetricsPort int

+ Port int

+ Type string

+ type HelmStackMeta struct

+ Name string

+ Version string

+ type HelmStorage struct

+ Class string

+ Size string

+ type HelmValues struct

+ ImageStorage *HelmImageStorage

+ Stack HelmStackMeta

+ VectorDB HelmVectorDB

+ func GenerateHelmValues(config *StackConfig) (*HelmValues, error)

+ type HelmVectorDB struct

+ Health HelmHealthCheck

+ Replicas int

+ Resources HelmResources

+ Service HelmService

+ Storage HelmStorage

+ Type string

+ Version string

+ type ImageStorageConfig struct

+ Bucket string

+ Endpoint string

+ Resources *ResourceRequirements

+ Type string

+ type InfrastructureConfig struct

+ ImageStorage *ImageStorageConfig

+ LLM *LLMConfig

+ VectorDB VectorDBConfig

+ type IngestionConfig struct

+ BatchSize int

+ Checkpoint *CheckpointConfig

+ Monitoring *MonitoringConfig

+ ParallelWorkers int

+ Phases []PhaseConfig

+ Retry *RetryConfig

+ Timeout *TimeoutConfig

+ type IngestionState struct

+ CompletedFiles []string

+ CurrentFile string

+ FailedFiles []FailedFile

+ Phase string

+ Progress Progress

+ StartedAt time.Time

+ UpdatedAt time.Time

+ type KindConfig struct

+ Config string

+ Name string

+ Nodes int

+ type KubernetesConfig struct

+ EKS *EKSConfig

+ GKE *GKEConfig

+ Kind *KindConfig

+ Minikube *MinikubeConfig

+ Provider string

+ type KubernetesResources struct

+ Deployment DeploymentConfig

+ type LLMConfig struct

+ Config map[string]interface{}

+ Models LLMModels

+ Provider string

+ type LLMModels struct

+ Chat string

+ Embedding string

+ type LogOutput struct

+ Path string

+ Type string

+ type LoggingConfig struct

+ Format string

+ Level string

+ Outputs []LogOutput

+ type MinikubeConfig struct

+ Addons []string

+ CPUs int

+ Driver string

+ Memory string

+ type MonitoringConfig struct

+ MemoryThreshold string

+ RestartOnOOM bool

+ VDBHealthCheck bool

+ type OperationsConfig struct

+ Backup *BackupConfig

+ Cleanup *CleanupConfig

+ Logging *LoggingConfig

+ type PhaseConfig struct

+ Collections []string

+ Name string

+ Parallel bool

+ RestartVDBBetweenFiles bool

+ type Probe struct

+ FailureThreshold int

+ HTTPGet *HTTPGetAction

+ InitialDelaySeconds int

+ PeriodSeconds int

+ TimeoutSeconds int

+ type Progress struct

+ Completed int

+ Failed int

+ Remaining int

+ TotalFiles int

+ type ResourceLimits struct

+ CPU string

+ Memory string

+ type ResourceRequirements struct

+ Limits ResourceLimits

+ Requests ResourceLimits

+ type RetryConfig struct

+ Backoff string

+ BaseDelay time.Duration

+ MaxAttempts int

+ type RuntimeConfig struct

+ ContainerRuntime string

+ Kubernetes KubernetesConfig

+ type SchemaConfig struct

+ Fields []SchemaField

+ VectorDimensions int

+ type SchemaField struct

+ Name string

+ Type string

+ type ServiceStatus struct

+ Health string

+ Name string

+ Resources string

+ Status string

+ Uptime string

+ type StackConfig struct

+ Collections []CollectionConfig

+ Dashboard *DashboardConfig

+ Description string

+ Infrastructure InfrastructureConfig

+ Ingestion *IngestionConfig

+ Name string

+ Operations *OperationsConfig

+ Runtime RuntimeConfig

+ Version string

+ func LoadStackConfig(path string) (*StackConfig, error)

+ type StackState struct

+ Cluster *ClusterInfo

+ Dashboard *DashboardState

+ Ingestion *IngestionState

+ Services map[string]ServiceStatus

+ UpdatedAt time.Time

+ type TimeoutConfig struct

+ PerFile time.Duration

+ Total time.Duration

+ type VectorDBConfig struct

+ Config map[string]interface{}

+ Health *HealthCheck

+ Kubernetes *KubernetesResources

+ Resources ResourceRequirements

+ Type string

+ Version string

+ type WebDashboard struct

+ API []APIRoute

+ Build *BuildConfig

+ Dev *DevConfig

+ EnvFile string

+ EnvVars map[string]string

+ Features []string

+ Framework string

+ Kubernetes *KubernetesResources

+ Language string

+ Version string

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