Documentation
¶
Index ¶
- func Merge(ctx context.Context, cfg MergeConfig) error
- func ValidateOutputIntegrity(outputRoot string, features map[string]meta.FeatureSpec) error
- type MergeConfig
- type StagingConfig
- type StagingWriter
- func (w *StagingWriter) AddFrame(ctx context.Context, frame map[string]any) error
- func (w *StagingWriter) AppendRGBVideoFrame(ctx context.Context, key string, frame video.VideoFrameRGB24) error
- func (w *StagingWriter) Close() error
- func (w *StagingWriter) SaveEpisode(ctx context.Context) (manifest.Episode, error)
- func (w *StagingWriter) SetH264Remux(ctx context.Context, tracks map[string][][]byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ValidateOutputIntegrity ¶ added in v1.1.0
func ValidateOutputIntegrity(outputRoot string, features map[string]meta.FeatureSpec) error
ValidateOutputIntegrity checks merged dataset has data parquet and video files.
Types ¶
type MergeConfig ¶
type StagingConfig ¶
type StagingWriter ¶
type StagingWriter struct {
// contains filtered or unexported fields
}
func NewStagingWriter ¶
func NewStagingWriter(cfg StagingConfig) (*StagingWriter, error)
func (*StagingWriter) AppendRGBVideoFrame ¶ added in v1.1.0
func (w *StagingWriter) AppendRGBVideoFrame(ctx context.Context, key string, frame video.VideoFrameRGB24) error
AppendRGBVideoFrame writes one RGB frame into a lazily-created encoder (decode fallback path).
func (*StagingWriter) Close ¶
func (w *StagingWriter) Close() error
func (*StagingWriter) SaveEpisode ¶
func (*StagingWriter) SetH264Remux ¶ added in v1.1.0
Click to show internal directories.
Click to hide internal directories.