Skip to content

Commit

Permalink
fix: remove undefined api in 3.1.2
Browse files Browse the repository at this point in the history
  • Loading branch information
huskar-t committed Oct 30, 2023
1 parent a3d62aa commit 7298f07
Show file tree
Hide file tree
Showing 5 changed files with 4 additions and 19 deletions.
2 changes: 2 additions & 0 deletions .github/workflows/go.yml
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,8 @@ on:
branches:
- 'main'
- '3.0'
- '3.1'
- '3.1.2'
workflow_dispatch:
inputs:
tbBranch:
Expand Down
2 changes: 2 additions & 0 deletions .github/workflows/push.yml
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,8 @@ on:
branches:
- 'main'
- '3.0'
- '3.1'
- '3.1.2'

env:
SCCACHE_GHA_ENABLED: "true"
Expand Down
4 changes: 0 additions & 4 deletions wrapper/taosc.go
Original file line number Diff line number Diff line change
Expand Up @@ -263,10 +263,6 @@ func TaosGetTablesVgID(conn unsafe.Pointer, db string, tables []string) (vgIDs [
//
//DLL_EXPORT int taos_set_conn_mode(TAOS* taos, int mode, int value);

func TaosSetConnMode(conn unsafe.Pointer, mode int, value int) int {
return int(C.taos_set_conn_mode(conn, C.int(mode), C.int(value)))
}

// TaosGetCurrentDB DLL_EXPORT int taos_get_current_db(TAOS *taos, char *database, int len, int *required)
func TaosGetCurrentDB(conn unsafe.Pointer) (db string, err error) {
cDb := C.CString(db)
Expand Down
10 changes: 0 additions & 10 deletions wrapper/taosc_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -571,16 +571,6 @@ func TestTaosGetTablesVgID(t *testing.T) {
assert.Equal(t, vgs2, vgs1)
}

func TestTaosSetConnMode(t *testing.T) {
conn, err := TaosConnect("", "root", "taosdata", "", 0)
assert.NoError(t, err)
defer TaosClose(conn)
code := TaosSetConnMode(conn, 0, 1)
if code != 0 {
t.Errorf("TaosSetConnMode() error code= %d, msg: %s", code, TaosErrorStr(nil))
}
}

func TestTaosGetCurrentDB(t *testing.T) {
conn, err := TaosConnect("", "root", "taosdata", "", 0)
assert.NoError(t, err)
Expand Down
5 changes: 0 additions & 5 deletions wrapper/tmq.go
Original file line number Diff line number Diff line change
Expand Up @@ -328,8 +328,3 @@ func TMQCommitOffsetAsync(consumer unsafe.Pointer, topic string, vGroupID int32,
defer C.free(unsafe.Pointer(topicName))
C.tmq_commit_offset_async((*C.tmq_t)(consumer), topicName, (C.int32_t)(vGroupID), (C.int64_t)(offset), (*C.tmq_commit_cb)(C.TMQCommitOffsetCB), h.Pointer())
}

// TMQGetConnect TAOS *tmq_get_connect(tmq_t *tmq)
func TMQGetConnect(consumer unsafe.Pointer) unsafe.Pointer {
return unsafe.Pointer(C.tmq_get_connect((*C.tmq_t)(consumer)))
}

0 comments on commit 7298f07

Please sign in to comment.