grpcdatasource

Apr 27, 2026

Changes in this version

+ const InvalidRef

+ type CallKind uint8

+ const CallKindEntity

+ const CallKindRequired

+ const CallKindResolve

+ const CallKindStandard

+ type DataSource struct

+ func NewDataSource(client grpc.ClientConnInterface, config DataSourceConfig) (*DataSource, error)

+ func (d *DataSource) Load(ctx context.Context, headers http.Header, input []byte) (data []byte, err error)

+ func (d *DataSource) LoadWithFiles(ctx context.Context, headers http.Header, input []byte, ...) (data []byte, err error)

+ type DataSourceConfig struct

+ Compiler *RPCCompiler

+ Definition *ast.Document

+ Disabled bool

+ FederationConfigs plan.FederationFieldConfigurations

+ Mapping *GRPCMapping

+ Operation *ast.Document

+ SubgraphName string

+ type DataType int8

+ const DataTypeBool

+ const DataTypeBytes

+ const DataTypeDouble

+ const DataTypeEnum

+ const DataTypeFloat

+ const DataTypeInt32

+ const DataTypeInt64

+ const DataTypeMessage

+ const DataTypeString

+ const DataTypeUint32

+ const DataTypeUint64

+ const DataTypeUnknown

+ func (i DataType) String() string

+ type DependencyGraph struct

+ func NewDependencyGraph(executionPlan *RPCExecutionPlan) *DependencyGraph

+ func (g *DependencyGraph) Fetch(index int) (FetchItem, error)

+ func (g *DependencyGraph) FetchDependencies(fetch *FetchItem) ([]FetchItem, error)

+ func (g *DependencyGraph) SetFetchData(index int, serviceCall *ServiceCall)

+ func (g *DependencyGraph) TopologicalSortResolve(resolver func(nodes []FetchItem) error) error

+ type Document struct

+ Enums []Enum

+ Imports []string

+ Messages []Message

+ Methods []Method

+ Package string

+ Services []Service

+ func (d *Document) EnumByName(name string) (Enum, bool)

+ func (d *Document) MessageByName(name string) (Message, bool)

+ func (d *Document) MessageByRef(ref int) Message

+ func (d *Document) MessageRefByName(name string) int

+ func (d *Document) ServiceByName(name string) *Service

+ type EntityRPCConfig struct

+ Key string

+ RequiredFields RequiredFieldsRPCMapping

+ type Enum struct

+ Name string

+ Values []EnumValue

+ type EnumValue struct

+ GraphqlValue string

+ Name string

+ Number int32

+ type EnumValueMapping struct

+ TargetValue string

+ Value string

+ type FetchItem struct

+ DependentFetches []int

+ ID int

+ Plan *RPCCall

+ ServiceCall *ServiceCall

+ type Field struct

+ MessageRef int

+ Name string

+ Number int32

+ Optional bool

+ Ref int

+ Repeated bool

+ Type DataType

+ func (f *Field) IsMessage() bool

+ func (f *Field) ResolveUnderlyingMessage(doc *Document) *Message

+ type FieldArgumentMap map[string]string

+ type FieldMap map[string]FieldMapData

+ type FieldMapData struct

+ ArgumentMappings FieldArgumentMap

+ TargetName string

+ type GRPCConfiguration struct

+ Compiler *RPCCompiler

+ Disabled bool

+ Mapping *GRPCMapping

+ type GRPCMapping struct

+ EntityRPCs map[string][]EntityRPCConfig

+ EnumValues map[string][]EnumValueMapping

+ Fields map[string]FieldMap

+ MutationRPCs RPCConfigMap[RPCConfig]

+ QueryRPCs RPCConfigMap[RPCConfig]

+ ResolveRPCs RPCConfigMap[ResolveRPCMapping]

+ Service string

+ SubscriptionRPCs RPCConfigMap[RPCConfig]

+ func (g *GRPCMapping) FindEntityRPCConfig(typeName, key string) (RPCConfig, bool)

+ func (g *GRPCMapping) FindEnumValueMapping(enumName, enumValue string) (string, bool)

+ func (g *GRPCMapping) FindFieldArgumentMapping(typeName, fieldName, argumentName string) (string, bool)

+ func (g *GRPCMapping) FindFieldMapping(typeName string, fieldName string) (string, bool)

