Code

Actor source#2

Code

Open

sjking wants to merge 45 commits intokliewkliew:masterkliewkliew/cornucopia:masterfrom sjking:actor-sourcesjking/cornucopia:actor-sourceCopy head branch name to clipboard

+1,427-483

Commits

Commits on Apr 23, 2017

• WIP: Refactored graph, and it compiles

  sjking

  committed
  31654a4

  Copy full SHA for 31654a4

Commits on Apr 24, 2017

• WIP: expose source actor in library object

  sjking

  committed
  0c2a572

  Copy full SHA for 0c2a572

Commits on Apr 26, 2017

• WIP: trying stuff

  sjking

  committed
  2a3cc4c

  Copy full SHA for 2a3cc4c

• version 0.4-SNAPSHOT

  sjking

  committed
  efc8775

  Copy full SHA for efc8775

Commits on Apr 27, 2017

• WIP: fixing the graph for actor source

  sjking

  committed
  9a2698e

  Copy full SHA for 9a2698e

• Add test for adding a new master using actor publisher

  sjking

  committed
  2b5865e

  Copy full SHA for 2b5865e

• Provide explicit type annotations for stream processing topology refresh

  sjking

  committed
  2f694dc

  Copy full SHA for 2f694dc

• Version 0.6-SNAPSHOT

  sjking

  committed
  76364cc

  Copy full SHA for 76364cc

• Update test to use proper redis uri

  sjking

  committed
  c791048

  Copy full SHA for c791048

• WIP: implementing the library interface

  sjking

  committed
  6d7c0ff

  Copy full SHA for 6d7c0ff

Commits on May 6, 2017

• Pass down the sender ActorRef through the graph so we can respond after mapping future on cluster reshard

  sjking

  committed
  afd0c9d

  Copy full SHA for afd0c9d

Commits on May 7, 2017

• Version 0.7-SNAPSHOT

  sjking

  committed
  2c8c665

  Copy full SHA for 2c8c665

Commits on May 8, 2017

• Stub logTopology in test

  sjking

  committed
  62d4de4

  Copy full SHA for 62d4de4

Commits on May 9, 2017

• Pass back an Either from reshard cluster

  sjking

  committed
  85a347a

  Copy full SHA for 85a347a

Commits on May 11, 2017

• We need to add the new master node to the cluster

  sjking

  committed
  32ab91f

  Copy full SHA for 32ab91f

• Send message to sender actor after adding a slave

  sjking

  committed
  f1c8718

  Copy full SHA for f1c8718

• Version 0.9-SNAPSHOT

  sjking

  committed
  2d59d4d

  Copy full SHA for 2d59d4d

Commits on May 12, 2017

• Add more logging

  sjking

  committed
  749865f

  Copy full SHA for 749865f

• Send the node type back to client

  sjking

  committed
  9e9b9d7

  Copy full SHA for 9e9b9d7

Commits on May 14, 2017

• Refactor the migrateSlot function

  sjking

  committed
  f52d9be

  Copy full SHA for f52d9be

Commits on May 15, 2017

• Rework resharding function

  Show description for 3dc2e86
  sjking

  committed
  3dc2e86

  Copy full SHA for 3dc2e86

• Just use mutable Buffer

  sjking

  committed
  05fbb94

  Copy full SHA for 05fbb94

• Print stack trace

  sjking

  committed
  1051452

  Copy full SHA for 1051452

• try this

  sjking

  committed
  428f571

  Copy full SHA for 428f571

• version bump

  sjking

  committed
  bcc6dda

  Copy full SHA for bcc6dda

• Try some funky conversion from Java to Scala

  sjking

  committed
  05cdf44

  Copy full SHA for 05cdf44

• Fix map problem

  sjking

  committed
  b14c799

  Copy full SHA for b14c799

• Move reshard table function into its own helper object

  sjking

  committed
  e455083

  Copy full SHA for e455083

• bump

  sjking

  committed
  cc3c89f

  Copy full SHA for cc3c89f

• Add an http server to accept Cornucopia Tasks

  sjking

  committed
  1219a0e

  Copy full SHA for 1219a0e

• Implement the API interface to the graph, and resharding works locally (yeah!)

  sjking

  committed
  36d1f77

  Copy full SHA for 36d1f77

Commits on May 16, 2017

• Version bump 0.20-SNAPSHOT

  sjking

  committed
  eb09430

  Copy full SHA for eb09430

• Handle different types of known migration errors

  sjking

  committed
  d9b4a8a

  Copy full SHA for d9b4a8a

• Docker stuff

  sjking

  committed
  f169091

  Copy full SHA for f169091

• Add Docker deployment configuration to build file

  sjking

  committed
  49f8085

  Copy full SHA for 49f8085

• bump

  sjking

  committed
  be7e737

  Copy full SHA for be7e737

Commits on May 17, 2017

• Use a helper function to retrieve new Salad API connections, which is easy to stub for tests

  sjking

  committed
  d78343f

  Copy full SHA for d78343f

• bump

  sjking

  committed
  4ee8f2a

  Copy full SHA for 4ee8f2a

• Add debug logging to Reshard Table compute function

  sjking

  committed
  86e5a66

  Copy full SHA for 86e5a66

• Add log4j.properties file as command-line parameter for Docker container (to be mounted as configmap in Kubernetes).

  sjking

  committed
  e057df8

  Copy full SHA for e057df8

• Add log messages during slot migration and reshard with new master functions

  sjking

  committed
  bd9c435

  Copy full SHA for bd9c435

Commits on May 18, 2017

• Throw a ReshardTableException if the reshard table does not compute the correct number of source slots, and handle the exception with recursive retries to reshard the cluster with a new master.

  sjking

  committed
  d1ab635

  Copy full SHA for d1ab635

• Bump

  sjking

  committed
  13b6f05

  Copy full SHA for 13b6f05

• Keep retrying to add nodes to cluster recursively if we fail to make a Redis connection to a node

  sjking

  committed
  42d5ffb

  Copy full SHA for 42d5ffb

• Bump version

  sjking

  committed
  dfe96bb

  Copy full SHA for dfe96bb