Skip to content

Commit

Permalink
Showing 22 changed files with 166 additions and 177 deletions.
2 changes: 1 addition & 1 deletion pulsar-functions/conf/function_worker.yml
Original file line number Diff line number Diff line change
@@ -30,7 +30,7 @@ pulsarWebServiceUrl: http://localhost:8080
numFunctionPackageReplicas: 1
downloadDirectory: /tmp/pulsar_functions
metricsConfig:
metricsSinkClassName: org.apache.pulsar.functions.runtime.metrics.sink.PrometheusSink
metricsSinkClassName: org.apache.pulsar.functions.metrics.sink.PrometheusSink
metricsCollectionInterval: 30
metricsSinkConfig:
path: /metrics
106 changes: 106 additions & 0 deletions pulsar-functions/metrics/pom.xml
Original file line number Diff line number Diff line change
@@ -0,0 +1,106 @@
<!--
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements. See the NOTICE file
distributed with this work for additional information
regarding copyright ownership. The ASF licenses this file
to you under the Apache License, Version 2.0 (the
"License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing,
software distributed under the License is distributed on an
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express or implied. See the License for the
specific language governing permissions and limitations
under the License.
-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<properties>
<gson.version>2.8.2</gson.version>
</properties>

<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-functions</artifactId>
<version>2.0.0-incubating-SNAPSHOT</version>
</parent>

<artifactId>pulsar-functions-metrics</artifactId>
<name>Pulsar Functions :: Metrics</name>

<dependencies>

<!-- logging -->
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-slf4j-impl</artifactId>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
</dependency>

<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-functions-proto</artifactId>
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-functions-utils</artifactId>
<version>${project.version}</version>
</dependency>


<dependency>
<groupId>com.fasterxml.jackson.dataformat</groupId>
<artifactId>jackson-dataformat-yaml</artifactId>
<version>${jackson.version}</version>
</dependency>

<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-annotations</artifactId>
<version>${jackson.version}</version>
</dependency>

<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>${jackson.version}</version>
</dependency>

<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>${gson.version}</version>
</dependency>


<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java</artifactId>
<version>3.5.1</version>
</dependency>

<dependency>
<groupId>net.jodah</groupId>
<artifactId>typetools</artifactId>
<version>0.5.0</version>
</dependency>

</dependencies>

</project>
Original file line number Diff line number Diff line change
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.functions.runtime.metrics;
package org.apache.pulsar.functions.metrics;

import java.util.Map;

Original file line number Diff line number Diff line change
@@ -19,4 +19,4 @@
/**
* Spanwer for spawning processes, threads, docker containers to execute functions.
*/
package org.apache.pulsar.functions.runtime.metrics;
package org.apache.pulsar.functions.metrics;
Original file line number Diff line number Diff line change
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.functions.runtime.metrics.sink;
package org.apache.pulsar.functions.metrics.sink;

import java.io.IOException;
import java.io.OutputStream;
@@ -33,7 +33,7 @@

import com.sun.net.httpserver.HttpServer;

import org.apache.pulsar.functions.runtime.metrics.MetricsSink;
import org.apache.pulsar.functions.metrics.MetricsSink;


/**
Original file line number Diff line number Diff line change
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.functions.runtime.metrics.sink;
package org.apache.pulsar.functions.metrics.sink;

import java.io.File;
import java.io.FileNotFoundException;
@@ -29,7 +29,7 @@
import com.google.protobuf.util.JsonFormat;
import org.apache.pulsar.functions.proto.Function;
import org.apache.pulsar.functions.proto.InstanceCommunication;
import org.apache.pulsar.functions.runtime.metrics.MetricsSink;
import org.apache.pulsar.functions.metrics.MetricsSink;
import org.apache.pulsar.functions.utils.FunctionConfigUtils;

/**
Original file line number Diff line number Diff line change
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.functions.runtime.metrics.sink;
package org.apache.pulsar.functions.metrics.sink;

import java.io.IOException;
import java.util.HashMap;
Original file line number Diff line number Diff line change
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.functions.runtime.metrics.sink;
package org.apache.pulsar.functions.metrics.sink;

import java.io.File;
import java.io.IOException;
Original file line number Diff line number Diff line change
@@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.functions.runtime.metrics.sink;
package org.apache.pulsar.functions.metrics.sink;

import java.io.IOException;
import java.util.Arrays;
1 change: 1 addition & 0 deletions pulsar-functions/pom.xml
Original file line number Diff line number Diff line change
@@ -35,6 +35,7 @@
<module>proto</module>
<module>api-java</module>
<module>utils</module>
<module>metrics</module>
<module>instance</module>
<module>runtime</module>
<module>worker</module>
6 changes: 6 additions & 0 deletions pulsar-functions/runtime/pom.xml
Original file line number Diff line number Diff line change
@@ -146,6 +146,12 @@
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-functions-metrics</artifactId>
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>com.fasterxml.jackson.dataformat</groupId>
<artifactId>jackson-dataformat-yaml</artifactId>

This file was deleted.

This file was deleted.

Original file line number Diff line number Diff line change
@@ -32,7 +32,7 @@
import org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatus;
import org.apache.pulsar.functions.runtime.container.FunctionContainerFactory;
import org.apache.pulsar.functions.runtime.container.FunctionContainer;
import org.apache.pulsar.functions.runtime.metrics.MetricsSink;
import org.apache.pulsar.functions.metrics.MetricsSink;
import org.apache.pulsar.functions.utils.FunctionConfigUtils;

@Slf4j

This file was deleted.

This file was deleted.

6 changes: 6 additions & 0 deletions pulsar-functions/worker/pom.xml
Original file line number Diff line number Diff line change
@@ -68,6 +68,12 @@
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>pulsar-functions-metrics</artifactId>
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>org.glassfish.jersey.media</groupId>
<artifactId>jersey-media-json-jackson</artifactId>
Loading

0 comments on commit 2d7a7f8

Please sign in to comment.