This repository has been archived by the owner on Dec 8, 2023. It is now read-only.
Init AMQP k6 plugin #1
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
* Open connection * Publish message to queue
As we have k6 limitation and cannot read data in parallel
Add listening functionality
simskij
suggested changes
Jul 21, 2021
README.md
Outdated
| @@ -2,7 +2,7 @@ | |||
| > | |||
| > As this is a proof of concept, it won't be supported by the k6 team. | |||
| > It may also break in the future as xk6 evolves. USE AT YOUR OWN RISK! | |||
| > Any issues with the tool should be raised [here](https://github.com/lxkuz/xk6-amqp/issues). | |||
| > Any issues with the tool should be raised [here](https://github.com/k6io/xk6-amqp/issues). | |||
There was a problem hiding this comment.
Suggested change
| > Any issues with the tool should be raised [here](https://github.com/k6io/xk6-amqp/issues). | |
| > Any issues with the tool should be raised [here](https://github.com/grafana/xk6-amqp/issues). |
There was a problem hiding this comment.
@simskij does it mean I should use github.com/grafana instead of github.com/k6io everywhere?
README.md
Outdated
| @@ -30,7 +30,7 @@ Then: | |||
|
|
|||
| 2. Build the binary: | |||
| ```bash | |||
| $ xk6 build --with github.com/lxkuz/xk6-amqp@latest | |||
| $ xk6 build --with github.com/k6io/xk6-amqp@latest | |||
There was a problem hiding this comment.
Suggested change
| $ xk6 build --with github.com/k6io/xk6-amqp@latest | |
| $ xk6 build --with github.com/grafana/xk6-amqp@latest |
amqp.go
Outdated
Comment on lines
117
to
118
| modules.Register("k6/x/amqp/queues", &queues) | ||
| modules.Register("k6/x/amqp/exchanges", &exchanges) |
There was a problem hiding this comment.
Suggested change
| modules.Register("k6/x/amqp/queues", &queues) | |
| modules.Register("k6/x/amqp/exchanges", &exchanges) | |
| modules.Register("k6/x/amqp/queue", &queues) | |
| modules.Register("k6/x/amqp/exchange", &exchanges) |
Use singularis throughout unless the pluralization adds semantic value.
exchanges.go
Outdated
| ConnectionUrl string | ||
| } | ||
|
|
||
| type EchangeDeclareOptions struct { |
There was a problem hiding this comment.
Suggested change
| type EchangeDeclareOptions struct { | |
| type ExchangeDeclareOptions struct { |
|
@simskij review comments handled |
simskij
suggested changes
Jul 23, 2021
README.md
Outdated
Comment on lines
60
to
67
| Queues.declare({ | ||
| name: queueName, | ||
| // durable: false, | ||
| // delete_when_unused: false, | ||
| // exclusive: false, | ||
| // no_wait: false, | ||
| // args: null | ||
| }) |
queues.go
Outdated
Comment on lines
1
to
116
| Name string | ||
| Durable bool | ||
| DeleteWhenUnused bool | ||
| Exclusive bool | ||
| NoWait bool | ||
| Args amqpDriver.Table | ||
| } | ||
|
|
||
| type QueueBindOptions struct { | ||
| QueueName string | ||
| ExchangeName string | ||
| RoutingKey string | ||
| NoWait bool | ||
| Args amqpDriver.Table | ||
| } | ||
|
|
||
| type QueueUnindOptions struct { | ||
| QueueName string | ||
| ExchangeName string | ||
| RoutingKey string | ||
| Args amqpDriver.Table | ||
| } | ||
|
|
||
| func (queues *Queues) Declare(options DeclareOptions) (amqpDriver.Queue, error) { | ||
| ch, err := queues.Connection.Channel() | ||
| if err != nil { | ||
| return amqpDriver.Queue{}, err | ||
| } | ||
| defer ch.Close() | ||
| return ch.QueueDeclare( | ||
| options.Name, | ||
| options.Durable, | ||
| options.DeleteWhenUnused, | ||
| options.Exclusive, | ||
| options.NoWait, | ||
| options.Args, | ||
| ) | ||
| } | ||
|
|
||
| func (queues *Queues) Inspect(name string) (amqpDriver.Queue, error) { | ||
| ch, err := queues.Connection.Channel() | ||
| if err != nil { | ||
| return amqpDriver.Queue{}, err | ||
| } | ||
| defer ch.Close() | ||
| return ch.QueueInspect(name) | ||
| } | ||
|
|
||
| func (queues *Queues) Delete(name string) error { | ||
| ch, err := queues.Connection.Channel() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| defer ch.Close() | ||
| _, err = ch.QueueDelete( | ||
| name, | ||
| false, // ifUnused | ||
| false, // ifEmpty | ||
| false, // noWait | ||
| ) | ||
| return err | ||
| } | ||
|
|
||
| func (queues *Queues) Bind(options QueueBindOptions) error { | ||
| ch, err := queues.Connection.Channel() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| defer ch.Close() | ||
| return ch.QueueBind( | ||
| options.QueueName, | ||
| options.RoutingKey, | ||
| options.ExchangeName, | ||
| options.NoWait, | ||
| options.Args, | ||
| ) | ||
| } | ||
|
|
||
| func (queues *Queues) Unbind(options QueueUnindOptions) error { | ||
| ch, err := queues.Connection.Channel() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| defer ch.Close() | ||
| return ch.QueueUnbind( | ||
| options.QueueName, | ||
| options.RoutingKey, | ||
| options.ExchangeName, | ||
| options.Args, | ||
| ) | ||
| } | ||
|
|
||
| func (queues *Queues) Purge(name string, noWait bool) (int, error) { | ||
| ch, err := queues.Connection.Channel() | ||
| if err != nil { | ||
| return 0, err | ||
| } | ||
| defer ch.Close() | ||
| return ch.QueuePurge(name, noWait) | ||
| } |
| @@ -0,0 +1,100 @@ | |||
| package amqp | |||
javaducky
pushed a commit
that referenced
this pull request
Nov 9, 2022
…ck-cypher Feature/add messagepack cypher
Sign up for free
to subscribe to this conversation on GitHub.
Already have an account?
Sign in.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Initial AMQP functionality including: