apache-ignite

1
# Licensed to the Apache Software Foundation (ASF) under one or more
2
# contributor license agreements.  See the NOTICE file distributed with
3
# this work for additional information regarding copyright ownership.
4
# The ASF licenses this file to You under the Apache License, Version 2.0
5
# (the "License"); you may not use this file except in compliance with
6
# the License.  You may obtain a copy of the License at
7
#
8
#    http://www.apache.org/licenses/LICENSE-2.0
9
#
10
# Unless required by applicable law or agreed to in writing, software
11
# distributed under the License is distributed on an "AS IS" BASIS,
12
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
# See the License for the specific language governing permissions and
14
# limitations under the License.
15

16
from ignitetest.services.ignite_app import IgniteApplicationService
17

18

19
class DumpUtility:
20
    """
21
    Control the cache dump operations.
22
    """
23
    def __init__(self, test_context, cluster):
24
        self.cluster = cluster
25

26
        self.app = IgniteApplicationService(
27
            test_context,
28
            cluster.config._replace(client_mode=True),
29
            java_class_name="org.apache.ignite.internal.ducktest.tests.dump.DumpUtility"
30
        )
31

32
    def create(self, dump_name):
33
        """
34
        Create cache dump.
35
        :param dump_name: Name of the dump.
36
        """
37
        self.app.params = {
38
            "cmd": "create",
39
            "dumpName": dump_name
40
        }
41

42
        self.app.start(clean=False)
43

44
        self.app.wait()
45

46
        dump_create_time_ms = self.app.extract_result("DUMP_CREATE_TIME_MS")
47

48
        return int(dump_create_time_ms) if dump_create_time_ms != "" else None
49