Package org.graylog2.restclient.models

Examples of org.graylog2.restclient.models.Node

495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
        if (!Permissions.isPermitted(RestPermissions.INPUTS_EDIT, inputId)) {
            return redirect(routes.StartpageController.redirect());
        }

        try {
            Node node;
            if (nodeId != null && !nodeId.isEmpty())
                node = nodeService.loadNode(nodeId);
            else
                node = nodeService.loadMasterNode();

            node.getInput(inputId).removeStaticField(key);

            return redirect(routes.InputsController.index());
        } catch (IOException e) {
            return status(500, views.html.errors.error.render(ApiClient.ERROR_MSG_IO, e, request()));
        } catch (APIException e) {
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
    }

    public Result show(String index, String id) {
        try {
            MessageResult message = messagesService.getMessage(index, id);
            Node sourceNode = getSourceNode(message);
            Radio sourceRadio = getSourceRadio(message);

            List<Stream> messageInStreams = Lists.newArrayList();

            for (String streamId : message.getStreamIds()) {
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
    }

    public Result partial(String index, String id) {
        try {
            MessageResult message = messagesService.getMessage(index, id);
            Node sourceNode = getSourceNode(message);
            Radio sourceRadio = getSourceRadio(message);
            List<Stream> messageInStreams = Lists.newArrayList();

            for (String streamId : message.getStreamIds()) {
                if (isPermitted(STREAMS_READ, streamId)) {
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
    @Inject
    private NodeService nodeService;

    public Result ofNode(String nodeId, String preFilter) {
        try {
            Node node = nodeService.loadNode(nodeId);

            BreadcrumbList bc = new BreadcrumbList();
            bc.addCrumb("System", routes.SystemController.index(0));
            bc.addCrumb("Nodes", routes.NodesController.nodes());
            bc.addCrumb(node.getShortNodeId(), routes.NodesController.node(node.getNodeId()));
            bc.addCrumb("Metrics", routes.MetricsController.ofNode(node.getNodeId(), ""));

            Map<String, Metric> metrics = node.getMetrics("org.graylog2");

            return ok(views.html.system.metrics.of_node.render(currentUser(), bc, node, metrics, preFilter));
        } catch (IOException e) {
            return status(500, views.html.errors.error.render(ApiClient.ERROR_MSG_IO, e, request()));
        } catch (APIException e) {
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
70
        return ok(views.html.system.logging.index.render(currentUser(), bc, loggers, subsystems));
    }

    public Result setSubsystemLevel(String nodeId, String subsystem, String level) {
        try {
            Node node = nodeService.loadNode(nodeId);
            node.setSubsystemLoggerLevel(subsystem, level);

            return redirect(routes.LoggingController.index());
        } catch (IOException e) {
            return status(500, views.html.errors.error.render(ApiClient.ERROR_MSG_IO, e, request()));
        } catch (APIException e) {
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
63
    public Result io(String nodeId, String inputId) {
        try {
            Map<String, Object> result = Maps.newHashMap();

            final Node node = nodeService.loadNode(nodeId);
            final Input input = node.getInput(inputId);
            final Input.IoStats ioStats = input.getIoStats();

            result.put("total_rx", Tools.byteToHuman(ioStats.readBytesTotal));
            result.put("total_tx", Tools.byteToHuman(ioStats.writtenBytesTotal));
            result.put("rx", Tools.byteToHuman(ioStats.readBytes));
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
113
    public Result connections(String nodeId, String inputId) {
        try {
            Map<String, Object> result = Maps.newHashMap();

            final Node node = nodeService.loadNode(nodeId);
            final Input input = node.getInput(inputId);

            result.put("active", input.getConnections());
            result.put("total", input.getTotalConnections());

            return ok(Json.toJson(result));
View Full Code Here
124
125
126
127
128
129
130
131
132
133
134
135
        return recentMessage(nodeId, inputId, true);
    }

    public Result recentMessage(String nodeId, String inputId, Boolean filtered) {
        try {
            Node node = nodeService.loadNode(nodeId);
            MessageResult recentlyReceivedMessage = node.getInput(inputId).getRecentlyReceivedMessage(nodeId);

            if (recentlyReceivedMessage == null) {
                return notFound();
            }
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
140
    }

    public Result nodeThroughput(String nodeId) {
        try {
            Map<String, Object> result = Maps.newHashMap();
            final Node node = nodeService.loadNode(nodeId);
            result.put("throughput", node.getThroughput());

            return ok(Json.toJson(result));
        } catch (NodeService.NodeNotFoundException e) {
            return status(404, "node not found");
        }
View Full Code Here
167
168
169
170
171
172
173
174
175
176
177
178
    }

    public Result heap(String nodeId) {
        try {
            Map<String, Object> result = Maps.newHashMap();
            Node node = nodeService.loadNode(nodeId);

            return ok(Json.toJson(jvmMap(node.jvm(), node.getBufferInfo())));
        } catch (NodeService.NodeNotFoundException e) {
            return status(404, "node not found");
        }
    }
View Full Code Here
TOP

Related Classes of org.graylog2.restclient.models.Node

  • com.codahale.metrics.MetricRegistry
  • com.fasterxml.jackson.databind.ObjectMapper
  • com.fasterxml.jackson.datatype.guava.GuavaModule
  • com.fasterxml.jackson.datatype.joda.JodaModule
  • com.github.joschi.jadconfig.JadConfig
  • com.github.joschi.jadconfig.repositories.InMemoryRepository
  • com.google.common.base.Stopwatch
  • com.google.common.util.concurrent.ThreadFactoryBuilder
  • com.mongodb.BasicDBObject
  • com.mongodb.DBObject
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.