Ashley Jeffs

Results 229 comments of Ashley Jeffs

@danthegoodman1 the `sql_select` input might be worth copying from as there's some overlap: https://github.com/Jeffail/benthos/blob/master/internal/impl/sql/input_sql_select.go, the implementation is the exact same as public plugins so the documentation is all here: https://pkg.go.dev/github.com/Jeffail/benthos/[email protected]/public/service....

@danthegoodman1 yeah a ticker based commit would probably be the best option here, and then a final flush on `Close`. Benthos is quite strict about graceful termination so you can...

The stack trace looks as though `Connect` is being blocked on `pgxpool.ConnectConfig`. Not sure why the service would shut down immediately, maybe try without your plugin and something like `http_server`...

Hey @huttotw, is there a formal spec for how a schema registry server expects these paths to be formed? We've had issues with this before: https://github.com/benthosdev/benthos/issues/2190 but I find it...

Hey @arunx2 it looks as though you're still using the older plugin APIs and config structs to register the plugin so before merging this we'd need to manually migrate it...

The existing elasticsearch output is now using the new APIs so you can mostly just copy/paste it: https://github.com/benthosdev/benthos/blob/main/internal/impl/elasticsearch/output.go

Hey @arunx2, I finally got around to working on this, sorry for the wait. It's been merged via https://github.com/benthosdev/benthos/commit/db914ab6de1c6836e0987c95059137c2407dbc48. I made a few changes to the original design as I...

@piclemx take a look at my follow up commit: https://github.com/benthosdev/benthos/commit/0b25d042b73ec1bd1bfe0d25db0d00eef45c76b5

Hey @lucasoares, the interval returned by a rate limit isn't intended to match the exact amount of time for the caller to wait before moving on, it's meant as a...

Hey @aadicodes, I think Couchbase support makes sense. There's an official client lib that looks well supported https://github.com/couchbase/gocb. In terms of how we'd integrate it I think an output similar...