coreruntime

type Dependencies struct {
	SQLDatabases map[string]*sql.DB
	RedisClients map[string]*redis.Client
	Tracer       runtimemodules.Tracer
	Logger       runtimemodules.Logger
	Redsync      *redsync.Redsync
}

type Engine interface {
	context.Context

	// Lifecycle
	Start(
		opt StartOperationOptions,
	) (Engine, error)
	Stop() error
	Cleanup() error

	// LOGGER
	Logger() runtimemodules.Logger

	// STORE
	Get(key string) (any, bool)
	Set(key string, value any)

	// HTTP
	HTTP(url string) aych.Request

	// REDIS
	RDB(
		key string,
	) gopts.Option[*redis.Client]

	DLock(key string) (*redsync.Mutex, error)

	// SQL
	SQL(key string) gopts.Option[squeel.Pipeline]
	SQLBegin(key, id string) (squeel.Pipeline, bool, error)
	SQLCommit(key, id string) error
	SQLRollback(key, id string) error

	// TRACES
	TraceID() string
	SpanID() string
	ParentID() string
}

type EngineOptions struct {
	Context  gopts.Option[context.Context]
	Timeout  gopts.Option[time.Duration]
	TraceID  gopts.Option[string]
	SpanID   gopts.Option[string]
	ParentID gopts.Option[string]
}

type StartOperationOptions struct {
	ModuleName    string
	OperationName string
	TransientArgs []runtimemodules.LoggerField
	ScopedArgs    []runtimemodules.LoggerField
}