diff --git a/examples/db/listTables/curl/listTables.sh b/examples/db/listTables/curl/listTables.sh new file mode 100755 index 0000000..dfcf046 --- /dev/null +++ b/examples/db/listTables/curl/listTables.sh @@ -0,0 +1,4 @@ +curl "http://localhost:8080/db/ListTables" \ +-H "Content-Type: application/json" \ +-H "Authorization: Bearer $MICRO_API_TOKEN" \ +-d '{}' \ No newline at end of file diff --git a/examples/db/listTables/go/listTables.go b/examples/db/listTables/go/listTables.go new file mode 100755 index 0000000..39651b9 --- /dev/null +++ b/examples/db/listTables/go/listTables.go @@ -0,0 +1,15 @@ +package example + +import ( + "fmt" + "os" + + "github.com/micro/services/clients/go/db" +) + +// +func ListTables() { + dbService := db.NewDbService(os.Getenv("MICRO_API_TOKEN")) + rsp, err := dbService.ListTables(&db.ListTablesRequest{}) + fmt.Println(rsp, err) +} diff --git a/examples/db/listTables/node/listTables.js b/examples/db/listTables/node/listTables.js new file mode 100755 index 0000000..e02fbed --- /dev/null +++ b/examples/db/listTables/node/listTables.js @@ -0,0 +1,10 @@ +const { DbService } = require("m3o/db"); + +// +async function listTables() { + let dbService = new DbService(process.env.MICRO_API_TOKEN); + let rsp = await dbService.listTables({}); + console.log(rsp); +} + +listTables(); diff --git a/examples/db/renameTable/curl/renameTable.sh b/examples/db/renameTable/curl/renameTable.sh new file mode 100755 index 0000000..09526c9 --- /dev/null +++ b/examples/db/renameTable/curl/renameTable.sh @@ -0,0 +1,7 @@ +curl "http://localhost:8080/db/RenameTable" \ +-H "Content-Type: application/json" \ +-H "Authorization: Bearer $MICRO_API_TOKEN" \ +-d '{ + "from": "events", + "to": "events_backup" +}' \ No newline at end of file diff --git a/examples/db/renameTable/go/renameTable.go b/examples/db/renameTable/go/renameTable.go new file mode 100755 index 0000000..554d370 --- /dev/null +++ b/examples/db/renameTable/go/renameTable.go @@ -0,0 +1,18 @@ +package example + +import ( + "fmt" + "os" + + "github.com/micro/services/clients/go/db" +) + +// +func RenameTable() { + dbService := db.NewDbService(os.Getenv("MICRO_API_TOKEN")) + rsp, err := dbService.RenameTable(&db.RenameTableRequest{ + From: "events", + To: "events_backup", + }) + fmt.Println(rsp, err) +} diff --git a/examples/db/renameTable/node/renameTable.js b/examples/db/renameTable/node/renameTable.js new file mode 100755 index 0000000..7cb168d --- /dev/null +++ b/examples/db/renameTable/node/renameTable.js @@ -0,0 +1,13 @@ +const { DbService } = require("m3o/db"); + +// +async function renameTable() { + let dbService = new DbService(process.env.MICRO_API_TOKEN); + let rsp = await dbService.renameTable({ + from: "events", + to: "events_backup", + }); + console.log(rsp); +} + +renameTable(); diff --git a/examples/event/publish/go/publishAnEvent.go b/examples/event/publish/go/publishAnEvent.go index cd945dc..a6a3b0e 100755 --- a/examples/event/publish/go/publishAnEvent.go +++ b/examples/event/publish/go/publishAnEvent.go @@ -12,9 +12,9 @@ func PublishAnEvent() { eventService := event.NewEventService(os.Getenv("MICRO_API_TOKEN")) rsp, err := eventService.Publish(&event.PublishRequest{ Message: map[string]interface{}{ - "id": "1", "type": "signup", "user": "john", + "id": "1", }, Topic: "user", }) diff --git a/examples/mq/publish/go/publishAMessage.go b/examples/mq/publish/go/publishAMessage.go index 6cbfe0d..159c090 100755 --- a/examples/mq/publish/go/publishAMessage.go +++ b/examples/mq/publish/go/publishAMessage.go @@ -12,9 +12,9 @@ func PublishAmessage() { mqService := mq.NewMqService(os.Getenv("MICRO_API_TOKEN")) rsp, err := mqService.Publish(&mq.PublishRequest{ Message: map[string]interface{}{ + "id": "1", "type": "signup", "user": "john", - "id": "1", }, Topic: "events", })