engine

type Configuration ¶

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

func NewConfiguration(schema *graphql.Schema) Configuration

func (e *Configuration) AddDataSource(dataSource plan.DataSource)

func (e *Configuration) AddFieldConfiguration(fieldConfig plan.FieldConfiguration)

func (e *Configuration) DataSources() []plan.DataSource

func (e *Configuration) FieldConfigurations() plan.FieldConfigurations

func (e *Configuration) Schema() *graphql.Schema

func (e *Configuration) SetCustomResolveMap(customResolveMap map[string]resolve.CustomResolve)

func (e *Configuration) SetDataSources(dataSources []plan.DataSource)

func (e *Configuration) SetFieldConfigurations(fieldConfigs plan.FieldConfigurations)

func (e *Configuration) SetWebsocketBeforeStartHook(hook WebsocketBeforeStartHook)

type DataSourceGeneratorOption ¶

type DataSourceGeneratorOption func(options *dataSourceGeneratorOptions)

func WithDataSourceGeneratorSubscriptionClientFactory(factory graphql_datasource.GraphQLSubscriptionClientFactory) DataSourceGeneratorOption

func WithDataSourceGeneratorSubscriptionConfiguration(streamingClient *http.Client, subscriptionType SubscriptionType) DataSourceGeneratorOption

type ExecutionEngine ¶

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

func NewExecutionEngine(ctx context.Context, logger abstractlogger.Logger, engineConfig Configuration, resolverOptions resolve.ResolverOptions) (*ExecutionEngine, error)

func (e *ExecutionEngine) Execute(ctx context.Context, operation *graphql.Request, writer resolve.SubscriptionResponseWriter, options ...ExecutionOptions) error

func (e *ExecutionEngine) GetWebsocketBeforeStartHook() WebsocketBeforeStartHook

type ExecutionOptions ¶

type ExecutionOptions func(ctx *internalExecutionContext)

func WithAdditionalHttpHeaders(headers http.Header, excludeByKeys ...string) ExecutionOptions

func WithRequestTraceOptions(options resolve.TraceOptions) ExecutionOptions

type FederationEngineConfigFactory ¶

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

FederationEngineConfigFactory is used to create an engine config for a supergraph with multiple data sources for subgraphs.

func NewFederationEngineConfigFactory(engineCtx context.Context, subgraphsConfigs []SubgraphConfiguration, opts ...FederationEngineConfigFactoryOption) *FederationEngineConfigFactory

func (f *FederationEngineConfigFactory) BuildEngineConfiguration() (conf Configuration, err error)

func (f *FederationEngineConfigFactory) LoadInternedString(engineConfig *nodev1.EngineConfiguration, str *nodev1.InternedString) (string, error)

type FederationEngineConfigFactoryOption ¶

type FederationEngineConfigFactoryOption func(options *federationEngineConfigFactoryOptions)

func WithCustomResolveMap(customResolveMap map[string]resolve.CustomResolve) FederationEngineConfigFactoryOption

func WithFederationHttpClient(client *http.Client) FederationEngineConfigFactoryOption

func WithFederationStreamingClient(client *http.Client) FederationEngineConfigFactoryOption

func WithFederationSubscriptionClientFactory(factory graphql_datasource.GraphQLSubscriptionClientFactory) FederationEngineConfigFactoryOption

func WithFederationSubscriptionType(subscriptionType SubscriptionType) FederationEngineConfigFactoryOption

type LocalTypeFieldExtractor ¶

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

LocalTypeFieldExtractor takes an ast.Document as input and generates the TypeField configuration for both root and child nodes. Root nodes are the root operation types (usually Query, Mutation and Schema--though these types can be configured via the schema keyword) plus "entities" as defined by the Apollo federation specification. In short, entities are types with a @key directive. Child nodes are field types recursively accessible via a root node. Nodes are either object or interface definitions or extensions. Root nodes only include "local" fields; they don't include fields that have the @external directive.

func NewLocalTypeFieldExtractor(document *ast.Document) *LocalTypeFieldExtractor

func (e *LocalTypeFieldExtractor) GetAllNodes() (rootNodes []plan.TypeField, childNodes []plan.TypeField)

type ProxyEngineConfigFactory ¶

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

ProxyEngineConfigFactory is used to create an engine config with a single upstream and a single data source for this upstream.

func NewProxyEngineConfigFactory(engineCtx context.Context, schema *graphql.Schema, proxyUpstreamConfig ProxyUpstreamConfig, opts ...ProxyEngineConfigFactoryOption) *ProxyEngineConfigFactory

func (p *ProxyEngineConfigFactory) EngineConfiguration() (Configuration, error)

type ProxyEngineConfigFactoryOption ¶

type ProxyEngineConfigFactoryOption func(options *proxyEngineConfigFactoryOptions)

func WithDataSourceID(id string) ProxyEngineConfigFactoryOption

func WithProxyHttpClient(client *http.Client) ProxyEngineConfigFactoryOption

func WithProxyStreamingClient(client *http.Client) ProxyEngineConfigFactoryOption

func WithProxySubscriptionClientFactory(factory graphqlDataSource.GraphQLSubscriptionClientFactory) ProxyEngineConfigFactoryOption

type ProxyUpstreamConfig ¶

type ProxyUpstreamConfig struct {
	URL              string
	Method           string
	StaticHeaders    http.Header
	SubscriptionType SubscriptionType
}

ProxyUpstreamConfig holds configuration to configure a single data source to a single upstream.

type SubgraphConfiguration ¶

type SubgraphConfiguration struct {
	Name string
	URL  string
	SDL  string

	SubscriptionUrl      string
	SubscriptionProtocol SubscriptionProtocol
}

type SubscriptionProtocol ¶

type SubscriptionProtocol string

const (
	SubscriptionProtocolWS      SubscriptionProtocol = "ws"
	SubscriptionProtocolSSE     SubscriptionProtocol = "sse"
	SubscriptionProtocolSSEPost SubscriptionProtocol = "sse_post"
)

type SubscriptionType ¶

type SubscriptionType int

type TypeFieldLookupKey ¶

type TypeFieldLookupKey string

func CreateTypeFieldLookupKey(typeName string, fieldName string) TypeFieldLookupKey

type WebsocketBeforeStartHook ¶

type WebsocketBeforeStartHook interface {
	OnBeforeStart(reqCtx context.Context, operation *graphql.Request) error
}