This topic describes how to use SDK for Go to query all event buses.
Sample code:
package main
import (
"fmt"
eventbridge "github.com/alibabacloud-go/eventbridge-sdk/eventbridge"
console "github.com/alibabacloud-go/tea-console/client"
"github.com/alibabacloud-go/tea/tea"
)
/**
* Uses the CreateClient() function to initialize common request parameters.
*/
func CreateClient() (_result *eventbridge.Client, _err error) {
config := &eventbridge.Config{}
// Your AccessKey ID.
config.AccessKeyId = tea.String("<accessKeyId>")
// Your AccessKey secret.
config.AccessKeySecret = tea.String("<accessKeySecret>")
// Your endpoint.
config.Endpoint = tea.String("<endpoint>")
_result = &eventbridge.Client{}
_result, _err = eventbridge.NewClient(config)
return _result, _err
}
func ListEventRuleSample(client *eventbridge.Client) (_err error) {
tryErr := func() (_e error) {
defer func() {
if r := tea.Recover(recover()); r != nil {
_e = r
}
}()
listEventRulesRequest := &eventbridge.ListRulesRequest{}
listEventRulesRequest.EventBusName = tea.String("demo-bus")
resp, _err := client.ListRules(listEventRulesRequest)
if _err != nil {
return _err
}
fmt.Println(resp)
console.Log(tea.String("--------------------list rule success--------------------"))
return nil
}()
_err = tryErr
if tryErr != nil {
var error = &tea.SDKError{}
if _t, ok := tryErr.(*tea.SDKError); ok {
error = _t
} else {
error.SetErrMsg(tryErr.Error())
}
console.Log(error.Message)
}
return _err
}
func main() {
client, _err := CreateClient()
if _err != nil {
panic(_err)
}
_err = ListEventRuleSample(client)
if _err != nil {
panic(_err)
}
}