core

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2026 License: GPL-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Core 

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

Core composes the upload, prepared-release, duplicate-check, media, description, and history capabilities over one dependency snapshot. It owns the repository only when construction opened that repository internally. Operation contexts are per call and are not retained by Core.

func NewWithContext 

func NewWithContext(ctx context.Context, deps api.CoreDependencies) (*Core, error)

NewWithContext constructs a Core and applies ctx to initialization work such as opening and migrating an internally created repository. The context is not retained after construction.

func (*Core) CancelReleaseWorkflowOperation added in v0.3.0 

func (c *Core) CancelReleaseWorkflowOperation(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	operationID api.WorkflowOperationID,
) (api.WorkflowOperationStatus, error)

CancelReleaseWorkflowOperation requests cancellation of one active operation.

func (*Core) Close 

func (c *Core) Close() error

Close closes the repository only when this Core opened and owns it.

func (*Core) ContinueReleaseWorkflow added in v0.3.0 

func (c *Core) ContinueReleaseWorkflow(
	ctx context.Context,
	ownerID string,
	request api.ContinueReleaseWorkflowRequest,
) (releaseworkflow.CommandResult, error)

ContinueReleaseWorkflow reconciles typed desired state through the central planner.

func (*Core) CurrentReleaseWorkflow added in v0.3.0 

func (c *Core) CurrentReleaseWorkflow(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
) (releaseworkflow.CommandResult, error)

CurrentReleaseWorkflow returns the current aggregate and immutable stage projections.

func (*Core) DVDMenuCapability added in v0.2.4 

func (c *Core) DVDMenuCapability(ctx context.Context) (api.DVDMenuEngineInfo, error)

DVDMenuCapability reports the pure-Go engine version and the external FFmpeg dvdvideo menu capability without returning executable paths.

func (*Core) DeleteAllHistoryReleases 

func (c *Core) DeleteAllHistoryReleases(ctx context.Context) (int, error)

DeleteAllHistoryReleases deletes stored releases sequentially. On cancellation or failure, the returned count includes releases deleted before the error.

func (*Core) DeleteHistoryRelease 

func (c *Core) DeleteHistoryRelease(ctx context.Context, sourcePath string) error

DeleteHistoryRelease purges a stored source and related stored child paths, removing only artifacts validated beneath the configured tmp, cache, or nfo roots.

func (*Core) DiscoverPlaylists 

func (c *Core) DiscoverPlaylists(ctx context.Context, sourcePath string) ([]api.PlaylistInfo, error)

DiscoverPlaylists scans the local source for Blu-ray playlists and returns them by descending score. Durations are seconds and item sizes are bytes.

func (*Core) ExecuteReleaseWorkflow added in v0.3.0 

func (c *Core) ExecuteReleaseWorkflow(
	ctx context.Context,
	ownerID string,
	command releaseworkflow.Command,
) (releaseworkflow.CommandResult, error)

ExecuteReleaseWorkflow applies one owner-scoped typed workflow command.

func (*Core) GetHistoryOverview 

func (c *Core) GetHistoryOverview(ctx context.Context, sourcePath string) (api.HistoryOverview, error)

GetHistoryOverview assembles persisted metadata, overrides, media, tracker state, and upload history for one source path.

func (*Core) GetInputHistory added in v0.3.2 

func (c *Core) GetInputHistory(ctx context.Context, source string) (api.InputHistory, error)

GetInputHistory returns retained correction and track evidence without triggering provider requests or media inspection.

func (*Core) ListHistory 

func (c *Core) ListHistory(ctx context.Context) ([]api.HistoryEntry, error)

ListHistory returns stored releases with their latest display status.

func (*Core) LiveTestEnabled added in v0.3.2 

func (c *Core) LiveTestEnabled() bool

LiveTestEnabled reports process policy without exposing mutable configuration.

func (*Core) OpenReleaseWorkflowMediaArtifact added in v0.3.0 

func (c *Core) OpenReleaseWorkflowMediaArtifact(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	media api.MediaArtifactSetRef,
	artifactID api.PublicResourceID,
) (releaseworkflow.MediaArtifactContent, error)

