storage

type DSNSelector func(context.Context) string

type Dialect string

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

type Options struct {
	// DataDirectory overrides the platform data directory used by an empty DSN.
	DataDirectory string
	// EventTTL controls how long inactive streams are retained.
	EventTTL time.Duration
	// MaxEventBytes bounds retained event payload bytes across all streams.
	MaxEventBytes int64
	// MaxOpenConns bounds PostgreSQL and MySQL pool size.
	MaxOpenConns int
	// MaxIdleConns bounds idle PostgreSQL and MySQL connections.
	MaxIdleConns int
	// ConnMaxLifetime limits connection reuse. The default remains below common
	// MySQL and proxy idle limits.
	ConnMaxLifetime time.Duration
	// Now is used for retention decisions. It defaults to time.Now.
	Now func() time.Time
}

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

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

type Store interface {
	mcp.EventStore
	Prune(context.Context) error
	Close() error
}