Documentation
¶
Overview ¶
Package organizer plans and schedules file chunks for the F2E runtime modes.
Index ¶
- func ValidateGlobalLimits(limits f2e.GlobalLimits) error
- func ValidatePrefixConfiguration(c f2e.PrefixConfiguration, limits f2e.GlobalLimits) error
- type ExecutionSummary
- type Service
- func (s Service) Plan(ctx context.Context, request f2e.OrganizerRequest) ([]f2e.ChunkJob, error)
- func (s Service) PlanWithSummary(ctx context.Context, request f2e.OrganizerRequest) (*ExecutionSummary, error)
- func (s Service) Publish(ctx context.Context, jobs []f2e.ChunkJob) error
- func (s Service) Replay(ctx context.Context, sourceJobID string, chunkIDs []string) ([]f2e.ChunkJob, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ValidateGlobalLimits ¶
func ValidateGlobalLimits(limits f2e.GlobalLimits) error
ValidateGlobalLimits checks that the global limits are within acceptable bounds.
func ValidatePrefixConfiguration ¶
func ValidatePrefixConfiguration(c f2e.PrefixConfiguration, limits f2e.GlobalLimits) error
ValidatePrefixConfiguration checks that the prefix configuration is within acceptable bounds and consistent with the global limits. It also validates routing fields (PrefixID, OutputQueueURL).
Types ¶
type ExecutionSummary ¶
type ExecutionSummary struct {
Summary *f2e.OrganizerSummary
Jobs []f2e.ChunkJob
}
ExecutionSummary contains metrics from a planning execution
type Service ¶
type Service struct {
Store port.ObjectStore
Queue port.Queue
Ledger port.JobLedger
Config config.Config
}
func (Service) PlanWithSummary ¶
func (s Service) PlanWithSummary(ctx context.Context, request f2e.OrganizerRequest) (*ExecutionSummary, error)
PlanWithSummary converts the organizer request into worker jobs and returns execution summary
Source Files
Click to show internal directories.
Click to hide internal directories.