Skip to content

Commit 53becab

Browse files
authored
Fix/examples (#3)
* fix(examples): add plugin_get_required_api_version() Signed-off-by: Leonardo Grasso <me@leonardograsso.com> * fix(examples/async): make RegisterAsyncExtractors work again Signed-off-by: Leonardo Grasso <me@leonardograsso.com>
1 parent 70a0433 commit 53becab

File tree

3 files changed

+21
-2
lines changed

3 files changed

+21
-2
lines changed

examples/async/async.go

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,11 @@ func plugin_get_description() *C.char {
7474
return C.CString(PluginDescription)
7575
}
7676

77+
// export plugin_get_required_api_version
78+
func plugin_get_required_api_version() *C.char {
79+
return C.CString("1.0.0")
80+
}
81+
7782
//export plugin_get_fields
7883
func plugin_get_fields() *C.char {
7984
log.Printf("[%s] plugin_get_fields\n", PluginName)
@@ -96,10 +101,14 @@ func plugin_extract_str(pluginState unsafe.Pointer, evtnum uint64, id uint32, ar
96101
return (*byte)(unsafe.Pointer(C.CString("ciao")))
97102
}
98103

104+
//export plugin_extract_u64
105+
func plugin_extract_u64(plgState unsafe.Pointer, evtnum uint64, id uint32, arg *byte, data *byte, datalen uint32, fieldPresent *uint32) uint64 {
106+
return 11
107+
}
108+
99109
//export plugin_register_async_extractor
100110
func plugin_register_async_extractor(pluginState unsafe.Pointer, asyncExtractorInfo unsafe.Pointer) int32 {
101-
log.Printf("[%s] plugin_register_async_extractor\n", PluginName)
102-
return sinsp.RegisterAsyncExtractors(pluginState, asyncExtractorInfo, plugin_extract_str)
111+
return sinsp.RegisterAsyncExtractors(pluginState, asyncExtractorInfo, plugin_extract_str, plugin_extract_u64)
103112
}
104113

105114
func main() {}

examples/batch/batch.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,11 @@ func plugin_get_description() *C.char {
8686
return C.CString(PluginDescription)
8787
}
8888

89+
// export plugin_get_required_api_version
90+
func plugin_get_required_api_version() *C.char {
91+
return C.CString("1.0.0")
92+
}
93+
8994
//export plugin_get_fields
9095
func plugin_get_fields() *C.char {
9196
log.Printf("[%s] plugin_get_fields\n", PluginName)

examples/dummy/dummy.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,11 @@ func plugin_get_description() *C.char {
8686
return C.CString(PluginDescription)
8787
}
8888

89+
// export plugin_get_required_api_version
90+
func plugin_get_required_api_version() *C.char {
91+
return C.CString("1.0.0")
92+
}
93+
8994
//export plugin_get_fields
9095
func plugin_get_fields() *C.char {
9196
log.Printf("[%s] plugin_get_fields\n", PluginName)

0 commit comments

Comments
 (0)