nats

Jul 24, 2023

Changes in this version

+ func ConfigJson(config Configuration) json.RawMessage

+ type Configuration struct

+ Bucket string

+ History int32

+ Operation wgpb.NatsKvOperation

+ ServerURL string

+ Token string

+ type Connector struct

+ type Factory struct

+ func (f *Factory) Planner(ctx context.Context) plan.DataSourcePlanner

+ type KeyValueSource struct

+ Operation wgpb.NatsKvOperation

+ func (s *KeyValueSource) Load(ctx context.Context, input []byte, w io.Writer) (err error)

+ func (s *KeyValueSource) Start(ctx context.Context, input []byte, next chan<- []byte) error

+ type Planner struct

+ 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 struct

+ Created int64

+ Key string

+ Revision uint64

+ Value json.RawMessage