mhjort

apiVersion: v1
kind: List
items:
- kind: Service
  apiVersion: v1
  metadata:
    name: partya
  spec:
    selector:
      app: partya

mhjort

extraAdvertisedServiceIds=[]
myLegalName="O=PartyB,L=Helsinki,C=FI"
p2pAddress="partyb:10002"
rpcSettings {
    address="partyb:10003"
    adminAddress="partyb:10004"
}
rpcUsers=[
    {
        password=test

mhjort

extraAdvertisedServiceIds=[]
myLegalName="O=PartyA,L=Helsinki,C=FI"
p2pAddress="partya:10002"
rpcSettings {
    address="partya:10003"
    adminAddress="partya:10004"
}
rpcUsers=[
    {
        password=test

mhjort

myLegalName="O=Notary,L=Helsinki,C=FI"
notary {
    validating=false
}
p2pAddress="notary:10002"

mhjort

#!/bin/sh

# If variable not present use default values
: ${CORDA_HOME:=/opt/corda}
: ${JAVA_OPTIONS:=-Dlog4j.configurationFile=/opt/corda/log4j.xml -Xmx2048m}

export CORDA_HOME JAVA_OPTIONS

cd ${CORDA_HOME}

mhjort

FROM tomorrow/corda:latest

ADD build/cordapps/*.jar /opt/corda/cordapps/

EXPOSE 10002
EXPOSE 10003
EXPOSE 10004

WORKDIR /opt/corda
ENV HOME=/opt/corda

mhjort

FROM openjdk:8u151-jre-alpine

ARG BUILDTIME_CORDA_VERSION=3.1-corda
ARG BUILDTIME_JAVA_OPTIONS

ENV CORDA_VERSION=${BUILDTIME_CORDA_VERSION}
ENV JAVA_OPTIONS=${BUILDTIME_JAVA_OPTIONS}

LABEL net.corda.version = ${CORDA_VERSION} \
      maintainer = "<webmaster@tomorrow.fi>" \

mhjort

(cond
  (= 0 failed-count) {:succeeded-count (count events)}
  (= (count events) failed-count) (throw-batch-failed-error failed-events)
  :else {:succeeded-count (- (count events) failed-count)
         :failed failed-events})))

(when-let [failed-events (:failed result)]
  (error "Failed to send some of the events in the batch. Failed events:" failed-events))

mhjort

(defn- next-delivery-stream []
  (rand-nth ["firehose-test" "firehose-test2"]))   

mhjort

Running scenario Article read scenario with 133 concurrency and
              requests 13333.
Running scenario Program start scenario with 67 concurrency and
              requests 6667.
...