stateio

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

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

type EngineConfig struct {
	State StateConfig `json:"state"`
}

type ExportError struct {
	Code    ExportErrorCode
	Message string
	Err     error
}

type ExportErrorCode string

type ExportInstancesResult struct {
	InstancesCount int
	Data           []byte
}

type ExportParams struct {
	// FilePath is the path to the output file (local or remote URL).
	FilePath string
	// InstanceFilters is a list of instance IDs or names to export.
	// If empty, all instances are exported.
	InstanceFilters []string
	// EngineConfig contains the deploy engine configuration.
	// Used to determine the storage backend (memfile or postgres).
	EngineConfig *EngineConfig
	// FileSystem is the filesystem to use for local file operations.
	FileSystem afero.Fs
	// Logger is the logger to use for logging.
	Logger core.Logger
	// RemoteOptions contains options for uploading to remote storage.
	RemoteOptions *RemoteUploadOptions
	// Exporter is an optional StateExporter for export.
	// If not provided, a default exporter will be created based on EngineConfig.
	Exporter StateExporter
}

type ExportResult struct {
	Success        bool   `json:"success"`
	InstancesCount int    `json:"instancesCount,omitempty"`
	FilePath       string `json:"filePath,omitempty"`
	Message        string `json:"message"`
}

type ImportError struct {
	Code    ImportErrorCode
	Message string
	Err     error
}

type ImportErrorCode string

type ImportInstancesResult struct {
	InstancesCount int
}

type ImportParams struct {
	// FilePath is the path to the input file (local or remote URL).
	FilePath string
	// EngineConfig contains the deploy engine configuration.
	// Used to determine the storage backend (memfile or postgres).
	EngineConfig *EngineConfig
	// FileSystem is the filesystem to use for operations.
	FileSystem afero.Fs
	// Logger is the logger to use for logging.
	Logger core.Logger
	// FileData contains the raw file data to import.
	// If provided, FilePath is ignored for reading (but may be used for logging).
	FileData []byte
	// RemoteOptions contains options for downloading from remote storage.
	RemoteOptions *RemoteDownloadOptions
	// Importer is an optional StateImporter for import.
	// If not provided, a default importer will be created based on EngineConfig.
	Importer StateImporter
}

type ImportResult struct {
	Success        bool   `json:"success"`
	InstancesCount int    `json:"instancesCount,omitempty"`
	Message        string `json:"message"`
}

type RemoteDownloadOptions struct {
	// S3Endpoint overrides the default S3 endpoint (useful for testing with LocalStack).
	S3Endpoint string
	// S3UsePathStyle enables path-style addressing for S3 (required for LocalStack).
	S3UsePathStyle bool
	// GCSEndpoint overrides the default GCS endpoint (useful for testing with fake-gcs-server).
	GCSEndpoint string
	// AzureConnectionString is the connection string for Azure Blob Storage.
	// If empty, DefaultAzureCredential will be used.
	AzureConnectionString string
}

type RemoteUploadOptions struct {
	// S3Endpoint overrides the default S3 endpoint (useful for testing with LocalStack).
	S3Endpoint string
	// S3UsePathStyle enables path-style addressing for S3 (required for LocalStack).
	S3UsePathStyle bool
	// GCSEndpoint overrides the default GCS endpoint (useful for testing with fake-gcs-server).
	GCSEndpoint string
	// AzureConnectionString is the connection string for Azure Blob Storage.
	// If empty, DefaultAzureCredential will be used.
	AzureConnectionString string
}

type StateConfig struct {
	StorageEngine               string `json:"storage_engine"`
	MemFileStateDir             string `json:"memfile_state_dir"`
	PostgresUser                string `json:"postgres_user"`
	PostgresPassword            string `json:"postgres_password"`
	PostgresHost                string `json:"postgres_host"`
	PostgresPort                int    `json:"postgres_port"`
	PostgresDatabase            string `json:"postgres_database"`
	PostgresSSLMode             string `json:"postgres_ssl_mode"`
	PostgresPoolMaxConns        int    `json:"postgres_pool_max_conns"`
	PostgresPoolMaxConnLifetime string `json:"postgres_pool_max_conn_lifetime"`
}

type StateExporter interface {
	// ExportInstances exports instances by their IDs or names.
	// If instanceFilters is empty, exports all instances.
	// Returns the full instance state including child blueprints.
	ExportInstances(ctx context.Context, instanceFilters []string) ([]state.InstanceState, error)
}

type StateImporter interface {
	// ImportInstances imports a slice of instance states.
	// Implementations should handle batch operations efficiently where possible.
	ImportInstances(ctx context.Context, instances []state.InstanceState) error
}