| version: "3" | |
| services: | |
| redis1: | |
| image: redis:latest | |
| command: redis-server --port 7001 --cluster-enabled yes --cluster-config-file nodes.conf --cluster-node-timeout 5000 --appendonly yes --cluster-announce-ip 172.16.0.11 --cluster-announce-port 7001 | |
| ports: | |
| - 7001:7001 | |
| volumes: | |
| - ./data/redis1:/data |
| module github.com/frain-dev/migrate | |
| go 1.19 | |
| require go.mongodb.org/mongo-driver v1.10.2 | |
| require ( | |
| github.com/golang/snappy v0.0.1 // indirect | |
| github.com/klauspost/compress v1.13.6 // indirect | |
| github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe // indirect |
| // Generate webhook URL. | |
| package main | |
| import ( | |
| "errors" | |
| "fmt" | |
| "io/ioutil" | |
| "net/http" | |
| "net/url" | |
| "time" |
| const sleep = (ms = 1000) => new Promise((resolve) => setTimeout(resolve, ms)); | |
| async function start() { | |
| const execFile = join(__dirname, './worker/index.js'); | |
| const pool = new ThreadPool<number, number>({ | |
| execFile, | |
| jobCallback, | |
| timeOutCallback, | |
| debug: true, | |
| threadTimeout: 3 |
Throughout all GoMoney services, we implement the JSend specification for serving API responses. More detail can be found on the omniti-labs/jsend github repo. But in a nutshell, this middleware attaches a JSend object to each request with success, fail, and error methods that can then be invoked later on. This means our responses usually follow the same general formats.
Successes
{
"status" : "success",
"data" : {
| fun <V : View> Activity.bind(@IdRes resource: Int): V { | |
| val lazyValue: Lazy<V> = lazy { findViewById(resource) } | |
| return lazyValue.value | |
| } |
| import faker from 'faker'; | |
| /** | |
| * Faker polyfill method `middleName` | |
| * | |
| * @method middleName | |
| * @param {mixed} gender | |
| * @memberof faker.name | |
| */ | |
| faker.name['middleName'] = function(gender) { |
| Process: Viso [50893] | |
| Path: /Applications/Viso.app/Contents/MacOS/Viso | |
| Identifier: com.viso.Viso | |
| Version: 4 (6) | |
| Code Type: X86-64 (Native) | |
| Parent Process: ??? [1] | |
| Responsible: Viso [50893] | |
| User ID: 501 | |
| Date/Time: 2019-06-24 22:08:36.989 +0100 |
| const WALLET_REPORT = '../../WalletReport.xlsx'; | |
| class GenerateReport { | |
| wallets: Wallet[] = []; | |
| duration: number = 0; | |
| constructor() { | |
| writeFileSync(join(__dirname, WALLET_REPORT), ''); | |
| } |
| const start_time = performance.now(); | |
| const count: number = 1000; | |
| const wallets: Wallet[] = []; | |
| const walletCount = await WalletModel.find({}).estimatedDocumentCount(); | |
| // create a cursor for every `currentIndex` documents in the collection | |
| const getNthCursor = async (currentIndex: number) => | |
| await WalletModel.find({ deleted_at: undefined }, { timeout: false }) | |
| .lean() |