Setup
bin/kafka-topics.sh \
--zookeeper zookeeper.example.com:2181 \
--create \
Andrew Vorobyov vorandrew
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import asyncio | |
| import datetime as dt | |
| import json | |
| import logging | |
| import re | |
| import requests | |
| import websockets | |
| URL = "https://api.tastytrade.com" |
vorandrew
/ bitbucket-pipelines.yml
Created
October 29, 2023 11:11
— forked from ahmetgeymen/bitbucket-pipelines.yml
Bitbucket Pipelines: Build Docker Image + GCR Image Push + GKE Deploy
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| image: openjdk:11-jdk-slim | |
| definitions: | |
| caches: | |
| gradlewrapper: ~/.gradle/wrapper | |
| gke-kubectl-pipe: &pipe atlassian/google-gke-kubectl-run:1.3.1 | |
| gke-kubectl-pipe-variables: &pipe-variables | |
| KEY_FILE: $GKE_API_KEYFILE | |
| PROJECT: $GCP_PROJECT_ID | |
| COMPUTE_ZONE: $GKE_COMPUTE_ZONE |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| data "google_client_config" "default" {} | |
| provider "kubernetes" { | |
| host = "https://${module.gke.endpoint}" | |
| token = data.google_client_config.default.access_token | |
| cluster_ca_certificate = base64decode(module.gke.ca_certificate) | |
| } | |
| module "gke" { | |
| source = "terraform-google-modules/kubernetes-engine/google" |
vorandrew
/ pstest_subscriber_test.go
Created
April 4, 2022 23:12
— forked from sugamon/pstest_subscriber_test.go
sample subscriber test
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package pubsub | |
| import ( | |
| "context" | |
| "testing" | |
| "time" | |
| "cloud.google.com/go/pubsub" | |
| "cloud.google.com/go/pubsub/pstest" | |
| "google.golang.org/api/option" |
vorandrew
/ benchmark-commands.md
Created
November 29, 2020 21:13
— forked from ueokande/benchmark-commands.md
Kafka Benchmark Commands
vorandrew
/ server.r
Last active
January 5, 2019 14:00
— forked from timelyportfolio/server.r
Example to Test Parameters on Moving Average System
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #almost entirely based on the 02_text and 03_mpg examples provided by RStudio Shiny | |
| #all credit belongs to them | |
| if (!require(PerformanceAnalytics)) { | |
| stop("This app requires the PerformanceAnalytics package. To install it, run 'install.packages(\"PerformanceAnalytics\")'.\n") | |
| } | |
| if (!require(quantmod)) { | |
| stop("This app requires the quantmod package. To install it, run 'install.packages(\"quantmod\")'.\n") |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| deribit-rxjs:ohlc-s5 2018-12-23T13:18:29.336Z BTC-PERPETUAL { t: 1545571105000, o: null, h: null, l: null, c: null, v: null } +5s | |
| deribit-rxjs:ohlc-s15 2018-12-23T13:18:29.336Z BTC-PERPETUAL { t: 1545571095000, o: null, h: null, l: null, c: null, v: null } +15s | |
| deribit-rxjs:ohlc-s30 2018-12-23T13:18:29.336Z BTC-PERPETUAL { t: 1545571080000, o: null, h: null, l: null, c: null, v: null } +30s | |
| deribit-rxjs:ohlc-s1 2018-12-23T13:18:30.009Z BTC-PERPETUAL { t: 1545571110000, o: null, h: null, l: null, c: null, v: null } +673ms | |
| deribit-rxjs:ohlc-s1 2018-12-23T13:18:31.019Z BTC-PERPETUAL { t: 1545571111000, o: null, h: null, l: null, c: null, v: null } +1s | |
| deribit-rxjs:ohlc-s1 2018-12-23T13:18:32.030Z BTC-PERPETUAL { t: 1545571112000, o: null, h: null, l: null, c: null, v: null } +1s | |
| deribit-rxjs:ohlc-s1 2018-12-23T13:18:33.040Z BTC-PERPETUAL { t: 1545571113000, o: null, h: null, l: null, c: null, v: null } +1s | |
| deribit-rxjs:ohlc-s1 2018-12-23T13:18:34.047Z BTC-PERPETUAL { t: 1545571114000, o: null, h: |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| deribit:api:ws:test {"id":742,"success":false,"testnet":false,"error":10000,"message":"authorization_required"} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| function MakeArray(size) { | |
| for (var i = 1; i <= size; i++) { | |
| this.length = size; | |
| this[i] = 0; | |
| } | |
| } | |
| /* |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| let data = _.flow( | |
| _.groupBy('country_id'), | |
| _.map( | |
| _.flow( // city group by level | |
| _.groupBy('city_id'), | |
| _.map( | |
| _.flow( // person group by level | |
| _.groupBy('person_id'), | |
| _.map(vals => { | |
| return { |
NewerOlder