/
metadata.go
63 lines (57 loc) · 1.99 KB
/
metadata.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package logs
import (
"fmt"
"github.com/kubemq-io/kubemq-targets/types"
)
const (
defaultLimit = 100
defaultSequenceToken = ""
)
type metadata struct {
method string
sequenceToken string
logGroupName string
logStreamName string
logGroupPrefix string
limit int64
}
var methodsMap = map[string]string{
"create_log_event_stream": "create_log_event_stream",
"describe_log_event_stream": "describe_log_event_stream",
"delete_log_event_stream": "delete_log_event_stream",
"put_log_event": "put_log_event",
"get_log_event": "get_log_event",
"create_log_group": "create_log_group",
"delete_log_group": "delete_log_group",
"describe_log_group": "describe_log_group",
}
func parseMetadata(meta types.Metadata) (metadata, error) {
m := metadata{}
var err error
m.method, err = meta.ParseStringMap("method", methodsMap)
if err != nil {
return metadata{}, meta.GetValidMethodTypes(methodsMap)
}
if m.method == "describe_log_group" {
m.logGroupPrefix, err = meta.MustParseString("log_group_prefix")
if err != nil {
return metadata{}, fmt.Errorf(" log_group_prefix is required for method :%s error parsing log_group_prefix, %w", m.method, err)
}
} else {
m.logGroupName, err = meta.MustParseString("log_group_name")
if err != nil {
return metadata{}, fmt.Errorf("log_group_name is required for method %s,error parsing log_group_name, %w", m.method, err)
}
if m.method == "put_log_event" || m.method == "get_log_event" || m.method == "create_log_event_stream" || m.method == "delete_log_event_stream" {
m.logStreamName, err = meta.MustParseString("log_stream_name")
if err != nil {
return metadata{}, fmt.Errorf("log_stream_name is required for method %s,error parsing log_stream_name, %w", m.method, err)
}
if m.method == "put_log_event" {
m.sequenceToken = meta.ParseString("sequence_token", defaultSequenceToken)
}
}
}
m.limit = int64(meta.ParseInt("limit", defaultLimit))
return m, nil
}