-
Notifications
You must be signed in to change notification settings - Fork 378
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
Feat msp storage switch to es #2861
Feat msp storage switch to es #2861
Conversation
Codecov Report
@@ Coverage Diff @@
## master #2861 +/- ##
==========================================
+ Coverage 17.09% 17.27% +0.17%
==========================================
Files 1292 1301 +9
Lines 131580 132388 +808
==========================================
+ Hits 22498 22873 +375
- Misses 106759 107151 +392
- Partials 2323 2364 +41
|
indices := p.Loader.Indices(ctx, sel.StartTime, sel.EndTime, loader.KeyPath{ | ||
Recursive: true, | ||
}) | ||
fmt.Println(indices) |
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.
remove it
"github.com/erda-project/erda/modules/msp/apm/exception/erda-error/storage" | ||
) | ||
|
||
// Data . |
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.
Error
// Data . | ||
type Error = interface{} | ||
|
||
// ListIterator . |
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.
ErrorListIterator
} | ||
|
||
// NewListIterator . | ||
func NewErrorListIterator(list ...Error) storekit.Iterator { |
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.
NewErrorListIterator
} | ||
|
||
func (it *scrollIterator) fetch(dir iteratorDir) error { | ||
fmt.Println(it.indices) |
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.
remove it
@@ -90,7 +90,7 @@ func (p *provider) Close() error { | |||
func init() { | |||
servicehub.Register("trace-storage", &servicehub.Spec{ | |||
Services: []string{"trace-storage"}, | |||
Dependencies: []string{"kafka", "cassandra", "kafka.topic.initializer"}, | |||
Dependencies: []string{"kafka", "cassandra"}, |
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.
why delete kafka.topic.initializer
Adjust your changelog into table please. |
/approve |
/cherry-pick release/1.4 |
* feature: msp storage switch to es * bugifx: msp fix queryspanbytraceid bug * feature-msp-storage-support-es&bugfix-msp-span-lost * fix ci go-import order problem * fix queryspancountbytraceid bug * fix code review problem from recallsong * fix ci check-imports problem * fix ci fmt problem * fix ci fmt problem again, sadly * change span es index shards default setting to 1
* feature: msp storage switch to es * bugifx: msp fix queryspanbytraceid bug * feature-msp-storage-support-es&bugfix-msp-span-lost * fix ci go-import order problem * fix queryspancountbytraceid bug * fix code review problem from recallsong * fix ci check-imports problem * fix ci fmt problem * fix ci fmt problem again, sadly * change span es index shards default setting to 1 Co-authored-by: li2329800 <9552289+li2329800@users.noreply.github.com>
What type of this PR
Add one of the following kinds:
/kind feature
/kind bugfix
What this PR does / why we need it:
Which issue(s) this PR fixes:
Specified Reviewers:
/assign @liuhaoyang @recallsong
ChangeLog
2. Support ES as beckend storage in msp platform
2.实现了msp平台后端存储对于ES的支持
Need cherry-pick to release versions?
Need cherry-pick to release/1.4