engineconfigloader

Documentation

Index

• type ApiTransportFactory
• type ApiTransportFactoryRoundTripperOptions
• type DefaultFactoryResolver
  • func NewDefaultFactoryResolver(transportFactory ApiTransportFactory, baseTransport *http.Transport, ...) *DefaultFactoryResolver
  • func (d *DefaultFactoryResolver) Resolve(ds *wgpb.DataSourceConfiguration) (plan.PlannerFactory, error)
• type EngineConfigLoader
  • func New(opts EngineConfigLoaderOptions, resolvers ...FactoryResolver) *EngineConfigLoader
  • func (l *EngineConfigLoader) Load(engineConfig *wgpb.EngineConfiguration, wgServerUrl string) (*plan.Configuration, error)
  • func (l *EngineConfigLoader) LoadInternedString(engineConfig *wgpb.EngineConfiguration, str *wgpb.InternedString) (string, error)
• type EngineConfigLoaderOptions
• type FactoryResolver

Types

type ApiTransportFactory

type ApiTransportFactory interface {
	RoundTripper(transport *http.Transport, opts ApiTransportFactoryRoundTripperOptions) http.RoundTripper
	DefaultTransportTimeout() time.Duration
	DefaultHTTPProxyURL() *url.URL
}

type ApiTransportFactoryRoundTripperOptions

type ApiTransportFactoryRoundTripperOptions struct {
	DataSourceID        string
	EnableStreamingMode bool
}

type DefaultFactoryResolver

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

func NewDefaultFactoryResolver

func NewDefaultFactoryResolver(transportFactory ApiTransportFactory, baseTransport *http.Transport,
	log *zap.Logger, hooksClient *hooks.Client) *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(opts EngineConfigLoaderOptions, resolvers ...FactoryResolver) *EngineConfigLoader

func (*EngineConfigLoader) Load

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

func (*EngineConfigLoader) LoadInternedString

func (l *EngineConfigLoader) LoadInternedString(engineConfig *wgpb.EngineConfiguration, str *wgpb.InternedString) (string, error)

type EngineConfigLoaderOptions

type EngineConfigLoaderOptions struct {
	WunderGraphDir       string
	NATSDefaultServerURL string
}

type FactoryResolver

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