temporal_fileprocessing

package
v0.18.0 Latest Latest
Warning

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

Go to latest
Published: Feb 21, 2026 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FileProcessingFlow

func FileProcessingFlow(ctx context.Context, log Logger, filename string) (*am.Machine, error)

FileProcessingFlow is an example of how to use the FileProcessing machine.

Types

type BlobStore

type BlobStore struct{}

type Logger

type Logger func(msg string, args ...any)

type MachineHandlers

type MachineHandlers struct {
	// default handler for the build in Exception state
	am.ExceptionHandler
	BlobStore         *BlobStore
	Filename          string
	DownloadedName    string
	ProcessedFileName string
}

MachineHandlers is a struct of handlers & their data for the FileProcessing machine. None of the handlers can block.

func (*MachineHandlers) DownloadingFileState

func (h *MachineHandlers) DownloadingFileState(e *am.Event)

DownloadingFileState is a _final_ entry handler for the DownloadingFile state.

func (*MachineHandlers) ProcessingFileEnd

func (h *MachineHandlers) ProcessingFileEnd(e *am.Event)

ProcessingFileEnd is a _final_ exit handler for the ProcessingFile state.

func (*MachineHandlers) ProcessingFileState

func (h *MachineHandlers) ProcessingFileState(e *am.Event)

ProcessingFileState is a _final_ entry handler for the ProcessingFile state.

func (*MachineHandlers) UploadingFileEnd

func (h *MachineHandlers) UploadingFileEnd(e *am.Event)

UploadingFileEnd is a _final_ exit handler for the UploadingFile state.

func (*MachineHandlers) UploadingFileState

func (h *MachineHandlers) UploadingFileState(e *am.Event)

UploadingFileState is a _final_ transition handler for the UploadingFile state.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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