Questions tagged [flux]
An application design paradigm used as a replacement for MVC, pioneered at Facebook by Jing Chen
1,519
questions
0
votes
1
answer
22
views
flux with linkerd and cert manager has issuer error
I am installing linkerd helm verison with flux and cert mananger for tls rotation
cert manager holds default config so there isnt much to talk there
flux and linkerd with this config:
release.yaml
...
0
votes
0
answers
16
views
Influxdb 2 - how to get schema of a bucket?
How can i get a schema / list of existing fields, tags and measurements in particular bucket? I want to achieve this with using InfluxDB API or influxdb-client-js package in my JS app. Can it be done ...
0
votes
1
answer
21
views
Spring WebClient is not emitting any data from request
This is the content type of the request
I use spring boot and this code to redirect the stream from the web server to the browser.
public Flux<String> getDataStream(String configType, String ...
4
votes
1
answer
53
views
Why doesn't Schedulers.newParallel() from project Reactor stop running after Flux is done emitting elements?
I have a primitive Flux of Strings, and run this code in the main() method.
package com.example;
import reactor.core.publisher.Flux;
import reactor.core.scheduler.Schedulers;
...
0
votes
1
answer
25
views
Combining two different sources with different timestamps in influxdb/flux
I have 2 measurements as follows:
metrics,app=app1 cpu=10 1654150510
metrics,app=app1 cpu=12 1654150512
metrics,app=app1 cpu=13 1654150514
metrics,app=app1 cpu=14 1654150516
metrics,app=app1 cpu=15 ...
-2
votes
0
answers
27
views
Reactive Programing in Java
I am very new to reactive programing ijust started and have few doubts-
1-i have mono of -
Mono<List<List<Marks>>>
i want to get ->
List<Marks>
. after merging all the ...
0
votes
1
answer
39
views
Why does Kubernetes Flux need multiple configuration intervals?
I am new to Flux.
I struggle to understand the interval configuration. I am following the original doc Flux
flux create source git podinfo \
--url=https://github.com/stefanprodan/podinfo \
--branch=...
0
votes
0
answers
27
views
Flux gitops not deploying despite source being added and showing my commit
Just working on getting a flux setup up and running using this tutorial from Victor from the Devops Toolkit https://gist.github.com/vfarcic/0431989df4836eb82bdac0cc53c7f3d6
Managed to add the sources ...
1
vote
1
answer
27
views
deleting columns from influx DN using flux command line
Is there any way to delete columns of an influx timeseries as we have accidentally injected data using the wrong data type (int instead of float).
Or to change the type of data instead.
0
votes
1
answer
66
views
Flux from (All buckets) in Influxdb 2
I have a dynamic amount of buckets that i want to list, i only want to list the buckets that contain a specific value from a field.
So a more specific explanation here:
I have x amount of bucket, each ...
0
votes
1
answer
55
views
Grafana influxdb2 not showing correct legend label
Using Grafana 8 & influx db2
I want to combine two measurements & add the values
measurement 1:
from(bucket: "myBucket")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
...
0
votes
2
answers
106
views
What's the actual need for RTK Query when fetch API is provided?
Initially the idea of Flux is pretty obvious. The view gets Actions and then emits events based on the Action with which the store is updated. However, when I read through redux-toolkit it seems there ...
0
votes
1
answer
18
views
Can not able create dashboard influxdb latest and above for grafana latest for jmetr data getting nulldata
Can not able use influxdb latest and above for grafana latest from download dashboard
I am using below dashboard
apache-jmeter-dashboard-by-ubikloadpack_rev1
I am getting everything as null
enter ...
2
votes
1
answer
53
views
Is there a name to this common state manegement pattern with rxjs? Does it have limitations?
In Angular applications, we typically do something like this to manage shared states:
import { BehaviorSubject } from 'rxjs';
interface User {
id: number;
}
class UserService {
private _users$ = ...
0
votes
0
answers
21
views
is usContext a reliable solution to drill state 2-3 level deep
I have a search component which needs to pass the state in which the visibility of my search modal is stored down 2-3 levels. I know that context is provided to prevent prop drilling but, performance-...
0
votes
1
answer
26
views
Cascade Flux results
I have two actions in Mono, both returning similar object -
Mono action1()
Mono action2()
I tried doing -
Flux1.blockFirst();
Flux2.blockFirst();
both of the flux are performing the action I want. But ...
0
votes
0
answers
25
views
flatMap on Mono<byte[]> takes a long time to execute
We have a function in our Spring webflux application which takes in a Mono<byte[]> as below.
public Mono<VirusScanResult> scanFile(Mono<byte[]> bytes) {
int RETRY_COUNT = 1;
...
0
votes
0
answers
24
views
Invalid configmap generation for helm chart grafana
I'm trying to create a configmap
I use this values file. Example :
datasources:
datasources.yaml:
apiVersion: 1
datasources:
- name: Prometheus
type: prometheus
uid: ...
1
vote
1
answer
61
views
Convert Mono<Stream<String>> to Flux<String>
I have a Mono like this Mono<Stream<String>> and I want to convert it to a Flux like this Flux<String>. In my junior mind I think it should be simple because Mono<Stream<String&...
0
votes
1
answer
88
views
TYPO3 v11 and fluidtypo3/flux v9.5.0: Class Page does not exist. Reflection failed
I did a fresh composer installation of TYPO3 v11.5.9...
composer require "typo3/cms-adminpanel:^11.5" "typo3/cms-backend:^11.5" "typo3/cms-belog:^11.5" "typo3/cms-...
0
votes
0
answers
15
views
CompletableFuture<List<CardItem>> to Mono object
i have an api that returns CompletableFuture
where CardItem{
cardType
cardStatus
cardDetails
}
but i'd like to iterate through the CompletableFuture and build a parent children object class where if ...
0
votes
0
answers
18
views
Uncomplete InfluxDB query result?
I have a bucket called "testdb" and I'm trying to execute some simple queries on it.
The structure of the bucket is very simple and (i think) is not important for the purpose of the question....
0
votes
0
answers
21
views
Flux Analysis Reports- Balance Sheet & Income Statement in NetSuite
I'm trying to set up custom reports in NetSuite which would generated Month over Month flux analysis (based on a certain $ amount threshold) for balance sheet and income statements. Is that something ...
0
votes
1
answer
37
views
Please correct flux query for grafa to calculate and display of a result for two columns AAA+BBB
// I'm using sequences for insreting in FluxDB:
'sever1,submeas=XXX AAA=899265',
'sever1,submeas=XXX BBB=2281289',
'sever2,submeas=XXX BBB=2672',
'sever2,submeas=XXX AAA=0',
'sever3,submeas=XXX AAA=...
0
votes
1
answer
49
views
Flux calculate rate per second using sample interval
The following Flux gives me DNS queries per second, but I'd like to not have a static value for the measurement interval (10 sec in the code below). How could this be done, is there a variable that ...
0
votes
0
answers
20
views
When joining two Fluxes that return a list, a value is lost
When joining two Fluxes that return a list, a value is lost.
When the smallest flux is resolved the process ends.
How can I get all the values at the same time?
@Test
void zipWith() {
List<...
0
votes
0
answers
23
views
React Icons + Flux containers cannot be used as a JSX component
While working on a big code base I all of a sudden get a bunch of errors such as "cannot be used as a JSX component." It seems only to happen to React Icons and all components that return ...
0
votes
0
answers
52
views
what is Mono.zipDelayError equal function in Flux
I want to Triger the below two calls parallelly and combine the Mono and flux.
Mono<EmpAddressDetail> empAddDetail = getTimeoutDuration()
.flatMapDelayError(duration -> ...
0
votes
2
answers
97
views
How to wrap a Reactor Flux stream with a Redisson lock and unlock?
I have a Flux stream that reads objects from the database.
For each of these objects, I have a processing function to be run.
I want the processing function to execute after acquiring Redis lock on ID ...
0
votes
0
answers
40
views
how does flatMapDelayError flow working in flux to make parallel call
I want to call two differnt down stream service and have zip the results. I have tired the below, want to confirm is there is any other best approach that we have or how does flatMapDelayError ...
0
votes
0
answers
31
views
Julia image feature extraction using EfficientNet.jl
I am trying to use Efficientnet.jl as a feature extractor, meaning I want to extract all features after a given block in the flux chain.
There is the build in function
features = model(x, Val(:stages))...
0
votes
1
answer
55
views
Java Flux Exception Handling?
Can someone please guide me as I am new to the flux and trying to understand how to handle this scenario?
Issue: I am getting readTimeout exception in one of the flux responses from getResp() method ...
1
vote
3
answers
105
views
Zip mono/flux with another that depends on the one I own
I want to zip two monos/fluxes, but the second one (the one I'll zip) is dependand from the first that I already own.
For example:
//...
fun addGroup(
input: GroupInput
): Mono<...
0
votes
0
answers
28
views
Mac : Getting Error while running makefile in flux error : make: execvp: ./docker/image-tag: Permission denied
I am new to the devops. currently i am trying to run make file of flux.
I am getting following error
Steps performed
make
Getting following error
make: execvp: ./docker/image-tag: Permission denied
...
1
vote
1
answer
120
views
Error "DimensionMismatch("A has dimensions (83,5) but B has dimensions (83,5)")" when using Flux package in Julia
I have encountered a problem where it says my dimension mismatch and I am not sure how to go about solving it. I tried making them the same but yet to no avail, it gives me the same error...Here are ...
0
votes
2
answers
78
views
TYPO3 fluid: f:format.html in backend removes links
I am using flux 9.5.0 in TYPO3 9.5.31 to create a simle "text" content element.
It has a preview section that is displayed in the TYPO3 backend with <f:format.html>:
<f:section ...
0
votes
1
answer
61
views
How to get _value of two tables into one table?
I'm trying to create a dashboard where i can filter data by gas station location and fuel type.
This is my Table from this query:
from(bucket: "homeassistant")
|> range(start: v....
0
votes
0
answers
300
views
flux cannot find kustomization path, stat /tmp/XXXXX/kustomize/monitor-nats/overlays/dev: no such file or directory
I'm getting this error while trying flux reconcile kustomization monitor-nats.
here's more info
local k8s cluster version v1.23.4 created using kind create
inside main flux repo:
apiVersion: kustomize....
3
votes
1
answer
548
views
Subscribe to flux from inside subscribe in Spring webFlux java
I have written a logic using spring reactor library to get all operators and then all devices for each operator (paginated) in async mode.
Created a flux to get all operator and then subscribing to it....
0
votes
1
answer
64
views
After updating TYPO3, PHP and FLUX: Content Element with uid "XXXX" and type "flux_XXXXX" has no rendering definition
I am currently supporting a friend by upgrading his TYPO3 Installation which is running FLUX 8.2.1, TYPO3 8.7.23 and PHP 7.1. We've no upgraded to 8.7.32, FLUX 9.5.0 and PHP 7.4.
After Upgrading we ...
0
votes
0
answers
14
views
How to make flow auto discover `.flow` declaration files
I'm trying to get basic flow support working on a Flux project. Flux published their own .flow declaration files but for some reason flow isn't auto discovering them and all exports are getting typed ...
1
vote
1
answer
353
views
return Mono.error inside Map Spring Webflux
For Matching condition, return Mono.error from code , but gives compilation error. I commented out
//return Mono.error(new RuntimeException("User Phone Exists already"));
Result:
...
0
votes
1
answer
54
views
FluxCD sync application from AWS Codecommit not work
I create a AWS codecommit repository that use for flux sync application but sync failed.
The deployment.yaml I create did not produce pods in EKS as I expected.
But in the flux log that looks great.
.....
2
votes
0
answers
102
views
Is there a way to reduce garbage collection and/or dynamic dispatch for Julia Flux gradient calls?
Does anyone know if there's any way to reduce the amount of gc and/or dynamic dispatch for a gradient call in flux? I've tried using FastClosures.jl, as well as wrapping loss into a callable struct to ...
0
votes
0
answers
71
views
Convert Object to Map<String,Object>in Java
I have a piece of code.
List<Bson> results = queryBuilder.createQuery(request, tableName, pivotValues);
Publisher<Employee> rows = getCollection().aggregate(results);
Flux.from(rows).map()....
0
votes
0
answers
121
views
How can I asynchronously emit to as Sink?
I have following proactive method.
void acceptSome(Consumer<? super String> consumer) {
consumer.accept("A");
consumer.accept("B");
}
And I wrote following method ...
0
votes
0
answers
93
views
Project Reactor: Sinks.Many not emitting data after flatMap and reduce while Flux.fromIterable does
I need to have an infinite Flux which gets data from a scheduled api request. The data from the request publishes the data to a Sink. An intermediate service applies the following grouping logic and ...
0
votes
1
answer
147
views
How to replace a while loop for a stream or a Flux to iterate my elements
I have this code
public String calculateShippingEstimateDate(LocalDateTime initialDate, Integer totalDaysToAdd, SaveOrderSourceData saveOrderSourceData) {
int workDays = totalDaysToAdd;
...
0
votes
0
answers
43
views
Multiply two irregular series (Influx/flux)
After reading a lot of forums I still can’t figure this out…
I have two irregular series. The first one reads data from my power cabinet ([kW], one sample every ~2nd second). The second one is the ...
0
votes
1
answer
45
views
Flux: How to get the last record for each value
Ok this have to be something easy, but I can not find out.
Y have the following table, obtained with flux:
Ok, I am monitoring Jira, and as you see, in the column "event_type" I have the ...