busruntime

type AttemptDecision uint8

type Continuation struct {
	ID          string
	WorkflowID  string
	DispatchID  string
	Phase       string
	Sequence    int
	Declaration int
	Trigger     ContinuationSummary
}

type ContinuationOutcome struct {
	Invocation      Continuation
	Status          string
	FailureCategory string
	CreatedAt       time.Time
	ScheduledAt     time.Time
	SettledAt       time.Time
}

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

type ContinuationSummary struct {
	Kind      string
	MemberID  string
	Total     int
	Pending   int
	Processed int
	Failed    int
	NextIndex int
	Completed bool
	Cancelled bool
}

type DeliveryAttempt struct {
	Number   int
	MaxRetry int
}

type DeliveryMetadata struct {
	Continuation  *Continuation `json:"continuation,omitempty"`
	SchemaVersion int           `json:"schema_version"`
	DispatchID    string        `json:"dispatch_id,omitempty"`
	JobID         string        `json:"job_id,omitempty"`
	ChainID       string        `json:"chain_id,omitempty"`
	BatchID       string        `json:"batch_id,omitempty"`
	Queue         string        `json:"queue,omitempty"`
}

type DeliveryProvenance struct {
	// GenerationID is an opaque identifier generated by the settlement owner
	// for the physical delivery currently invoking the handler.
	GenerationID string
	// RecoveredGenerationID identifies the earlier unsettled generation when
	// that identity survived reclamation.
	RecoveredGenerationID string
	// Recovered reports stale-generation evidence even when a legacy delivery
	// did not retain an owner identifier.
	Recovered bool
}

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

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

type DirectRuntime interface {
	Runtime
	// BusDispatchDirect submits application bytes with correlation kept in the metadata channel.
	BusDispatchDirect(ctx context.Context, jobType string, payload []byte, metadata DeliveryMetadata, opts JobOptions) error
}

type Handler func(ctx context.Context, job InboundJob) error

type InboundJob interface {
	Bind(dst any) error
	PayloadBytes() []byte
}

type JobOptions struct {
	Queue     string
	Delay     time.Duration
	Timeout   time.Duration
	Retry     int
	Backoff   time.Duration
	UniqueFor time.Duration
}

type Runtime interface {
	BusRegister(jobType string, handler Handler)
	BusDispatch(ctx context.Context, jobType string, payload []byte, opts JobOptions) error
	StartWorkers(ctx context.Context) error
	Shutdown(ctx context.Context) error
}