Versions in this module Expand all Collapse all v0 v0.5.1 Oct 16, 2020 Changes in this version + func CollectTypes(typ graphql.Type, types map[graphql.Type]string) error + func ExecuteRequest(ctx context.Context, req *thunderpb.ExecuteRequest, gqlSchema *graphql.Schema, ...) (*thunderpb.ExecuteResponse, error) + func MarshalQuery(query *graphql.Query) (*thunderpb.Query, error) + func UnmarshalQuery(query *thunderpb.Query) (*graphql.Query, error) + type DirectExecutorClient struct + Client thunderpb.ExecutorServer + func (c *DirectExecutorClient) Execute(ctx context.Context, request *QueryRequest) (*QueryResponse, error) + type Executor struct + Executors map[string]ExecutorClient + func NewExecutor(ctx context.Context, executors map[string]ExecutorClient, ...) (*Executor, error) + func (e *Executor) Execute(ctx context.Context, query *graphql.Query, metadata interface{}) (interface{}, []interface{}, error) + type ExecutorClient interface + Execute func(ctx context.Context, request *QueryRequest) (*QueryResponse, error) + type FieldInfo struct + Services map[string]bool + type IntrospectionQueryResult struct + Schema introspectionSchema + type IntrospectionSchemaSyncer struct + func NewIntrospectionSchemaSyncer(ctx context.Context, executors map[string]ExecutorClient, ...) *IntrospectionSchemaSyncer + func (s *IntrospectionSchemaSyncer) FetchPlanner(ctx context.Context) (*Planner, error) + type MergeMode string + const Intersection + const Union + type PathStep struct + Kind StepKind + Name string + type Plan struct + After []*Plan + Kind string + Path []PathStep + SelectionSet *graphql.SelectionSet + Service string + Type string + type Planner struct + func NewPlanner(types *SchemaWithFederationInfo, optionalServiceSelector ServiceSelector) (*Planner, error) + type QueryRequest struct + Metadata interface{} + Query *graphql.Query + type QueryResponse struct + Metadata interface{} + Result []byte + type SchemaSyncer interface + FetchPlanner func(ctx context.Context) (*Planner, error) + type SchemaSyncerConfig struct + SchemaSyncIntervalSeconds func(ctx context.Context) int64 + SchemaSyncer SchemaSyncer + type SchemaWithFederationInfo struct + Fields map[*graphql.Field]*FieldInfo + Schema *graphql.Schema + func ConvertVersionedSchemas(schemas serviceSchemas) (*SchemaWithFederationInfo, error) + type Server struct + func NewServer(schema *graphql.Schema) (*Server, error) + func (s *Server) Execute(ctx context.Context, req *thunderpb.ExecuteRequest) (*thunderpb.ExecuteResponse, error) + type ServiceSelector func(typeName string, fieldName string) string + type StepKind int + const KindField + const KindType + type Syncer struct