streamruntime

type DeclStats struct {
	Streams    int
	Consumers  int
	Publishers int
}

type Declarations interface {
	IsEmpty() bool
	Stats() DeclStats
}

type Handle interface {
	Start(ctx context.Context, decls Declarations) error
	Close() error
	StopConsumers()
	SetTenantStamps(enabled bool)
	Ready() bool
	Stats() map[string]any
}

type HeldMessage struct {
	Consumer   string
	Stream     string
	Offset     int64
	TenantID   string
	Data       []byte
	Properties map[string]any
	HeldAt     time.Time
}

type HoldLedger interface {
	Park(ctx context.Context, msg *HeldMessage) error
	HeldTenants(ctx context.Context, consumer string) ([]string, error)
}

type HoldReplayer interface {
	HoldConsumers() []string
	Replay(ctx context.Context, consumer string, msg *HeldMessage) error
	// ReloadHeld refreshes one consumer's held set from the ledger. It takes no
	// listing: the generation that guards the set has to be read BEFORE the ledger
	// is, and only the streams package holds it, so the read belongs on that side
	// of the port.
	ReloadHeld(ctx context.Context, consumer string) error
}

type ManagerOptions struct {
	URI                 string
	AddressResolverHost string
	AddressResolverPort int
	OffsetStoreCount    int
	OffsetStoreInterval time.Duration
	Logger              logger.Logger
	Hold                HoldLedger
}

type Module interface {
	Name() string
}

type Runtime interface {
	CollectDeclarations(modules []Module, log logger.Logger) (Declarations, error)
	NewManager(opts *ManagerOptions) Handle
	CanDrainHold() bool
}