Skip to content

Instantly share code, notes, and snippets.

View lanwen's full-sized avatar
🎃
Thats my status

Kirill Merkushev lanwen

🎃
Thats my status
View GitHub Profile
18:31:38.972 [public/default/serde-0] INFO org.apache.pulsar.functions.instance.JavaInstanceRunnable - Load JAR: /pulsar/download/pulsar_functions/public/default/serde/0/functions-all.jar
18:31:39.127 [public/default/serde-0] WARN org.apache.pulsar.common.nar.NarClassLoader - /tmp/pulsar-nar/functions-all.jar-unpacked does not contain META-INF/bundled-dependencies!
18:31:39.128 [public/default/serde-0] INFO org.apache.pulsar.functions.instance.JavaInstanceRunnable - Initialize function class loader for function serde at function cache manager
18:31:39.704 [client-scheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.clients.impl.channel.StorageServerChannelManager - Added range server (hostname: "172.17.0.3"
port: 4181
) into the channel manager.
18:31:39.868 [public/default/serde-0] INFO org.apache.pulsar.functions.instance.JavaInstanceRunnable - Starting state table for function serde
18:31:39.914 [client-scheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.clients.impl.channel.StorageServe
name: Node.js Package
on:
release:
types: [published]
jobs:
build:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v2
# Setup .npmrc file to publish to GitHub Packages

Keybase proof

I hereby claim:

  • I am lanwen on github.
  • I am lanwen (https://keybase.io/lanwen) on keybase.
  • I have a public key ASBR2aZhteAK0ewG6gxcUJbPvwNYGpz0Z6cC0fmdK-y3YQo

To claim this, I am signing this object:

----
CREATE DATABASE lanwen;
DROP TABLE IF EXISTS lanwen.source;
DROP TABLE IF EXISTS lanwen.aggregate;
DROP TABLE IF EXISTS lanwen.view;
DROP TABLE IF EXISTS lanwen.anonymous;
DROP TABLE IF EXISTS lanwen.anonymous_view;
CREATE TABLE lanwen.source (
def coverageStatus(String sha, String base) {
step([
$class: 'GitHubCommitStatusSetter',
commitShaSource: [$class: 'ManuallyEnteredShaSource', sha: sha],
contextSource: [$class: 'ManuallyEnteredCommitContextSource', context: 'coverage/line'],
reposSource: [
$class: 'ManuallyEnteredRepositorySource',
url: 'https://github.com/org/name'
],
errorHandlers: [[$class: 'ShallowAnyErrorHandler']],
-Dcom.sun.management.jmxremote \
-Dcom.sun.management.jmxremote.port=9999 \
-Dcom.sun.management.jmxremote.authenticate=false \
-Dcom.sun.management.jmxremote.ssl=false \
-Dcom.sun.management.jmxremote.local.only=false \
-Djava.rmi.server.hostname=localhost \
-Dcom.sun.management.jmxremote.rmi.port=9999 
@lanwen
lanwen / eventsource.js
Created March 19, 2017 22:11 — forked from mattpodwysocki/eventsource.js
Adding support for server-sent events for RxJS
if (!!root.EventSource) {
/**
* This method wraps an EventSource as an observable sequence.
* @param {String} url The url of the server-side script.
* @param {Observer} [openObserver] An optional observer for the 'open' event for the server side event.
* @returns {Observable} An observable sequence which represents the data from a server-side event.
*/
dom.fromEventSource = function (url, openObserver) {
return new AnonymousObservable(function (observer) {
public class CreateTicketBuildStep extends Builder implements SimpleBuildStep {
public static class ConverterImpl extends XStream2.PassthruConverter<CreateTicketBuildStep> {
private static final Logger LOGGER = LoggerFactory.getLogger(ConverterImpl.class);
public ConverterImpl(XStream2 xstream) {
super(xstream);
}
@Override
@lanwen
lanwen / sse.go
Created March 14, 2017 20:48 — forked from schmohlio/sse.go
Example SSE server in Golang
// v2 of the great example of SSE in go by @ismasan.
// includes fixes:
// * infinite loop ending in panic
// * closing a client twice
// * potentially blocked listen() from closing a connection during multiplex step.
package main
import (
"fmt"
"log"
@lanwen
lanwen / nosetests profiling
Created June 16, 2016 22:43 — forked from jassinm/nosetests profiling
nosetest profiling
nosetests --with-profile --profile-stats-file=nose.prof
python -c "import hotshot.stats ; stats = hotshot.stats.load('nose.prof') ; stats.sort_stats('time', 'calls') ; stats.print_stats(20)"