Versions in this module Expand all Collapse all v2 v2.0.2 Jan 29, 2024 v2.0.1 Jan 29, 2024 Changes in this version + func ConfigJson(config Configuration) json.RawMessage + type Configuration struct + Events []EventConfiguration + type Connector interface + New func(ctx context.Context) PubSub + type EventConfiguration struct + FieldName string + Topic string + Type EventType + TypeName string + type EventType string + const EventTypePublish + const EventTypeRequest + const EventTypeSubscribe + func EventTypeFromString(s string) (EventType, error) + type Factory struct + Connector Connector + func (f *Factory) Planner(ctx context.Context) plan.DataSourcePlanner + type Planner struct + func (p *Planner) ConfigureFetch() resolve.FetchConfiguration + func (p *Planner) ConfigureSubscription() plan.SubscriptionConfiguration + func (p *Planner) DataSourcePlanningBehavior() plan.DataSourcePlanningBehavior + func (p *Planner) DownstreamResponseFieldAlias(downstreamFieldRef int) (alias string, exists bool) + func (p *Planner) EnterDocument(operation, definition *ast.Document) + func (p *Planner) EnterField(ref int) + func (p *Planner) Register(visitor *plan.Visitor, configuration plan.DataSourceConfiguration, ...) error + func (p *Planner) UpstreamSchema(dataSourceConfig plan.DataSourceConfiguration) *ast.Document + type PubSub interface + ID func() string + Publish func(ctx context.Context, topic string, data []byte) error + Request func(ctx context.Context, topic string, data []byte, w io.Writer) error + Subscribe func(ctx context.Context, topic string, updater resolve.SubscriptionUpdater) error + type PublishDataSource struct + func (s *PublishDataSource) Load(ctx context.Context, input []byte, w io.Writer) error + type RequestDataSource struct + func (s *RequestDataSource) Load(ctx context.Context, input []byte, w io.Writer) error + type SubscriptionSource struct + func (s *SubscriptionSource) Start(ctx *resolve.Context, input []byte, updater resolve.SubscriptionUpdater) error + func (s *SubscriptionSource) UniqueRequestID(ctx *resolve.Context, input []byte, xxh *xxhash.Digest) error
Go to main page