engine

type AddressResolver func(envelope any) (string, error)

type Config struct {
	Resolver    Resolver
	Retry       RetryPolicy
	Sink        EventSink
	LaneIdleTTL time.Duration
}

type Delivery interface {
	Envelope() any
	Attempt() int
	MaxAttempts() int
	InProgress(ctx context.Context) error
	Ack(ctx context.Context) error
	Retry(ctx context.Context, delay time.Duration, reason string) error
	DeadLetter(ctx context.Context, reason string) error
}

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

type Event struct {
	Type        EventType
	Reason      string
	RetryDelay  time.Duration
	Attempt     int
	MaxAttempts int
}

type EventSink interface {
	Publish(ctx context.Context, event Event)
}

type EventType string

type Handler func(ctx context.Context, delivery Delivery) error

type LaneKeyResolver func(envelope any) string

type LaneStatus struct {
	Active int
	Keys   []string
}

type ResolveError struct {
	Address string
}

type Resolver interface {
	LaneKey(delivery Delivery) string
}

type RetryPolicy struct {
	IsRetryable    func(error) bool
	Backoff        func(attempt int) time.Duration
	RetryExhausted func(delivery Delivery) bool
}

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

type RuntimeConfig struct {
	Registry    dispatch.Registry
	AddressOf   AddressResolver
	LaneKey     LaneKeyResolver
	Retry       RetryPolicy
	Sink        EventSink
	LaneIdleTTL time.Duration
}

type Source interface {
	Run(ctx context.Context, handler Handler) error
}