icebob

Loki logger for Moleculer microservices framework

It sends the Moleculer log messages to a Grafana Loki server directly. I'm using it to send logs from Fly.io moleculer app to Grafana Cloud.

For Kubernetes, I recommend to use Grafana Agent to send log messages because Agent adds K8s pod relevant labels to the messages.

Usage

// moleculer.config.js

icebob

import * as pulumi from '@pulumi/pulumi';

export interface PostgresRestartArgs {
  resourceGroupName: pulumi.Input<string>;
  serverName: pulumi.Input<string>;
}

class PostgresRestartProvider implements pulumi.dynamic.ResourceProvider {
  public async check(
    olds: any,

icebob

const fetch = require("node-fetch");
const { createWriteStream, existsSync } = require("fs");
const fs = require("fs").promises;

const outputFileName = "stars.csv";
const githubUser = "icebob";

function log(msg) {
    console.log(`[${new Date().toISOString().substr(11, 8)}] -`, msg);
}

icebob

version: '3'

services:
  server:
    image: "rancher/k3s:latest"
    command: server
    tmpfs:
    - /run
    - /var/run
    privileged: true

icebob

sudo apt-get install open-iscsi
kubectl apply -f https://raw.githubusercontent.com/longhorn/longhorn/master/deploy/longhorn.yaml
kubectl -n longhorn-system get all

icebob

kubectl apply -f https://raw.githubusercontent.com/nginxinc/kubernetes-ingress/master/deployments/common/ns-and-sa.yaml
kubectl apply -f https://raw.githubusercontent.com/nginxinc/kubernetes-ingress/master/deployments/common/default-server-secret.yaml
kubectl apply -f https://raw.githubusercontent.com/nginxinc/kubernetes-ingress/master/deployments/common/nginx-config.yaml
kubectl apply -f https://raw.githubusercontent.com/nginxinc/kubernetes-ingress/master/deployments/rbac/rbac.yaml
kubectl apply -f https://raw.githubusercontent.com/nginxinc/kubernetes-ingress/master/deployments/daemon-set/nginx-ingress.yaml

icebob

# Install K3S
curl -sfL https://get.k3s.io | sh -

# Copy k3s config
mkdir $HOME/.kube
sudo cp /etc/rancher/k3s/k3s.yaml $HOME/.kube/config
sudo chmod 644 $HOME/.kube/config

# Check K3S 
kubectl get pods -n kube-system

icebob

'use strict';

const path = require('path');
const fs = require('fs');
const YAML = require('yaml');

function WebpackMoleculerServicePlugin(options) {
  options = options || {};
  if (typeof options === 'string') {
    this.options = { output: options };

icebob

Health-check middleware for Moleculer

Use it for Kubernetes liveness & readiness checks. The middleware opens a HTTP server on port 3001. To check, open the http://localhost:3001/live & http://localhost:3001/ready URL.

Response

{
  "state": "up",
  "uptime": 7.419,

icebob

"use strict";

const _ = require("lodash");
const chalk = require("chalk");
const Promise = require("bluebird");
const ServiceBroker = require("../src/service-broker");
const { MoleculerError } = require("../src/errors");

// --- SAGA MIDDLEWARE ---
const SagaMiddleware = function() {