engineconfigloader

Documentation

Index

• type ApiTransportFactory
• type DefaultFactoryResolver
  • func NewDefaultFactoryResolver(transportFactory ApiTransportFactory, baseTransport http.RoundTripper, ...) *DefaultFactoryResolver
  • func (d *DefaultFactoryResolver) Resolve(ds *wgpb.DataSourceConfiguration) (plan.PlannerFactory, error)
• type EngineConfigLoader
  • func New(resolvers ...FactoryResolver) *EngineConfigLoader
  • func (l *EngineConfigLoader) Load(engineConfig wgpb.EngineConfiguration) (*plan.Configuration, error)
  • func (l *EngineConfigLoader) LoadJson(engineConfigJson json.RawMessage) (*plan.Configuration, error)
• type FactoryResolver

Types

type ApiTransportFactory

type ApiTransportFactory func(tripper http.RoundTripper) http.RoundTripper

type DefaultFactoryResolver

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

func NewDefaultFactoryResolver

func NewDefaultFactoryResolver(transportFactory ApiTransportFactory, baseTransport http.RoundTripper, debug bool, log abstractlogger.Logger) *DefaultFactoryResolver

func (*DefaultFactoryResolver) Resolve

func (d *DefaultFactoryResolver) Resolve(ds *wgpb.DataSourceConfiguration) (plan.PlannerFactory, error)

type EngineConfigLoader

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

func New

func New(resolvers ...FactoryResolver) *EngineConfigLoader

func (*EngineConfigLoader) Load

func (l *EngineConfigLoader) Load(engineConfig wgpb.EngineConfiguration) (*plan.Configuration, error)

func (*EngineConfigLoader) LoadJson

func (l *EngineConfigLoader) LoadJson(engineConfigJson json.RawMessage) (*plan.Configuration, error)

type FactoryResolver

type FactoryResolver interface {
	Resolve(ds *wgpb.DataSourceConfiguration) (plan.PlannerFactory, error)
}