mirror of
https://github.com/kevin-DL/services.git
synced 2026-01-22 23:35:26 +00:00
Commit from GitHub Actions (Generate Clients & Examples)
This commit is contained in:
@@ -34,7 +34,7 @@ func (t *DbService) Delete(request *DeleteRequest) (*DeleteResponse, error) {
|
|||||||
return rsp, t.client.Call("db", "Delete", request, rsp)
|
return rsp, t.client.Call("db", "Delete", request, rsp)
|
||||||
}
|
}
|
||||||
|
|
||||||
//
|
// List tables in the DB
|
||||||
func (t *DbService) ListTables(request *ListTablesRequest) (*ListTablesResponse, error) {
|
func (t *DbService) ListTables(request *ListTablesRequest) (*ListTablesResponse, error) {
|
||||||
rsp := &ListTablesResponse{}
|
rsp := &ListTablesResponse{}
|
||||||
return rsp, t.client.Call("db", "ListTables", request, rsp)
|
return rsp, t.client.Call("db", "ListTables", request, rsp)
|
||||||
@@ -46,7 +46,7 @@ func (t *DbService) Read(request *ReadRequest) (*ReadResponse, error) {
|
|||||||
return rsp, t.client.Call("db", "Read", request, rsp)
|
return rsp, t.client.Call("db", "Read", request, rsp)
|
||||||
}
|
}
|
||||||
|
|
||||||
//
|
// Rename a table
|
||||||
func (t *DbService) RenameTable(request *RenameTableRequest) (*RenameTableResponse, error) {
|
func (t *DbService) RenameTable(request *RenameTableRequest) (*RenameTableResponse, error) {
|
||||||
rsp := &RenameTableResponse{}
|
rsp := &RenameTableResponse{}
|
||||||
return rsp, t.client.Call("db", "RenameTable", request, rsp)
|
return rsp, t.client.Call("db", "RenameTable", request, rsp)
|
||||||
@@ -100,6 +100,7 @@ type ListTablesRequest struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
type ListTablesResponse struct {
|
type ListTablesResponse struct {
|
||||||
|
// list of tables
|
||||||
Tables []string `json:"tables"`
|
Tables []string `json:"tables"`
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -130,8 +131,10 @@ type ReadResponse struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
type RenameTableRequest struct {
|
type RenameTableRequest struct {
|
||||||
|
// current table name
|
||||||
From string `json:"from"`
|
From string `json:"from"`
|
||||||
To string `json:"to"`
|
// new table name
|
||||||
|
To string `json:"to"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type RenameTableResponse struct {
|
type RenameTableResponse struct {
|
||||||
|
|||||||
@@ -79,5 +79,5 @@
|
|||||||
"prepare": "npm run build"
|
"prepare": "npm run build"
|
||||||
},
|
},
|
||||||
"types": "index.d.ts",
|
"types": "index.d.ts",
|
||||||
"version": "1.0.736"
|
"version": "1.0.738"
|
||||||
}
|
}
|
||||||
@@ -7,7 +7,7 @@ import (
|
|||||||
"github.com/micro/services/clients/go/db"
|
"github.com/micro/services/clients/go/db"
|
||||||
)
|
)
|
||||||
|
|
||||||
//
|
// List tables in the DB
|
||||||
func ListTables() {
|
func ListTables() {
|
||||||
dbService := db.NewDbService(os.Getenv("MICRO_API_TOKEN"))
|
dbService := db.NewDbService(os.Getenv("MICRO_API_TOKEN"))
|
||||||
rsp, err := dbService.ListTables(&db.ListTablesRequest{})
|
rsp, err := dbService.ListTables(&db.ListTablesRequest{})
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
const { DbService } = require("m3o/db");
|
const { DbService } = require("m3o/db");
|
||||||
|
|
||||||
//
|
// List tables in the DB
|
||||||
async function listTables() {
|
async function listTables() {
|
||||||
let dbService = new DbService(process.env.MICRO_API_TOKEN);
|
let dbService = new DbService(process.env.MICRO_API_TOKEN);
|
||||||
let rsp = await dbService.listTables({});
|
let rsp = await dbService.listTables({});
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ import (
|
|||||||
"github.com/micro/services/clients/go/db"
|
"github.com/micro/services/clients/go/db"
|
||||||
)
|
)
|
||||||
|
|
||||||
//
|
// Rename a table
|
||||||
func RenameTable() {
|
func RenameTable() {
|
||||||
dbService := db.NewDbService(os.Getenv("MICRO_API_TOKEN"))
|
dbService := db.NewDbService(os.Getenv("MICRO_API_TOKEN"))
|
||||||
rsp, err := dbService.RenameTable(&db.RenameTableRequest{
|
rsp, err := dbService.RenameTable(&db.RenameTableRequest{
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
const { DbService } = require("m3o/db");
|
const { DbService } = require("m3o/db");
|
||||||
|
|
||||||
//
|
// Rename a table
|
||||||
async function renameTable() {
|
async function renameTable() {
|
||||||
let dbService = new DbService(process.env.MICRO_API_TOKEN);
|
let dbService = new DbService(process.env.MICRO_API_TOKEN);
|
||||||
let rsp = await dbService.renameTable({
|
let rsp = await dbService.renameTable({
|
||||||
|
|||||||
@@ -12,9 +12,9 @@ func PublishAnEvent() {
|
|||||||
eventService := event.NewEventService(os.Getenv("MICRO_API_TOKEN"))
|
eventService := event.NewEventService(os.Getenv("MICRO_API_TOKEN"))
|
||||||
rsp, err := eventService.Publish(&event.PublishRequest{
|
rsp, err := eventService.Publish(&event.PublishRequest{
|
||||||
Message: map[string]interface{}{
|
Message: map[string]interface{}{
|
||||||
|
"user": "john",
|
||||||
"id": "1",
|
"id": "1",
|
||||||
"type": "signup",
|
"type": "signup",
|
||||||
"user": "john",
|
|
||||||
},
|
},
|
||||||
Topic: "user",
|
Topic: "user",
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user