-
Notifications
You must be signed in to change notification settings - Fork 1.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Implement DSL for LogPoller #12793
Implement DSL for LogPoller #12793
Conversation
3432012
to
d6aa675
Compare
I see you updated files related to
|
Go solidity wrappers are out-of-date, regenerate them via the |
7e81204
to
847e26f
Compare
Go solidity wrappers are out-of-date, regenerate them via the |
1 similar comment
Go solidity wrappers are out-of-date, regenerate them via the |
847e26f
to
ac43608
Compare
Go solidity wrappers are out-of-date, regenerate them via the |
ac43608
to
d6fdb13
Compare
2a59e99
to
22ae19f
Compare
2559c27
to
2d14233
Compare
2d14233
to
4bba5f9
Compare
f69ff74
to
b7b91d9
Compare
0f1f98f
to
ec69292
Compare
179ac48
to
197e35b
Compare
@@ -121,7 +121,7 @@ func (e *eventBinding) QueryKey(ctx context.Context, filter query.KeyFilter, lim | |||
} | |||
remapped.Expressions = append(defaultExpressions, remapped.Expressions...) | |||
|
|||
logs, err := e.lp.FilteredLogs(ctx, remapped, limitAndSort) | |||
logs, err := e.lp.FilteredLogs(ctx, remapped, limitAndSort, e.contractName+"-"+e.eventName) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I am not sure if this is enough from observability perspective. We can query for same event from same contract with different filters. We should either pass a queryName from QueryKey
or somehow turn limitAndSort and filter into a string? Although to make it easier we can do this in a separate PR under a separate ticket.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think a separate PR would be best to iron out the rest of this detail.
This commit implements the query DSL within LogPoller by remapping comparer filters to topic and word filters. A parser then creates an SQL statement from the remapped events and queries the log poller database directly.
39abe02
to
7d4d24a
Compare
Quality Gate passedIssues Measures |
This commit implements the query DSL within LogPoller by remapping comparer filters to
topic and word filters. A parser then creates an SQL statement from the remapped events
and queries the log poller database directly.