diff options
| author | Valery Piashchynski <[email protected]> | 2023-01-26 14:19:09 +0100 |
|---|---|---|
| committer | GitHub <[email protected]> | 2023-01-26 14:19:09 +0100 |
| commit | f8fb555f8ee18d61868c8fa1f794191276372337 (patch) | |
| tree | 5a5ee5c0509ae8d6980bab028634e996e4adc5de | |
| parent | 9949cb9c4c2f168d3e9891247de1df8bf18856c8 (diff) | |
| parent | 31e6ca81ca5b30ff5219757953447b9e587c6d03 (diff) | |
[#1430]: pre-release: `v2023.1.0-alpha.1`v2023.1.0-alpha.1
| -rw-r--r-- | .rr.yaml | 298 | ||||
| -rw-r--r-- | go.mod | 74 | ||||
| -rw-r--r-- | go.sum | 146 |
3 files changed, 283 insertions, 235 deletions
@@ -1532,165 +1532,211 @@ jobs: # If the job has priority set to 0, it will inherit the pipeline's priority. Default: 10. priority: 1 - # Topic name: https://kafka.apache.org/intro#intro_concepts_and_terms + # Kafka brokers, array. If there is no port specified, 9092 will be used as default # - # This option is required and should not be empty. - topic: test-1 + # Required, no default + brokers: [ 127.0.0.1:9092 ] - # Offsets for the partitions + # SASL authentication options to use for all connections. Depending on the auth type, plain or aws_msk_plain sections might be removed. # - # This option is optional. If empty, RR will read from the partition 0, OffsetNewest. Should be a positive number. - # We also have 2 special cases for the offsets (negative numbers): - # -1: OffsetNewest - stands for the log head offset, i.e. the offset that will be assigned to the next message - # that will be produced to the partition. - # -2: OffsetOldest - stands for the oldest offset available on the broker for a partition. - partitions_offsets: - - 0: 0 - - 1: 0 - - 2: 0 - - # Kafka group id - # - # Optional, default - empty - group_id: "foo" + # Optional, default: empty + sasl: - # Max number of outstanding requests a connection is allowed to have before sending on it blocks - # - # Optional, default: 5. - # Throughput can improve but message ordering is not guaranteed if producer_options.idempotent is disabled, see: - # https://kafka.apache.org/protocol#protocol_network - # https://kafka.apache.org/28/documentation.html#producerconfigs_max.in.flight.requests.per.connection - max_open_requests: 100 + # PLAIN auth section ----- - # A user provided string sent with every request to the brokers for logging, debugging, and auditing purposes. - # - # Optional, default: roadrunner - client_id: "roadrunner" + # Mechanism used for the authentication + # + # Required for the section. Might be: 'aws_msk_iam' or 'plain' + mechanism: plain - # Kafka version. - # - # Defaults to the oldest supported stable version (1.0.0.0). Since Kafka provides - # backwards-compatibility, setting it to a version older than you have - # will not break anything, although it may prevent you from using the - # latest features. Setting it to a version greater than you are actually - # running may lead to random breakage. - kafka_version: 3.2.0.0 - - # Create topics configuration. If topic doesn't exist, RR may create a topic with provided configuration - # - # Optional, default: null. - create_topics: + # Username to use for authentication. + # + # Required for the plain auth mechanism. + username: foo - # Replication factor for the data stored across several Kafka brokers. + # Password to use for authentication. # - # Optional, default: 1. Docs: https://kafka.apache.org/documentation/#replication - replication_factor: 1 + # Required for the plain auth mechanism. + password: bar - # Partition replica assigment. + # Zid is an optional authorization ID to use in authenticating. # - # Optional, default: null. Docs: https://kafka.apache.org/documentation/#basic_ops_cluster_expansion - replica_assignment: - 1: [ 1,2,3 ] - 2: [ 2,3 ] + # Optional, default: empty. + zid: "foo" + + # AWS_MSK_IAM auth section ----- - # Topic creation options. + # AWS Access key ID. # - # Optional, default: null. Docs: https://kafka.apache.org/documentation/#configuration - # Note: 'compression:type' will be replaced with 'compression.type', so ':' -> '.'. - # All options should use ':' as the delimiter. - config_entries: - compression:type: snappy + # Required + access_key: foo + + # AWS Secret Access Key. + # + # + secret_key: bar + + # SessionToken, if non-empty, is a session / security token to use for authentication. + # See the following link for more details: + # + # https://docs.aws.amazon.com/STS/latest/APIReference/welcome.html + session_token: bar + + + # UserAgent is the user agent to for the client to use when connecting + # to Kafka, overriding the default "franz-go/<runtime.Version()>/<hostname>". + # Setting a UserAgent allows authorizing based on the aws:UserAgent + # condition key; see the following link for more details: + # https://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_condition-keys.html#condition-keys-useragent + user_agent: baz + + # Auto create topic for the consumer/producer + # + # Optional, default: false + auto_create_topics_enable: false # Kafka producer options # - # Optional, default: depends on Kafka version + # Optional, required only if Push/PushBatch is used. producer_options: - # Maximum permitted size of a message. + # disable_idempotent disables idempotent produce requests, opting out of + # Kafka server-side deduplication in the face of reissued requests due to + # transient network problems. + # Idempotent production is strictly a win, but does require the IDEMPOTENT_WRITE permission on CLUSTER + # (pre Kafka 3.0), and not all clients can have that permission. + # + # Optional, defaut: false + disable_idempotent: false + + # required_acks sets the required acks for produced records. # - # Optional, default: 1000000. Should be set equal to or smaller than the broker's `message.max.bytes`. - max_message_bytes: 1000 - - # The level of acknowledgement reliability needed from the broker. Equivalent to the `request.required.acks` - # RequiredAcks is used in Produce Requests to tell the broker how many replica acknowledgements - # it must see before responding. Any of the constants defined here are valid. On broker versions - # prior to 0.8.2.0 any other positive int16 is also valid (the broker will wait for that many - # acknowledgements) but in 0.8.2.0 and later this will raise an exception (it has been replaced - # by setting the `min.isr` value in the brokers configuration). + # Optional, default: AllISRAcks. Possible values: NoAck, LeaderAck, AllISRAck + required_acks: AllISRAck + + # max_message_bytes upper bounds the size of a record batch, overriding the default 1,000,012 bytes. + # This mirrors Kafka's max.message.bytes. # - # Optional, default: -1 - # Should be one of the following values: - # 0: NoResponse - doesn't send any response. - # 1: WaitForLocal - waits for only the local commit to succeed before responding. - # -1 WaitForAll, (default) - waits for all in-sync replicas to commit before responding. - # The minimum number of in-sync replicas is configured on the broker via - # the `min.insync.replicas` configuration key. - required_acks: -1 - - # The maximum duration in seconds the broker will wait the receipt of the number of - # required_acks. + # Optional, default: 1000012 + max_message_bytes: 1000012 + + # request_timeout sets how long Kafka broker's are allowed to respond produce requests, overriding the default 10s. + # If a broker exceeds this duration, it will reply with a request timeout error. # - # Optional, default: 10 - timeout: 10 + # Optional, default: 10s. Possible values: 10s, 10m. + request_timeout: 10s - # The type of compression to use on messages (defaults to no compression). - # Similar to `compression.codec` setting of the JVM producer. + # delivery_timeout sets a rough time of how long a record can sit around in a batch before timing out, + # overriding the unlimited default. If idempotency is enabled (as it is by default), this option is only + # enforced if it is safe to do so without creating invalid sequence numbers. # - # Optional, default: none. Possible values: none, gzip, snappy, lz4, zstd - compression_codec: snappy + # Optional, default: delivery.timeout.ms Kafka option. Possible values: 10s, 10m. + delivery_timeout: 100s - # The level of compression to use on messages. The meaning depends - # on the actual compression type used and defaults to default compression - # level for the codec. + # transaction_timeout sets the allowed for a transaction, overriding the default 40s. It is a good idea to + # keep this less than a group's session timeout. # - # Optional, default: depends on compression_codec option. - compression_level: 10 + # Optional, default 40s. Possible values: 10s, 10m. + transaction_timeout: 100 - # If enabled, the producer will ensure that exactly one copy of each message is - # written. + # compression_codec sets the compression codec to use for producing records. # - # Optional, default false - idempotent: false + # Optional, default is chosen in the order preferred based on broker support. Possible values: gzip, snappy, lz4, zstd. + compression_codec: gzip - # Kafka consumer options + # Kafka Consumer options. Needed to consume messages from the Kafka cluster. + # + # Optional, needed only if `consume` is used. consumer_options: - # The minimum number of message bytes to fetch in a request - the broker - # will wait until at least this many are available. The default is 1, - # as 0 causes the consumer to spin when no messages are available. - # Equivalent to the JVM's `fetch.min.bytes`. + # topics: adds topics to use for consuming + # + # Default: empty (will produce an error), possible to use regexp if `consume_regexp` is set to true. + topics: [ "foo", "bar", "^[a-zA-Z0-9._-]+$" ] + + # consume_regexp sets the client to parse all topics passed to `topics` as regular expressions. + # When consuming via regex, every metadata request loads *all* topics, so that all topics can be passed to + # any regular expressions. Every topic is evaluated only once ever across all regular expressions; either it + # permanently is known to match, or is permanently known to not match. # - # Optional, default - 1 byte - min_fetch_message_size: 100000 - - # The default number of message bytes to fetch from the broker in each - # request (default 1MB). This should be larger than the majority of - # your messages, or else the consumer will spend a lot of time - # negotiating sizes and not actually consuming. Similar to the JVM's - # `fetch.message.max.bytes`. + # Optional, default: false. + consume_regexp: true + + # max_fetch_message_size sets the maximum amount of bytes a broker will try to send during a fetch, overriding the default 50MiB. + # Note that brokers may not obey this limit if it has records larger than this limit. + # Also note that this client sends a fetch to each broker concurrently, meaning the client will + # buffer up to <brokers * max bytes> worth of memory. This corresponds to the Java fetch.max.bytes setting. + # + # Optional, default 50000 + max_fetch_message_size: 50000 + + # min_fetch_message_size sets the minimum amount of bytes a broker will try to send during a fetch, + # overriding the default 1 byte. With the default of 1, data is sent as soon as it is available. + # This corresponds to the Java fetch.min.bytes setting. + # + # Optional, default: 1. + min_fetch_message_size: 1 + + # consume_partitions sets partitions to consume from directly and the offsets to start consuming those partitions from. + # This option is basically a way to explicitly consume from subsets of partitions in topics, or to consume at exact offsets. # - # Optional, default 1000000 - max_fetch_message_size: 1000000 - - # The timeout in seconds used to detect consumer failures when using Kafka's group management facility. - # The consumer sends periodic heartbeats to indicate its liveness to the broker. - # If no heartbeats are received by the broker before the expiration of this session timeout, - # then the broker will remove this consumer from the group and initiate a rebalance. - # Note that the value must be in the allowable range as configured in the broker configuration - # by `group.min.session.timeout.ms` and `group.max.session.timeout.ms` + # NOTE: This option is not compatible with group consuming and regex consuming. # - # Optional, default: 10 - session_timeout: 60 - - # The expected time in seconds between heartbeats to the consumer coordinator when using Kafka's group - # management facilities. Heartbeats are used to ensure that the consumer's session stays active and - # to facilitate rebalancing when new consumers join or leave the group. - # The value must be set lower than 'session_timeout', but typically should be set no - # higher than 1/3 of that value. - # It can be adjusted even lower to control the expected time for normal rebalances. + # Optional, default: empty + consume_partitions: + + # Topic for the consume_partitions + # + # Optional, default: empty. + foo: + + # Partition for the topic. + # + # Optional, default: empty. + 0: + + # Partition offset. + # + # Required if all options is used. No default, error on empty. + # Possible values: AtEnd, At, AfterMilli, AtStart, Relative, WithEpoch + type: AtStart + + # Value for the: At, AfterMilli, Relative and WithEpoch offsets. + # + # Optional, default: 0. + value: 1 + + # consumer_offset sets the offset to start consuming from, or if OffsetOutOfRange is seen while fetching, + # to restart consuming from. + # + # Optional, default: AtStart + consumer_offset: + + # Partition offset. + # + # Optional, default: AtStart. Possible values: AtEnd, At, AfterMilli, AtStart, Relative, WithEpoch + type: AtStart + + # Value for the: At, AfterMilli, Relative and WithEpoch offsets. + # + # Optional, default: 0. + value: 1 + + # group_options sets the consumer group for the client to join and consume in. + # This option is required if using any other group options. + # + # Default: empty. + group_options: + + # group_id sets the group to consume. + # + # Required if using group consumer. + group_id: foo + + # block_rebalance_on_poll switches the client to block rebalances whenever you poll. # - # Optional, default: 3 - heartbeat_interval: 10 + # Optional, default: false. + block_rebalance_on_poll: true # list of pipelines to be consumed by the server automatically at the start, keep empty if you want to start consuming manually consume: @@ -8,58 +8,58 @@ require ( github.com/fatih/color v1.14.1 github.com/joho/godotenv v1.4.0 github.com/olekukonko/tablewriter v0.0.5 - github.com/roadrunner-server/amqp/v4 v4.1.0 + github.com/roadrunner-server/amqp/v4 v4.1.1 github.com/roadrunner-server/api/v3 v3.2.1 - github.com/roadrunner-server/app-logger/v4 v4.0.0 - github.com/roadrunner-server/beanstalk/v4 v4.1.0 - github.com/roadrunner-server/boltdb/v4 v4.2.0 - github.com/roadrunner-server/centrifuge/v4 v4.0.0 - github.com/roadrunner-server/config/v4 v4.1.0 + github.com/roadrunner-server/app-logger/v4 v4.0.1 + github.com/roadrunner-server/beanstalk/v4 v4.1.1 + github.com/roadrunner-server/boltdb/v4 v4.2.1 + github.com/roadrunner-server/centrifuge/v4 v4.0.2 + github.com/roadrunner-server/config/v4 v4.1.1 github.com/roadrunner-server/endure/v2 v2.0.1 github.com/roadrunner-server/errors v1.2.0 - github.com/roadrunner-server/fileserver/v4 v4.0.0 + github.com/roadrunner-server/fileserver/v4 v4.0.1 github.com/roadrunner-server/goridge/v3 v3.6.2 - github.com/roadrunner-server/grpc/v4 v4.0.0 - github.com/roadrunner-server/gzip/v4 v4.0.0 + github.com/roadrunner-server/grpc/v4 v4.0.2 + github.com/roadrunner-server/gzip/v4 v4.0.1 github.com/roadrunner-server/headers/v4 v4.0.0 - github.com/roadrunner-server/http/v4 v4.0.1 - github.com/roadrunner-server/informer/v4 v4.0.0 - github.com/roadrunner-server/jobs/v4 v4.2.0 - github.com/roadrunner-server/kv/v4 v4.1.0 - github.com/roadrunner-server/logger/v4 v4.0.0 - github.com/roadrunner-server/memcached/v4 v4.1.1 - github.com/roadrunner-server/memory/v4 v4.1.0 - github.com/roadrunner-server/metrics/v4 v4.0.0 - github.com/roadrunner-server/nats/v4 v4.1.0 - github.com/roadrunner-server/otel/v4 v4.0.0 - github.com/roadrunner-server/prometheus/v4 v4.0.0 - github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.0 + github.com/roadrunner-server/http/v4 v4.0.2 + github.com/roadrunner-server/informer/v4 v4.0.1 + github.com/roadrunner-server/jobs/v4 v4.2.1 + github.com/roadrunner-server/kv/v4 v4.1.1 + github.com/roadrunner-server/logger/v4 v4.0.1 + github.com/roadrunner-server/memcached/v4 v4.1.2 + github.com/roadrunner-server/memory/v4 v4.1.1 + github.com/roadrunner-server/metrics/v4 v4.0.1 + github.com/roadrunner-server/nats/v4 v4.1.1 + github.com/roadrunner-server/otel/v4 v4.0.2 + github.com/roadrunner-server/prometheus/v4 v4.0.1 + github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.1 github.com/roadrunner-server/redis/v4 v4.1.1 - github.com/roadrunner-server/reload/v4 v4.0.0 - github.com/roadrunner-server/resetter/v4 v4.0.0 - github.com/roadrunner-server/rpc/v4 v4.0.0 + github.com/roadrunner-server/reload/v4 v4.0.1 + github.com/roadrunner-server/resetter/v4 v4.0.1 + github.com/roadrunner-server/rpc/v4 v4.0.1 github.com/roadrunner-server/sdk/v4 v4.0.0 - github.com/roadrunner-server/send/v4 v4.0.0 - github.com/roadrunner-server/server/v4 v4.0.0 + github.com/roadrunner-server/send/v4 v4.0.1 + github.com/roadrunner-server/server/v4 v4.0.1 github.com/roadrunner-server/service/v4 v4.0.2 - github.com/roadrunner-server/sqs/v4 v4.1.0 - github.com/roadrunner-server/static/v4 v4.0.0 - github.com/roadrunner-server/status/v4 v4.0.0 - github.com/roadrunner-server/tcp/v4 v4.0.0 + github.com/roadrunner-server/sqs/v4 v4.1.1 + github.com/roadrunner-server/static/v4 v4.0.1 + github.com/roadrunner-server/status/v4 v4.0.1 + github.com/roadrunner-server/tcp/v4 v4.0.1 github.com/spf13/cobra v1.6.1 github.com/spf13/viper v1.15.0 github.com/stretchr/testify v1.8.1 - github.com/temporalio/roadrunner-temporal/v4 v4.0.0 + github.com/temporalio/roadrunner-temporal/v4 v4.0.1 go.buf.build/protocolbuffers/go/roadrunner-server/api v1.3.27 go.uber.org/automaxprocs v1.5.1 - golang.org/x/exp v0.0.0-20230124195608-d38c7dcee874 + golang.org/x/exp v0.0.0-20230125214544-b3c2aaf6208d ) require ( github.com/andybalholm/brotli v1.0.4 // indirect github.com/aws/aws-sdk-go-v2 v1.17.3 // indirect - github.com/aws/aws-sdk-go-v2/config v1.18.9 // indirect - github.com/aws/aws-sdk-go-v2/credentials v1.13.9 // indirect + github.com/aws/aws-sdk-go-v2/config v1.18.10 // indirect + github.com/aws/aws-sdk-go-v2/credentials v1.13.10 // indirect github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.21 // indirect github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.27 // indirect github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.21 // indirect @@ -68,7 +68,7 @@ require ( github.com/aws/aws-sdk-go-v2/service/sqs v1.20.1 // indirect github.com/aws/aws-sdk-go-v2/service/sso v1.12.0 // indirect github.com/aws/aws-sdk-go-v2/service/ssooidc v1.14.0 // indirect - github.com/aws/aws-sdk-go-v2/service/sts v1.18.1 // indirect + github.com/aws/aws-sdk-go-v2/service/sts v1.18.2 // indirect github.com/aws/smithy-go v1.13.5 // indirect github.com/beanstalkd/go-beanstalk v0.2.0 // indirect github.com/beorn7/perks v1.0.1 // indirect @@ -180,8 +180,8 @@ require ( golang.org/x/text v0.6.0 // indirect golang.org/x/time v0.3.0 // indirect golang.org/x/tools v0.5.0 // indirect - google.golang.org/genproto v0.0.0-20230124163310-31e0e69b6fc2 // indirect - google.golang.org/grpc v1.52.1 // indirect + google.golang.org/genproto v0.0.0-20230125152338-dcaf20b6aeaa // indirect + google.golang.org/grpc v1.52.3 // indirect google.golang.org/protobuf v1.28.1 // indirect gopkg.in/ini.v1 v1.67.0 // indirect gopkg.in/natefinch/lumberjack.v2 v2.0.0 // indirect @@ -394,10 +394,10 @@ github.com/andybalholm/brotli v1.0.4/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHG github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY= github.com/aws/aws-sdk-go-v2 v1.17.3 h1:shN7NlnVzvDUgPQ+1rLMSxY8OWRNDRYtiqe0p/PgrhY= github.com/aws/aws-sdk-go-v2 v1.17.3/go.mod h1:uzbQtefpm44goOPmdKyAlXSNcwlRgF3ePWVW6EtJvvw= -github.com/aws/aws-sdk-go-v2/config v1.18.9 h1:pd+QUO1dvro6vGOuhgglJV6adGunU95xSTSzsQGhKpY= -github.com/aws/aws-sdk-go-v2/config v1.18.9/go.mod h1:2Lx9yaA/McDeQS8ft+edKrmOd5ry1v1euFQ+oGwUxsM= -github.com/aws/aws-sdk-go-v2/credentials v1.13.9 h1:oxM/C8eXGsiHH+u0gZGo1++QTFPf+N5MUb1tfaaQMpU= -github.com/aws/aws-sdk-go-v2/credentials v1.13.9/go.mod h1:45DrDZTok50mEx4Uw59ym7n11Oy7G4gt0Pez2Z4ktAA= +github.com/aws/aws-sdk-go-v2/config v1.18.10 h1:Znce11DWswdh+5kOsIp+QaNfY9igp1QUN+fZHCKmeCI= +github.com/aws/aws-sdk-go-v2/config v1.18.10/go.mod h1:VATKco+pl+Qe1WW+RzvZTlPPe/09Gg9+vM0ZXsqb16k= +github.com/aws/aws-sdk-go-v2/credentials v1.13.10 h1:T4Y39IhelTLg1f3xiKJssThnFxsndS8B6OnmcXtKK+8= +github.com/aws/aws-sdk-go-v2/credentials v1.13.10/go.mod h1:tqAm4JmQaShel+Qi38hmd1QglSnnxaYt50k/9yGQzzc= github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.21 h1:j9wi1kQ8b+e0FBVHxCqCGo4kxDU175hoDHcWAi0sauU= github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.21/go.mod h1:ugwW57Z5Z48bpvUyZuaPy4Kv+vEfJWnIrky7RmkBvJg= github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.27 h1:I3cakv2Uy1vNmmhRQmFptYDxOvBnwCdNwyw63N0RaRU= @@ -414,8 +414,8 @@ github.com/aws/aws-sdk-go-v2/service/sso v1.12.0 h1:/2gzjhQowRLarkkBOGPXSRnb8sQ2 github.com/aws/aws-sdk-go-v2/service/sso v1.12.0/go.mod h1:wo/B7uUm/7zw/dWhBJ4FXuw1sySU5lyIhVg1Bu2yL9A= github.com/aws/aws-sdk-go-v2/service/ssooidc v1.14.0 h1:Jfly6mRxk2ZOSlbCvZfKNS7TukSx1mIzhSsqZ/IGSZI= github.com/aws/aws-sdk-go-v2/service/ssooidc v1.14.0/go.mod h1:TZSH7xLO7+phDtViY/KUp9WGCJMQkLJ/VpgkTFd5gh8= -github.com/aws/aws-sdk-go-v2/service/sts v1.18.1 h1:q3xG67qnKp1gsYSJY5AtTvFKY2IlmGPGrTw/Wy8EjeQ= -github.com/aws/aws-sdk-go-v2/service/sts v1.18.1/go.mod h1:+lGbb3+1ugwKrNTWcf2RT05Xmp543B06zDFTwiTLp7I= +github.com/aws/aws-sdk-go-v2/service/sts v1.18.2 h1:J/4wIaGInCEYCGhTSruxCxeoA5cy91a+JT7cHFKFSHQ= +github.com/aws/aws-sdk-go-v2/service/sts v1.18.2/go.mod h1:+lGbb3+1ugwKrNTWcf2RT05Xmp543B06zDFTwiTLp7I= github.com/aws/smithy-go v1.13.5 h1:hgz0X/DX0dGqTYpGALqXJoRKRj5oQ7150i5FdTePzO8= github.com/aws/smithy-go v1.13.5/go.mod h1:Tg+OJXh4MB2R/uN61Ko2f6hTZwB/ZYGOtib8J3gBHzA= github.com/beanstalkd/go-beanstalk v0.2.0 h1:6UOJugnu47uNB2jJO/lxyDgeD1Yds7owYi1USELqexA= @@ -744,84 +744,84 @@ github.com/rabbitmq/amqp091-go v1.6.0/go.mod h1:wfClAtY0C7bOHxd3GjmF26jEHn+rR/0B github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc= github.com/rivo/uniseg v0.4.3 h1:utMvzDsuh3suAEnhH0RdHmoPbU648o6CvXxTx4SBMOw= github.com/rivo/uniseg v0.4.3/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88= -github.com/roadrunner-server/amqp/v4 v4.1.0 h1:WrGtDt3RAiJvXKUIerzOTm7la8CNgOyijaeGvNCorP0= -github.com/roadrunner-server/amqp/v4 v4.1.0/go.mod h1:nVUBXcLcRLHuVw3GElw1HA6KvvPaVk0BufDssadKzLk= +github.com/roadrunner-server/amqp/v4 v4.1.1 h1:WzOUWaYlAuOIPVyfaN6YwR1cEQQpWoSmBwwDWInHQck= +github.com/roadrunner-server/amqp/v4 v4.1.1/go.mod h1:nVUBXcLcRLHuVw3GElw1HA6KvvPaVk0BufDssadKzLk= github.com/roadrunner-server/api/v3 v3.2.1 h1:N4rokKVkN8Phoodbqtil90G65t2BqIWvHCKaxIKajvs= github.com/roadrunner-server/api/v3 v3.2.1/go.mod h1:hlv546SS3tZVIDu68YekPCLS/82Y/AoS8Eu5xysvwBQ= github.com/roadrunner-server/api/v4 v4.0.0 h1:4zAnlMHp2BKgxxPSuPGQSVCMtPKX/R+/czWewpDkPak= github.com/roadrunner-server/api/v4 v4.0.0/go.mod h1:tbk/rqlNiLFAchTKrXvsJ4boAg0qZmxyK8vWH2PlV8U= -github.com/roadrunner-server/app-logger/v4 v4.0.0 h1:/6tRPnUFGJ+6vm4iTF9zeU2hHl10goUsF4khtE+uxHM= -github.com/roadrunner-server/app-logger/v4 v4.0.0/go.mod h1:cWV6nWhwQmkyGZtefeWrqs59v0XTrQdm5B7y8ukFpQU= -github.com/roadrunner-server/beanstalk/v4 v4.1.0 h1:LJIFJiAGA4SBCTJ4LVIhPIhmCblyYIM1kbjYYNoTaUA= -github.com/roadrunner-server/beanstalk/v4 v4.1.0/go.mod h1:Ekpce6ise0aet/WJDregbecSho502uIgu9sKfce5/T4= -github.com/roadrunner-server/boltdb/v4 v4.2.0 h1:K+Ijgpp8MgkNPypdolLUo0TiPjXqyBUgx1Huise01QM= -github.com/roadrunner-server/boltdb/v4 v4.2.0/go.mod h1:dVgez5eFAVivFeCEcycVT2fbb33dKbgESjXrkqmck3o= -github.com/roadrunner-server/centrifuge/v4 v4.0.0 h1:0Ac7nS2Hv/EJ0tKnAUqu9U9rq02GABRoERWlIigFgN4= -github.com/roadrunner-server/centrifuge/v4 v4.0.0/go.mod h1:rTkGOF4XBJxSKP9KNVudbiMBSLms03m4tp9ZgLpUvF8= -github.com/roadrunner-server/config/v4 v4.1.0 h1:EyM632R4qVeO9tvhNItffBZMIBtuw70D3oYpPyRWoAs= -github.com/roadrunner-server/config/v4 v4.1.0/go.mod h1:dlrCUD2OxFxCiaXXiKY+/OqIJKz3BZbtkBVnrtvGWks= +github.com/roadrunner-server/app-logger/v4 v4.0.1 h1:WLKt/mgVl5Nc/j31mklsqbn82UsWZ2VpU2pBojI9xXo= +github.com/roadrunner-server/app-logger/v4 v4.0.1/go.mod h1:cWV6nWhwQmkyGZtefeWrqs59v0XTrQdm5B7y8ukFpQU= +github.com/roadrunner-server/beanstalk/v4 v4.1.1 h1:Y1OvPJdJ71Bhtqgo83ZE0c0n0MaEYVP2duGS92hQ06E= +github.com/roadrunner-server/beanstalk/v4 v4.1.1/go.mod h1:Ekpce6ise0aet/WJDregbecSho502uIgu9sKfce5/T4= +github.com/roadrunner-server/boltdb/v4 v4.2.1 h1:jykVxfJWOtYIYLQwM0PKMeHTYEzRXFbEQXed6bIoCGg= +github.com/roadrunner-server/boltdb/v4 v4.2.1/go.mod h1:dVgez5eFAVivFeCEcycVT2fbb33dKbgESjXrkqmck3o= +github.com/roadrunner-server/centrifuge/v4 v4.0.2 h1:HcqGSJVdxAcKlx8Iot2U1nGNShUjMm61EajsjigfaLw= +github.com/roadrunner-server/centrifuge/v4 v4.0.2/go.mod h1:oGPwAOZ1n9jguzcjxDl6hUzK1/D3Xi70fu+c3zqS54M= +github.com/roadrunner-server/config/v4 v4.1.1 h1:YICoAy0E8wpicqTFIQCxUUg+z2GDE5hVtH6p8gwitIo= +github.com/roadrunner-server/config/v4 v4.1.1/go.mod h1:dlrCUD2OxFxCiaXXiKY+/OqIJKz3BZbtkBVnrtvGWks= github.com/roadrunner-server/endure/v2 v2.0.1 h1:2greoQ669iCjsYNt14dwXXQGHAKDmLtFzL0OIE0ZATc= github.com/roadrunner-server/endure/v2 v2.0.1/go.mod h1:RDrC9SFlyCGqGA2v9SqFIA+EqWTFmPxafIb4SMeHCHM= github.com/roadrunner-server/errors v1.2.0 h1:qBmNXt8Iex9QnYTjCkbJKsBZu2EtYkQCM06GUDcQBbI= github.com/roadrunner-server/errors v1.2.0/go.mod h1:z0ECxZp/dDa5RahtMcy4mBIavVxiZ9vwE5kByl7kFtY= -github.com/roadrunner-server/fileserver/v4 v4.0.0 h1:DfkS9GaFc2MDOg92oNuD0y0aAv6IHAeEoFtYhKQ9m+8= -github.com/roadrunner-server/fileserver/v4 v4.0.0/go.mod h1:tNdopQyNAJR/wKUp57je8ZVbw93lvFGOBvNN5odR1L4= +github.com/roadrunner-server/fileserver/v4 v4.0.1 h1:+TInwLPHz+7AP1u1p38n16SlakHpKM1oLtr7kqYN4BE= +github.com/roadrunner-server/fileserver/v4 v4.0.1/go.mod h1:XX4nCWno1iQgM+c46qf0bLnTrOuI8uxLVu4UVPLxH3M= github.com/roadrunner-server/goridge/v3 v3.6.2 h1:LH5HXfCygDp05KnOaXpa4fqVPWTsH7V3lfvPtMwFU3k= github.com/roadrunner-server/goridge/v3 v3.6.2/go.mod h1:3B95k/wM5GGAD0h2hZlJagS9PlTDGs5jh8MpZYC12vA= -github.com/roadrunner-server/grpc/v4 v4.0.0 h1:cGb4k5Dwm7T5iJfv/ovYVcfYt9ME1px1xAo6hVhnr2g= -github.com/roadrunner-server/grpc/v4 v4.0.0/go.mod h1:OCYiwsJEVWsu4pwXajIcQ8J4PVe5L6ZosahBM5t0prs= -github.com/roadrunner-server/gzip/v4 v4.0.0 h1:EQA0LSRsSXnKVr+Q88YPVOYixRB5bJzbTTyQOmynUX0= -github.com/roadrunner-server/gzip/v4 v4.0.0/go.mod h1:KhmnEQ5M1R5jVm8rsbzaV07k7d/JBpTfKAnecrEjVWg= +github.com/roadrunner-server/grpc/v4 v4.0.2 h1:W+JnZJJqK4WmOMnEA/sW1rDe+Vvc/k5eoouKY6Y7w6E= +github.com/roadrunner-server/grpc/v4 v4.0.2/go.mod h1:QEZMZSMC0u1HBTS7U9EsZKs6lHSeoRa06jWwtjgN8rA= +github.com/roadrunner-server/gzip/v4 v4.0.1 h1:7tqynGSqhIJBFGtAsWjfgS9JPyccZb+a/ql5Dx5Pncw= +github.com/roadrunner-server/gzip/v4 v4.0.1/go.mod h1:+bAl80yCNCR0DYHJE/DfxALBY29p74yh9/2Q4NpGW5E= github.com/roadrunner-server/headers/v4 v4.0.0 h1:7chQFVBlGZwlsW6vQnfmnpAjx0U4bjDP3HdP3r0ZTE4= github.com/roadrunner-server/headers/v4 v4.0.0/go.mod h1:QsJI5vD0gR8oTuNtINwXIUZl6iz2CNOO2OYskEE+7hs= -github.com/roadrunner-server/http/v4 v4.0.1 h1:GTUOI9O8EKVvX+edbMZyCFK3dhg0WA/pgAovEdG2oCM= -github.com/roadrunner-server/http/v4 v4.0.1/go.mod h1:Di/bjFMbbhphXUXgggr8Ia1WR+z3EM8GubAy4Tu+it0= -github.com/roadrunner-server/informer/v4 v4.0.0 h1:D7mo8VsSat5DHsEmvySD0OXRT32IOcQjs3hBBAaB4b4= -github.com/roadrunner-server/informer/v4 v4.0.0/go.mod h1:jZRhcXHWyp1Wz/KbHgOHKxxATQkST7qL1omVLFN7tog= -github.com/roadrunner-server/jobs/v4 v4.2.0 h1:rQqHO2D9qRrxaZbSJvXnrvcSZFLQJNCLskDbewDkMsg= -github.com/roadrunner-server/jobs/v4 v4.2.0/go.mod h1:oR+ARIW4oGLB+11Mn8Uk3OtLf44fGVluAoFQJEC18/0= -github.com/roadrunner-server/kv/v4 v4.1.0 h1:Em7VypWeNMlZ3PQweMJHxXD3xSQAN3shryIrb0yibPg= -github.com/roadrunner-server/kv/v4 v4.1.0/go.mod h1:OkPP8M2xqas1JpzlwkvP/CrRhr9+lVHkLI3QATA1MD0= -github.com/roadrunner-server/logger/v4 v4.0.0 h1:IH0rA4klye0yqEtTNkkd6ScAa1HrD8w3CRrs1juC6PY= -github.com/roadrunner-server/logger/v4 v4.0.0/go.mod h1:p2bTOmH6dmD3WPkFzDrO4jmDxbd/s2rxXY6EO6RFdbY= -github.com/roadrunner-server/memcached/v4 v4.1.1 h1:f6lNgb1oHMRvlYlyBlUDz0Ei0ZBSlRjLfniLfQILa9I= -github.com/roadrunner-server/memcached/v4 v4.1.1/go.mod h1:td60kmGDWVHL7Wku4tz7JpV6d4xJ5w43uIaFfVzzFg8= -github.com/roadrunner-server/memory/v4 v4.1.0 h1:06ctmj6FXAVxcQVlC1pYiVGHMHg7D+4azZJW9DR37zU= -github.com/roadrunner-server/memory/v4 v4.1.0/go.mod h1:S8vKQmpu7fjGl0xSJcWkuoZyF0JMLoArlmniGcYP8uk= -github.com/roadrunner-server/metrics/v4 v4.0.0 h1:Yuh2/b0iih1aTDueJvBaeNIhT7pmvvwOTA7WRu1TLL8= -github.com/roadrunner-server/metrics/v4 v4.0.0/go.mod h1:+PoWwf2Mjq1Axi/CWEwbegvGxY7Kjr52YC5bXsxq3k8= -github.com/roadrunner-server/nats/v4 v4.1.0 h1:208fC+HKN1kmX/POhJTuzIuUvqCeCwdl9b/iVD81JzY= -github.com/roadrunner-server/nats/v4 v4.1.0/go.mod h1:m0XK3VLzbAiww8cpG9/qSwX335pFWcmxYoykpg/NUXg= -github.com/roadrunner-server/otel/v4 v4.0.0 h1:czxmPJL+tkwqX0rfL0gIptygdE+FUKsxnm6QLADUAts= -github.com/roadrunner-server/otel/v4 v4.0.0/go.mod h1:7Qap+MrqNsaYG34r4SAE5xq3128Ew/K79Zms9MDEsxU= -github.com/roadrunner-server/prometheus/v4 v4.0.0 h1:L3U7GR+1AlE6v/X6aIt155z7N0OCXJiqncg65xBVR8Q= -github.com/roadrunner-server/prometheus/v4 v4.0.0/go.mod h1:kBpAeeS3DtIrkj6beXR5TYZx6mhvCAuF2IlnACHPmXk= -github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.0 h1:P1mSXeYkGRJijOZlMXkRBnnp4H/AnHbEwcTRv2qSAlc= -github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.0/go.mod h1:Yiq4DdP3NGTXD8kViZMnyJvcQz3Co9Bh5O66brc9eK8= +github.com/roadrunner-server/http/v4 v4.0.2 h1:VZOjTtl49LlzoZGkXxow3Gsdm0AS8HxV9o9b+EEBI1s= +github.com/roadrunner-server/http/v4 v4.0.2/go.mod h1:Di/bjFMbbhphXUXgggr8Ia1WR+z3EM8GubAy4Tu+it0= +github.com/roadrunner-server/informer/v4 v4.0.1 h1:Zv0iiuXZjXtV9zBDs4kVzRbYCjVpxQ4Xjh+HOuQnl3M= +github.com/roadrunner-server/informer/v4 v4.0.1/go.mod h1:E8jbsSlsRUs/q8cUbRHS+bfj336RRhQoqmCtsfKvAmw= +github.com/roadrunner-server/jobs/v4 v4.2.1 h1:Ja0lflRP1iKyjouLohUNACFsbSNXQ46/rsYZYoRfLJU= +github.com/roadrunner-server/jobs/v4 v4.2.1/go.mod h1:UhOCFpJrWYPzSZTe32w8e+FborXbsC0zg0wIN1G202Q= +github.com/roadrunner-server/kv/v4 v4.1.1 h1:eUth+RUTxRmtPHmTgfM7WyupyZyevUNFb4T1kSi3ygQ= +github.com/roadrunner-server/kv/v4 v4.1.1/go.mod h1:OkPP8M2xqas1JpzlwkvP/CrRhr9+lVHkLI3QATA1MD0= +github.com/roadrunner-server/logger/v4 v4.0.1 h1:2sZYaLIG4hnxgIqVhBKQ1n8ximdbztpNcf2IXzOp0bU= +github.com/roadrunner-server/logger/v4 v4.0.1/go.mod h1:rZn2gwJLCzsCkEnkoBMR8I+lEYhqJagozAo4tE1NYeE= +github.com/roadrunner-server/memcached/v4 v4.1.2 h1:EAbHKIIaYWAKMYtlHGHroqzZXqusf4Q9VKsmGHRU3EU= +github.com/roadrunner-server/memcached/v4 v4.1.2/go.mod h1:U1Pm9Vjldw/KdIMLlZIHJ4PvYVAUM1VJWx7/6Dd3Mrs= +github.com/roadrunner-server/memory/v4 v4.1.1 h1:HWq5xfJwsBrhodFSH9Z5VcXNfR/sS9myhXIjdicAfBA= +github.com/roadrunner-server/memory/v4 v4.1.1/go.mod h1:S8vKQmpu7fjGl0xSJcWkuoZyF0JMLoArlmniGcYP8uk= +github.com/roadrunner-server/metrics/v4 v4.0.1 h1:KzZqaM+Wu2awx5TduMt90cPWAMa28mArvWDWAYc+2JI= +github.com/roadrunner-server/metrics/v4 v4.0.1/go.mod h1:gWIYZcckdLQsBkB+3ahElYkn61XF3WLWnGvHW8SHr94= +github.com/roadrunner-server/nats/v4 v4.1.1 h1:R0xwE4d7z2kMdV+Fd3ql6pdWDCKmI9x5zU8wNewOxc0= +github.com/roadrunner-server/nats/v4 v4.1.1/go.mod h1:m0XK3VLzbAiww8cpG9/qSwX335pFWcmxYoykpg/NUXg= +github.com/roadrunner-server/otel/v4 v4.0.2 h1:NInbzIsXphUs8VjTQ3FKy2toWQdGxldLaXKE4KQA3To= +github.com/roadrunner-server/otel/v4 v4.0.2/go.mod h1:Om/VMnnEglEojcRuhGIt94vxIj4cMWkHUKygF6OB3uk= +github.com/roadrunner-server/prometheus/v4 v4.0.1 h1:dKizv/bpmowA0Oj6mY7QpQUwNR8oB0aTUnAfAvS+CDw= +github.com/roadrunner-server/prometheus/v4 v4.0.1/go.mod h1:kBpAeeS3DtIrkj6beXR5TYZx6mhvCAuF2IlnACHPmXk= +github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.1 h1:AndGSRbb3ZdUM2NzxSY2yKZoyskpjBqa6xpPzsP0qF8= +github.com/roadrunner-server/proxy_ip_parser/v4 v4.0.1/go.mod h1:Yiq4DdP3NGTXD8kViZMnyJvcQz3Co9Bh5O66brc9eK8= github.com/roadrunner-server/redis/v4 v4.1.1 h1:kQm+f6et32hD0XS84Njswffe/C6KbxAAxvy8ccY4Cx0= github.com/roadrunner-server/redis/v4 v4.1.1/go.mod h1:TE5pe6wzfgfgAd7Y6zB6g+NRFEh6x5ck+1c80UZe6eE= -github.com/roadrunner-server/reload/v4 v4.0.0 h1:86t25qzlLr0yDhJkLqw81VWemMvmOAtRZm8dx7HbaLI= -github.com/roadrunner-server/reload/v4 v4.0.0/go.mod h1:PM6WHpckWSA8vcmyAIDDH7/ZgozML0hn+EIhaiZeag4= -github.com/roadrunner-server/resetter/v4 v4.0.0 h1:BIK3poD8N9tyWrF2JsHn7FW7Qnb9GbPQlr5pquJOmc8= -github.com/roadrunner-server/resetter/v4 v4.0.0/go.mod h1:0G9PTsje6i0akXrpy9WzLelbhRewT8iVX7a/wVrYJbo= -github.com/roadrunner-server/rpc/v4 v4.0.0 h1:i3mm2xu4qivdxZFB6hijIQD8acKqHEFRAqatIxqlsQQ= -github.com/roadrunner-server/rpc/v4 v4.0.0/go.mod h1:coXxN5SXuc/ijqOkRaTFOXmUoym0nqZ63dmRmMyK1Qk= +github.com/roadrunner-server/reload/v4 v4.0.1 h1:zzyXqVI0lpJGghQ7b+L1ABMvCmu+C/Er9QnLRwREAww= +github.com/roadrunner-server/reload/v4 v4.0.1/go.mod h1:o6N85BsxcV7emsMBcK0CXSKoAOopyN4oIGAj62747uY= +github.com/roadrunner-server/resetter/v4 v4.0.1 h1:mbGJYLG1KqIjxb9w09VpU3DJ6iHSKpeq1ZwqRArjqjc= +github.com/roadrunner-server/resetter/v4 v4.0.1/go.mod h1:cJnriPp1I7eolQW+4LrX1Q2/wi1Sbowk6ik1M1+qZEc= +github.com/roadrunner-server/rpc/v4 v4.0.1 h1:xpHketPNINjrTPHkWBrRGdX8a8KsJo9rOf3BB96paHs= +github.com/roadrunner-server/rpc/v4 v4.0.1/go.mod h1:j+6oUgvrTb1ytBZetgHfS4kklrCVAw+CEf9S/PDdeoE= github.com/roadrunner-server/sdk/v4 v4.0.0 h1:obdmZLtSA1g/1zsklMcGyRpR5q7tCx+wLiLHupVR8zc= github.com/roadrunner-server/sdk/v4 v4.0.0/go.mod h1:l6Up2e+OJgmQWMfElE0vEAznuzDBLCewSyo0KMr63YU= -github.com/roadrunner-server/send/v4 v4.0.0 h1:v51GqqWGHPpGRA9O9N6qV4ku+MtfW97tQo+hZ06lEYQ= -github.com/roadrunner-server/send/v4 v4.0.0/go.mod h1:GIQUMT3VS3XXDYbWxF1ZeHDBt3Th9sdxvHq/janA6QE= -github.com/roadrunner-server/server/v4 v4.0.0 h1:S5YhlvpiNS+FTWjBM9hsVonCXteUGnI7tDOUbqL5u9U= -github.com/roadrunner-server/server/v4 v4.0.0/go.mod h1:pskfIK77QvJui9a6z9WNpikuTV2OLPoiiB+7eYrkQ3E= +github.com/roadrunner-server/send/v4 v4.0.1 h1:F8GHciXKZgbHyqNOQIjgKQX6ll2zOG/8Q2Hf++G5HA4= +github.com/roadrunner-server/send/v4 v4.0.1/go.mod h1:GIQUMT3VS3XXDYbWxF1ZeHDBt3Th9sdxvHq/janA6QE= +github.com/roadrunner-server/server/v4 v4.0.1 h1:hWvngTrbCHnAIwjK7mWPnSr8G5DMwNtkY8/dZkceu4A= +github.com/roadrunner-server/server/v4 v4.0.1/go.mod h1:obFiXYPZb4gYtatPQsi0IOdfVv2hfxHpFjkWC8qDOk4= github.com/roadrunner-server/service/v4 v4.0.2 h1:uSeHJsnaJI/AEiVEwFxvKwadTAHQbJTInXRbwFHwvBM= github.com/roadrunner-server/service/v4 v4.0.2/go.mod h1:ACrVtE4LjPAFWl6grDTTE4rHP84QEVFPlyFjlUIiIs8= -github.com/roadrunner-server/sqs/v4 v4.1.0 h1:9yNui537zLXtHpA6sX0VfETj2gzT01M55XXkoWbD52k= -github.com/roadrunner-server/sqs/v4 v4.1.0/go.mod h1:TDDBYz09MC+ToTSTs1RzQCOeu3pDpEDOYLtmneUsGI0= -github.com/roadrunner-server/static/v4 v4.0.0 h1:23yfaUwVYc7BKmFk3HLU4m6MVrfgb5zcM59GOhMOAS4= -github.com/roadrunner-server/static/v4 v4.0.0/go.mod h1:AXN8DCov81ZdW8m1uVpYMD84zJXS4NlHWOucXpEnS1w= -github.com/roadrunner-server/status/v4 v4.0.0 h1:tvvf/ZBYThzG1zFw/cZGR9TC61aXX+MzC6fRMppQIv4= -github.com/roadrunner-server/status/v4 v4.0.0/go.mod h1:SIyvsboGXZgIkh6ucLJffpP6SXJt45680i03Rf6E4OU= -github.com/roadrunner-server/tcp/v4 v4.0.0 h1:Lb4xIGrgRnDXPKnWAbJBDqZAh6PaVaWwmk94C3n/hVM= -github.com/roadrunner-server/tcp/v4 v4.0.0/go.mod h1:njvNgrR/90XzVFDxKtgodhFq+0hVsNBjkBIRP07sqA0= +github.com/roadrunner-server/sqs/v4 v4.1.1 h1:fL15srKB/TYf1pEokZ4UrtR2OCclSFGvkiKbzQHQjSQ= +github.com/roadrunner-server/sqs/v4 v4.1.1/go.mod h1:tFhXniMBq4i5jfyCn9i0AG9eRbvGfLkksDKSP4XcnX4= +github.com/roadrunner-server/static/v4 v4.0.1 h1:bK/qK+FXwQ/Oefc0ESEB68qCDeCQ6y1/mhCf4MRRJcg= +github.com/roadrunner-server/static/v4 v4.0.1/go.mod h1:AXN8DCov81ZdW8m1uVpYMD84zJXS4NlHWOucXpEnS1w= +github.com/roadrunner-server/status/v4 v4.0.1 h1:3xRN6Kyh6tyYkJKV1VVTuIHEQFctTy+VH9EdsF+jPXo= +github.com/roadrunner-server/status/v4 v4.0.1/go.mod h1:GfyQGw30coNNO4nPmkx0cNI/sEIN0X0r3yLyLgR5vVk= +github.com/roadrunner-server/tcp/v4 v4.0.1 h1:qCrb8LrfkMkWSxR/5mfYAGocO82oFhZKRQZ/BKSQxQM= +github.com/roadrunner-server/tcp/v4 v4.0.1/go.mod h1:njvNgrR/90XzVFDxKtgodhFq+0hVsNBjkBIRP07sqA0= github.com/roadrunner-server/tcplisten v1.2.1 h1:9hVVMlCRvMPewnJCnfSe/kKAqn2ZOF3wHy+ji0M/NKU= github.com/roadrunner-server/tcplisten v1.2.1/go.mod h1:TRJLGwIruiJ7QhmGVRgJFY5Ch72mPoLhLAxuxLnavpU= github.com/robfig/cron v1.2.0 h1:ZjScXvvxeQ63Dbyxy76Fj3AT3Ut0aKsyd2/tl3DTMuQ= @@ -871,8 +871,8 @@ github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKs github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= github.com/subosito/gotenv v1.4.2 h1:X1TuBLAMDFbaTAChgCBLu3DU3UPyELpnF2jjJ2cz/S8= github.com/subosito/gotenv v1.4.2/go.mod h1:ayKnFf/c6rvx/2iiLrJUk1e6plDbT3edrFNGqEflhK0= -github.com/temporalio/roadrunner-temporal/v4 v4.0.0 h1:BSh0CquOw6gW24xPW16t6SkI6nYNjrg7b91Qcg/UYQ0= -github.com/temporalio/roadrunner-temporal/v4 v4.0.0/go.mod h1:G9sBbZWg66yD9pPtylCaB2/xr/RxCG19K99kTecezPY= +github.com/temporalio/roadrunner-temporal/v4 v4.0.1 h1:muRsbz6a9FdU8RJQ7mLnGDe+3+mz9tVnZAlspUDDflc= +github.com/temporalio/roadrunner-temporal/v4 v4.0.1/go.mod h1:KXfEoswEfVwQ2YsyXkJqE1XzbWuWNN2n0B9AaOk7x3A= github.com/tklauser/go-sysconf v0.3.11 h1:89WgdJhk5SNwJfu+GKyYveZ4IaJ7xAkecBo+KdJV0CM= github.com/tklauser/go-sysconf v0.3.11/go.mod h1:GqXfhXY3kiPa0nAXPDIQIWzJbMCB7AmcWpGR8lSZfqI= github.com/tklauser/numcpus v0.6.0 h1:kebhY2Qt+3U6RNK7UqpYNA+tJ23IBEGKkB7JQBfDYms= @@ -996,8 +996,8 @@ golang.org/x/exp v0.0.0-20191227195350-da58074b4299/go.mod h1:2RIsYlXP63K8oxa1u0 golang.org/x/exp v0.0.0-20200119233911-0405dc783f0a/go.mod h1:2RIsYlXP63K8oxa1u096TMicItID8zy7Y6sNkU49FU4= golang.org/x/exp v0.0.0-20200207192155-f17229e696bd/go.mod h1:J/WKrq2StrnmMY6+EHIKF9dgMWnmCNThgcyBT1FY9mM= golang.org/x/exp v0.0.0-20200224162631-6cc2880d07d6/go.mod h1:3jZMyOhIsHpP37uCMkUooju7aAi5cS1Q23tOzKc+0MU= -golang.org/x/exp v0.0.0-20230124195608-d38c7dcee874 h1:kWC3b7j6Fu09SnEBr7P4PuQyM0R6sqyH9R+EjIvT1nQ= -golang.org/x/exp v0.0.0-20230124195608-d38c7dcee874/go.mod h1:CxIveKay+FTh1D0yPZemJVgC/95VzuuOLq5Qi4xnoYc= +golang.org/x/exp v0.0.0-20230125214544-b3c2aaf6208d h1:9Bio0JlZpJ1P4NXsK5i8Rf2MclrRzMGzJWOIkhZ5Um8= +golang.org/x/exp v0.0.0-20230125214544-b3c2aaf6208d/go.mod h1:CxIveKay+FTh1D0yPZemJVgC/95VzuuOLq5Qi4xnoYc= golang.org/x/image v0.0.0-20190227222117-0694c2d4d067/go.mod h1:kZ7UVZpmo3dzQBMxlp+ypCbDeSB+sBbTgSJuh5dn5js= golang.org/x/image v0.0.0-20190802002840-cff245a6509b/go.mod h1:FeLwcggjj3mMvU+oOTbSwawSJRM1uh48EjtB4UJZlP0= golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE= @@ -1472,8 +1472,9 @@ google.golang.org/genproto v0.0.0-20221117204609-8f9c96812029/go.mod h1:rZS5c/ZV google.golang.org/genproto v0.0.0-20221118155620-16455021b5e6/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= google.golang.org/genproto v0.0.0-20221201164419-0e50fba7f41c/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= google.golang.org/genproto v0.0.0-20221207170731-23e4bf6bdc37/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM= -google.golang.org/genproto v0.0.0-20230124163310-31e0e69b6fc2 h1:O97sLx/Xmb/KIZHB/2/BzofxBs5QmmR0LcihPtllmbc= google.golang.org/genproto v0.0.0-20230124163310-31e0e69b6fc2/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM= +google.golang.org/genproto v0.0.0-20230125152338-dcaf20b6aeaa h1:qQPhfbPO23fwm/9lQr91L1u62Zo6cm+zI+slZT+uf+o= +google.golang.org/genproto v0.0.0-20230125152338-dcaf20b6aeaa/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM= google.golang.org/grpc v1.12.0/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= @@ -1513,8 +1514,9 @@ google.golang.org/grpc v1.49.0/go.mod h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCD google.golang.org/grpc v1.50.0/go.mod h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCDK+GI= google.golang.org/grpc v1.50.1/go.mod h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCDK+GI= google.golang.org/grpc v1.51.0/go.mod h1:wgNDFcnuBGmxLKI/qn4T+m5BtEBYXJPvibbUPsAIPww= -google.golang.org/grpc v1.52.1 h1:2NpOPk5g5Xtb0qebIEs7hNIa++PdtZLo2AQUpc1YnSU= google.golang.org/grpc v1.52.1/go.mod h1:pu6fVzoFb+NBYNAvQL08ic+lvB2IojljRYuun5vorUY= +google.golang.org/grpc v1.52.3 h1:pf7sOysg4LdgBqduXveGKrcEwbStiK2rtfghdzlUYDQ= +google.golang.org/grpc v1.52.3/go.mod h1:pu6fVzoFb+NBYNAvQL08ic+lvB2IojljRYuun5vorUY= google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0/go.mod h1:6Kw0yEErY5E/yWrBtf03jp27GLLJujG4z/JK95pnjjw= google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8= google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0= |