INNER CODE UNIT · Go

main

shijuvar/go-distributed-sys · eventstream/bootstrapper/main.go:17

func main() {
	// Creates Stream in JetStream server
	createJStream(orderStream, orderStreamSubjects)
	// Creates Event Store schema
	createEventStoreDB()
	// Creates Orders schema
	createOrdersDB()
}

// createStream creates a stream by using JetStreamContext
func createJStream(streamName string, streamSubjects string) error {
	natsComponent := natsutil.NewNATSComponent("bootstrapper")
	err := natsComponent.ConnectToServer(nats.DefaultURL)
	if err != nil {
		log.Fatal(err)
	}
	var js nats.JetStreamContext
	js, err = natsComponent.JetStreamContext()

View source record →