thomaspoignant

root: handler1_name
steps:
  handler1_name:
    type: handlerImpl1
    next: handler2_name

  handler2_name:
    type: handlerImpl2

thomaspoignant

  /**
   * createApiGatewayForLambda is creating a Rest API Gateway to access to your lambda function
   * @param id - CDK id for this lambda
   * @param handler - Lambda function to call
   * @param description - Description of this endpoint
   */
  createApiGatewayForLambda(id: string, handler: lambda.Function, description: string): LambdaRestApi{
    return new LambdaRestApi(this, id, {
      handler,
      description

thomaspoignant

  /**
   * buildAndInstallGOLambda build the code and create the lambda
   * @param id - CDK id for this lambda
   * @param lambdaPath - Location of the code
   * @param handler - name of the handler to call for this lambda
   */
  buildAndInstallGOLambda(id: string, lambdaPath: string, handler: string): lambda.Function {
    const environment = {
      CGO_ENABLED: '0',
      GOOS: 'linux',

thomaspoignant

var chiLambda *chiadapter.ChiLambda

// handler is the function called by the lambda.
func handler(ctx context.Context, req events.APIGatewayProxyRequest) (events.APIGatewayProxyResponse, error) {
	return chiLambda.ProxyWithContext(ctx, req)
}

// main is called when a new lambda starts, so don't
// expect to have something done for every query here.
func main() {

thomaspoignant

import * as cdk from '@aws-cdk/core';
import {CfnResource} from "@aws-cdk/core";

export class CdkCustomResourcesStack extends cdk.Stack {
  constructor(scope: cdk.Construct, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

    const monitorType = new CfnResource(this, 'datadog_monitor_id',{
      type: 'AWS::CloudFormation::ResourceVersion',
      properties:{

thomaspoignant

new CfnResource(this, 'datadog_monitor_id',{
  type: 'AWS::CloudFormation::ResourceVersion',
  properties:{
    'TypeName': 'Datadog::Monitors::Monitor',
    'SchemaHandlerPackage':
        's3://datadog-cloudformation-resources/datadog-monitors-monitor/datadog' +
        '-monitors-monitor-2.1.0.zip'
  }
})

thomaspoignant

GOCMD=go
GOTEST=$(GOCMD) test
GOVET=$(GOCMD) vet
BINARY_NAME=example
VERSION?=0.0.0
SERVICE_PORT?=3000
DOCKER_REGISTRY?= #if set it should finished by /
EXPORT_RESULT?=false # for CI please set EXPORT_RESULT to true

GREEN  := $(shell tput -Txterm setaf 2)

thomaspoignant

var cache map[string]interface{}

func main() {
 ticker = time.NewTicker(3 * time.Second)
 defer ticker.Stop() // stop the ticker

 updaterChan = make(chan struct{})
 defer close(updaterChan) // close the channel

 // ...

thomaspoignant

ticker = time.NewTicker(3 * time.Second)
defer ticker.Stop() // stop the ticker
//...
case <- ticker.C:
        // update cache
        // ...

thomaspoignant

package main

import (
	"fmt"
	"sync"
	"time"
)

var mutex      sync.RWMutex
var cache map[string]interface{}