taion809

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"log"
	"net/http"

	"github.com/go-chi/chi"

taion809

package main

import (
	"fmt"
	"strings"
)

type Ring struct {
	buffer   []string
	size     int

taion809

Observable FSharp Microservices (dotnetcore2.2+)

Let us define an observable microservice as one that exposes its internal state through events, metrics, and trace data. Ideally we can aggregate this data in some sort of centralized observability system for alerting and diagnostics. In my opinion there are tools that work much better than others and I will use those in this example but the most important part is that you have a starting point and your services can be observed and alerted on somehow. If your company does not have the means to setup all of this infrastructure you should consider buying one of the many SaaS options out today.

Disclaimer: I am not a native .net or F# developer, I think at this point in my career I've logged 2 weeks on an F# dev team so the implementations given below may not be idiomatic, however, my experience comes from being apart of both Devops and microservices dev teams in other teams and organizations.

That being said; let's start building an "observable" micro

taion809

namespace PoeIngester
open HttpFs.Client
open System.Net.Http
open Hopac
open Newtonsoft.Json

module Bookmark =
    type responseBody = {
        [<JsonProperty(PropertyName="next_change_id")>]
        NextChangeId: string;

taion809

load("@com_google_protobuf//:protobuf.bzl", "cc_proto_library")

def envoy_package():
    native.package(default_visibility = ["//visibility:public"])

# Compute the final copts based on various options.
def envoy_copts(repository, test = False):
    return [
        "-Wall",
        "-Wextra",

taion809

Output the state of the DAG when a task executes (output to logs)
Save the version of your workflow and the task code you used (so you can check logs later and recreate data as needed)
script a way to prune the data from any point in the DAG that will also prune data downstream so you can rerun workflows.
log task ids, hadoop application ids, etc when the task executes.

taion809

package transceiver

import (
	"context"
	"strings"

	"github.com/confluentinc/confluent-kafka-go/kafka"
)

type Tx interface {

taion809

private function _formatTreeIntoArray(&$tree, $current_depth = 0)
    {
        $formattedTree = array();
        while($leaf = current($tree))
        {
            if($leaf->DEPTH > $current_depth)
            {
                $formattedTree[] = $this->_formatTreeIntoArray($tree, $leaf->DEPTH);
            }
            elseif($leaf->DEPTH < $current_depth)

taion809

{
    "$schema": "http://json-schema.org/draft-04/schema",
    "title": "Package",
    "type": "object",
    "additionalProperties": false,
    "properties": {
        "name": {
            "type": "string",
            "description": "Package name, including 'vendor-name/' prefix."
        },

taion809

FROM            ubuntu
MAINTAINER      Nicholas Johns "nicholas.a.johns5@gmail.com"

# Force update
# install python-software-properties for adding PPA's
RUN echo "deb http://archive.ubuntu.com/ubuntu precise main universe" > /etc/apt/sources.list
RUN apt-get update
RUN apt-get upgrade -y
RUN apt-get install -y python-software-properties