File tree Expand file tree Collapse file tree
data-prepper-plugins/mongodb/src/test/java/org/opensearch/dataprepper/plugins/mongo Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1+ package org .opensearch .dataprepper .plugins .mongo .documentdb ;
2+
3+ import org .junit .jupiter .api .extension .ExtendWith ;
4+ import org .mockito .InjectMocks ;
5+ import org .mockito .Mock ;
6+ import org .mockito .junit .jupiter .MockitoExtension ;
7+ import org .opensearch .dataprepper .model .buffer .Buffer ;
8+ import org .opensearch .dataprepper .model .event .Event ;
9+ import org .opensearch .dataprepper .model .record .Record ;
10+
11+ @ ExtendWith (MockitoExtension .class )
12+ public class DocumentDBServiceTest {
13+ @ Mock
14+ private Buffer <Record <Event >> buffer ;
15+
16+ @ InjectMocks
17+ private DocumentDBService documentDBService ;
18+
19+ /* @Test
20+ public void start() {
21+ documentDBService.start(buffer);
22+
23+ verify(documentDBService).start(buffer);
24+ }
25+
26+ @Test
27+ public void shutdown() {
28+ documentDBService.shutdown();
29+
30+ verify(documentDBService).shutdown();
31+ }*/
32+ }
Original file line number Diff line number Diff line change 1+ package org .opensearch .dataprepper .plugins .mongo .documentdb ;
2+
3+ import org .junit .jupiter .api .extension .ExtendWith ;
4+ import org .mockito .InjectMocks ;
5+ import org .mockito .Mock ;
6+ import org .mockito .junit .jupiter .MockitoExtension ;
7+ import org .opensearch .dataprepper .model .buffer .Buffer ;
8+ import org .opensearch .dataprepper .model .event .Event ;
9+ import org .opensearch .dataprepper .model .record .Record ;
10+
11+ @ ExtendWith (MockitoExtension .class )
12+ public class DocumentDBSourceTest {
13+ @ Mock
14+ private DocumentDBService documentDBService ;
15+
16+ @ Mock
17+ private Buffer <Record <Event >> buffer ;
18+
19+ @ InjectMocks
20+ private DocumentDBSource documentDBSource ;
21+
22+ /*@Test
23+ public void start() {
24+ documentDBSource.start(buffer);
25+
26+ verify(documentDBService).start(buffer);
27+ }
28+
29+ @Test
30+ public void stop() {
31+ documentDBSource.stop();
32+
33+ verify(documentDBService).shutdown();
34+ }*/
35+ }
Original file line number Diff line number Diff line change 11package org .opensearch .dataprepper .plugins .mongo .stream ;
22
33import com .mongodb .MongoSecurityException ;
4- import org .bson .BsonDocument ;
54import org .junit .jupiter .api .BeforeEach ;
65import org .junit .jupiter .api .Test ;
76import org .junit .jupiter .api .extension .ExtendWith ;
You can’t perform that action at this time.
0 commit comments