Documentation ¶
Index ¶
- func ConfigJson(config Configuration) json.RawMessage
- type Configuration
- type Connector
- type Factory
- type KeyValueSource
- type Planner
- func (p *Planner) ConfigureFetch() plan.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) EnterOperationDefinition(ref int)
- func (p *Planner) Register(visitor *plan.Visitor, configuration plan.DataSourceConfiguration, ...) (err error)
- type ResponseKeyValueEntry
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigJson ¶
func ConfigJson(config Configuration) json.RawMessage
Types ¶
type Configuration ¶
type KeyValueSource ¶
type KeyValueSource struct { Operation wgpb.NatsKvOperation // contains filtered or unexported fields }
type Planner ¶
type Planner struct {
// contains filtered or unexported fields
}
func (*Planner) ConfigureFetch ¶
func (p *Planner) ConfigureFetch() plan.FetchConfiguration
func (*Planner) ConfigureSubscription ¶
func (p *Planner) ConfigureSubscription() plan.SubscriptionConfiguration
func (*Planner) DataSourcePlanningBehavior ¶
func (p *Planner) DataSourcePlanningBehavior() plan.DataSourcePlanningBehavior
func (*Planner) DownstreamResponseFieldAlias ¶
func (*Planner) EnterDocument ¶
func (*Planner) EnterField ¶
func (*Planner) EnterOperationDefinition ¶
type ResponseKeyValueEntry ¶
type ResponseKeyValueEntry struct { Key string `json:"key"` Value json.RawMessage `json:"value"` Revision uint64 `json:"revision"` Created int64 `json:"created"` }
Click to show internal directories.
Click to hide internal directories.