Datastore

The Datastore component is responsible for holding metadata about jobs, tasks and worker nodes.

Types

Out of the box, Tork supports Postgres as a Datastore implementation.

Registering a custom Datastore

To register a custom Datastore 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.RegisterDatastoreProvider hook:

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

	engine.RegisterDatastoreProvider("mydb", func() (datastore.Datastore, error) {
        // example of using config
        // url := conf.String("datastore.mydb.url")
		return nil, errors.New("not implemented yet")
	})

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

Update your config file to make use of your implementation:

[datastore]
type = mydb

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