+ func (g *GRPCMapping) FindRequiredFieldsRPCConfig(typeName, key, field string) (RequiredFieldsRPCTypeField, bool)

+ func (g *GRPCMapping) FindResolveTypeFieldMapping(typeName, fieldName string) *ResolveRPCTypeField

+ type LevelInfo struct

+ Optional bool

+ type ListMetadata struct

+ LevelInfo []LevelInfo

+ NestingLevel int

+ type Message struct

+ Desc protoref.MessageDescriptor

+ Fields map[uint64]Field

+ Name string

+ func (m *Message) AllocFields(count int)

+ func (m *Message) GetField(name string) *Field

+ func (m *Message) SetField(f Field)

+ type Method struct

+ InputName string

+ InputRef int

+ Name string

+ OutputName string

+ OutputRef int

+ type NodeKind int

+ const NodeKindEnum

+ const NodeKindMessage

+ const NodeKindService

+ const NodeKindUnknown

+ type OneOfType uint8

+ const OneOfTypeInterface

+ const OneOfTypeNone

+ const OneOfTypeUnion

+ func (o OneOfType) FieldName() string

+ type PlanVisitor interface

+ PlanOperation func(operation, definition *ast.Document) (*RPCExecutionPlan, error)

+ func NewPlanner(subgraphName string, mapping *GRPCMapping, ...) (PlanVisitor, error)

+ type ProtoConfig struct

+ Schema string

+ type RPCCall struct

+ DependentCalls []int

+ ID int

+ Kind CallKind

+ MethodName string

+ Request RPCMessage

+ RequestedEntityType string

+ Response RPCMessage

+ ResponsePath ast.Path

+ ServiceName string

+ type RPCCompiler struct

+ Ancestor []Message

+ func NewProtoCompiler(schema string, mapping *GRPCMapping) (*RPCCompiler, error)

+ func (p *RPCCompiler) CompileFetches(graph *DependencyGraph, fetches []FetchItem, inputData gjson.Result) ([]ServiceCall, error)

+ func (p *RPCCompiler) CompileNode(graph *DependencyGraph, fetch FetchItem, inputData gjson.Result) (ServiceCall, error)

+ type RPCConfig struct

+ RPC string

+ Request string

+ Response string

+ type RPCConfigMap map[string]T

+ type RPCExecutionPlan struct

+ Calls []RPCCall

+ func (r *RPCExecutionPlan) String() string

+ type RPCField struct

+ Alias string

+ EnumName string

+ IsListType bool

+ JSONPath string

+ ListMetadata *ListMetadata

+ Message *RPCMessage

+ Name string

+ Optional bool

+ ProtoTypeName DataType

+ Repeated bool

+ ResolvePath ast.Path

+ StaticValue string

+ func (r *RPCField) AliasOrPath() string

+ func (r *RPCField) IsOptionalScalar() bool

+ func (r *RPCField) ToOptionalTypeMessage(protoName string) *RPCMessage

+ type RPCFieldSelectionSet map[string]RPCFields

+ func (r RPCFieldSelectionSet) Add(fragmentName string, field ...RPCField)

+ func (r RPCFieldSelectionSet) SelectFieldsForTypes(validTypes []string) RPCFields

+ type RPCFields []RPCField

+ func (r RPCFields) ByName(name string) *RPCField

+ func (r RPCFields) Exists(name, alias string) bool

+ func (r RPCFields) Last() *RPCField

+ type RPCMapping interface

+ type RPCMessage struct

+ Fields RPCFields

+ FragmentFields RPCFieldSelectionSet

+ MemberTypes []string

+ Name string

+ OneOfType OneOfType

+ func (r *RPCMessage) IsOneOf() bool

+ func (r *RPCMessage) SelectValidTypes(typeName string) []string

+ type RequiredFieldsRPCMapping map[string]RequiredFieldsRPCTypeField

+ type RequiredFieldsRPCTypeField struct

+ TargetName string

+ type ResolveRPCMapping map[string]ResolveRPCTypeField

+ type ResolveRPCTypeField struct

+ FieldMappingData FieldMapData

+ RPC string

+ Request string

+ Response string

+ type Service struct

+ FullName string

+ MethodsRefs []int

+ Name string

+ type ServiceCall struct

+ Input protoref.Message

+ MethodName string

+ Output protoref.Message

+ RPC *RPCCall

+ ServiceName string

+ Skip bool

+ func (s *ServiceCall) MethodFullName() string