File tree Expand file tree Collapse file tree 2 files changed +5
-21
lines changed
src/test/java/org/apache/skywalking/banyandb/v1/client Expand file tree Collapse file tree 2 files changed +5
-21
lines changed Original file line number Diff line number Diff line change @@ -63,25 +63,6 @@ public void testMeasureRegistry_createAndGet() throws BanyanDBException {
6363 Assert .assertEquals (expectedMeasure , actualMeasure );
6464 }
6565
66- @ Test
67- public void testMeasureRegistry_createAndUpdate () throws BanyanDBException {
68- this .client .define (buildMeasure ());
69- Measure beforeMeasure = client .findMeasure ("sw_metric" , "service_cpm_minute" );
70- Assert .assertNotNull (beforeMeasure );
71- Assert .assertNotNull (beforeMeasure .getUpdatedAt ());
72-
73- Measure updatedMeasure = beforeMeasure .toBuilder ()
74- .setInterval (Duration .ofMinutes (2 ).format ())
75- .build ();
76- this .client .update (updatedMeasure );
77- Measure afterMeasure = client .findMeasure ("sw_metric" , "service_cpm_minute" );
78- Assert .assertNotNull (afterMeasure );
79- Assert .assertNotNull (afterMeasure .getUpdatedAt ());
80- updatedMeasure = updatedMeasure .toBuilder ().clearUpdatedAt ().setMetadata (updatedMeasure .getMetadata ().toBuilder ().clearModRevision ().clearCreateRevision ()).build ();
81- afterMeasure = afterMeasure .toBuilder ().clearUpdatedAt ().setMetadata (afterMeasure .getMetadata ().toBuilder ().clearModRevision ().clearCreateRevision ()).build ();
82- Assert .assertEquals (updatedMeasure , afterMeasure );
83- }
84-
8566 @ Test
8667 public void testMeasureRegistry_createAndList () throws BanyanDBException {
8768 Measure expectedMeasure = buildMeasure ();
Original file line number Diff line number Diff line change @@ -66,8 +66,11 @@ public void testStreamRegistry_createAndUpdate() throws BanyanDBException {
6666 Stream beforeStream = client .findStream ("sw_record" , "trace" );
6767 Assert .assertNotNull (beforeStream );
6868 Assert .assertNotNull (beforeStream .getUpdatedAt ());
69- Stream updatedStream = beforeStream .toBuilder ().setEntity (Entity .newBuilder ().addAllTagNames (
70- Arrays .asList ("service_id" , "is_error" ))).build ();
69+ Stream updatedStream = beforeStream .toBuilder ().addTagFamilies (TagFamilySpec .newBuilder ()
70+ .setName ("ex" )
71+ .addTags (TagSpec .newBuilder ()
72+ .setName ("ex" )
73+ .setType (TagType .TAG_TYPE_INT ))).build ();
7174 this .client .update (updatedStream );
7275 Stream afterStream = client .findStream ("sw_record" , "trace" );
7376 Assert .assertNotNull (afterStream );
You can’t perform that action at this time.
0 commit comments