-
Notifications
You must be signed in to change notification settings - Fork 72
/
enums.go
150 lines (124 loc) · 6.51 KB
/
enums.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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
package aclcmdutil
import kafkainstanceclient "github.com/redhat-developer/app-services-sdk-go/kafkainstance/apiv1/client"
var resourceTypeFilterMap = map[string]kafkainstanceclient.AclResourceTypeFilter{
ResourceTypeANY: kafkainstanceclient.ACLRESOURCETYPEFILTER_ANY,
ResourceTypeCLUSTER: kafkainstanceclient.ACLRESOURCETYPEFILTER_CLUSTER,
ResourceTypeTOPIC: kafkainstanceclient.ACLRESOURCETYPEFILTER_TOPIC,
ResourceTypeGROUP: kafkainstanceclient.ACLRESOURCETYPEFILTER_GROUP,
ResourceTypeTRANSACTIONAL_ID: kafkainstanceclient.ACLRESOURCETYPEFILTER_TRANSACTIONAL_ID,
}
var resourceTypeMap = map[string]kafkainstanceclient.AclResourceType{
ResourceTypeCLUSTER: kafkainstanceclient.ACLRESOURCETYPE_CLUSTER,
ResourceTypeTOPIC: kafkainstanceclient.ACLRESOURCETYPE_TOPIC,
ResourceTypeGROUP: kafkainstanceclient.ACLRESOURCETYPE_GROUP,
ResourceTypeTRANSACTIONAL_ID: kafkainstanceclient.ACLRESOURCETYPE_TRANSACTIONAL_ID,
}
var operationFilterMap = map[string]kafkainstanceclient.AclOperationFilter{
OperationALL: kafkainstanceclient.ACLOPERATIONFILTER_ALL,
OperationREAD: kafkainstanceclient.ACLOPERATIONFILTER_READ,
OperationWRITE: kafkainstanceclient.ACLOPERATIONFILTER_WRITE,
OperationCREATE: kafkainstanceclient.ACLOPERATIONFILTER_CREATE,
OperationDELETE: kafkainstanceclient.ACLOPERATIONFILTER_DELETE,
OperationALTER: kafkainstanceclient.ACLOPERATIONFILTER_ALTER,
OperationDESCRIBE: kafkainstanceclient.ACLOPERATIONFILTER_DESCRIBE,
OperationDESCRIBE_CONFIGS: kafkainstanceclient.ACLOPERATIONFILTER_DESCRIBE_CONFIGS,
OperationALTER_CONFIGS: kafkainstanceclient.ACLOPERATIONFILTER_ALTER_CONFIGS,
}
var operationMap = map[string]kafkainstanceclient.AclOperation{
OperationALL: kafkainstanceclient.ACLOPERATION_ALL,
OperationREAD: kafkainstanceclient.ACLOPERATION_READ,
OperationWRITE: kafkainstanceclient.ACLOPERATION_WRITE,
OperationCREATE: kafkainstanceclient.ACLOPERATION_CREATE,
OperationDELETE: kafkainstanceclient.ACLOPERATION_DELETE,
OperationALTER: kafkainstanceclient.ACLOPERATION_ALTER,
OperationDESCRIBE: kafkainstanceclient.ACLOPERATION_DESCRIBE,
OperationDESCRIBE_CONFIGS: kafkainstanceclient.ACLOPERATION_DESCRIBE_CONFIGS,
OperationALTER_CONFIGS: kafkainstanceclient.ACLOPERATION_ALTER_CONFIGS,
}
var permissionTypeFilterMap = map[string]kafkainstanceclient.AclPermissionTypeFilter{
PermissionANY: kafkainstanceclient.ACLPERMISSIONTYPEFILTER_ANY,
PermissionALLOW: kafkainstanceclient.ACLPERMISSIONTYPEFILTER_ALLOW,
PermissionDENY: kafkainstanceclient.ACLPERMISSIONTYPEFILTER_DENY,
}
var permissionTypeMap = map[string]kafkainstanceclient.AclPermissionType{
PermissionALLOW: kafkainstanceclient.ACLPERMISSIONTYPE_ALLOW,
PermissionDENY: kafkainstanceclient.ACLPERMISSIONTYPE_DENY,
}
var patternTypeFilterMap = map[string]kafkainstanceclient.AclPatternTypeFilter{
PatternTypeANY: kafkainstanceclient.ACLPATTERNTYPEFILTER_ANY,
PatternTypeLITERAL: kafkainstanceclient.ACLPATTERNTYPEFILTER_LITERAL,
PatternTypePREFIX: kafkainstanceclient.ACLPATTERNTYPEFILTER_PREFIXED,
}
var patternTypeMap = map[string]kafkainstanceclient.AclPatternType{
PatternTypeLITERAL: kafkainstanceclient.ACLPATTERNTYPE_LITERAL,
PatternTypePREFIX: kafkainstanceclient.ACLPATTERNTYPE_PREFIXED,
}
var resourceTypeOperationKeyMap = map[string]string{
ResourceTypeCLUSTER: "cluster",
ResourceTypeTOPIC: "topic",
ResourceTypeGROUP: "group",
ResourceTypeTRANSACTIONAL_ID: "transactional_id",
}
var validOperationsResponseMap = map[string]string{
"alter_configs": OperationALTER_CONFIGS,
"describe_configs": OperationDESCRIBE_CONFIGS,
}
// GetOperationTypeFilterMap gets the mappings for ACL type filters
func GetOperationFilterMap() map[string]kafkainstanceclient.AclOperationFilter {
return operationFilterMap
}
func GetOperationMap() map[string]kafkainstanceclient.AclOperation {
return operationMap
}
// GetMappedOperationFilterValue gets the mapped operation filter value
func GetMappedOperationFilterValue(operation string) kafkainstanceclient.AclOperationFilter {
return operationFilterMap[operation]
}
// GetMappedOperationValue gets the mapped operation value
func GetMappedOperationValue(operation string) kafkainstanceclient.AclOperation {
return operationMap[operation]
}
// GetPatternTypeFilterMap gets the mappings for ACL pattern type filters
func GetPatternTypeFilterMap() map[string]kafkainstanceclient.AclPatternTypeFilter {
return patternTypeFilterMap
}
// GetPatternTypeMap gets the mappings for ACL pattern type
func GetPatternTypeMap() map[string]kafkainstanceclient.AclPatternType {
return patternTypeMap
}
// GetMappedPatternTypeFilterValue gets the mapped pattern type filter value
func GetMappedPatternTypeFilterValue(patternType string) kafkainstanceclient.AclPatternTypeFilter {
return patternTypeFilterMap[patternType]
}
// GetMappedPatternTypeValue gets the mapped pattern type value
func GetMappedPatternTypeValue(patternType string) kafkainstanceclient.AclPatternType {
return patternTypeMap[patternType]
}
// GetPermissionTypeFilterMap gets the mappings for ACL permission type filters
func GetPermissionTypeFilterMap() map[string]kafkainstanceclient.AclPermissionTypeFilter {
return permissionTypeFilterMap
}
// GetPermissionTypeMap gets the mappings for ACL permission types
func GetPermissionTypeMap() map[string]kafkainstanceclient.AclPermissionType {
return permissionTypeMap
}
// GetMappedPermissionTypeFilterValue gets the mapped permission type filter value
func GetMappedPermissionTypeFilterValue(permission string) kafkainstanceclient.AclPermissionTypeFilter {
return permissionTypeFilterMap[permission]
}
// GetMappedPermissionTypeValue gets the mapped permission type value
func GetMappedPermissionTypeValue(permission string) kafkainstanceclient.AclPermissionType {
return permissionTypeMap[permission]
}
// GetResourceTypeFilterMap gets the mappings for ACL resource type filters
func GetResourceTypeFilterMap() map[string]kafkainstanceclient.AclResourceTypeFilter {
return resourceTypeFilterMap
}
// GetMappedResourceTypeFilterValue gets the mapped resource type filter value
func GetMappedResourceTypeFilterValue(resourceType string) kafkainstanceclient.AclResourceTypeFilter {
return resourceTypeFilterMap[resourceType]
}
// GetResourceTypeMap gets the mappings for ACL resource types
func GetResourceTypeMap() map[string]kafkainstanceclient.AclResourceType {
return resourceTypeMap
}