Broker

The Broker component is responsible for routing messages between the Coordinator and Worker nodes.

---

Types

There are two types of Broker implementations that are supported out of the box with Tork:

1. In-memory
2. RabbitMQ

Registering a custom Broker

To register a custom Broker implementation follow the instructions on the Extending Tork guide to get Tork running in embedded mode.

Update your main function to make use of the engine.RegisterBrokerProvider hook:

func main() {

  if err := conf.LoadConfig(); err != nil {
    fmt.Println(err)
    os.Exit(1)
  }

  engine.RegisterBrokerProvider("mymq", func() (mq.Broker, error) {
    // example of using config
        // url := conf.String("broker.mymq.url")
    return nil, errors.Errorf("not implementd yet")
  })


  if err := cli.New().Run(); err != nil {
    fmt.Println(err)
    os.Exit(1)
  }

}

Update your config file to make use of your implementation:

[broker]
type = mymq

[broker.mymq]
url = mydb://user@password:localhost