OpenReleaseWorkflowMediaArtifact returns one owner-scoped opaque workflow media resource without exposing its retained filesystem path.

func (*Core) OpenReleaseWorkflowPreview added in v0.3.0 

func (c *Core) OpenReleaseWorkflowPreview(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	previewID api.PublicResourceID,
) (releaseworkflow.MediaArtifactContent, error)

OpenReleaseWorkflowPreview returns one owner-scoped opaque transient preview.

func (*Core) PreviewReleaseWorkflowFrame added in v0.3.0 

func (c *Core) PreviewReleaseWorkflowFrame(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	expectedRevision api.WorkflowRevision,
	discID string,
	timestampSeconds float64,
) (api.FramePreview, error)

PreviewReleaseWorkflowFrame creates one owner-scoped non-authoritative frame preview.

func (*Core) ReleaseWorkflowMediaPlan added in v0.3.0 

func (c *Core) ReleaseWorkflowMediaPlan(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
) (api.MediaPlan, error)

ReleaseWorkflowMediaPlan returns the safe media plan for the workflow's current exact release and tracker projections.

func (*Core) ReleaseWorkflowOperation added in v0.3.0 

func (c *Core) ReleaseWorkflowOperation(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	operationID api.WorkflowOperationID,
) (api.WorkflowOperationStatus, error)

ReleaseWorkflowOperation returns one pollable workflow operation.

func (*Core) ReleaseWorkflowOperationEvents added in v0.3.0 

func (c *Core) ReleaseWorkflowOperationEvents(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	operationID api.WorkflowOperationID,
	after uint64,
	limit int,
) ([]api.WorkflowEvent, error)

ReleaseWorkflowOperationEvents returns retained operation events after one workflow-global cursor.

func (*Core) RenderDescription 

func (c *Core) RenderDescription(ctx context.Context, raw string) (string, error)

RenderDescription renders raw BBCode after rejecting a pre-canceled context.

func (*Core) StageReleaseWorkflowMediaResource added in v0.3.0 

func (c *Core) StageReleaseWorkflowMediaResource(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	expectedRevision api.WorkflowRevision,
	content releaseworkflow.StagedMediaContent,
) (api.WorkflowResourceRef, error)

StageReleaseWorkflowMediaResource retains private image bytes for a later exact workflow attachment command.

func (*Core) StartLiveTestReleaseWorkflowUpload added in v0.3.2 

func (c *Core) StartLiveTestReleaseWorkflowUpload(
	ctx context.Context,
	ownerID string,
	request api.CreateReleaseWorkflowUploadRequest,
) (releaseworkflow.CommandResult, error)

StartLiveTestReleaseWorkflowUpload drives ordinary rule evaluation to dry-run. This in-process CLI entrypoint is intentionally absent from the public API.

func (*Core) StartReleaseWorkflow added in v0.3.0 

func (c *Core) StartReleaseWorkflow(
	ctx context.Context,
	ownerID string,
	command releaseworkflow.Command,
) (api.WorkflowOperationStatus, error)

StartReleaseWorkflow durably accepts one long-running workflow command.

func (*Core) StartReleaseWorkflowUpload added in v0.3.0 

func (c *Core) StartReleaseWorkflowUpload(
	ctx context.Context,
	ownerID string,
	request api.CreateReleaseWorkflowUploadRequest,
) (releaseworkflow.CommandResult, error)

StartReleaseWorkflowUpload starts or idempotently replays one owner-scoped durable composite upload.

func (*Core) SubmitReleaseWorkflowUploadFeedback added in v0.3.0 

func (c *Core) SubmitReleaseWorkflowUploadFeedback(
	ctx context.Context,
	ownerID string,
	workflowID api.WorkflowID,
	feedback api.ReleaseWorkflowUploadFeedback,
) (releaseworkflow.CommandResult, error)

SubmitReleaseWorkflowUploadFeedback applies one exact required-action response and starts the resumed composite operation.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.