ddc

Documentation

Index

• func CreateEngine(id string, ctx cruntime.ReconcileRequestContext) (engine base.Engine, err error)
• func GenerateEngineID(namespacedName types.NamespacedName) string
• func InferEngineImpl(runtimeStatus fluidv1alpha1.RuntimeStatus, defaultImpl string) string

Functions

func CreateEngine

func CreateEngine(id string, ctx cruntime.ReconcileRequestContext) (engine base.Engine, err error)

CreateEngine chooses one engine implementation according to `ctx.EngineImpl` and builds a concrete engine.

func GenerateEngineID

func GenerateEngineID(namespacedName types.NamespacedName) string

GenerateEngineID generates an Engine ID

func InferEngineImpl

func InferEngineImpl(runtimeStatus fluidv1alpha1.RuntimeStatus, defaultImpl string) string

InferEngineImpl infers which engineImpl should be use for a given runtime. For a new runtime which has not been set up, returns the default engineImpl. NOTE: for backward compatibility, the func checks runtimeStatus.ValueFileConfigmap to identify the engine implementation for a running Runtime. TODO: This could change in the future by checking runtimeStatus.engineImpl instead.