Skip to content

Commit 2fd8054

Browse files
committed
golang 支持 PutLogs
1 parent 0c0181f commit 2fd8054

File tree

7 files changed

+2267
-2
lines changed

7 files changed

+2267
-2
lines changed

alibabacloud-gateway-sls/golang/client/client.go

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,15 @@ func (client *Client) ModifyRequest(context *spi.InterceptorContext, attributeMa
8585
// get body bytes
8686
var bodyBytes []byte
8787
if !tea.BoolValue(util.IsUnset(request.Body)) {
88-
if tea.BoolValue(string_.Equals(request.ReqBodyType, tea.String("json"))) || tea.BoolValue(string_.Equals(request.ReqBodyType, tea.String("formData"))) {
88+
// PutLogs
89+
if tea.BoolValue(string_.Equals(request.Action, tea.String("PutLogs"))) {
90+
bodyBytes, _err = sls_util.SerializeLogGroupToPB(request.Body)
91+
if _err != nil {
92+
return _err
93+
}
94+
95+
request.Headers["content-type"] = tea.String("application/x-protobuf")
96+
} else if tea.BoolValue(string_.Equals(request.ReqBodyType, tea.String("json"))) || tea.BoolValue(string_.Equals(request.ReqBodyType, tea.String("formData"))) {
8997
request.Headers["content-type"] = tea.String("application/json")
9098
bodyStr := util.ToJSONString(request.Body)
9199
bodyBytes = util.ToBytes(bodyStr)

alibabacloud-gateway-sls/golang/go.mod

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ require (
1010
github.com/alibabacloud-go/darabonba-map v0.0.2
1111
github.com/alibabacloud-go/darabonba-signature-util v0.0.7
1212
github.com/alibabacloud-go/darabonba-string v1.0.2
13-
github.com/alibabacloud-go/openapi-util v0.1.0
13+
github.com/alibabacloud-go/openapi-util v0.1.1
1414
github.com/alibabacloud-go/tea v1.2.3-0.20240605082020-e6e537a31150
1515
github.com/alibabacloud-go/tea-utils/v2 v2.0.6
1616
)

alibabacloud-gateway-sls/util/golang/client/client.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,3 +81,7 @@ func IsDecompressorAvailable(compressType *string) (_result *bool) {
8181
func BytesLength(src []byte) (_result *int64) {
8282
return tea.Int64(int64(len(src)))
8383
}
84+
85+
func SerializeLogGroupToPB(logGroup interface{}) (_result []byte, _err error) {
86+
return serializeLogGroupToPB(logGroup)
87+
}

0 commit comments

Comments
 (0)